schema

Documentation

Index

• type Action
• type Buffer
• type Cfg
• type Container
• type Loader
• type NewPlug
• type Opts
• type Plug
• type PlugTools

Types

type Action

type Action int

const (
	STOP Action = iota
	CONTINUE
	SKIP
)

type Buffer

type Buffer interface {
	Write([]byte) error
	Read() []byte
}

type Cfg

type Cfg struct {
	Viper  *viper.Viper
	Logger log.Log
}

type Container

type Container interface {
	Init() error
	FInit() error
	Add([]Plug) error
	Remove(string) error
	Get(...string) ([]Plug, error)
}

type Loader

type Loader interface {
	Init() error
	FInit() error
	Load(...NewPlug) ([]Plug, error)
}

type NewPlug

type NewPlug = func(func(*Cfg)) (Plug, error)

var NewPlugObj NewPlug

type Opts

type Opts interface {
	Set(interface{}, interface{})
	Get(interface{}) (interface{}, bool)
}

type Plug

type Plug interface {
	Name() string
	Init() error
	FInit() error
	Interest(*proto.Msg, PlugTools) (Action, error)
	PreProcess(*proto.Msg, PlugTools) (Action, error)
	Process(*proto.Msg, PlugTools) (Action, error)
	PostProcess(*proto.Msg, PlugTools) (Action, error)
}

type PlugTools

type PlugTools interface {
	Opts
	Buffer
}