apiserver

Documentation

Index

• type APIServer
  • func New(bctx context.Context, log logrus.FieldLogger, cfg *config.Config, port int, ...) (*APIServer, error)
  • func (srv *APIServer) ControlStream(ch *cp.Channel, rctx *req_context.Context) error
  • func (srv *APIServer) Listen() error
  • func (srv *APIServer) ServiceMapStream(ch *cp.Channel, rctx *req_context.Context) error
  • func (srv *APIServer) Shutdown() error
• type HttpHandlerMiddleware
• type LoggingMiddleware
  • func (lm *LoggingMiddleware) Clone() cp.ChannelMiddleware
  • func (lm *LoggingMiddleware) RunBeforePolling(ch *cp.Channel, msg *cp.Message) error
• type WrappedRouteHandler
• type WrappedRouteOptions

Types

type APIServer

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

func New

func New(

	bctx context.Context,
	log logrus.FieldLogger,
	cfg *config.Config,
	port int,
	rootRoute string,
	clients api_clients.APIClientsInterface,
	handlerMiddleware HttpHandlerMiddleware,
) (*APIServer, error)

func (*APIServer) ControlStream

func (srv *APIServer) ControlStream(
	ch *cp.Channel, rctx *req_context.Context,
) error

func (*APIServer) Listen

func (srv *APIServer) Listen() error

func (*APIServer) ServiceMapStream

func (srv *APIServer) ServiceMapStream(
	ch *cp.Channel, rctx *req_context.Context,
) error

func (*APIServer) Shutdown

func (srv *APIServer) Shutdown() error

type HttpHandlerMiddleware

type HttpHandlerMiddleware = func(http.Handler) http.Handler

type LoggingMiddleware

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

func (*LoggingMiddleware) Clone

func (lm *LoggingMiddleware) Clone() cp.ChannelMiddleware

func (*LoggingMiddleware) RunBeforePolling

func (lm *LoggingMiddleware) RunBeforePolling(ch *cp.Channel, msg *cp.Message) error

type WrappedRouteHandler

type WrappedRouteHandler func(*cp.Channel, *rcontext.Context) error

type WrappedRouteOptions

type WrappedRouteOptions struct {
	TimescapeRequired bool
}