diff --git a/CHANGELOG.next.asciidoc b/CHANGELOG.next.asciidoc index 359dede60..b25552cfb 100644 --- a/CHANGELOG.next.asciidoc +++ b/CHANGELOG.next.asciidoc @@ -8,7 +8,12 @@ - Add error detail to catch-all HTTP error response. {pull}1854[1854] - Update apikey.cache_hit log field name to match convention. {pull}1900[1900] - LoadServerLimits will not overwrite specified limits when loading default/agent number specified values. {issue}1841[1841] {pull}1912[1912] +<<<<<<< HEAD - Fix issue were errors where being ignored written to elasticsearch. {pull}1896[1896] +======= +- Use seperate rate limiters for internal and external API listeners. {issue}1859[1859] {pull}1904[1904] +- Fix fleet.migration.total log key overlap {pull}1951[1951] +>>>>>>> 60ba1cf (Fix fleet.migration.total log key overlap (#1951)) ==== New Features diff --git a/internal/pkg/dl/migration.go b/internal/pkg/dl/migration.go index 4beb26741..92599c3a3 100644 --- a/internal/pkg/dl/migration.go +++ b/internal/pkg/dl/migration.go @@ -115,6 +115,7 @@ func updateAgentMetadata(ctx context.Context, bulker bulk.Bulk, body []byte) (in } log.Info(). +<<<<<<< HEAD Int("took", resp.Took). Bool("timed_out", resp.TimedOut). Int("total", resp.Total). @@ -127,6 +128,21 @@ func updateAgentMetadata(ctx context.Context, bulker bulk.Bulk, body []byte) (in Int("retries.search", resp.Retries.Search). Dur("rtt", time.Since(start)). Msg("migrate agent records response") +======= + Str("fleet.migration.name", name). + Int("fleet.migration.es.took", resp.Took). + Bool("fleet.migration.es.timed_out", resp.TimedOut). + Int("fleet.migration.updated", resp.Updated). + Int("fleet.migration.deleted", resp.Deleted). + Int("fleet.migration.batches", resp.Batches). + Int("fleet.migration.version_conflicts", resp.VersionConflicts). + Int("fleet.migration.noops", resp.Noops). + Int("fleet.migration.retries.bulk", resp.Retries.Bulk). + Int("fleet.migration.retries.search", resp.Retries.Search). + Dur("fleet.migration.total.duration", time.Since(start)). + Int("fleet.migration.total.count", resp.Total). + Msgf("migration %s done", name) +>>>>>>> 60ba1cf (Fix fleet.migration.total log key overlap (#1951)) for _, fail := range resp.Failures { log.Error().RawJSON("failure", fail).Msg("migration failure")