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

# Functions

CloseOnSignal closes the outlet, once the signal triggers.
ConnectTo creates a new Connector, combining a beat.Pipeline with an outlet Factory.
NewOutletFactory creates a new outlet factory for connecting an input to the publisher pipeline.
SubOutlet create a sub-outlet, which can be closed individually, without closing the underlying outlet.

# Structs

No description provided by the author

# Interfaces

Outleter is the outlet for an input.

# Type aliases

Connector creates an Outlet connecting the event publishing with some internal pipeline.
Factory is used to create a new Outlet instance.