mediator

Nov 13, 2024

Changes in this version

type InMemMediator

+ func (m *InMemMediator) GracefulShutdown(ctx context.Context) error

Oct 30, 2024

Changes in this version

type InMemMediator

+ func (m *InMemMediator) WithLogger(logger *slog.Logger)

Sep 9, 2024

Changes in this version

type InMemMediator

+ func (m *InMemMediator) WithGenContext(fn func(ctx context.Context) context.Context)

+ func (m *InMemMediator) WithTimeout(timeout time.Duration)

Aug 31, 2022

Changes in this version

+ type Option func(*inMemMediator)

+ func WithOrphanEventHandler(fn func(Event)) Option

Jul 30, 2024

Changes in this version

+ func Dispatch(ev Event)

+ func SetDefault(m Mediator)

+ func Subscribe(hdl EventHandler)

+ type Event interface

+ Kind func() EventKind

+ type EventCollection interface

+ Add func(Event)

+ Raise func(Mediator)

+ func NewEventCollection() EventCollection

+ type EventHandler interface

+ Handle func(context.Context, Event)

+ Listening func() []EventKind

+ type EventKind string

+ type InMemMediator struct

+ func (m *InMemMediator) Dispatch(ev Event)

+ func (m *InMemMediator) Subscribe(hdl EventHandler)

+ func (m *InMemMediator) WithOrphanEventHandler(fn func(Event))

+ type Mediator interface

+ Dispatch func(Event)

+ Subscribe func(EventHandler)

+ func Default() Mediator

+ func NewInMemMediator(opt Options) (Mediator, error)

+ type Options struct

+ Concurrent int

+ Timeout string