emitter

type AllCompleteFunc = func() (interface{}, error)

type AllCompleter interface {
	AllComplete(fnList ...AllCompleteFunc) ([]interface{}, error)
}

type Consumer interface {
	Consume(on OnEvent)
}

type Decode func([]byte) (DomainEvent, Error)

type Decoder interface {
	Decode([]byte) Error
}

type DomainEvent interface{}

type DomainEventHandler func(event DomainEvent) error

type Emitter interface {
	Sender

	AfterRevive() gone.AfterReviveError

	GetConsumeEventTypes() []string
}

type Encoder interface {
	Encode() ([]byte, Error)
}

type Error error

type Headers map[string]interface{}

type MQ interface {
	//Consumer 订阅消息
	Consumer(Subscriber)

	//Send 发送消息
	Send(MQMsg) (msgIds []string, err error)
}

type MQMsg interface {
	GetHeaders() Headers
	GetBody() []byte
}

type OnEvent func(handler interface{})

type Sender interface {
	Send(event DomainEvent, duration ...time.Duration) error
}

type Subscriber func(MQMsg) error