events

Documentation

Index

• type Event
• type Exchange
  • func NewExchange() *Exchange
  • func (e *Exchange) Forward(ctx context.Context, envelope *events.Envelope) error
  • func (e *Exchange) Publish(ctx context.Context, topic string, event Event) error
  • func (e *Exchange) Subscribe(ctx context.Context, filters ...filters.Filter) (ch <-chan *events.Envelope, errs <-chan error)
• type Forwarder
• type Publisher

Types

type Event

type Event interface{}

type Exchange

type Exchange struct {
	// contains filtered or unexported fields
}

func NewExchange

func NewExchange() *Exchange

func (*Exchange) Forward

func (e *Exchange) Forward(ctx context.Context, envelope *events.Envelope) error

Forward accepts an envelope to be direcly distributed on the exchange.

func (*Exchange) Publish

func (e *Exchange) Publish(ctx context.Context, topic string, event Event) error

Publish packages and sends an event. The caller will be considered the initial publisher of the event. This means the timestamp will be calculated at this point and this method may read from the calling context.

func (*Exchange) Subscribe

func (e *Exchange) Subscribe(ctx context.Context, filters ...filters.Filter) (ch <-chan *events.Envelope, errs <-chan error)

Subscribe to events on the exchange. Events are sent through the returned channel ch. If an error is encountered, it will be sent on channel errs and errs will be closed. To end the subscription, cancel the provided context.

type Forwarder

type Forwarder interface {
	Forward(ctx context.Context, envelope *events.Envelope) error
}

type Publisher

type Publisher interface {
	Publish(ctx context.Context, topic string, event Event) error
}

Publisher posts the event.