httpstream

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 HttpStream

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 {
}

func (*Config) ConfigValidate

func (c *Config) ConfigValidate() error

type HttpStream

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