message

Documentation

Index

• func HandleSubscription[K comparable, V any](meta Metadata, subscription <-chan watchable.Snapshot[K, V], ...)
• type GatewayAPIStatuses
  • func (s *GatewayAPIStatuses) Close()
• type InfraIR
• type Metadata
• type ProviderResources
  • func (p *ProviderResources) Close()
  • func (p *ProviderResources) GetResources() []*gatewayapi.Resources
  • func (p *ProviderResources) GetResourcesByGatewayClass(name string) *gatewayapi.Resources
  • func (p *ProviderResources) GetResourcesKey() string
• type Update
• type Xds
• type XdsIR

Functions

func HandleSubscription

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

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 watchable.Map already contains entries before .Subscribe is called.

Types

type GatewayAPIStatuses

type GatewayAPIStatuses struct {
	GatewayStatuses   watchable.Map[types.NamespacedName, *gwapiv1.GatewayStatus]
	HTTPRouteStatuses watchable.Map[types.NamespacedName, *gwapiv1.HTTPRouteStatus]
}

GatewayAPIStatuses contains gateway API resources statuses

func (*GatewayAPIStatuses) Close

func (s *GatewayAPIStatuses) Close()

type InfraIR

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

InfraIR message

type Metadata

type Metadata struct {
	Runner  string
	Message string
}

type ProviderResources

type ProviderResources struct {
	// GatewayAPIResources is a map from a GatewayClass name to
	// a group of gateway API and other related resources.
	GatewayAPIResources watchable.Map[string, *gatewayapi.ControllerResources]

	// GatewayAPIStatuses is a group of gateway api
	// resource statuses maps.
	GatewayAPIStatuses
}

ProviderResources message

func (*ProviderResources) Close

func (p *ProviderResources) Close()

func (*ProviderResources) GetResources

func (p *ProviderResources) GetResources() []*gatewayapi.Resources

func (*ProviderResources) GetResourcesByGatewayClass

func (p *ProviderResources) GetResourcesByGatewayClass(name string) *gatewayapi.Resources

func (*ProviderResources) GetResourcesKey

func (p *ProviderResources) GetResourcesKey() string

type Update

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

type Xds

type Xds struct {
	watchable.Map[string, *xdstypes.ResourceVersionTable]
}

Xds message

type XdsIR

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

XdsIR message