message

Documentation

Index

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

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

Types

type InfraIR

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

InfraIR message

type ProviderResources

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

	GatewayStatuses   watchable.Map[types.NamespacedName, *gwapiv1b1.Gateway]
	HTTPRouteStatuses watchable.Map[types.NamespacedName, *gwapiv1b1.HTTPRoute]
	GRPCRouteStatuses watchable.Map[types.NamespacedName, *gwapiv1a2.GRPCRoute]
	TLSRouteStatuses  watchable.Map[types.NamespacedName, *gwapiv1a2.TLSRoute]
	TCPRouteStatuses  watchable.Map[types.NamespacedName, *gwapiv1a2.TCPRoute]
	UDPRouteStatuses  watchable.Map[types.NamespacedName, *gwapiv1a2.UDPRoute]
}

ProviderResources message

func (*ProviderResources) Close

func (p *ProviderResources) Close()

func (*ProviderResources) GetResources

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

func (*ProviderResources) GetResourcesKey

func (p *ProviderResources) GetResourcesKey() string

type RateLimitInfraIR

type RateLimitInfraIR struct {
	watchable.Map[string, *ir.RateLimitInfra]
}

RateLimitInfraIR message

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