package
6.8.16+incompatible
Repository: https://github.com/tencentblueking/beats.git
Documentation: pkg.go.dev

# Packages

Package memqueue provides an in-memory queue.Queue implementation for use with the publisher pipeline.
Package queuetest provides common functionality tests all queue implementations must pass.
No description provided by the author

# 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.