mediator

Documentation

Index

• type Event
• type EventCollection
  • func NewEventCollection() EventCollection
• type EventHandler
• type EventKind
• type Mediator
  • func NewInMemMediator(concurrent int, opts ...Option) Mediator
• type Option
  • func WithOrphanEventHandler(fn func(Event)) Option

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 Mediator

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

func NewInMemMediator

func NewInMemMediator(concurrent int, opts ...Option) Mediator

type Option

type Option func(*inMemMediator)

func WithOrphanEventHandler

func WithOrphanEventHandler(fn func(Event)) Option