ctrlapi

Documentation

Index

• type API
  • func New(cfg *Config, exchangeSvc ExchangeService) *API
  • func (a *API) RegisterService(req *api.RegisterRequest, ...) error
  • func (a *API) Run(ctx context.Context) error
• type Config
• type ExchangeService

Types

type API

type API struct {
	api.UnimplementedExchangeServiceServer
	// contains filtered or unexported fields
}

func New

func New(cfg *Config, exchangeSvc ExchangeService) *API

func (*API) RegisterService

func (a *API) RegisterService(req *api.RegisterRequest, stream grpc.ServerStreamingServer[api.ConnectCommand]) error

func (*API) Run

func (a *API) Run(ctx context.Context) error

type Config

type Config struct {
	Listen string
}

type ExchangeService

type ExchangeService interface {
	RegisterRevProxy(ctx context.Context, nameSpace string, services []string) (*exchange.RevProxy, error)
	UnregisterRevProxy(proxy *exchange.RevProxy)
}