redis

Documentation

Index

• Variables
• type EventPublisher
  • func NewEventPublisher(appID, server, password string) (*EventPublisher, error)
  • func NewEventPublisherWithPool(appID string, pool *redis.Pool) (*EventPublisher, error)
  • func (b *EventPublisher) Close() error
  • func (b *EventPublisher) HandleEvent(ctx context.Context, event eh.Event) error

Variables

var ErrCouldNotMarshalEvent = errors.New("could not marshal event")

ErrCouldNotMarshalEvent is when an event could not be marshaled into BSON.

var ErrCouldNotUnmarshalEvent = errors.New("could not unmarshal event")

ErrCouldNotUnmarshalEvent is when an event could not be unmarshaled into a concrete type.

Types

type EventPublisher

type EventPublisher struct {
	*local.EventPublisher
	// contains filtered or unexported fields
}

EventPublisher is an event bus that notifies registered EventHandlers of published events. It will use the SimpleEventHandlingStrategy by default.

func NewEventPublisher

func NewEventPublisher(appID, server, password string) (*EventPublisher, error)

NewEventPublisher creates a EventPublisher for remote events.

func NewEventPublisherWithPool

func NewEventPublisherWithPool(appID string, pool *redis.Pool) (*EventPublisher, error)

NewEventPublisherWithPool creates a EventPublisher for remote events.

func (*EventPublisher) Close

func (b *EventPublisher) Close() error

Close exits the receive goroutine by unsubscribing to all channels.

func (*EventPublisher) HandleEvent

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

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