gcp

Feb 13, 2024

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