cache_v2

Documentation

Index

• Variables
• func NewApiListenerCache() apiListenerCache
• type ApiRouteConfigurationCache
• type ClusterCache
  • func NewClusterCache() ClusterCache
  • func (cache *ClusterCache) Delete()
  • func (cache *ClusterCache) Dump() []*cluster_v2.Cluster
  • func (cache *ClusterCache) Flush()
  • func (cache *ClusterCache) GetApiCluster(key string) *cluster_v2.Cluster
  • func (cache *ClusterCache) GetApiClusterStatus(key string) core_v2.ApiStatus
  • func (cache *ClusterCache) GetCdsHash(key string) uint64
  • func (cache *ClusterCache) GetEdsHash(key string) uint64
  • func (cache *ClusterCache) GetResourceNames() sets.Set[string]
  • func (cache *ClusterCache) SetApiCluster(key string, value *cluster_v2.Cluster)
  • func (cache *ClusterCache) SetCdsHash(key string, value uint64)
  • func (cache *ClusterCache) SetEdsHash(key string, value uint64)
  • func (cache *ClusterCache) UpdateApiClusterIfExists(key string, value *cluster_v2.Cluster) bool
  • func (cache *ClusterCache) UpdateApiClusterStatus(key string, status core_v2.ApiStatus)
• type ListenerCache
  • func NewListenerCache() ListenerCache
  • func (cache *ListenerCache) AddOrUpdateLdsHash(key string, value uint64)
  • func (cache *ListenerCache) DeleteApiListener(key string)
  • func (cache *ListenerCache) Dump() []*listener_v2.Listener
  • func (cache *ListenerCache) Flush()
  • func (cache *ListenerCache) GetApiListener(key string) *listener_v2.Listener
  • func (cache *ListenerCache) GetLdsHash(key string) uint64
  • func (cache *ListenerCache) GetResourceNames() sets.Set[string]
  • func (cache *ListenerCache) SetApiListener(key string, value *listener_v2.Listener)
  • func (cache *ListenerCache) UpdateApiListenerStatus(key string, status core_v2.ApiStatus)
• type RouteConfigCache
  • func NewRouteConfigCache() RouteConfigCache
  • func (cache *RouteConfigCache) Dump() []*route_v2.RouteConfiguration
  • func (cache *RouteConfigCache) Flush()
  • func (cache *RouteConfigCache) GetApiRouteConfig(key string) *route_v2.RouteConfiguration
  • func (cache *RouteConfigCache) GetRdsHash(key string) uint64
  • func (cache *RouteConfigCache) GetResourceNames() sets.Set[string]
  • func (cache *RouteConfigCache) SetApiRouteConfig(key string, value *route_v2.RouteConfiguration)
  • func (cache *RouteConfigCache) SetRdsHash(key string, value uint64)
  • func (cache *RouteConfigCache) UpdateApiRouteStatus(key string, status core_v2.ApiStatus)

Variables

var RWListener sync.RWMutex

Functions

func NewApiListenerCache

func NewApiListenerCache() apiListenerCache

Types

type ApiRouteConfigurationCache

type ApiRouteConfigurationCache map[string]*route_v2.RouteConfiguration

type ClusterCache

type ClusterCache struct {
	// contains filtered or unexported fields
}

func NewClusterCache

func NewClusterCache() ClusterCache

func (*ClusterCache) Delete

func (cache *ClusterCache) Delete()

Delete delete the clusters marked Delete status.

func (*ClusterCache) Dump

func (cache *ClusterCache) Dump() []*cluster_v2.Cluster

func (*ClusterCache) Flush

func (cache *ClusterCache) Flush()

Flush flushes the cluster to bpf map.

func (*ClusterCache) GetApiCluster

func (cache *ClusterCache) GetApiCluster(key string) *cluster_v2.Cluster

func (*ClusterCache) GetApiClusterStatus

func (cache *ClusterCache) GetApiClusterStatus(key string) core_v2.ApiStatus

func (*ClusterCache) GetCdsHash

func (cache *ClusterCache) GetCdsHash(key string) uint64

func (*ClusterCache) GetEdsHash

func (cache *ClusterCache) GetEdsHash(key string) uint64

func (*ClusterCache) GetResourceNames

func (cache *ClusterCache) GetResourceNames() sets.Set[string]

func (*ClusterCache) SetApiCluster

func (cache *ClusterCache) SetApiCluster(key string, value *cluster_v2.Cluster)

func (*ClusterCache) SetCdsHash

func (cache *ClusterCache) SetCdsHash(key string, value uint64)

func (*ClusterCache) SetEdsHash

func (cache *ClusterCache) SetEdsHash(key string, value uint64)

func (*ClusterCache) UpdateApiClusterIfExists

func (cache *ClusterCache) UpdateApiClusterIfExists(key string, value *cluster_v2.Cluster) bool

func (*ClusterCache) UpdateApiClusterStatus

func (cache *ClusterCache) UpdateApiClusterStatus(key string, status core_v2.ApiStatus)

type ListenerCache

type ListenerCache struct {
	// contains filtered or unexported fields
}

func NewListenerCache

func NewListenerCache() ListenerCache

func (*ListenerCache) AddOrUpdateLdsHash

func (cache *ListenerCache) AddOrUpdateLdsHash(key string, value uint64)

func (*ListenerCache) DeleteApiListener

func (cache *ListenerCache) DeleteApiListener(key string)

func (*ListenerCache) Dump

func (cache *ListenerCache) Dump() []*listener_v2.Listener

func (*ListenerCache) Flush

func (cache *ListenerCache) Flush()

func (*ListenerCache) GetApiListener

func (cache *ListenerCache) GetApiListener(key string) *listener_v2.Listener

func (*ListenerCache) GetLdsHash

func (cache *ListenerCache) GetLdsHash(key string) uint64

func (*ListenerCache) GetResourceNames

func (cache *ListenerCache) GetResourceNames() sets.Set[string]

func (*ListenerCache) SetApiListener

func (cache *ListenerCache) SetApiListener(key string, value *listener_v2.Listener)

func (*ListenerCache) UpdateApiListenerStatus

func (cache *ListenerCache) UpdateApiListenerStatus(key string, status core_v2.ApiStatus)

type RouteConfigCache

type RouteConfigCache struct {
	// contains filtered or unexported fields
}

func NewRouteConfigCache

func NewRouteConfigCache() RouteConfigCache

func (*RouteConfigCache) Dump

func (cache *RouteConfigCache) Dump() []*route_v2.RouteConfiguration

func (*RouteConfigCache) Flush

func (cache *RouteConfigCache) Flush()

func (*RouteConfigCache) GetApiRouteConfig

func (cache *RouteConfigCache) GetApiRouteConfig(key string) *route_v2.RouteConfiguration

func (*RouteConfigCache) GetRdsHash

func (cache *RouteConfigCache) GetRdsHash(key string) uint64

func (*RouteConfigCache) GetResourceNames

func (cache *RouteConfigCache) GetResourceNames() sets.Set[string]

func (*RouteConfigCache) SetApiRouteConfig

func (cache *RouteConfigCache) SetApiRouteConfig(key string, value *route_v2.RouteConfiguration)

func (*RouteConfigCache) SetRdsHash

func (cache *RouteConfigCache) SetRdsHash(key string, value uint64)

func (*RouteConfigCache) UpdateApiRouteStatus

func (cache *RouteConfigCache) UpdateApiRouteStatus(key string, status core_v2.ApiStatus)