stdout

Documentation

Index

• func DecodeConfig(md toml.MetaData, primValue toml.Primitive) (c interface{}, err error)
• func NewStdout(ctx context.Context, config interface{}) (output.Output, error)
• type Config
  • func (c *Config) ConfigValidate() error
• type Stdout
  • func (s *Stdout) InputChan() chan *event.ProcessorEvent
  • func (s *Stdout) Run() (err error)
  • func (s *Stdout) Stop()

Functions

func DecodeConfig

func DecodeConfig(md toml.MetaData, primValue toml.Primitive) (c interface{}, err error)

func NewStdout

func NewStdout(ctx context.Context, config interface{}) (output.Output, error)

Types

type Config

type Config struct {
	Name string `tome:"name"`
}

func (*Config) ConfigValidate

func (c *Config) ConfigValidate() error

type Stdout

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

func (*Stdout) InputChan

func (s *Stdout) InputChan() chan *event.ProcessorEvent

func (*Stdout) Run

func (s *Stdout) Run() (err error)

func (*Stdout) Stop

func (s *Stdout) Stop()