apis

Documentation

Index

• type ApiName
• type ApiRequestState
• type GetApiAddress
• type LocalApiGatewayService
  • func NewLocalApiGatewayService(getApiAddress GetApiAddress) *LocalApiGatewayService
  • func (a *LocalApiGatewayService) ApiDetails(ctx context.Context, req *apispb.ApiDetailsRequest) (*apispb.ApiDetailsResponse, error)
  • func (l *LocalApiGatewayService) GetState() State
  • func (l *LocalApiGatewayService) PublishActionState(state ApiRequestState)
  • func (l *LocalApiGatewayService) Serve(stream apispb.Api_ServeServer) error
  • func (l *LocalApiGatewayService) SubscribeToAction(subscription func(ApiRequestState))
  • func (l *LocalApiGatewayService) SubscribeToState(subscriberFunction func(State))
• type ServiceName
• type State

Types

type ApiName

type ApiName = string

type ApiRequestState

type ApiRequestState struct {
	Api      string
	ReqCtx   *fasthttp.RequestCtx
	HttpResp *apispb.HttpResponse
}

type GetApiAddress

type GetApiAddress = func(apiName string) string

type LocalApiGatewayService

type LocalApiGatewayService struct {
	*apis.RouteWorkerManager
	// contains filtered or unexported fields
}

func NewLocalApiGatewayService

func NewLocalApiGatewayService(getApiAddress GetApiAddress) *LocalApiGatewayService

func (*LocalApiGatewayService) ApiDetails

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

func (*LocalApiGatewayService) GetState

func (l *LocalApiGatewayService) GetState() State

GetState - Returns a copy of internal state

func (*LocalApiGatewayService) PublishActionState

func (l *LocalApiGatewayService) PublishActionState(state ApiRequestState)

func (*LocalApiGatewayService) Serve

func (l *LocalApiGatewayService) Serve(stream apispb.Api_ServeServer) error

func (*LocalApiGatewayService) SubscribeToAction

func (l *LocalApiGatewayService) SubscribeToAction(subscription func(ApiRequestState))

func (*LocalApiGatewayService) SubscribeToState

func (l *LocalApiGatewayService) SubscribeToState(subscriberFunction func(State))

type ServiceName

type ServiceName = string

type State

type State = map[ApiName]map[ServiceName][]*apispb.RegistrationRequest