moe

package

v1.6.0 Latest Latest Go to latest Published: Aug 17, 2023 License: Apache-2.0 Imports: 16 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/mosn/mosn

Links

Open Source Insights

Documentation ¶

Index ¶

func ConfigFactory(config interface{}) api.HttpFilterFactory
func CreateStreamFilterChain(ctx context.Context, filterChainName string) *streamfilter.DefaultStreamFilterChainImpl
func DestroyStreamFilterChain(fm *streamfilter.DefaultStreamFilterChainImpl)
type ActiveStream

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 (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

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL