Versions in this module Expand all Collapse all v0 v0.2.0 Mar 21, 2018 v0.1.0 Mar 21, 2018 Changes in this version + var ErrCouldNotMarshalEvent = errors.New("could not marshal event") + var ErrCouldNotUnmarshalEvent = errors.New("could not unmarshal event") + type Error struct + Ctx context.Context + Err error + Event eh.Event + func (e Error) Error() string + type EventPublisher struct + func NewEventPublisher(projectID, appID string) (*EventPublisher, error) + func (b *EventPublisher) Close() error + func (b *EventPublisher) Errors() <-chan Error + func (b *EventPublisher) HandleEvent(ctx context.Context, event eh.Event) error
Go to main page