v1alpha1

Documentation

Index

• Variables
• type EventsServiceServer
  • func (e *EventsServiceServer) EnsureConsumer(ctx context.Context, req *eventsv1alpha1.EnsureConsumerRequest) (*eventsv1alpha1.EnsureConsumerResponse, error)
  • func (e *EventsServiceServer) EnsureStream(ctx context.Context, req *eventsv1alpha1.EnsureStreamRequest) (*eventsv1alpha1.EnsureStreamResponse, error)
  • func (e *EventsServiceServer) Events(server eventsv1alpha1.EventsService_EventsServer) error
  • func (e *EventsServiceServer) PublishEvent(ctx context.Context, req *eventsv1alpha1.PublishEventRequest) (*eventsv1alpha1.PublishEventResponse, error)

Variables

var Module = fx.Module(
	"grpc.v1alpha1",
	fx.Provide(sprout.Logger("grpc.events.v1alpha1"), fx.Private),
	fx.Provide(newEventsServiceServer),
	fx.Invoke(register),
)

Types

type EventsServiceServer

type EventsServiceServer struct {
	eventsv1alpha1.UnimplementedEventsServiceServer
	// contains filtered or unexported fields
}

func (*EventsServiceServer) EnsureConsumer

func (e *EventsServiceServer) EnsureConsumer(ctx context.Context, req *eventsv1alpha1.EnsureConsumerRequest) (*eventsv1alpha1.EnsureConsumerResponse, error)

func (*EventsServiceServer) EnsureStream

func (e *EventsServiceServer) EnsureStream(ctx context.Context, req *eventsv1alpha1.EnsureStreamRequest) (*eventsv1alpha1.EnsureStreamResponse, error)

func (*EventsServiceServer) Events

func (e *EventsServiceServer) Events(server eventsv1alpha1.EventsService_EventsServer) error

func (*EventsServiceServer) PublishEvent

func (e *EventsServiceServer) PublishEvent(ctx context.Context, req *eventsv1alpha1.PublishEventRequest) (*eventsv1alpha1.PublishEventResponse, error)