local

Documentation

Index

• func Broker(options ...BrokerOption) eventsource.Broker
• type BrokerOption
  • func WithErrorHandler(handler fail.ErrorHandler) BrokerOption

Functions

func Broker

func Broker(options ...BrokerOption) eventsource.Broker

Broker creates a new local/in-memory broker that dispatches events to subscribers running just within this Go process.

Types

type BrokerOption

type BrokerOption func(*broker)

BrokerOption allows you to tweak the local broker's behavior in some way.

func WithErrorHandler

func WithErrorHandler(handler fail.ErrorHandler) BrokerOption

WithErrorHandler swaps the default error handler for this one.