channel

package

v6.1.2+incompatible Latest Latest Go to latest Published: Jan 9, 2018 License: Apache-2.0 Imports: 5 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/jreyeshdez/beats

Links

Open Source Insights

Documentation ¶

Index ¶

type Factory
type OutletFactory
- func NewOutletFactory(done <-chan struct{}, pipeline beat.Pipeline, wgEvents eventCounter) *OutletFactory
- func (f *OutletFactory) Create(cfg *common.Config, dynFields *common.MapStrPointer) (Outleter, error)
type Outleter
- func CloseOnSignal(outlet Outleter, sig <-chan struct{}) Outleter
- func SubOutlet(out Outleter) Outleter

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Factory ¶

type Factory func(*common.Config, *common.MapStrPointer) (Outleter, error)

Factory is used to create a new Outlet instance

type OutletFactory ¶

type OutletFactory struct {
	// contains filtered or unexported fields
}

func NewOutletFactory ¶

func NewOutletFactory(
	done <-chan struct{},
	pipeline beat.Pipeline,
	wgEvents eventCounter,
) *OutletFactory

NewOutletFactory creates a new outlet factory for connecting a prospector to the publisher pipeline.

func (*OutletFactory) Create ¶

func (f *OutletFactory) Create(cfg *common.Config, dynFields *common.MapStrPointer) (Outleter, error)

Create builds a new Outleter, while applying common prospector settings. Prospectors and all harvesters use the same pipeline client instance. This guarantees ordering between events as required by the registrar for file.State updates

type Outleter ¶

type Outleter interface {
	Close() error
	OnEvent(data *util.Data) bool
}

Outleter is the outlet for a prospector

func CloseOnSignal ¶

func CloseOnSignal(outlet Outleter, sig <-chan struct{}) Outleter

CloseOnSignal closes the outlet, once the signal triggers.

func SubOutlet ¶

func SubOutlet(out Outleter) Outleter

SubOutlet create a sub-outlet, which can be closed individually, without closing the underlying outlet.

Source Files ¶

View all Source files

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