http

Documentation

Index

• Constants
• Variables
• func FillRequestHeadersFromCtxVar(ctx context.Context, headers mosnhttp.RequestHeader, remoteAddr net.Addr)
• func NewConnPool(ctx context.Context, host types.Host) types.ConnectionPool
• func SetDefaultStreamConfig(c StreamConfig)
• type StreamConfig
• type StreamConnFactory
  • func (f *StreamConnFactory) CreateBiDirectStream(context context.Context, connection types.ClientConnection, ...) types.ClientStreamConnection
  • func (f *StreamConnFactory) CreateClientStream(context context.Context, connection types.ClientConnection, ...) types.ClientStreamConnection
  • func (f *StreamConnFactory) CreateServerStream(context context.Context, connection api.Connection, ...) types.ServerStreamConnection
  • func (f *StreamConnFactory) ProtocolMatch(context context.Context, prot string, magic []byte) error

Constants

const (
	VarRequestMethod = "http_request_method"
	VarRequestLength = "http_request_length"
)

Variables

var (
	HKConnection = []byte("Connection") // header key 'Connection'
	HVKeepAlive  = []byte("keep-alive") // header value 'keep-alive'

)

Functions

func FillRequestHeadersFromCtxVar

func FillRequestHeadersFromCtxVar(ctx context.Context, headers mosnhttp.RequestHeader, remoteAddr net.Addr)

func NewConnPool

func NewConnPool(ctx context.Context, host types.Host) types.ConnectionPool

func SetDefaultStreamConfig

func SetDefaultStreamConfig(c StreamConfig)

SetDefaultStreamConfig can change the default config for http. Call this function before mosn service start. DONOT call it when mosn is serving.

Types

type StreamConfig

type StreamConfig struct {
	MaxHeaderSize      int `json:"max_header_size,omitempty"`
	MaxRequestBodySize int `json:"max_request_body_size,omitempty"`
}

type StreamConnFactory

type StreamConnFactory struct{}

func (*StreamConnFactory) CreateBiDirectStream

func (f *StreamConnFactory) CreateBiDirectStream(context context.Context, connection types.ClientConnection,
	clientCallbacks types.StreamConnectionEventListener,
	serverCallbacks types.ServerStreamConnectionEventListener) types.ClientStreamConnection

func (*StreamConnFactory) CreateClientStream

func (f *StreamConnFactory) CreateClientStream(context context.Context, connection types.ClientConnection,
	streamConnCallbacks types.StreamConnectionEventListener, connCallbacks api.ConnectionEventListener) types.ClientStreamConnection

func (*StreamConnFactory) CreateServerStream

func (f *StreamConnFactory) CreateServerStream(context context.Context, connection api.Connection,
	callbacks types.ServerStreamConnectionEventListener) types.ServerStreamConnection

func (*StreamConnFactory) ProtocolMatch

func (f *StreamConnFactory) ProtocolMatch(context context.Context, prot string, magic []byte) error