gcp

Documentation

Index

• Variables
• type EventBus
  • func NewEventBus(projectID, appID string, opts ...option.ClientOption) (*EventBus, error)
  • func (b *EventBus) AddHandler(ctx context.Context, m eh.EventMatcher, h eh.EventHandler) error
  • func (b *EventBus) Errors() <-chan eh.EventBusError
  • func (b *EventBus) HandleEvent(ctx context.Context, event eh.Event) error
  • func (b *EventBus) HandlerType() eh.EventHandlerType
  • func (b *EventBus) Wait()

Variables

var DefaultQueueSize = 10

DefaultQueueSize is the default queue size per handler for publishing events.

Types

type EventBus

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

EventBus is a local event bus that delegates handling of published events to all matching registered handlers, in order of registration.

func NewEventBus

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

NewEventBus creates an EventBus, with optional GCP connection settings.

func (*EventBus) AddHandler

func (b *EventBus) AddHandler(ctx context.Context, m eh.EventMatcher, h eh.EventHandler) error

AddHandler implements the AddHandler method of the eventhorizon.EventBus interface.

func (*EventBus) Errors

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

Errors implements the Errors method of the eventhorizon.EventBus interface.

func (*EventBus) HandleEvent

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

HandleEvent implements the HandleEvent method of the eventhorizon.EventHandler interface.

func (*EventBus) HandlerType

func (b *EventBus) HandlerType() eh.EventHandlerType

HandlerType implements the HandlerType method of the eventhorizon.EventHandler interface.

func (*EventBus) Wait

func (b *EventBus) Wait()

Wait for all channels to close in the event bus group