message

package
v0.2.0 Latest Latest
Warning

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

Go to latest
Published: Oct 20, 2022 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func HandleSubscription

func HandleSubscription[K comparable, V any](
	subscription <-chan watchable.Snapshot[K, V],
	handle func(Update[K, V]),
)

HandleSubscription takes a channel returned by watchable.Map.Subscribe() (or .SubscribeSubset()), and calls the given function for each initial value in the map, and for any updates.

This is better than simply iterating over snapshot.Updates because it handles the case where the the watchable.Map already contains entries before .Subscribe is called.

Types

type InfraIR

type InfraIR struct {
	watchable.Map[string, *ir.Infra]
}

InfraIR message

type ProviderResources

ProviderResources message

func (*ProviderResources) GetGatewayClasses

func (p *ProviderResources) GetGatewayClasses() []*gwapiv1b1.GatewayClass

func (*ProviderResources) GetGateways

func (p *ProviderResources) GetGateways() []*gwapiv1b1.Gateway

func (*ProviderResources) GetHTTPRoutes

func (p *ProviderResources) GetHTTPRoutes() []*gwapiv1b1.HTTPRoute

func (*ProviderResources) GetNamespaces

func (p *ProviderResources) GetNamespaces() []*corev1.Namespace

func (*ProviderResources) GetReferenceGrants

func (p *ProviderResources) GetReferenceGrants() []*gwapiv1a2.ReferenceGrant

func (*ProviderResources) GetSecrets

func (p *ProviderResources) GetSecrets() []*corev1.Secret

func (*ProviderResources) GetServices

func (p *ProviderResources) GetServices() []*corev1.Service

func (*ProviderResources) GetTLSRoutes

func (p *ProviderResources) GetTLSRoutes() []*gwapiv1a2.TLSRoute

type Update

type Update[K comparable, V any] watchable.Update[K, V]

type Xds

Xds message

type XdsIR

type XdsIR struct {
	watchable.Map[string, *ir.Xds]
}

XdsIR message

Jump to

Keyboard shortcuts

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