Documentation ¶
Index ¶
- func ConfigFactory(config interface{}) api.HttpFilterFactory
- func CreateStreamFilterChain(ctx context.Context, filterChainName string) *streamfilter.DefaultStreamFilterChainImpl
- func DestroyStreamFilterChain(fm *streamfilter.DefaultStreamFilterChainImpl)
- type ActiveStream
- func (s *ActiveStream) AppendData(buf mosnApi.IoBuffer, endStream bool)
- func (s *ActiveStream) AppendHeaders(headers mosnApi.HeaderMap, endStream bool)
- func (s *ActiveStream) AppendTrailers(trailers mosnApi.HeaderMap)
- func (s *ActiveStream) Connection() mosnApi.Connection
- func (s *ActiveStream) DecodeData(buffer api.BufferInstance, endStream bool) api.StatusType
- func (s *ActiveStream) DecodeHeaders(header api.RequestHeaderMap, endStream bool) api.StatusType
- func (s *ActiveStream) DecodeTrailers(trailer api.RequestTrailerMap) api.StatusType
- func (s *ActiveStream) EncodeData(buffer api.BufferInstance, endStream bool) api.StatusType
- func (s *ActiveStream) EncodeHeaders(header api.ResponseHeaderMap, endStream bool) api.StatusType
- func (s *ActiveStream) EncodeTrailers(trailer api.ResponseTrailerMap) api.StatusType
- func (s *ActiveStream) GetFilterCurrentPhase() mosnApi.ReceiverFilterPhase
- func (s *ActiveStream) GetRequestData() mosnApi.IoBuffer
- func (s *ActiveStream) GetRequestHeaders() mosnApi.HeaderMap
- func (s *ActiveStream) GetRequestTrailers() mosnApi.HeaderMap
- func (s *ActiveStream) GetResponseData() mosnApi.IoBuffer
- func (s *ActiveStream) GetResponseHeaders() mosnApi.HeaderMap
- func (s *ActiveStream) GetResponseTrailers() mosnApi.HeaderMap
- func (s *ActiveStream) OnDestroy(reason api.DestroyReason)
- func (s *ActiveStream) RequestInfo() mosnApi.RequestInfo
- func (s *ActiveStream) Route() mosnApi.Route
- func (s *ActiveStream) SendDirectResponse(headers mosnApi.HeaderMap, buf mosnApi.IoBuffer, trailers mosnApi.HeaderMap)
- func (s *ActiveStream) SendHijackReply(code int, headers mosnApi.HeaderMap)
- func (s *ActiveStream) SendHijackReplyWithBody(code int, headers mosnApi.HeaderMap, body string)
- func (s *ActiveStream) SetCurrentReceiverPhase(phase mosnApi.ReceiverFilterPhase)
- func (s *ActiveStream) SetRequestData(buf mosnApi.IoBuffer)
- func (s *ActiveStream) SetRequestHeaders(headers mosnApi.HeaderMap)
- func (s *ActiveStream) SetRequestTrailers(trailers mosnApi.HeaderMap)
- func (s *ActiveStream) SetResponseData(buf mosnApi.IoBuffer)
- func (s *ActiveStream) SetResponseHeaders(headers mosnApi.HeaderMap)
- func (s *ActiveStream) SetResponseTrailers(trailers mosnApi.HeaderMap)
- func (s *ActiveStream) TerminateStream(code int) bool
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ConfigFactory ¶
func ConfigFactory(config interface{}) api.HttpFilterFactory
func CreateStreamFilterChain ¶
func CreateStreamFilterChain(ctx context.Context, filterChainName string) *streamfilter.DefaultStreamFilterChainImpl
func DestroyStreamFilterChain ¶
func DestroyStreamFilterChain(fm *streamfilter.DefaultStreamFilterChainImpl)
Types ¶
type ActiveStream ¶
type ActiveStream struct {
// contains filtered or unexported fields
}
func (*ActiveStream) AppendData ¶
func (s *ActiveStream) AppendData(buf mosnApi.IoBuffer, endStream bool)
func (*ActiveStream) AppendHeaders ¶
func (s *ActiveStream) AppendHeaders(headers mosnApi.HeaderMap, endStream bool)
func (*ActiveStream) AppendTrailers ¶
func (s *ActiveStream) AppendTrailers(trailers mosnApi.HeaderMap)
func (*ActiveStream) Connection ¶
func (s *ActiveStream) Connection() mosnApi.Connection
func (*ActiveStream) DecodeData ¶
func (s *ActiveStream) DecodeData(buffer api.BufferInstance, endStream bool) api.StatusType
func (*ActiveStream) DecodeHeaders ¶
func (s *ActiveStream) DecodeHeaders(header api.RequestHeaderMap, endStream bool) api.StatusType
func (*ActiveStream) DecodeTrailers ¶
func (s *ActiveStream) DecodeTrailers(trailer api.RequestTrailerMap) api.StatusType
func (*ActiveStream) EncodeData ¶
func (s *ActiveStream) EncodeData(buffer api.BufferInstance, endStream bool) api.StatusType
func (*ActiveStream) EncodeHeaders ¶
func (s *ActiveStream) EncodeHeaders(header api.ResponseHeaderMap, endStream bool) api.StatusType
func (*ActiveStream) EncodeTrailers ¶
func (s *ActiveStream) EncodeTrailers(trailer api.ResponseTrailerMap) api.StatusType
func (*ActiveStream) GetFilterCurrentPhase ¶
func (s *ActiveStream) GetFilterCurrentPhase() mosnApi.ReceiverFilterPhase
func (*ActiveStream) GetRequestData ¶
func (s *ActiveStream) GetRequestData() mosnApi.IoBuffer
func (*ActiveStream) GetRequestHeaders ¶
func (s *ActiveStream) GetRequestHeaders() mosnApi.HeaderMap
func (*ActiveStream) GetRequestTrailers ¶
func (s *ActiveStream) GetRequestTrailers() mosnApi.HeaderMap
func (*ActiveStream) GetResponseData ¶
func (s *ActiveStream) GetResponseData() mosnApi.IoBuffer
func (*ActiveStream) GetResponseHeaders ¶
func (s *ActiveStream) GetResponseHeaders() mosnApi.HeaderMap
func (*ActiveStream) GetResponseTrailers ¶
func (s *ActiveStream) GetResponseTrailers() mosnApi.HeaderMap
func (*ActiveStream) OnDestroy ¶
func (s *ActiveStream) OnDestroy(reason api.DestroyReason)
func (*ActiveStream) RequestInfo ¶
func (s *ActiveStream) RequestInfo() mosnApi.RequestInfo
func (*ActiveStream) Route ¶
func (s *ActiveStream) Route() mosnApi.Route
func (*ActiveStream) SendDirectResponse ¶
func (*ActiveStream) SendHijackReply ¶
func (s *ActiveStream) SendHijackReply(code int, headers mosnApi.HeaderMap)
func (*ActiveStream) SendHijackReplyWithBody ¶
func (s *ActiveStream) SendHijackReplyWithBody(code int, headers mosnApi.HeaderMap, body string)
func (*ActiveStream) SetCurrentReceiverPhase ¶
func (s *ActiveStream) SetCurrentReceiverPhase(phase mosnApi.ReceiverFilterPhase)
func (*ActiveStream) SetRequestData ¶
func (s *ActiveStream) SetRequestData(buf mosnApi.IoBuffer)
func (*ActiveStream) SetRequestHeaders ¶
func (s *ActiveStream) SetRequestHeaders(headers mosnApi.HeaderMap)
func (*ActiveStream) SetRequestTrailers ¶
func (s *ActiveStream) SetRequestTrailers(trailers mosnApi.HeaderMap)
func (*ActiveStream) SetResponseData ¶
func (s *ActiveStream) SetResponseData(buf mosnApi.IoBuffer)
func (*ActiveStream) SetResponseHeaders ¶
func (s *ActiveStream) SetResponseHeaders(headers mosnApi.HeaderMap)
func (*ActiveStream) SetResponseTrailers ¶
func (s *ActiveStream) SetResponseTrailers(trailers mosnApi.HeaderMap)
func (*ActiveStream) TerminateStream ¶
func (s *ActiveStream) TerminateStream(code int) bool
Click to show internal directories.
Click to hide internal directories.