messaging

package
v1.1.4-alpha.3 Latest Latest
Warning

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

Go to latest
Published: Nov 1, 2023 License: Apache-2.0 Imports: 15 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

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) GetGatewayUpdatePubSub added in v1.1.0

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

GetGatewayUpdatePubSub returns the PubSub instance corresponding to gateway update events

func (*Broker) GetIngressUpdatePubSub added in v1.1.0

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 added in v1.1.0

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) GetTotalDispatchedGatewayEventCount added in v1.1.0

func (b *Broker) GetTotalDispatchedGatewayEventCount() uint64

GetTotalDispatchedGatewayEventCount returns the total number of events dispatched to subscribed gateways

func (*Broker) GetTotalDispatchedIngressEventCount added in v1.1.0

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

func (b *Broker) GetTotalQEventCount() uint64

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

func (*Broker) GetTotalQGatewayEventCount added in v1.1.0

func (b *Broker) GetTotalQGatewayEventCount() uint64

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

func (*Broker) GetTotalQIngressEventCount added in v1.1.0

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