mirror of
https://github.com/elastic/logstash.git
synced 2025-04-25 07:07:54 -04:00
Store duration_in_millis under the 'events' section in metrics
Fixes #5472
This commit is contained in:
parent
97a2f16b48
commit
fdf19eab2e
1 changed files with 2 additions and 2 deletions
|
@ -24,8 +24,8 @@ module LogStash
|
||||||
namespaced_metric = metric.namespace(@filter.plugin_unique_name.to_sym)
|
namespaced_metric = metric.namespace(@filter.plugin_unique_name.to_sym)
|
||||||
@filter.metric = metric
|
@filter.metric = metric
|
||||||
|
|
||||||
namespaced_metric.gauge(:name, config_name)
|
|
||||||
@metric_events = namespaced_metric.namespace(:events)
|
@metric_events = namespaced_metric.namespace(:events)
|
||||||
|
namespaced_metric.gauge(:name, config_name)
|
||||||
|
|
||||||
# Not all the filters will do bufferings
|
# Not all the filters will do bufferings
|
||||||
define_flush_method if @filter.respond_to?(:flush)
|
define_flush_method if @filter.respond_to?(:flush)
|
||||||
|
@ -38,7 +38,7 @@ module LogStash
|
||||||
def multi_filter(events)
|
def multi_filter(events)
|
||||||
@metric_events.increment(:in, events.size)
|
@metric_events.increment(:in, events.size)
|
||||||
|
|
||||||
clock = @filter.metric.time(:duration_in_millis)
|
clock = @metric_events.time(:duration_in_millis)
|
||||||
new_events = @filter.multi_filter(events)
|
new_events = @filter.multi_filter(events)
|
||||||
clock.stop
|
clock.stop
|
||||||
|
|
||||||
|
|
Loading…
Add table
Add a link
Reference in a new issue