eventbus

type Bus interface {
	ClusteringBroadcast(event string, data interface{}) error
	ClusteringSubscribe(channel string, fn func(data []byte))
	Broadcast(channel string, data interface{})
	Subscribe(channel string, cb Callback)
}

type Callback func(data interface{})

type CrudData struct {
	Entity   string          `json:"entity"`
	ID       string          `json:"id"`
	WID      string          `json:"wid"`
	CacheKey string          `json:"cache_key"`
	Data     json.RawMessage `json:"data"`
}

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

type EventFanoutData struct {
	EventId    string   `json:"event_id"`
	AttemptIds []string `json:"attempt_ids"`
}

type Message struct {
	Event string          `json:"event"`
	Time  int64           `json:"time"`
	Node  string          `json:"node"`
	Data  json.RawMessage `json:"data"`
}