schema

Documentation

Index

• type Action
• type Buffer
• type Cfg
• type Container
• type Loader
• type NewPlugin
• type Opts
• type Plugin
• type PluginTools

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.Logger
}

type Container

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

type Loader

type Loader interface {
	Init() error
	FInit() error
	Load(...NewPlugin) ([]Plugin, error)
}

type NewPlugin

type NewPlugin = func(*Cfg) (Plugin, error)

var NewPluginObj NewPlugin

type Opts

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

type Plugin

type Plugin interface {
	Name() string
	Init() error
	FInit() error
	Interest(msg *proto.Msg, tools PluginTools) (Action, error)
	PreProcess(msg *proto.Msg, tools PluginTools) (Action, error)
	Process(msg *proto.Msg, tools PluginTools) (Action, error)
	PostProcess(msg *proto.Msg, tools PluginTools) (Action, error)
}

type PluginTools

type PluginTools interface {
	Opts
	Buffer
}