filter

Documentation

Index

• type BaseFilter
  • 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

Types

type BaseFilter

type BaseFilter struct{}

BaseFilter base filter support default implemention

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 {
	SetStartAt(startAt int64)
	SetEndAt(endAt int64)
	GetStartAt() int64
	GetEndAt() int64

	GetProxyServerAddr() string
	GetProxyOuterRequest() *fasthttp.Request
	GetProxyResponse() *fasthttp.Response
	NeedMerge() bool

	GetOriginRequestCtx() *fasthttp.RequestCtx

	GetMaxQPS() int

	ValidateProxyOuterRequest() bool

	InBlacklist(ip string) bool
	InWhitelist(ip string) bool

	IsCircuitOpen() bool
	IsCircuitHalf() bool

	GetOpenToCloseFailureRate() int
	GetHalfTrafficRate() int
	GetHalfToOpenSucceedRate() int
	GetOpenToCloseCollectSeconds() int

	ChangeCircuitStatusToClose()
	ChangeCircuitStatusToOpen()

	RecordMetricsForRequest()
	RecordMetricsForResponse()
	RecordMetricsForFailure()
	RecordMetricsForReject()

	GetRecentlyRequestSuccessedCount(sec int) int
	GetRecentlyRequestCount(sec int) int
	GetRecentlyRequestFailureCount(sec int) int
}

Context filter context

type Filter

type Filter interface {
	Name() string

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

Filter filter interface