service

Documentation

Index

• type EventsService
  • func NewEventsService(broker *broker.Broker) (*EventsService, error)
  • func (svc *EventsService) Publish(ctx context.Context, req *connect.Request[eventsv1.Event]) (*connect.Response[emptypb.Empty], error)
  • func (svc *EventsService) PublishStream(ctx context.Context, stream *connect.ClientStream[eventsv1.Event]) (*connect.Response[emptypb.Empty], error)
  • func (svc *EventsService) Subscribe(ctx context.Context, ...) error
  • func (svc *EventsService) SubscribeOnce(ctx context.Context, req *connect.Request[eventsv1.SubscribeOnceRequest], ...) error

Types

type EventsService

type EventsService struct {
	eventsv1connect.UnimplementedEventServiceHandler
	// contains filtered or unexported fields
}

func NewEventsService

func NewEventsService(broker *broker.Broker) (*EventsService, error)

func (*EventsService) Publish

func (svc *EventsService) Publish(ctx context.Context, req *connect.Request[eventsv1.Event]) (*connect.Response[emptypb.Empty], error)

func (*EventsService) PublishStream

func (svc *EventsService) PublishStream(ctx context.Context, stream *connect.ClientStream[eventsv1.Event]) (*connect.Response[emptypb.Empty], error)

func (*EventsService) Subscribe

func (svc *EventsService) Subscribe(ctx context.Context, stream *connect.BidiStream[eventsv1.SubscribeRequest, eventsv1.Event]) error

func (*EventsService) SubscribeOnce

func (svc *EventsService) SubscribeOnce(ctx context.Context, req *connect.Request[eventsv1.SubscribeOnceRequest], stream *connect.ServerStream[eventsv1.Event]) error