Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Batch ¶
type Batch interface {
Events() []Event
// signals
ACK()
Drop()
Retry()
RetryEvents(events []Event)
Cancelled()
CancelledEvents(events []Event)
}
Batch is used to pass a batch of events to the outputs and asynchronously listening for signals from these outpts. After a batch is processed (completed or errors), one of the signal methods must be called.
type Event ¶
type Event struct {
Content beat.Event
Flags EventFlags
}
Event is used by the publisher pipeline and broker to pass additional meta-data to the consumers/outputs.
func (*Event) Guaranteed ¶
Guaranteed checks if the event must not be dropped by the output or the publisher pipeline.
type EventFlags ¶
type EventFlags uint8
EventFlags provides additional flags/option types for used with the outputs.
const ( // GuaranteedSend requires an output to not drop the event on failure, but // retry until ACK. GuaranteedSend EventFlags = 0x01 )
Source Files
Directories
¶
| Path | Synopsis |
|---|---|
|
Package pipeline combines all publisher functionality (processors, queue, outputs) to create instances of complete publisher pipelines, beats can connect to publish events to.
|
Package pipeline combines all publisher functionality (processors, queue, outputs) to create instances of complete publisher pipelines, beats can connect to publish events to. |
|
memqueue
Package memqueue provides an in-memory queue.Queue implementation for use with the publisher pipeline.
|
Package memqueue provides an in-memory queue.Queue implementation for use with the publisher pipeline. |
|
queuetest
Package queuetest provides common functionality tests all queue implementations must pass.
|
Package queuetest provides common functionality tests all queue implementations must pass. |
Click to show internal directories.
Click to hide internal directories.