Versions in this module Expand all Collapse all v0 v0.15.6 Jun 13, 2022 Changes in this version + type EventBus struct + func NewEventBus(projectID, appID string, options ...Option) (*EventBus, error) + func (b *EventBus) AddHandler(ctx context.Context, m eh.EventMatcher, h eh.EventHandler) error + func (b *EventBus) Close() error + func (b *EventBus) Errors() <-chan error + func (b *EventBus) HandleEvent(ctx context.Context, event eh.Event) error + func (b *EventBus) HandlerType() eh.EventHandlerType + type Option func(*EventBus) error + func WithCodec(codec eh.EventCodec) Option + func WithPubSubOptions(opts ...option.ClientOption) Option + func WithTopicOptions(topicConfig *pubsub.TopicConfig) Option
Go to main page