stdin

Documentation

Index

• type StdinInput
  • func (g *StdinInput) Start(_ operator.Persister) error
  • func (g *StdinInput) Stop() error
• type StdinInputConfig
  • func NewStdinInputConfig(operatorID string) *StdinInputConfig
  • func (c *StdinInputConfig) Build(logger *zap.SugaredLogger) (operator.Operator, error)

Types

type StdinInput

type StdinInput struct {
	helper.InputOperator
	// contains filtered or unexported fields
}

StdinInput is an operator that reads input from stdin

func (*StdinInput) Start

func (g *StdinInput) Start(_ operator.Persister) error

Start will start generating log entries.

func (*StdinInput) Stop

func (g *StdinInput) Stop() error

Stop will stop generating logs.

type StdinInputConfig

type StdinInputConfig struct {
	helper.InputConfig `yaml:",inline"`
}

StdinInputConfig is the configuration of a stdin input operator.

func NewStdinInputConfig

func NewStdinInputConfig(operatorID string) *StdinInputConfig

NewStdinInputConfig creates a new stdin input config with default values

func (*StdinInputConfig) Build

func (c *StdinInputConfig) Build(logger *zap.SugaredLogger) (operator.Operator, error)

Build will build a stdin input operator.