sample

Documentation

Index

• func DecodeConfig(md toml.MetaData, primValue toml.Primitive) (c interface{}, err error)
• func Process(ctx context.Context, config interface{}, input <-chan *event.ProcessorEvent) (output chan *event.ProcessorEvent, err error)
• type Config
  • func (c *Config) ConfigValidate() error
• type Sample

Functions

func DecodeConfig

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

func Process

func Process(ctx context.Context, config interface{}, input <-chan *event.ProcessorEvent) (output chan *event.ProcessorEvent, err error)

Types

type Config

type Config struct {
	Local        bool             `toml:"local"`
	SampleConfig map[string]int64 `toml:"sampleConfig"`
}

func (*Config) ConfigValidate

func (c *Config) ConfigValidate() error

type Sample

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