event

Documentation

Index

• func NewContext(ctx context.Context, d *Dispatcher) context.Context
• type Dispatcher
  • func FromContext(ctx context.Context) (*Dispatcher, bool)
  • func NewDispatcher(opts ...Option) *Dispatcher
  • func (d *Dispatcher) AddListener(listeners ...Listener)
  • func (d *Dispatcher) Dispatch(event Event)
  • func (d *Dispatcher) DispatchAsync(event Event)
  • func (d *Dispatcher) Wait()
• type Event
• type Listener
• type Option
  • func WithRecovery(recovery func(err any, listener Listener, event Event)) Option
• type Provider
  • func NewProvider(dispatcher *Dispatcher) *Provider
  • func (p *Provider) Bootstrap(ctx context.Context) (context.Context, error)
  • func (p *Provider) Terminate(ctx context.Context) (context.Context, error)

Functions

func NewContext

func NewContext(ctx context.Context, d *Dispatcher) context.Context

Types

type Dispatcher

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

func FromContext

func FromContext(ctx context.Context) (*Dispatcher, bool)

func NewDispatcher

func NewDispatcher(opts ...Option) *Dispatcher

func (*Dispatcher) AddListener

func (d *Dispatcher) AddListener(listeners ...Listener)

func (*Dispatcher) Dispatch

func (d *Dispatcher) Dispatch(event Event)

func (*Dispatcher) DispatchAsync

func (d *Dispatcher) DispatchAsync(event Event)

func (*Dispatcher) Wait

func (d *Dispatcher) Wait()

type Event

type Event interface {
	Event() any
}

type Listener

type Listener interface {
	Listen() []Event
	Handle(event Event)
}

type Option

type Option func(*Dispatcher)

func WithRecovery

func WithRecovery(recovery func(err any, listener Listener, event Event)) Option

type Provider

type Provider struct {
	*Dispatcher
}

func NewProvider

func NewProvider(dispatcher *Dispatcher) *Provider

func (*Provider) Bootstrap

func (p *Provider) Bootstrap(ctx context.Context) (context.Context, error)

func (*Provider) Terminate

func (p *Provider) Terminate(ctx context.Context) (context.Context, error)