messaging

Documentation

Overview

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

Index

• type Broker
  • func NewBroker(stopCh <-chan struct{}) *Broker
  • func (b *Broker) GetQueue() workqueue.TypedRateLimitingInterface[events.PubSubMessage]
  • func (b *Broker) GetSidecarUpdatePubSub() *pubsub.PubSub
  • func (b *Broker) Unsub(pubSub *pubsub.PubSub, ch chan interface{})

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

func (b *Broker) GetQueue() workqueue.TypedRateLimitingInterface[events.PubSubMessage]

GetQueue returns the workqueue instance

func (*Broker) GetSidecarUpdatePubSub

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

GetSidecarUpdatePubSub returns the PubSub instance corresponding to sidecar update events

func (*Broker) Unsub

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

Unsub unsubscribes the given channel from the PubSub instance