events

Documentation

Overview

Package events contains events sink gRPC server implementation.

Index

• type Adapter
• type Event
• type Sink
  • func NewSink(a Adapter, supportedTypes []proto.Message) *Sink
  • func (s *Sink) Publish(ctx context.Context, e *events.EventRequest) (*events.EventResponse, error)

Types

type Adapter

type Adapter interface {
	HandleEvent(ctx context.Context, event Event) error
}

Adapter is an abstract event stream receiver.

type Event

type Event struct {
	Payload proto.Message
	TypeURL string
	ID      string
	Node    string
	ActorID string
}

Event as received from the API.

type Sink

type Sink struct {
	events.UnimplementedEventSinkServiceServer
	// contains filtered or unexported fields
}

Sink implements events.EventSinkServiceServer.

func NewSink

func NewSink(a Adapter, supportedTypes []proto.Message) *Sink

NewSink creates new events sink service.

func (*Sink) Publish

func (s *Sink) Publish(ctx context.Context, e *events.EventRequest) (*events.EventResponse, error)

Publish implements events.EventSinkServiceServer.