pubsub

Documentation

Index

• type CLAChan
• type Event
• type EventChan
• type Hub
  • func NewHub() Hub
• type Subscription
  • func (s Subscription) Accept(e *Event)
  • func (s Subscription) Close()

Types

type CLAChan

type CLAChan chan *cp.ClusterLoadAssignment

type Event

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

type EventChan

type EventChan chan *Event

type Hub

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

func NewHub

func NewHub() Hub

type Subscription

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

Subscription is a unique channel of ClusterLoadAssignments

func (Subscription) Accept

func (s Subscription) Accept(e *Event)

func (Subscription) Close

func (s Subscription) Close()