event

Documentation

Index

• type Barrier
  • func NewBarrier(stream Stream) (*Barrier, func())
  • func (b *Barrier) ID() string
  • func (b *Barrier) Wait(ctx context.Context) error
• type Broker
  • func NewBroker(syslog *zap.SugaredLogger) *Broker
  • func (b *Broker) Publish(event *Event)
  • func (b *Broker) Subscribe(handler Handler, opts ...Opt) func()
• type Event
  • func Unmarshal(event *eventsv1.Event) (*Event, error)
  • func (e *Event) Marshal() (*eventsv1.Event, error)
• type Handler
• type Opt
  • func WithPredicate(predicate Predicate) Opt
• type Opts
• type Predicate
• type Sequencer
  • func NewSequencer(stream Stream) *Sequencer
  • func (s *Sequencer) Publish(event *Event)
• type Stream

Types

type Barrier

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

func NewBarrier

func NewBarrier(stream Stream) (*Barrier, func())

func (*Barrier) ID

func (b *Barrier) ID() string

func (*Barrier) Wait

func (b *Barrier) Wait(ctx context.Context) error

type Broker

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

func NewBroker

func NewBroker(syslog *zap.SugaredLogger) *Broker

func (*Broker) Publish

func (b *Broker) Publish(event *Event)

func (*Broker) Subscribe

func (b *Broker) Subscribe(handler Handler, opts ...Opt) func()

type Event

type Event struct {
	Meta    *eventsv1.Meta
	Payload proto.Message
}

func Unmarshal

func Unmarshal(event *eventsv1.Event) (*Event, error)

func (*Event) Marshal

func (e *Event) Marshal() (*eventsv1.Event, error)

type Handler

type Handler func(event *Event)

type Opt

type Opt interface {
	Apply(opts *Opts)
}

func WithPredicate

func WithPredicate(predicate Predicate) Opt

type Opts

type Opts struct {
	Predicates []Predicate
}

type Predicate

type Predicate func(event *Event) bool

type Sequencer

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

func NewSequencer

func NewSequencer(stream Stream) *Sequencer

func (*Sequencer) Publish

func (s *Sequencer) Publish(event *Event)

type Stream

type Stream interface {
	Publish(event *Event)
	Subscribe(handler Handler, opts ...Opt) func()
}