baztchannelendpoint

Documentation

Index

• type Endpoint
  • func NewEndpoint(deps *module.Dependencies) Endpoint
• type EndpointHandlers
  • func (handlers *EndpointHandlers) Register(gateway *zanzibar.Gateway) error
• type SimpleServiceCallHandler
  • func NewSimpleServiceCallHandler(deps *module.Dependencies) *SimpleServiceCallHandler
  • func (h *SimpleServiceCallHandler) Handle(ctx context.Context, reqHeaders map[string]string, sr stream.Reader) (ctxRes context.Context, isSuccessful bool, response zanzibar.RWTStruct, ...)
  • func (h *SimpleServiceCallHandler) Register(g *zanzibar.Gateway) error
• type SimpleServiceEchoHandler
  • func NewSimpleServiceEchoHandler(deps *module.Dependencies) *SimpleServiceEchoHandler
  • func (h *SimpleServiceEchoHandler) Handle(ctx context.Context, reqHeaders map[string]string, sr stream.Reader) (ctxRes context.Context, isSuccessful bool, response zanzibar.RWTStruct, ...)
  • func (h *SimpleServiceEchoHandler) Register(g *zanzibar.Gateway) error

Types

type Endpoint

type Endpoint interface {
	Register(*zanzibar.Gateway) error
}

Endpoint registers a request handler on a gateway

func NewEndpoint

func NewEndpoint(deps *module.Dependencies) Endpoint

NewEndpoint returns a collection of endpoints that can be registered on a gateway

type EndpointHandlers

type EndpointHandlers struct {
	SimpleServiceCallHandler *SimpleServiceCallHandler
	SimpleServiceEchoHandler *SimpleServiceEchoHandler
}

EndpointHandlers is a collection of individual endpoint handlers

func (*EndpointHandlers) Register

func (handlers *EndpointHandlers) Register(gateway *zanzibar.Gateway) error

Register registers the endpoint handlers with the gateway

type SimpleServiceCallHandler

type SimpleServiceCallHandler struct {
	Deps *module.Dependencies
	// contains filtered or unexported fields
}

SimpleServiceCallHandler is the handler for "SimpleService::Call".

func NewSimpleServiceCallHandler

func NewSimpleServiceCallHandler(deps *module.Dependencies) *SimpleServiceCallHandler

NewSimpleServiceCallHandler creates a handler to be registered with a thrift server.

func (*SimpleServiceCallHandler) Handle

func (h *SimpleServiceCallHandler) Handle(
	ctx context.Context,
	reqHeaders map[string]string,
	sr stream.Reader,
) (ctxRes context.Context, isSuccessful bool, response zanzibar.RWTStruct, headers map[string]string, e error)

Handle handles RPC call of "SimpleService::Call".

func (*SimpleServiceCallHandler) Register

func (h *SimpleServiceCallHandler) Register(g *zanzibar.Gateway) error

Register adds the tchannel handler to the gateway's tchannel router

type SimpleServiceEchoHandler

type SimpleServiceEchoHandler struct {
	Deps *module.Dependencies
	// contains filtered or unexported fields
}

SimpleServiceEchoHandler is the handler for "SimpleService::Echo".

func NewSimpleServiceEchoHandler

func NewSimpleServiceEchoHandler(deps *module.Dependencies) *SimpleServiceEchoHandler

NewSimpleServiceEchoHandler creates a handler to be registered with a thrift server.

func (*SimpleServiceEchoHandler) Handle

func (h *SimpleServiceEchoHandler) Handle(
	ctx context.Context,
	reqHeaders map[string]string,
	sr stream.Reader,
) (ctxRes context.Context, isSuccessful bool, response zanzibar.RWTStruct, headers map[string]string, e error)

Handle handles RPC call of "SimpleService::Echo".

func (*SimpleServiceEchoHandler) Register

func (h *SimpleServiceEchoHandler) Register(g *zanzibar.Gateway) error

Register adds the tchannel handler to the gateway's tchannel router