eventbus

Documentation

Index

• func New() pubsub.Exchange
• type EventBus
  • func (bus *EventBus) EventSequenceTable(kindPrefix []byte) []*pubsub.EventRecord
  • func (bus *EventBus) Publish(event pubsub.Event)
  • func (bus *EventBus) RegisterEndpoint(ep pubsub.Endpoint)
  • func (bus *EventBus) UnregisterEndpoint(ep pubsub.Endpoint)

Functions

func New

func New() pubsub.Exchange

Types

type EventBus

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

func (*EventBus) EventSequenceTable

func (bus *EventBus) EventSequenceTable(kindPrefix []byte) []*pubsub.EventRecord

func (*EventBus) Publish

func (bus *EventBus) Publish(event pubsub.Event)

func (*EventBus) RegisterEndpoint

func (bus *EventBus) RegisterEndpoint(ep pubsub.Endpoint)

func (*EventBus) UnregisterEndpoint

func (bus *EventBus) UnregisterEndpoint(ep pubsub.Endpoint)