From 8af66d3007a897474b3cfdfb69d8162677d7316e Mon Sep 17 00:00:00 2001 From: bas smit Date: Fri, 11 Oct 2024 11:50:50 +0200 Subject: [PATCH] make update-snapshots --- .../nodestats_response_test.snap | 68 +++++++++---------- 1 file changed, 34 insertions(+), 34 deletions(-) diff --git a/fetcher/responses/__snapshots__/nodestats_response_test.snap b/fetcher/responses/__snapshots__/nodestats_response_test.snap index 6063488..884a267 100755 --- a/fetcher/responses/__snapshots__/nodestats_response_test.snap +++ b/fetcher/responses/__snapshots__/nodestats_response_test.snap @@ -47,12 +47,12 @@ responses.NodeStatsResponse{ }, Events: responses.EventsResponse{In:3751, Filtered:1250, Out:1250, DurationInMillis:494960, QueuePushDurationInMillis:49451}, Flow: responses.FlowResponse{ - InputThroughput: struct { Current float64 "json:\"current\""; Lifetime float64 "json:\"lifetime\"" }{Current:0, Lifetime:73.9}, - FilterThroughput: struct { Current float64 "json:\"current\""; Lifetime float64 "json:\"lifetime\"" }{Current:0, Lifetime:24.63}, - OutputThroughput: struct { Current float64 "json:\"current\""; Lifetime float64 "json:\"lifetime\"" }{Current:0, Lifetime:24.63}, - QueueBackpressure: struct { Current float64 "json:\"current\""; Lifetime float64 "json:\"lifetime\"" }{Current:1, Lifetime:0.9743}, - WorkerConcurrency: struct { Current float64 "json:\"current\""; Lifetime float64 "json:\"lifetime\"" }{Current:10, Lifetime:9.752}, - WorkerUtilization: struct { Current float64 "json:\"current\""; Lifetime float64 "json:\"lifetime\"" }{}, + InputThroughput: struct { Current responses.InfinityFloat "json:\"current\""; Lifetime responses.InfinityFloat "json:\"lifetime\"" }{Current:0, Lifetime:73.9}, + FilterThroughput: struct { Current responses.InfinityFloat "json:\"current\""; Lifetime responses.InfinityFloat "json:\"lifetime\"" }{Current:0, Lifetime:24.63}, + OutputThroughput: struct { Current responses.InfinityFloat "json:\"current\""; Lifetime responses.InfinityFloat "json:\"lifetime\"" }{Current:0, Lifetime:24.63}, + QueueBackpressure: struct { Current responses.InfinityFloat "json:\"current\""; Lifetime responses.InfinityFloat "json:\"lifetime\"" }{Current:1, Lifetime:0.9743}, + WorkerConcurrency: struct { Current responses.InfinityFloat "json:\"current\""; Lifetime responses.InfinityFloat "json:\"lifetime\"" }{Current:10, Lifetime:9.752}, + WorkerUtilization: struct { Current responses.InfinityFloat "json:\"current\""; Lifetime responses.InfinityFloat "json:\"lifetime\"" }{}, }, Reloads: responses.ReloadResponse{}, Os: responses.OsResponse{}, @@ -62,14 +62,14 @@ responses.NodeStatsResponse{ Monitoring: responses.PipelineLogstashMonitoringResponse{}, Events: struct { Out int "json:\"out\""; Filtered int "json:\"filtered\""; In int "json:\"in\""; DurationInMillis int "json:\"duration_in_millis\""; QueuePushDurationInMillis int "json:\"queue_push_duration_in_millis\"" }{}, Flow: responses.FlowResponse{ - InputThroughput: struct { Current float64 "json:\"current\""; Lifetime float64 "json:\"lifetime\"" }{Current:1, Lifetime:2}, - FilterThroughput: struct { Current float64 "json:\"current\""; Lifetime float64 "json:\"lifetime\"" }{Current:3, Lifetime:4}, - OutputThroughput: struct { Current float64 "json:\"current\""; Lifetime float64 "json:\"lifetime\"" }{Current:9, Lifetime:10}, - QueueBackpressure: struct { Current float64 "json:\"current\""; Lifetime float64 "json:\"lifetime\"" }{Current:7, Lifetime:8}, - WorkerConcurrency: struct { Current float64 "json:\"current\""; Lifetime float64 "json:\"lifetime\"" }{Current:5, Lifetime:6}, - WorkerUtilization: struct { Current float64 "json:\"current\""; Lifetime float64 "json:\"lifetime\"" }{Current:11, Lifetime:12}, + InputThroughput: struct { Current responses.InfinityFloat "json:\"current\""; Lifetime responses.InfinityFloat "json:\"lifetime\"" }{Current:1, Lifetime:2}, + FilterThroughput: struct { Current responses.InfinityFloat "json:\"current\""; Lifetime responses.InfinityFloat "json:\"lifetime\"" }{Current:3, Lifetime:4}, + OutputThroughput: struct { Current responses.InfinityFloat "json:\"current\""; Lifetime responses.InfinityFloat "json:\"lifetime\"" }{Current:9, Lifetime:10}, + QueueBackpressure: struct { Current responses.InfinityFloat "json:\"current\""; Lifetime responses.InfinityFloat "json:\"lifetime\"" }{Current:7, Lifetime:8}, + WorkerConcurrency: struct { Current responses.InfinityFloat "json:\"current\""; Lifetime responses.InfinityFloat "json:\"lifetime\"" }{Current:5, Lifetime:6}, + WorkerUtilization: struct { Current responses.InfinityFloat "json:\"current\""; Lifetime responses.InfinityFloat "json:\"lifetime\"" }{Current:11, Lifetime:12}, }, - Plugins: struct { Inputs []struct { ID string "json:\"id\""; Name string "json:\"name\""; Events struct { Out int "json:\"out\""; QueuePushDurationInMillis int "json:\"queue_push_duration_in_millis\"" } "json:\"events\"" } "json:\"inputs\""; Codecs []struct { ID string "json:\"id\""; Name string "json:\"name\""; Decode struct { Out int "json:\"out\""; WritesIn int "json:\"writes_in\""; DurationInMillis int "json:\"duration_in_millis\"" } "json:\"decode\""; Encode struct { WritesIn int "json:\"writes_in\""; DurationInMillis int "json:\"duration_in_millis\"" } "json:\"encode\"" } "json:\"codecs\""; Filters []struct { ID string "json:\"id\""; Name string "json:\"name\""; Events struct { Out int "json:\"out\""; In int "json:\"in\""; DurationInMillis int "json:\"duration_in_millis\"" } "json:\"events\""; Flow struct { WorkerUtilization struct { Current float64 "json:\"current\""; Lifetime float64 "json:\"lifetime\"" } "json:\"worker_utilization\""; WorkerMillisPerEvent struct { Lifetime float64 "json:\"lifetime\"" } "json:\"worker_millis_per_event\"" } "json:\"flow\"" } "json:\"filters\""; Outputs []struct { ID string "json:\"id\""; Name string "json:\"name\""; Events struct { Out int "json:\"out\""; In int "json:\"in\""; DurationInMillis int "json:\"duration_in_millis\"" } "json:\"events\""; Documents struct { Successes int "json:\"successes\""; NonRetryableFailures int "json:\"non_retryable_failures\"" } "json:\"documents\""; BulkRequests struct { WithErrors int "json:\"with_errors\""; Responses map[string]int "json:\"responses\"" } "json:\"bulk_requests\""; Flow struct { WorkerUtilization struct { Current float64 "json:\"current\""; Lifetime float64 "json:\"lifetime\"" } "json:\"worker_utilization\"" } "json:\"flow\"" } "json:\"outputs\"" }{ + Plugins: struct { Inputs []struct { ID string "json:\"id\""; Name string "json:\"name\""; Events struct { Out int "json:\"out\""; QueuePushDurationInMillis int "json:\"queue_push_duration_in_millis\"" } "json:\"events\"" } "json:\"inputs\""; Codecs []struct { ID string "json:\"id\""; Name string "json:\"name\""; Decode struct { Out int "json:\"out\""; WritesIn int "json:\"writes_in\""; DurationInMillis int "json:\"duration_in_millis\"" } "json:\"decode\""; Encode struct { WritesIn int "json:\"writes_in\""; DurationInMillis int "json:\"duration_in_millis\"" } "json:\"encode\"" } "json:\"codecs\""; Filters []struct { ID string "json:\"id\""; Name string "json:\"name\""; Events struct { Out int "json:\"out\""; In int "json:\"in\""; DurationInMillis int "json:\"duration_in_millis\"" } "json:\"events\""; Flow struct { WorkerUtilization struct { Current responses.InfinityFloat "json:\"current\""; Lifetime responses.InfinityFloat "json:\"lifetime\"" } "json:\"worker_utilization\""; WorkerMillisPerEvent struct { Lifetime responses.InfinityFloat "json:\"lifetime\"" } "json:\"worker_millis_per_event\"" } "json:\"flow\"" } "json:\"filters\""; Outputs []struct { ID string "json:\"id\""; Name string "json:\"name\""; Events struct { Out int "json:\"out\""; In int "json:\"in\""; DurationInMillis int "json:\"duration_in_millis\"" } "json:\"events\""; Documents struct { Successes int "json:\"successes\""; NonRetryableFailures int "json:\"non_retryable_failures\"" } "json:\"documents\""; BulkRequests struct { WithErrors int "json:\"with_errors\""; Responses map[string]int "json:\"responses\"" } "json:\"bulk_requests\""; Flow struct { WorkerUtilization struct { Current float64 "json:\"current\""; Lifetime float64 "json:\"lifetime\"" } "json:\"worker_utilization\"" } "json:\"flow\"" } "json:\"outputs\"" }{ Inputs: { { ID: "9a9bed30135e19c8047fe6aa0588b70b15280fb9161fea8ed8e7368e1fb1e6d3", @@ -113,14 +113,14 @@ responses.NodeStatsResponse{ Monitoring: responses.PipelineLogstashMonitoringResponse{}, Events: struct { Out int "json:\"out\""; Filtered int "json:\"filtered\""; In int "json:\"in\""; DurationInMillis int "json:\"duration_in_millis\""; QueuePushDurationInMillis int "json:\"queue_push_duration_in_millis\"" }{Out:1250, Filtered:1250, In:3751, DurationInMillis:495018, QueuePushDurationInMillis:49455}, Flow: responses.FlowResponse{ - InputThroughput: struct { Current float64 "json:\"current\""; Lifetime float64 "json:\"lifetime\"" }{Current:0, Lifetime:74.88}, - FilterThroughput: struct { Current float64 "json:\"current\""; Lifetime float64 "json:\"lifetime\"" }{Current:0, Lifetime:24.95}, - OutputThroughput: struct { Current float64 "json:\"current\""; Lifetime float64 "json:\"lifetime\"" }{Current:0, Lifetime:24.95}, - QueueBackpressure: struct { Current float64 "json:\"current\""; Lifetime float64 "json:\"lifetime\"" }{Current:1, Lifetime:0.9872}, - WorkerConcurrency: struct { Current float64 "json:\"current\""; Lifetime float64 "json:\"lifetime\"" }{Current:10, Lifetime:9.882}, - WorkerUtilization: struct { Current float64 "json:\"current\""; Lifetime float64 "json:\"lifetime\"" }{Current:100, Lifetime:98.82}, + InputThroughput: struct { Current responses.InfinityFloat "json:\"current\""; Lifetime responses.InfinityFloat "json:\"lifetime\"" }{Current:0, Lifetime:74.88}, + FilterThroughput: struct { Current responses.InfinityFloat "json:\"current\""; Lifetime responses.InfinityFloat "json:\"lifetime\"" }{Current:0, Lifetime:24.95}, + OutputThroughput: struct { Current responses.InfinityFloat "json:\"current\""; Lifetime responses.InfinityFloat "json:\"lifetime\"" }{Current:0, Lifetime:24.95}, + QueueBackpressure: struct { Current responses.InfinityFloat "json:\"current\""; Lifetime responses.InfinityFloat "json:\"lifetime\"" }{Current:1, Lifetime:0.9872}, + WorkerConcurrency: struct { Current responses.InfinityFloat "json:\"current\""; Lifetime responses.InfinityFloat "json:\"lifetime\"" }{Current:10, Lifetime:9.882}, + WorkerUtilization: struct { Current responses.InfinityFloat "json:\"current\""; Lifetime responses.InfinityFloat "json:\"lifetime\"" }{Current:100, Lifetime:98.82}, }, - Plugins: struct { Inputs []struct { ID string "json:\"id\""; Name string "json:\"name\""; Events struct { Out int "json:\"out\""; QueuePushDurationInMillis int "json:\"queue_push_duration_in_millis\"" } "json:\"events\"" } "json:\"inputs\""; Codecs []struct { ID string "json:\"id\""; Name string "json:\"name\""; Decode struct { Out int "json:\"out\""; WritesIn int "json:\"writes_in\""; DurationInMillis int "json:\"duration_in_millis\"" } "json:\"decode\""; Encode struct { WritesIn int "json:\"writes_in\""; DurationInMillis int "json:\"duration_in_millis\"" } "json:\"encode\"" } "json:\"codecs\""; Filters []struct { ID string "json:\"id\""; Name string "json:\"name\""; Events struct { Out int "json:\"out\""; In int "json:\"in\""; DurationInMillis int "json:\"duration_in_millis\"" } "json:\"events\""; Flow struct { WorkerUtilization struct { Current float64 "json:\"current\""; Lifetime float64 "json:\"lifetime\"" } "json:\"worker_utilization\""; WorkerMillisPerEvent struct { Lifetime float64 "json:\"lifetime\"" } "json:\"worker_millis_per_event\"" } "json:\"flow\"" } "json:\"filters\""; Outputs []struct { ID string "json:\"id\""; Name string "json:\"name\""; Events struct { Out int "json:\"out\""; In int "json:\"in\""; DurationInMillis int "json:\"duration_in_millis\"" } "json:\"events\""; Documents struct { Successes int "json:\"successes\""; NonRetryableFailures int "json:\"non_retryable_failures\"" } "json:\"documents\""; BulkRequests struct { WithErrors int "json:\"with_errors\""; Responses map[string]int "json:\"responses\"" } "json:\"bulk_requests\""; Flow struct { WorkerUtilization struct { Current float64 "json:\"current\""; Lifetime float64 "json:\"lifetime\"" } "json:\"worker_utilization\"" } "json:\"flow\"" } "json:\"outputs\"" }{ + Plugins: struct { Inputs []struct { ID string "json:\"id\""; Name string "json:\"name\""; Events struct { Out int "json:\"out\""; QueuePushDurationInMillis int "json:\"queue_push_duration_in_millis\"" } "json:\"events\"" } "json:\"inputs\""; Codecs []struct { ID string "json:\"id\""; Name string "json:\"name\""; Decode struct { Out int "json:\"out\""; WritesIn int "json:\"writes_in\""; DurationInMillis int "json:\"duration_in_millis\"" } "json:\"decode\""; Encode struct { WritesIn int "json:\"writes_in\""; DurationInMillis int "json:\"duration_in_millis\"" } "json:\"encode\"" } "json:\"codecs\""; Filters []struct { ID string "json:\"id\""; Name string "json:\"name\""; Events struct { Out int "json:\"out\""; In int "json:\"in\""; DurationInMillis int "json:\"duration_in_millis\"" } "json:\"events\""; Flow struct { WorkerUtilization struct { Current responses.InfinityFloat "json:\"current\""; Lifetime responses.InfinityFloat "json:\"lifetime\"" } "json:\"worker_utilization\""; WorkerMillisPerEvent struct { Lifetime responses.InfinityFloat "json:\"lifetime\"" } "json:\"worker_millis_per_event\"" } "json:\"flow\"" } "json:\"filters\""; Outputs []struct { ID string "json:\"id\""; Name string "json:\"name\""; Events struct { Out int "json:\"out\""; In int "json:\"in\""; DurationInMillis int "json:\"duration_in_millis\"" } "json:\"events\""; Documents struct { Successes int "json:\"successes\""; NonRetryableFailures int "json:\"non_retryable_failures\"" } "json:\"documents\""; BulkRequests struct { WithErrors int "json:\"with_errors\""; Responses map[string]int "json:\"responses\"" } "json:\"bulk_requests\""; Flow struct { WorkerUtilization struct { Current float64 "json:\"current\""; Lifetime float64 "json:\"lifetime\"" } "json:\"worker_utilization\"" } "json:\"flow\"" } "json:\"outputs\"" }{ Inputs: { { ID: "5ee0ea3d45c32bab3b41963bd900e758ba6e193a11079649302574c706fd5e2f", @@ -158,49 +158,49 @@ responses.NodeStatsResponse{ ID: "prune-http-input-fields", Name: "prune", Events: struct { Out int "json:\"out\""; In int "json:\"in\""; DurationInMillis int "json:\"duration_in_millis\"" }{Out:1250, In:1250, DurationInMillis:127}, - Flow: struct { WorkerUtilization struct { Current float64 "json:\"current\""; Lifetime float64 "json:\"lifetime\"" } "json:\"worker_utilization\""; WorkerMillisPerEvent struct { Lifetime float64 "json:\"lifetime\"" } "json:\"worker_millis_per_event\"" }{ - WorkerUtilization: struct { Current float64 "json:\"current\""; Lifetime float64 "json:\"lifetime\"" }{Current:0, Lifetime:0.02535}, - WorkerMillisPerEvent: struct { Lifetime float64 "json:\"lifetime\"" }{Lifetime:0.1016}, + Flow: struct { WorkerUtilization struct { Current responses.InfinityFloat "json:\"current\""; Lifetime responses.InfinityFloat "json:\"lifetime\"" } "json:\"worker_utilization\""; WorkerMillisPerEvent struct { Lifetime responses.InfinityFloat "json:\"lifetime\"" } "json:\"worker_millis_per_event\"" }{ + WorkerUtilization: struct { Current responses.InfinityFloat "json:\"current\""; Lifetime responses.InfinityFloat "json:\"lifetime\"" }{Current:0, Lifetime:0.02535}, + WorkerMillisPerEvent: struct { Lifetime responses.InfinityFloat "json:\"lifetime\"" }{Lifetime:0.1016}, }, }, { ID: "ca953dac49c8fd3b00ba8275af10f9c6bcd9ca95755cd7892952966c5a13d427", Name: "ruby", Events: struct { Out int "json:\"out\""; In int "json:\"in\""; DurationInMillis int "json:\"duration_in_millis\"" }{Out:1250, In:2500, DurationInMillis:489610}, - Flow: struct { WorkerUtilization struct { Current float64 "json:\"current\""; Lifetime float64 "json:\"lifetime\"" } "json:\"worker_utilization\""; WorkerMillisPerEvent struct { Lifetime float64 "json:\"lifetime\"" } "json:\"worker_millis_per_event\"" }{ - WorkerUtilization: struct { Current float64 "json:\"current\""; Lifetime float64 "json:\"lifetime\"" }{Current:100, Lifetime:97.74}, - WorkerMillisPerEvent: struct { Lifetime float64 "json:\"lifetime\"" }{Lifetime:195.8}, + Flow: struct { WorkerUtilization struct { Current responses.InfinityFloat "json:\"current\""; Lifetime responses.InfinityFloat "json:\"lifetime\"" } "json:\"worker_utilization\""; WorkerMillisPerEvent struct { Lifetime responses.InfinityFloat "json:\"lifetime\"" } "json:\"worker_millis_per_event\"" }{ + WorkerUtilization: struct { Current responses.InfinityFloat "json:\"current\""; Lifetime responses.InfinityFloat "json:\"lifetime\"" }{Current:100, Lifetime:97.74}, + WorkerMillisPerEvent: struct { Lifetime responses.InfinityFloat "json:\"lifetime\"" }{Lifetime:195.8}, }, }, { ID: "drop-non-existent", Name: "drop", Events: struct { Out int "json:\"out\""; In int "json:\"in\""; DurationInMillis int "json:\"duration_in_millis\"" }{}, - Flow: struct { WorkerUtilization struct { Current float64 "json:\"current\""; Lifetime float64 "json:\"lifetime\"" } "json:\"worker_utilization\""; WorkerMillisPerEvent struct { Lifetime float64 "json:\"lifetime\"" } "json:\"worker_millis_per_event\"" }{}, + Flow: struct { WorkerUtilization struct { Current responses.InfinityFloat "json:\"current\""; Lifetime responses.InfinityFloat "json:\"lifetime\"" } "json:\"worker_utilization\""; WorkerMillisPerEvent struct { Lifetime responses.InfinityFloat "json:\"lifetime\"" } "json:\"worker_millis_per_event\"" }{}, }, { ID: "json-filter", Name: "json", Events: struct { Out int "json:\"out\""; In int "json:\"in\""; DurationInMillis int "json:\"duration_in_millis\"" }{Out:1250, In:1250, DurationInMillis:214}, - Flow: struct { WorkerUtilization struct { Current float64 "json:\"current\""; Lifetime float64 "json:\"lifetime\"" } "json:\"worker_utilization\""; WorkerMillisPerEvent struct { Lifetime float64 "json:\"lifetime\"" } "json:\"worker_millis_per_event\"" }{ - WorkerUtilization: struct { Current float64 "json:\"current\""; Lifetime float64 "json:\"lifetime\"" }{Current:0, Lifetime:0.04272}, - WorkerMillisPerEvent: struct { Lifetime float64 "json:\"lifetime\"" }{Lifetime:0.1712}, + Flow: struct { WorkerUtilization struct { Current responses.InfinityFloat "json:\"current\""; Lifetime responses.InfinityFloat "json:\"lifetime\"" } "json:\"worker_utilization\""; WorkerMillisPerEvent struct { Lifetime responses.InfinityFloat "json:\"lifetime\"" } "json:\"worker_millis_per_event\"" }{ + WorkerUtilization: struct { Current responses.InfinityFloat "json:\"current\""; Lifetime responses.InfinityFloat "json:\"lifetime\"" }{Current:0, Lifetime:0.04272}, + WorkerMillisPerEvent: struct { Lifetime responses.InfinityFloat "json:\"lifetime\"" }{Lifetime:0.1712}, }, }, { ID: "mutate-path-001", Name: "mutate", Events: struct { Out int "json:\"out\""; In int "json:\"in\""; DurationInMillis int "json:\"duration_in_millis\"" }{Out:1250, In:1250, DurationInMillis:170}, - Flow: struct { WorkerUtilization struct { Current float64 "json:\"current\""; Lifetime float64 "json:\"lifetime\"" } "json:\"worker_utilization\""; WorkerMillisPerEvent struct { Lifetime float64 "json:\"lifetime\"" } "json:\"worker_millis_per_event\"" }{ - WorkerUtilization: struct { Current float64 "json:\"current\""; Lifetime float64 "json:\"lifetime\"" }{Current:0, Lifetime:0.03394}, - WorkerMillisPerEvent: struct { Lifetime float64 "json:\"lifetime\"" }{Lifetime:0.136}, + Flow: struct { WorkerUtilization struct { Current responses.InfinityFloat "json:\"current\""; Lifetime responses.InfinityFloat "json:\"lifetime\"" } "json:\"worker_utilization\""; WorkerMillisPerEvent struct { Lifetime responses.InfinityFloat "json:\"lifetime\"" } "json:\"worker_millis_per_event\"" }{ + WorkerUtilization: struct { Current responses.InfinityFloat "json:\"current\""; Lifetime responses.InfinityFloat "json:\"lifetime\"" }{Current:0, Lifetime:0.03394}, + WorkerMillisPerEvent: struct { Lifetime responses.InfinityFloat "json:\"lifetime\"" }{Lifetime:0.136}, }, }, { ID: "drop-80-percent", Name: "drop", Events: struct { Out int "json:\"out\""; In int "json:\"in\""; DurationInMillis int "json:\"duration_in_millis\"" }{}, - Flow: struct { WorkerUtilization struct { Current float64 "json:\"current\""; Lifetime float64 "json:\"lifetime\"" } "json:\"worker_utilization\""; WorkerMillisPerEvent struct { Lifetime float64 "json:\"lifetime\"" } "json:\"worker_millis_per_event\"" }{}, + Flow: struct { WorkerUtilization struct { Current responses.InfinityFloat "json:\"current\""; Lifetime responses.InfinityFloat "json:\"lifetime\"" } "json:\"worker_utilization\""; WorkerMillisPerEvent struct { Lifetime responses.InfinityFloat "json:\"lifetime\"" } "json:\"worker_millis_per_event\"" }{}, }, }, Outputs: {