Documentation
¶
Overview ¶
Package messaging implements the messaging infrastructure between different components within the control plane.
Index ¶
- func GetPubSubTopicForProxyUUID(uuid string) string
- type Broker
- func (b *Broker) GetCertPubSub() *pubsub.PubSub
- func (b *Broker) GetKubeEventPubSub() *pubsub.PubSub
- func (b *Broker) GetProxyUpdatePubSub() *pubsub.PubSub
- func (b *Broker) GetQueue() workqueue.RateLimitingInterface
- func (b *Broker) GetTotalDispatchedProxyEventCount() uint64
- func (b *Broker) GetTotalQEventCount() uint64
- func (b *Broker) GetTotalQProxyEventCount() uint64
- func (b *Broker) Unsub(pubSub *pubsub.PubSub, ch chan interface{})
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GetPubSubTopicForProxyUUID ¶ added in v1.0.0
GetPubSubTopicForProxyUUID returns the topic on which PubSubMessages specific to a proxy UUID are published
Types ¶
type Broker ¶
type Broker struct {
// contains filtered or unexported fields
}
Broker implements the message broker functionality
func NewBroker ¶
func NewBroker(stopCh <-chan struct{}) *Broker
NewBroker returns a new message broker instance and starts the internal goroutine to process events added to the workqueue.
func (*Broker) GetCertPubSub ¶
GetCertPubSub returns the PubSub instance corresponding to certificate events
func (*Broker) GetKubeEventPubSub ¶
GetKubeEventPubSub returns the PubSub instance corresponding to k8s events
func (*Broker) GetProxyUpdatePubSub ¶
GetProxyUpdatePubSub returns the PubSub instance corresponding to proxy update events
func (*Broker) GetQueue ¶
func (b *Broker) GetQueue() workqueue.RateLimitingInterface
GetQueue returns the workqueue instance
func (*Broker) GetTotalDispatchedProxyEventCount ¶
GetTotalDispatchedProxyEventCount returns the total number of events dispatched to subscribed proxies
func (*Broker) GetTotalQEventCount ¶
GetTotalQEventCount returns the total number of events queued throughout the lifetime of the workqueue.
func (*Broker) GetTotalQProxyEventCount ¶
GetTotalQProxyEventCount returns the total number of events read from the workqueue pertaining to proxy updates
Source Files