plugin

Documentation

Index

• Variables
• func HTTPReqCall(buf []byte, conn net.Conn) (*flatbuffers.Builder, error)
• func HTTPRespCall(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 RequestFilterFunc, rsv ResponseFilterFunc) 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 ParseConfFunc
• type RequestFilterFunc
• type ResponseFilterFunc
• type RuleConf
  • func GetRuleConf(token uint32) (RuleConf, error)

Variables

var (
	ErrMissingName                 = errors.New("missing name")
	ErrMissingParseConfMethod      = errors.New("missing ParseConf method")
	ErrMissingRequestFilterMethod  = errors.New("missing RequestFilter method")
	ErrMissingResponseFilterMethod = errors.New("missing ResponseFilter method")

	RequestPhase  = requestPhase{}
	ResponsePhase = responsePhase{}
)

Functions

func HTTPReqCall

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

func HTTPRespCall

func HTTPRespCall(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 RequestFilterFunc, rsv ResponseFilterFunc) 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 ParseConfFunc

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

type RequestFilterFunc

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

type ResponseFilterFunc

type ResponseFilterFunc func(conf interface{}, w pkgHTTP.Response)

type RuleConf

type RuleConf []ConfEntry

func GetRuleConf

func GetRuleConf(token uint32) (RuleConf, error)