service

type EventBus interface {
	context.Context
	SendMessage(target uwe.WorkerName, data interface{}) error
	MessageBus() <-chan *Message
}

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

type Message struct {
	UID    int64
	Target uwe.WorkerName
	Sender uwe.WorkerName
	Data   interface{}
}

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