imq

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

type EventBus interface {
	context.Context
	SenderBus
	ReaderBus
}

type Message struct {
	Target uwe.WorkerName
	Sender uwe.WorkerName
	Kind   MessageKind
	Data   interface{}
}

type MessageKind int

type ReaderBus interface {
	Messages() <-chan *Message
}

type SenderBus interface {
	Send(target uwe.WorkerName, data interface{})
	SendWithKind(target uwe.WorkerName, kind MessageKind, data interface{})
	SendToMany(kind MessageKind, data interface{}, targets ...uwe.WorkerName)
	SelfInit(name uwe.WorkerName) EventBus
}