messaging

Documentation

Overview

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

Index

• Constants
• func GetPubSubTopicForProxyUUID(uuid string) string
• type Broker
  • func NewBroker(stopCh <-chan struct{}) *Broker
  • func (b *Broker) GetCertPubSub() *pubsub.PubSub
  • func (b *Broker) GetConnectorUpdatePubSub() *pubsub.PubSub
  • func (b *Broker) GetGatewayUpdatePubSub() *pubsub.PubSub
  • func (b *Broker) GetIngressUpdatePubSub() *pubsub.PubSub
  • func (b *Broker) GetKubeEventPubSub() *pubsub.PubSub
  • func (b *Broker) GetMCSEventPubSub() *pubsub.PubSub
  • func (b *Broker) GetProxyUpdatePubSub() *pubsub.PubSub
  • func (b *Broker) GetQueue() workqueue.RateLimitingInterface
  • func (b *Broker) GetServiceUpdatePubSub() *pubsub.PubSub
  • func (b *Broker) GetTotalDispatchedConnectorEventCount() uint64
  • func (b *Broker) GetTotalDispatchedGatewayEventCount() uint64
  • func (b *Broker) GetTotalDispatchedIngressEventCount() uint64
  • func (b *Broker) GetTotalDispatchedProxyEventCount() uint64
  • func (b *Broker) GetTotalDispatchedServiceEventCount() uint64
  • func (b *Broker) GetTotalQConnectorEventCount() uint64
  • func (b *Broker) GetTotalQEventCount() uint64
  • func (b *Broker) GetTotalQGatewayEventCount() uint64
  • func (b *Broker) GetTotalQIngressEventCount() uint64
  • func (b *Broker) GetTotalQProxyEventCount() uint64
  • func (b *Broker) GetTotalQServiceEventCount() uint64
  • func (b *Broker) Unsub(pubSub *pubsub.PubSub, ch chan interface{})

Constants

const (

	// ConnectorUpdateSlidingWindow is the sliding window duration used to batch connector update events
	ConnectorUpdateSlidingWindow = 2 * time.Second

	// ConnectorUpdateMaxWindow is the max window duration used to batch connector update events, and is
	// the max amount of time a connector update event can be held for batching before being dispatched.
	ConnectorUpdateMaxWindow = 5 * time.Second
)

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) GetConnectorUpdatePubSub

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

GetConnectorUpdatePubSub returns the PubSub instance corresponding to connector update events

func (*Broker) GetGatewayUpdatePubSub

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

GetGatewayUpdatePubSub returns the PubSub instance corresponding to gateway update events

func (*Broker) GetIngressUpdatePubSub

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

GetIngressUpdatePubSub returns the PubSub instance corresponding to ingress update events

func (*Broker) GetKubeEventPubSub

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

GetKubeEventPubSub returns the PubSub instance corresponding to k8s events

func (*Broker) GetMCSEventPubSub

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

GetMCSEventPubSub returns the PubSub instance corresponding to MCS update 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) GetServiceUpdatePubSub

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

GetServiceUpdatePubSub returns the PubSub instance corresponding to service update events

func (*Broker) GetTotalDispatchedConnectorEventCount

func (b *Broker) GetTotalDispatchedConnectorEventCount() uint64

GetTotalDispatchedConnectorEventCount returns the total number of events dispatched to subscribed connectors

func (*Broker) GetTotalDispatchedGatewayEventCount

func (b *Broker) GetTotalDispatchedGatewayEventCount() uint64

GetTotalDispatchedGatewayEventCount returns the total number of events dispatched to subscribed gateways

func (*Broker) GetTotalDispatchedIngressEventCount

func (b *Broker) GetTotalDispatchedIngressEventCount() uint64

GetTotalDispatchedIngressEventCount returns the total number of events dispatched to subscribed ingresses

func (*Broker) GetTotalDispatchedProxyEventCount

func (b *Broker) GetTotalDispatchedProxyEventCount() uint64

GetTotalDispatchedProxyEventCount returns the total number of events dispatched to subscribed proxies

func (*Broker) GetTotalDispatchedServiceEventCount

func (b *Broker) GetTotalDispatchedServiceEventCount() uint64

GetTotalDispatchedServiceEventCount returns the total number of events dispatched to subscribed services

func (*Broker) GetTotalQConnectorEventCount

func (b *Broker) GetTotalQConnectorEventCount() uint64

GetTotalQConnectorEventCount returns the total number of events read from the workqueue pertaining to connector updates

func (*Broker) GetTotalQEventCount

func (b *Broker) GetTotalQEventCount() uint64

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

func (*Broker) GetTotalQGatewayEventCount

func (b *Broker) GetTotalQGatewayEventCount() uint64

GetTotalQGatewayEventCount returns the total number of events read from the workqueue pertaining to gateway updates

func (*Broker) GetTotalQIngressEventCount

func (b *Broker) GetTotalQIngressEventCount() uint64

GetTotalQIngressEventCount returns the total number of events read from the workqueue pertaining to ingress updates

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) GetTotalQServiceEventCount

func (b *Broker) GetTotalQServiceEventCount() uint64

GetTotalQServiceEventCount returns the total number of events read from the workqueue pertaining to service updates

func (*Broker) Unsub

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

Unsub unsubscribes the given channel from the PubSub instance