package
6.8.16+incompatible
Repository: https://github.com/tencentblueking/beats.git
Documentation: pkg.go.dev
# Functions
Feature creates a new type of queue.
FindFactory retrieves a queue types constructor.
RegisterType registers a new queue type.
# Variables
Namespace is the feature namespace for queue definition.
# Structs
BufferConfig returns the pipelines buffering settings, for the pipeline to use.
ProducerConfig as used by the Pipeline to configure some custom callbacks between pipeline and queue.
# Interfaces
Batch of events to be returned to Consumers.
Consumer interface to be used by the pipeline output workers.
Eventer listens to special events to be send by queue implementations.
Producer interface to be used by the pipelines client to forward events to be published to the queue.
Queue is responsible for accepting, forwarding and ACKing events.
# Type aliases
Factory for creating a queue used by a pipeline instance.