localbus

Documentation

Index

• func NewLocalBus(options ...Option) eventbus.EventBus
• type Option
  • func WithBufferSize(size int) Option
  • func WithContext(ctx context.Context) Option
  • func WithLogger(logger logger.Logger) Option

Functions

func NewLocalBus

func NewLocalBus(options ...Option) eventbus.EventBus

NewLocalBus creates a new localBus instance and configures it with the given options.

Types

type Option

type Option func(bus *localBus)

Option is a function that configures a localBus

func WithBufferSize

func WithBufferSize(size int) Option

WithBufferSize sets the size of the event buffer. If the buffer is full, Publish will block until there is space in the buffer.

func WithContext

func WithContext(ctx context.Context) Option

func WithLogger

func WithLogger(logger logger.Logger) Option

WithLogger sets the logger to use by the localBus.