pubsub

type CLAChan chan *cp.ClusterLoadAssignment

type Event struct {
	CLA      []*cp.ClusterLoadAssignment
	Clusters []*cp.Cluster
	Routes   []*cp.RouteConfiguration
}

type EventChan chan *Event

type Hub interface {
	Subscribe() *Subscription
	Publish(event *Event)
	Size() int
}

type Subscription struct {
	ID      uuid.UUID
	Events  EventChan
	OnClose func(uuid.UUID)
}