forward

Documentation

Index

• type ForwardOutput
  • func (f *ForwardOutput) Process(ctx context.Context, entry *entry.Entry) error
  • func (f *ForwardOutput) Start() error
  • func (f *ForwardOutput) Stop() error
• type ForwardOutputConfig
  • func NewForwardOutputConfig(operatorID string) *ForwardOutputConfig
  • func (c ForwardOutputConfig) Build(bc operator.BuildContext) ([]operator.Operator, error)

Types

type ForwardOutput

type ForwardOutput struct {
	helper.OutputOperator
	// contains filtered or unexported fields
}

ForwardOutput is an operator that sends entries to another stanza instance

func (*ForwardOutput) Process

func (f *ForwardOutput) Process(ctx context.Context, entry *entry.Entry) error

Process adds an entry to the outputs buffer

func (*ForwardOutput) Start

func (f *ForwardOutput) Start() error

Start signals to the ForwardOutput to begin flushing

func (*ForwardOutput) Stop

func (f *ForwardOutput) Stop() error

Stop tells the ForwardOutput to stop gracefully

type ForwardOutputConfig

type ForwardOutputConfig struct {
	helper.OutputConfig `yaml:",inline"`
	BufferConfig        buffer.Config  `json:"buffer"  yaml:"buffer"`
	FlusherConfig       flusher.Config `json:"flusher" yaml:"flusher"`
	Address             string         `json:"address" yaml:"address"`
}

ForwardOutputConfig is the configuration of a forward output operator.

func NewForwardOutputConfig

func NewForwardOutputConfig(operatorID string) *ForwardOutputConfig

NewForwardOutputConfig creates a new forward output config with default values

func (ForwardOutputConfig) Build

func (c ForwardOutputConfig) Build(bc operator.BuildContext) ([]operator.Operator, error)

Build will build an forward output operator.