mosn

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

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 (s *ActiveStream) SendDirectResponse(headers mosnApi.HeaderMap, buf mosnApi.IoBuffer, trailers mosnApi.HeaderMap)

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