eventbus

type ClusteringHandler func(v []byte)

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

type EventBus interface {
	ClusteringBroadcast(ctx context.Context, channel string, value Marshaler) error
	ClusteringSubscribe(channel string, handler ClusteringHandler)
	Broadcast(ctx context.Context, channel string, value interface{})
	Subscribe(channel string, handler Handler)
}

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

type Handler func(v interface{})

type Marshaler interface {
	Marshal() ([]byte, error)
}

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