messaging

package
v1.0.0-rc.3 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jan 10, 2022 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Overview

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

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func GetPubSubTopicForProxyUUID added in v1.0.0

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL