consumer

Documentation

Index

• type Config
  • func NewConfig() *Config
• type Consumer
• type Session

Types

type Config

type Config struct {
	SessionInfos []Session `mapstructure:"sessioninfo"`
}

func NewConfig

func NewConfig() *Config

type Consumer

type Consumer interface {
	Consume(data *model.DataBlock) error
}

type Session

type Session struct {
	Class  string            `mapstructure:"class"`
	Name   string            `mapstructure:"name"`
	Params map[string]string `mapstructure:"params"`
}