gcp

Jan 9, 2020

Changes in this version

+ var DefaultQueueSize = 10

+ type EventBus struct

+ func NewEventBus(projectID, appID string, opts ...option.ClientOption) (*EventBus, error)

+ func (b *EventBus) AddHandler(m eh.EventMatcher, h eh.EventHandler)

+ func (b *EventBus) AddObserver(m eh.EventMatcher, h eh.EventHandler)

+ func (b *EventBus) Errors() <-chan eh.EventBusError

+ func (b *EventBus) PublishEvent(ctx context.Context, event eh.Event) error