messaging

Documentation

Overview

Package messaging implements the messaging infrastructure between different components within the control plane.

Index

• func GetPubSubTopicForProxyUUID(uuid string) string
• type Broker
  • func NewBroker(stopCh <-chan struct{}) *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{})

Functions

func GetPubSubTopicForProxyUUID

func GetPubSubTopicForProxyUUID(uuid string) string

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

func (b *Broker) GetCertPubSub() *pubsub.PubSub

GetCertPubSub returns the PubSub instance corresponding to certificate events

func (*Broker) GetKubeEventPubSub

func (b *Broker) GetKubeEventPubSub() *pubsub.PubSub

GetKubeEventPubSub returns the PubSub instance corresponding to k8s events

func (*Broker) GetProxyUpdatePubSub

func (b *Broker) GetProxyUpdatePubSub() *pubsub.PubSub

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

func (b *Broker) GetTotalDispatchedProxyEventCount() uint64

GetTotalDispatchedProxyEventCount returns the total number of events dispatched to subscribed proxies

func (*Broker) GetTotalQEventCount

func (b *Broker) GetTotalQEventCount() uint64

GetTotalQEventCount returns the total number of events queued throughout the lifetime of the workqueue.

func (*Broker) GetTotalQProxyEventCount

func (b *Broker) GetTotalQProxyEventCount() uint64

GetTotalQProxyEventCount returns the total number of events read from the workqueue pertaining to proxy updates

func (*Broker) Unsub

func (b *Broker) Unsub(pubSub *pubsub.PubSub, ch chan interface{})

Unsub unsubscribes the given channel from the PubSub instance