event

type Address struct {
	ID        string `json:"id"`
	MachineID string `json:"machineId"`
	LocalID   string `json:"localId"`
}

type EventEmitter interface {
	Emit(ctx context.Context, address *Address, pkg *Package) error
	EmitLocal(ctx context.Context, address *Address, pkg *Package) error
	Listen(address *Address, listener Listener)
	RemoveListener(address *Address, listener Listener)
	Close() error
}

type Listener interface {
	Listen(ctx context.Context, pkg *Package)
	IsClose() bool
	Close(ctx context.Context, code string) error
}

type Package struct {
	From       *Address        `json:"from"`
	CreatedAt  int64           `json:"createdAt"`
	RequestId  string          `json:"requestId"`
	RoutingKey string          `json:"routingKey"`
	Content    json.RawMessage `json:"content"`
}