context

type BodyFlushFunc = func(body []byte, complete bool) (newBody []byte)

type Context interface {
	stdcontext.Context
	Protocol() Protocol
}

type FilterBuff struct {
	Name string
	Buff []byte
}

type FinishFunc = func()

type HTTPContext interface {
	Context
	Lock()
	Unlock()

	Request() HTTPRequest
	Response() HTTPResponse

	Cancel(err error)
	Cancelled() bool
	ClientDisconnected() bool

	OnFinish(FinishFunc)    // For setting final client statistics, etc.
	AddTag(tag string)      // For debug, log, etc.
	AddLazyTag(LazyTagFunc) // Return LazyTags as strings.

	StatMetric() *httpstat.Metric

	Finish()

	Template() texttemplate.TemplateEngine
	SetTemplate(ht *HTTPTemplate)
	SaveReqToTemplate(filterName string) error
	SaveRspToTemplate(filterName string) error

	CallNextHandler(lastResult string) string
	SetHandlerCaller(caller HandlerCaller)

	Tracing() *tracing.Tracing
}

type HTTPRequest interface {
	RealIP() string

	Method() string
	SetMethod(method string)

	// URL
	Scheme() string
	Host() string
	SetHost(host string)
	Path() string
	SetPath(path string)
	EscapedPath() string
	Query() string
	SetQuery(query string)
	Fragment() string

	Proto() string

	Header() *httpheader.HTTPHeader
	Cookie(name string) (*http.Cookie, error)
	Cookies() []*http.Cookie
	AddCookie(cookie *http.Cookie)

	Body() io.Reader
	SetBody(io.Reader, bool)

	Std() *http.Request

	Size() uint64 // bytes
}

type HTTPResponse interface {
	StatusCode() int // Default is 200
	SetStatusCode(code int)

	Header() *httpheader.HTTPHeader
	SetCookie(cookie *http.Cookie)

	SetBody(body io.Reader)
	Body() io.Reader
	OnFlushBody(BodyFlushFunc)

	Std() http.ResponseWriter

	Size() uint64 // bytes
}

type HTTPResult struct {
	Err error
}

type HTTPTemplate struct {
	Engine texttemplate.TemplateEngine
	// contains filtered or unexported fields
}

type HandlerCaller func(lastResult string) string

type LazyTagFunc = func() string

type MQTTClient interface {
	ClientID() string
	UserName() string
	Load(key interface{}) (value interface{}, ok bool)
	Store(key interface{}, value interface{})
	Delete(key interface{})
}

type MQTTContext interface {
	Context
	Client() MQTTClient
	Cancel(error)
	Canceled() bool
	Duration() time.Duration
	Finish()

	PacketType() MQTTPacketType
	ConnectPacket() *packets.ConnectPacket         // read only
	DisconnectPacket() *packets.DisconnectPacket   // read only
	SubscribePacket() *packets.SubscribePacket     // read only
	UnsubscribePacket() *packets.UnsubscribePacket // read only
	PublishPacket() *packets.PublishPacket         // read only

	SetDrop()         // set drop value to true
	Drop() bool       // if true, this mqtt packet will be dropped
	SetDisconnect()   // set disconnect value to true
	Disconnect() bool // if true, this mqtt client will be disconnected
	SetEarlyStop()    // set early stop value to true
	EarlyStop() bool  // if early stop is true, pipeline will skip following filters and return

	SetKV(string, interface{})
	GetKV(string) interface{}
}

type MQTTPacketType int

type MQTTResult struct {
	ErrString string
}

type MockMQTTClient struct {
	MockClientID string
	MockUserName string
	MockKVMap    sync.Map
}

type Protocol string

type TCPContext interface {
	Context
}

type TCPResult struct {
	Err error
}

type UDPContext interface {
	Context
}

type UDPResult struct {
	Err error
}