mediator

Documentation

Index

• func Dispatch(ev Event)
• func SetDefault(m Mediator)
• func Subscribe(hdl EventHandler)
• type Event
• type EventCollection
  • func NewEventCollection() EventCollection
• type EventHandler
• type EventKind
• type InMemMediator
  • func (m *InMemMediator) Dispatch(ev Event)
  • func (m *InMemMediator) Subscribe(hdl EventHandler)
  • func (m *InMemMediator) WithOrphanEventHandler(fn func(Event))
• type Mediator
  • func Default() Mediator
  • func NewInMemMediator(opt Options) (Mediator, error)
• type Options

Functions

func Dispatch

func Dispatch(ev Event)

func SetDefault

func SetDefault(m Mediator)

func Subscribe

func Subscribe(hdl EventHandler)

Types

type Event

type Event interface {
	Kind() EventKind
}

Event 事件接口.

type EventCollection

type EventCollection interface {
	Add(Event)
	Raise(Mediator)
}

func NewEventCollection

func NewEventCollection() EventCollection

type EventHandler

type EventHandler interface {
	Listening() []EventKind
	Handle(context.Context, Event)
}

type EventKind

type EventKind string

EventKind 事件类型描述.

type InMemMediator

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

func (*InMemMediator) Dispatch

func (m *InMemMediator) Dispatch(ev Event)

func (*InMemMediator) Subscribe

func (m *InMemMediator) Subscribe(hdl EventHandler)

func (*InMemMediator) WithOrphanEventHandler

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

type Mediator

type Mediator interface {
	Dispatch(Event)
	Subscribe(EventHandler)
}

func Default

func Default() Mediator

func NewInMemMediator

func NewInMemMediator(opt Options) (Mediator, error)

type Options

type Options struct {
	Timeout    string `json:"timeout" yaml:"timeout" toml:"timeout"`
	Concurrent int    `json:"concurrent" yaml:"concurrent" toml:"concurrent"`
}