publisher

package
v6.1.0+incompatible Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Dec 11, 2017 License: Apache-2.0 Imports: 1 Imported by: 2,514

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

func (e *Event) Guaranteed() bool

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
)

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.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL