apis

Documentation

Index

• type ApiName
• type ApiRequestHandler
• type RouteWorker
• type RouteWorkerManager
  • func New() *RouteWorkerManager
  • func (a *RouteWorkerManager) ApiDetails(ctx context.Context, req *apispb.ApiDetailsRequest) (*apispb.ApiDetailsResponse, error)
  • func (s *RouteWorkerManager) HandleRequest(apiName string, request *apispb.ServerMessage) (*apispb.ClientMessage, error)
  • func (s *RouteWorkerManager) Serve(stream apispb.Api_ServeServer) error
  • func (s *RouteWorkerManager) WorkerCount() int
• type WorkerConnection

Types

type ApiName

type ApiName = string

type ApiRequestHandler

type ApiRequestHandler interface {
	apispb.ApiServer
	HandleRequest(apiName string, request *apispb.ServerMessage) (*apispb.ClientMessage, error)
	WorkerCount() int
}

type RouteWorker

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

type RouteWorkerManager

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

func New

func New() *RouteWorkerManager

func (*RouteWorkerManager) ApiDetails

func (a *RouteWorkerManager) ApiDetails(ctx context.Context, req *apispb.ApiDetailsRequest) (*apispb.ApiDetailsResponse, error)

func (*RouteWorkerManager) HandleRequest

func (s *RouteWorkerManager) HandleRequest(apiName string, request *apispb.ServerMessage) (*apispb.ClientMessage, error)

func (*RouteWorkerManager) Serve

func (s *RouteWorkerManager) Serve(stream apispb.Api_ServeServer) error

func (*RouteWorkerManager) WorkerCount

func (s *RouteWorkerManager) WorkerCount() int

type WorkerConnection

type WorkerConnection = workers.WorkerRequestBroker[*apispb.ServerMessage, *apispb.ClientMessage]