Documentation ¶
Index ¶
- type ApiServer
- func (s *ApiServer) DeleteInstallation(ctx context.Context, req *connect.Request[proto.DeleteInstallationRequest]) (*connect.Response[emptypb.Empty], error)
- func (s *ApiServer) RegisterInstallation(ctx context.Context, req *connect.Request[proto.RegisterInstallationRequest]) (*connect.Response[proto.RegisterInstallationResponse], error)
- func (s *ApiServer) Start()
- func (s *ApiServer) Stop()
- func (s *ApiServer) Subscribe(ctx context.Context, req *connect.Request[proto.SubscribeRequest]) (*connect.Response[emptypb.Empty], error)
- func (s *ApiServer) SubscribeWithMetadata(ctx context.Context, req *connect.Request[proto.SubscribeWithMetadataRequest]) (*connect.Response[emptypb.Empty], error)
- func (s *ApiServer) Unsubscribe(ctx context.Context, req *connect.Request[proto.UnsubscribeRequest]) (*connect.Response[emptypb.Empty], error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ApiServer ¶
type ApiServer struct {
// contains filtered or unexported fields
}
func NewApiServer ¶
func NewApiServer(logger *zap.Logger, opts options.ApiOptions, installations interfaces.Installations, subscriptions interfaces.Subscriptions) *ApiServer
func (*ApiServer) DeleteInstallation ¶
func (*ApiServer) RegisterInstallation ¶
func (*ApiServer) SubscribeWithMetadata ¶
Click to show internal directories.
Click to hide internal directories.