http

Documentation

Index

• func GetRequestData(ctx context.Context) (map[string]interface{}, error)
• func RegisterFilter(filterType string, handler RequestHandler)
• type ContextKeyRequestData
• type DispatchFilter
  • func (dis *DispatchFilter) OnDestroy()
  • func (dis *DispatchFilter) OnReceive(ctx context.Context, headers api.HeaderMap, buf buffer.IoBuffer, ...) api.StreamFilterStatus
  • func (dis *DispatchFilter) SetReceiveFilterHandler(handler api.StreamReceiverFilterHandler)
• type Endpoint
• type ParamsScanner
• type PathResolver
  • func NewPathResolver(path string) *PathResolver
  • func (p *PathResolver) HasNext() bool
  • func (p *PathResolver) Next() string
  • func (p *PathResolver) UnresolvedPath() string
• type RequestHandler
• type ServiceFactory
  • func (f *ServiceFactory) CreateFilterChain(context context.Context, callbacks api.StreamFilterChainFactoryCallbacks)

Functions

func GetRequestData

func GetRequestData(ctx context.Context) (map[string]interface{}, error)

func RegisterFilter

func RegisterFilter(filterType string, handler RequestHandler)

Types

type ContextKeyRequestData

type ContextKeyRequestData struct {
}

type DispatchFilter

type DispatchFilter struct {
	// contains filtered or unexported fields
}

func (*DispatchFilter) OnDestroy

func (dis *DispatchFilter) OnDestroy()

func (*DispatchFilter) OnReceive

func (dis *DispatchFilter) OnReceive(ctx context.Context, headers api.HeaderMap, buf buffer.IoBuffer, trailers api.HeaderMap) api.StreamFilterStatus

func (*DispatchFilter) SetReceiveFilterHandler

func (dis *DispatchFilter) SetReceiveFilterHandler(handler api.StreamReceiverFilterHandler)

type Endpoint

type Endpoint interface {
	Handle(ctx context.Context, params ParamsScanner) (jsonObject map[string]interface{}, err error)
}

type ParamsScanner

type ParamsScanner interface {
	//Next get the next param.
	Next() string
	HasNext() bool
}

type PathResolver

type PathResolver struct {
	// contains filtered or unexported fields
}

PathResolver is a util to extract elements in http path.

func NewPathResolver

func NewPathResolver(path string) *PathResolver

func (*PathResolver) HasNext

func (p *PathResolver) HasNext() bool

func (*PathResolver) Next

func (p *PathResolver) Next() string

func (*PathResolver) UnresolvedPath

func (p *PathResolver) UnresolvedPath() string

type RequestHandler

type RequestHandler interface {
	GetEndpoint(name string) (endpoint Endpoint, ok bool)
}

type ServiceFactory

type ServiceFactory struct {
	// contains filtered or unexported fields
}

func (*ServiceFactory) CreateFilterChain

func (f *ServiceFactory) CreateFilterChain(context context.Context, callbacks api.StreamFilterChainFactoryCallbacks)