plugin

Documentation

Index

• Variables
• func HTTPReqCall(buf []byte, conn net.Conn) (*flatbuffers.Builder, error)
• func InitConfCache(ttl time.Duration)
• func PrepareConf(buf []byte) (*flatbuffers.Builder, error)
• func RegisterPlugin(name string, pc ParseConfFunc, sv FilterFunc) error
• func SetRuleConfInTest(token uint32, conf RuleConf) error
• type ConfCache
  • func (cc *ConfCache) Get(token uint32) (RuleConf, error)
  • func (cc *ConfCache) Set(req *pc.Req) (uint32, error)
  • func (cc *ConfCache) SetInTest(token uint32, entries RuleConf) error
• type ConfEntry
• type ErrPluginRegistered
  • func (err ErrPluginRegistered) Error() string
• type FilterFunc
• type ParseConfFunc
• type RuleConf
  • func GetRuleConf(token uint32) (RuleConf, error)

Variables

var (
	ErrMissingName            = errors.New("missing name")
	ErrMissingParseConfMethod = errors.New("missing ParseConf method")
	ErrMissingFilterMethod    = errors.New("missing Filter method")
)

Functions

func HTTPReqCall

func HTTPReqCall(buf []byte, conn net.Conn) (*flatbuffers.Builder, error)

func InitConfCache

func InitConfCache(ttl time.Duration)

func PrepareConf

func PrepareConf(buf []byte) (*flatbuffers.Builder, error)

func RegisterPlugin

func RegisterPlugin(name string, pc ParseConfFunc, sv FilterFunc) error

func SetRuleConfInTest

func SetRuleConfInTest(token uint32, conf RuleConf) error

Types

type ConfCache

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

func (*ConfCache) Get

func (cc *ConfCache) Get(token uint32) (RuleConf, error)

func (*ConfCache) Set

func (cc *ConfCache) Set(req *pc.Req) (uint32, error)

func (*ConfCache) SetInTest

func (cc *ConfCache) SetInTest(token uint32, entries RuleConf) error

type ConfEntry

type ConfEntry struct {
	Name  string
	Value interface{}
}

type ErrPluginRegistered

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

func (ErrPluginRegistered) Error

func (err ErrPluginRegistered) Error() string

type FilterFunc

type FilterFunc func(conf interface{}, w http.ResponseWriter, r pkgHTTP.Request)

type ParseConfFunc

type ParseConfFunc func(in []byte) (conf interface{}, err error)

type RuleConf

type RuleConf []ConfEntry

func GetRuleConf

func GetRuleConf(token uint32) (RuleConf, error)