From 9f311e74645fc6815c46a9f2c111ddf2f550e123 Mon Sep 17 00:00:00 2001 From: urso Date: Fri, 28 Jul 2017 21:57:59 +0200 Subject: [PATCH] fix typo --- libbeat/publisher/beat/pipeline.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/libbeat/publisher/beat/pipeline.go b/libbeat/publisher/beat/pipeline.go index c74e8c2d947..86023601fa3 100644 --- a/libbeat/publisher/beat/pipeline.go +++ b/libbeat/publisher/beat/pipeline.go @@ -72,9 +72,9 @@ type ClientEventer interface { Closing() // Closing indicates the client is being shutdown next Closed() // Closed indicates the client being fully shutdown - Published() // event been has successfully forwarded to the publisher pipeline + Published() // event has been successfully forwarded to the publisher pipeline FilteredOut(Event) // event has been filtered out/dropped by processors - DroppedOnPublish(Event) // event has been dropped, while waiting for the broker + DroppedOnPublish(Event) // event has been dropped, while waiting for the queue } // PipelineACKHandler configures some pipeline-wide event ACK handler.