counter

Documentation

Index

• type CountOutput
  • func (co *CountOutput) Process(_ context.Context, _ *entry.Entry) error
  • func (co *CountOutput) Start() error
  • func (co *CountOutput) Stop() error
• type CountOutputConfig
  • func NewCounterOutputConfig(operatorID string) *CountOutputConfig
  • func (c CountOutputConfig) Build(bc operator.BuildContext) ([]operator.Operator, error)

Types

type CountOutput

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

CountOutput is an output operator

func (*CountOutput) Process

func (co *CountOutput) Process(_ context.Context, _ *entry.Entry) error

Process increments the counter of the output operator

func (*CountOutput) Start

func (co *CountOutput) Start() error

Start begins messaging count output to either stdout or a file

func (*CountOutput) Stop

func (co *CountOutput) Stop() error

Stop tells the CountOutput to stop gracefully

type CountOutputConfig

type CountOutputConfig struct {
	helper.OutputConfig `yaml:",inline"`
	Path                string          `json:"path,omitempty" yaml:"path,omitempty"`
	Duration            helper.Duration `json:"duration,omitempty" yaml:"duration,omitempty"`
}

CountOutputConfig is the configuration of a count output operator.

func NewCounterOutputConfig

func NewCounterOutputConfig(operatorID string) *CountOutputConfig

NewCounterOutputConfig creates the default config for the count_output operator.

func (CountOutputConfig) Build

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

Build will build an instance of the count_output operator