Documentation ¶
Index ¶
- Variables
- type EvrysService
- func (s *EvrysService) GetEvent(ctx context.Context, req *evryspb.GetEventRequest) (*cloudeventpb.CloudEvent, error)
- func (s *EvrysService) RecordEvent(ctx context.Context, req *cloudeventpb.CloudEvent) (*evryspb.RecordEventResponse, error)
- func (s *EvrysService) Serve(ctx context.Context, ls net.Listener) error
- func (s *EvrysService) SliceEvents(req *evryspb.SliceEventsRequest, stream evryspb.Evrys_SliceEventsServer) error
Constants ¶
This section is empty.
Variables ¶
View Source
var ErrServerStopped = grpc.ErrServerStopped
Functions ¶
This section is empty.
Types ¶
type EvrysService ¶
type EvrysService struct { evryspb.UnimplementedEvrysServer // contains filtered or unexported fields }
func NewEvrysService ¶
func NewEvrysService(logger *zap.Logger) *EvrysService
func (*EvrysService) GetEvent ¶
func (s *EvrysService) GetEvent(ctx context.Context, req *evryspb.GetEventRequest) (*cloudeventpb.CloudEvent, error)
func (*EvrysService) RecordEvent ¶
func (s *EvrysService) RecordEvent(ctx context.Context, req *cloudeventpb.CloudEvent) (*evryspb.RecordEventResponse, error)
func (*EvrysService) SliceEvents ¶
func (s *EvrysService) SliceEvents(req *evryspb.SliceEventsRequest, stream evryspb.Evrys_SliceEventsServer) error
Click to show internal directories.
Click to hide internal directories.