filter

Documentation

Index

• Constants
• func NewCachedValue(body, contentType []byte) []byte
• func ParseCachedValue(data []byte) ([]byte, []byte)
• type BaseFilter
  • func (f BaseFilter) Init(cfg string) error
  • func (f BaseFilter) Post(c Context) (statusCode int, err error)
  • func (f BaseFilter) PostErr(c Context)
  • func (f BaseFilter) Pre(c Context) (statusCode int, err error)
• type Context
• type Filter

Constants

const (
	// UsingCachingValue using cached value to response
	UsingCachingValue = "__using_cache_value__"
)

Functions

func NewCachedValue

func NewCachedValue(body, contentType []byte) []byte

NewCachedValue returns a cached value

func ParseCachedValue

func ParseCachedValue(data []byte) ([]byte, []byte)

ParseCachedValue returns cached value as content-type and body value

Types

type BaseFilter

type BaseFilter struct{}

BaseFilter base filter support default implemention

func (BaseFilter) Init

func (f BaseFilter) Init(cfg string) error

Init init filter

func (BaseFilter) Post

func (f BaseFilter) Post(c Context) (statusCode int, err error)

Post execute after proxy

func (BaseFilter) PostErr

func (f BaseFilter) PostErr(c Context)

PostErr execute proxy has errors

func (BaseFilter) Pre

func (f BaseFilter) Pre(c Context) (statusCode int, err error)

Pre execute before proxy

type Context

type Context interface {
	StartAt() time.Time
	EndAt() time.Time

	OriginRequest() *fasthttp.RequestCtx
	ForwardRequest() *fasthttp.Request
	Response() *fasthttp.Response

	API() *metapb.API
	DispatchNode() *metapb.DispatchNode
	Server() *metapb.Server
	Analysis() *util.Analysis

	SetAttr(key string, value interface{})
	GetAttr(key string) interface{}
}

Context filter context

type Filter

type Filter interface {
	Name() string
	Init(cfg string) error

	Pre(c Context) (statusCode int, err error)
	Post(c Context) (statusCode int, err error)
	PostErr(c Context)
}

Filter filter interface