drop

Documentation

Index

• type DropOutput
  • func (p *DropOutput) Process(ctx context.Context, entry *entry.Entry) error
• type DropOutputConfig
  • func NewDropOutputConfig(operatorID string) *DropOutputConfig
  • func (c DropOutputConfig) Build(context operator.BuildContext) ([]operator.Operator, error)

Types

type DropOutput

type DropOutput struct {
	helper.OutputOperator
}

DropOutput is an operator that consumes and ignores incoming entries.

func (*DropOutput) Process

func (p *DropOutput) Process(ctx context.Context, entry *entry.Entry) error

Process will drop the incoming entry.

type DropOutputConfig

type DropOutputConfig struct {
	helper.OutputConfig `yaml:",inline"`
}

DropOutputConfig is the configuration of a drop output operator.

func NewDropOutputConfig

func NewDropOutputConfig(operatorID string) *DropOutputConfig

NewDropOutputConfig creates a new drop output config with default values

func (DropOutputConfig) Build

func (c DropOutputConfig) Build(context operator.BuildContext) ([]operator.Operator, error)

Build will build a drop output operator.