objects

package
v0.1.0 Latest Latest
Warning

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

 Go to latest Published: Mar 7, 2024 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func SharedClusterIpLister 

func SharedClusterIpLister() *clusterIpLister

func SharedlbLister 

func SharedlbLister() *lbLister

Types

type AviGraphLister 

type AviGraphLister struct {
	AviGraphStore *ObjectMapStore
}

func SharedAviGraphLister 

func SharedAviGraphLister() *AviGraphLister

func (*AviGraphLister) Delete 

func (a *AviGraphLister) Delete(vsName string)

func (*AviGraphLister) Get 

func (a *AviGraphLister) Get(vsName string) (bool, interface{})

func (*AviGraphLister) GetAll 

func (a *AviGraphLister) GetAll() interface{}

func (*AviGraphLister) Save 

func (a *AviGraphLister) Save(vsName string, aviGraph interface{})

type AviInfraSettingL7Lister 

type AviInfraSettingL7Lister struct {
	InfraSettingIngRouteLock sync.RWMutex
	InfraSettingGwSvcLock    sync.RWMutex

	// namespaced ingress/route -> infrasetting
	IngRouteInfraSettingStore *ObjectMapStore

	// infrasetting -> shardSize
	InfraSettingShardSizeStore *ObjectMapStore

	// infrasetting -> tenant
	InfraSettingTenantStore *ObjectMapStore

	// namespaced gw/svc -> infrasetting
	GWSvcInfraSettingStore *ObjectMapStore

	// infrasettig -> namespaces
	NSScopedInfraSettingStore *ObjectMapStore
}

func InfraSettingL7Lister 

func InfraSettingL7Lister() *AviInfraSettingL7Lister

func (*AviInfraSettingL7Lister) DeleteInfraSettingToNamespaceMapping 

func (v *AviInfraSettingL7Lister) DeleteInfraSettingToNamespaceMapping(infraSetting string)

func (*AviInfraSettingL7Lister) GetAllTenants 

func (v *AviInfraSettingL7Lister) GetAllTenants() map[string]struct{}

func (*AviInfraSettingL7Lister) GetAviInfraSettingToTenant 

func (v *AviInfraSettingL7Lister) GetAviInfraSettingToTenant(infraSettingName string) string

func (*AviInfraSettingL7Lister) GetGwSvcToInfraSetting 

func (v *AviInfraSettingL7Lister) GetGwSvcToInfraSetting(name string) string

func (*AviInfraSettingL7Lister) GetInfraSettingScopedNamespaces 

func (v *AviInfraSettingL7Lister) GetInfraSettingScopedNamespaces(infraSetting string) []interface{}

func (*AviInfraSettingL7Lister) GetInfraSettingToShardSize 

func (v *AviInfraSettingL7Lister) GetInfraSettingToShardSize(infraSettingName string) (bool, string)

func (*AviInfraSettingL7Lister) GetIngRouteToInfraSetting 

func (v *AviInfraSettingL7Lister) GetIngRouteToInfraSetting(ingrouteNsName string) (bool, string)

func (*AviInfraSettingL7Lister) RemoveGwSvcToInfraSettingMapping 

func (v *AviInfraSettingL7Lister) RemoveGwSvcToInfraSettingMapping(resourceNSName string) bool

func (*AviInfraSettingL7Lister) RemoveIngRouteInfraSettingMappings 

func (v *AviInfraSettingL7Lister) RemoveIngRouteInfraSettingMappings(ingrouteNsName string) bool

func (*AviInfraSettingL7Lister) UpdateAviInfraToTenantMapping 

func (v *AviInfraSettingL7Lister) UpdateAviInfraToTenantMapping(infraSettingName, tenant string)

func (*AviInfraSettingL7Lister) UpdateGwSvcToInfraSettingMapping 

func (v *AviInfraSettingL7Lister) UpdateGwSvcToInfraSettingMapping(resourceNSName, infraSetting string)

func (*AviInfraSettingL7Lister) UpdateInfraSettingToNamespaceMapping 

func (v *AviInfraSettingL7Lister) UpdateInfraSettingToNamespaceMapping(infraSetting string, namespaces []interface{})

func (*AviInfraSettingL7Lister) UpdateIngRouteInfraSettingMappings 

func (v *AviInfraSettingL7Lister) UpdateIngRouteInfraSettingMappings(ingrouteNsName, infraSettingName, shardSize string)

type CRDLister 

type CRDLister struct {
	// since the stored values can be from separate namespaces
	// this struct is locked
	NSLock sync.RWMutex

	// TODO: can be removed once we move to indexers
	// fqdn.com: hr1
	FqdnHostRuleCache *ObjectMapStore

	// hr1: fqdn.com - required for httprule
	HostRuleFQDNCache *ObjectMapStore

	// hr1: gsfqdn.com
	FqdnToGSFQDNCache *ObjectMapStore

	// TODO: can be removed once we move to indexers
	// fqdn.com: {path1: rr1, path2: rr1, path3: rr2}
	FqdnHTTPRulesCache *ObjectMapStore

	// rr1: fqdn1.com, rr2: fqdn2.com
	HTTPRuleFqdnCache *ObjectMapStore

	// shared-vs1-fqdn.com: Shared-VS-L7-1, shared-vs2-fqdn.com: SharedVS-L7-2
	FqdnSharedVSModelCache *ObjectMapStore

	// Shared-VS-L7-1: shared-vs1-fqdn.com, SharedVS-L7-2: shared-vs2-fqdn.com
	SharedVSModelFqdnCache *ObjectMapStore

	// shared-vs1-fqdn: contains, foo.com: exact
	FqdnFqdnTypeCache *ObjectMapStore

	// fqdn: alias1.com, alias2.com
	FQDNToAliasesCache *ObjectMapStore

	// TODO: can be removed once we move to indexers
	// fqdn.com: hr1
	FqdnSSORuleCache *ObjectMapStore

	// hr1: fqdn.com - required for httprule
	SSORuleFQDNCache *ObjectMapStore

	// L7CRD : HostruleCRD
	L7RuleHostRuleCache *ObjectMapStore
}
var CRDinstance *CRDLister

func SharedCRDLister 

func SharedCRDLister() *CRDLister

SharedCRDLister store is used to keep CRD mappings with relevant objects

func (*CRDLister) DeleteFQDNFQDNTypeMapping 

func (c *CRDLister) DeleteFQDNFQDNTypeMapping(fqdn string) bool

func (*CRDLister) DeleteFQDNSharedVSModelMapping 

func (c *CRDLister) DeleteFQDNSharedVSModelMapping(fqdn string) bool

func (*CRDLister) DeleteFQDNToAliasesMapping 

func (c *CRDLister) DeleteFQDNToAliasesMapping(fqdn string) bool

func (*CRDLister) DeleteHostruleFQDNMapping 

func (c *CRDLister) DeleteHostruleFQDNMapping(hostrule string) bool

func (*CRDLister) DeleteL7RuleToHostRuleMapping 

func (c *CRDLister) DeleteL7RuleToHostRuleMapping(l7Rule string, hostRule string)

func (*CRDLister) DeleteLocalFqdnToGsFqdnMap 

func (c *CRDLister) DeleteLocalFqdnToGsFqdnMap(fqdn string) bool

func (*CRDLister) DeleteSSORuleFQDNMapping 

func (c *CRDLister) DeleteSSORuleFQDNMapping(ssoRule string) bool

func (*CRDLister) DeleteSharedVSModelFQDNMapping 

func (c *CRDLister) DeleteSharedVSModelFQDNMapping(modelName string) bool

func (*CRDLister) GetAllFQDNToAliasesMapping 

func (c *CRDLister) GetAllFQDNToAliasesMapping() map[string]interface{}

func (*CRDLister) GetFQDNFQDNTypeMapping 

func (c *CRDLister) GetFQDNFQDNTypeMapping(fqdn string) string

func (*CRDLister) GetFQDNToAliasesMapping 

func (c *CRDLister) GetFQDNToAliasesMapping(fqdn string) (bool, []string)

func (*CRDLister) GetFQDNToHostruleMapping 

func (c *CRDLister) GetFQDNToHostruleMapping(fqdn string) (bool, string)

FqdnHostRuleCache

func (*CRDLister) GetFQDNToHostruleMappingWithType 

func (c *CRDLister) GetFQDNToHostruleMappingWithType(fqdn string) (bool, string)

func (*CRDLister) GetFQDNToSSORuleMapping 

func (c *CRDLister) GetFQDNToSSORuleMapping(fqdn string) (bool, string)

FqdnSSORuleCache

func (*CRDLister) GetFQDNToSharedVSModelMapping 

func (c *CRDLister) GetFQDNToSharedVSModelMapping(fqdn, fqdnType string) (bool, []string)

FqdnSharedVSModelCache/SharedVSModelFqdnCache

func (*CRDLister) GetFqdnHTTPRulesMapping 

func (c *CRDLister) GetFqdnHTTPRulesMapping(fqdn string) (bool, map[string]string)

func (*CRDLister) GetHTTPRuleFqdnMapping 

func (c *CRDLister) GetHTTPRuleFqdnMapping(httprule string) (bool, string)

func (*CRDLister) GetHostruleToFQDNMapping 

func (c *CRDLister) GetHostruleToFQDNMapping(hostrule string) (bool, string)

func (*CRDLister) GetL7RuleToHostRuleMapping 

func (c *CRDLister) GetL7RuleToHostRuleMapping(l7Rule string) (bool, map[string]bool)

func (*CRDLister) GetLocalFqdnToGSFQDNMapping 

func (c *CRDLister) GetLocalFqdnToGSFQDNMapping(fqdn string) (bool, string)

func (*CRDLister) GetSSORuleToFQDNMapping 

func (c *CRDLister) GetSSORuleToFQDNMapping(ssoRule string) (bool, string)

func (*CRDLister) GetSharedVSModelFQDNMapping 

func (c *CRDLister) GetSharedVSModelFQDNMapping(modelName string) (bool, string)

func (*CRDLister) RemoveFqdnHTTPRulesMappings 

func (c *CRDLister) RemoveFqdnHTTPRulesMappings(httprule string) bool

func (*CRDLister) UpdateFQDNFQDNTypeMapping 

func (c *CRDLister) UpdateFQDNFQDNTypeMapping(fqdn, fqdnType string)

func (*CRDLister) UpdateFQDNHostruleMapping 

func (c *CRDLister) UpdateFQDNHostruleMapping(fqdn string, hostrule string)

func (*CRDLister) UpdateFQDNSSORuleMapping 

func (c *CRDLister) UpdateFQDNSSORuleMapping(fqdn string, ssoRule string)

func (*CRDLister) UpdateFQDNSharedVSModelMappings 

func (c *CRDLister) UpdateFQDNSharedVSModelMappings(fqdn, modelName string)

func (*CRDLister) UpdateFQDNToAliasesMappings 

func (c *CRDLister) UpdateFQDNToAliasesMappings(fqdn string, aliases []string)

func (*CRDLister) UpdateFqdnHTTPRulesMappings 

func (c *CRDLister) UpdateFqdnHTTPRulesMappings(fqdn, path, httprule string)

func (*CRDLister) UpdateL7RuleToHostRuleMapping 

func (c *CRDLister) UpdateL7RuleToHostRuleMapping(l7Rule string, hostRule string)

func (*CRDLister) UpdateLocalFQDNToGSFqdnMapping 

func (c *CRDLister) UpdateLocalFQDNToGSFqdnMapping(fqdn string, gsFqdn string)

type IngClassNSCache 

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

func (*IngClassNSCache) DeleteIngToClassMapping 

func (v *IngClassNSCache) DeleteIngToClassMapping(ingName string) bool

func (*IngClassNSCache) GetIngToClass 

func (v *IngClassNSCache) GetIngToClass(ingName string) (bool, string)

func (*IngClassNSCache) UpdateIngToClassMapping 

func (v *IngClassNSCache) UpdateIngToClassMapping(ingName string, class string)

type IngHostCache 

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

func (*IngHostCache) DeleteIngToHostMapping 

func (v *IngHostCache) DeleteIngToHostMapping(ingName string) bool

func (*IngHostCache) GetIngToHost 

func (v *IngHostCache) GetIngToHost(ingName string) (bool, map[string]map[string][]string)

func (*IngHostCache) GetRouteIngToHost 

func (v *IngHostCache) GetRouteIngToHost(ingName string) (bool, map[string]*RouteIngrhost)

func (*IngHostCache) UpdateIngToHostMapping 

func (v *IngHostCache) UpdateIngToHostMapping(ingName string, hostMap map[string]map[string][]string)

func (*IngHostCache) UpdateRouteIngToHostMapping 

func (v *IngHostCache) UpdateRouteIngToHostMapping(ingName string, hostMap map[string]*RouteIngrhost)

type IngNSCache 

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

func (*IngNSCache) DeleteIngToSvcMapping 

func (v *IngNSCache) DeleteIngToSvcMapping(ingName string) bool

func (*IngNSCache) GetIngToSvc 

func (v *IngNSCache) GetIngToSvc(ingName string) (bool, []string)

func (*IngNSCache) UpdateIngToSvcMapping 

func (v *IngNSCache) UpdateIngToSvcMapping(ingName string, svcList []string)

type K8sNodeStore 

type K8sNodeStore struct {
	*ObjectMapStore
}

func SharedNodeLister 

func SharedNodeLister() *K8sNodeStore

func (*K8sNodeStore) PopulateAllNodes 

func (o *K8sNodeStore) PopulateAllNodes(cs *kubernetes.Clientset, isNodePort bool, nodeLabels map[string]string)

type NPLLister 

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

NPLLister stores a list of NPL annotations for a pod

func SharedNPLLister 

func SharedNPLLister() *NPLLister

func (*NPLLister) Delete 

func (a *NPLLister) Delete(key string)

func (*NPLLister) Get 

func (a *NPLLister) Get(key string) (bool, interface{})

func (*NPLLister) GetAll 

func (a *NPLLister) GetAll() interface{}

func (*NPLLister) Save 

func (a *NPLLister) Save(key string, val interface{})

type ObjectMapStore 

type ObjectMapStore struct {
	ObjectMap map[string]interface{}
	ObjLock   sync.RWMutex
}

func NewObjectMapStore 

func NewObjectMapStore() *ObjectMapStore

func (*ObjectMapStore) AddOrUpdate 

func (o *ObjectMapStore) AddOrUpdate(objName string, obj interface{})

func (*ObjectMapStore) CopyAllObjects 

func (o *ObjectMapStore) CopyAllObjects() map[string]interface{}

func (*ObjectMapStore) Delete 

func (o *ObjectMapStore) Delete(objName string) bool

func (*ObjectMapStore) Get 

func (o *ObjectMapStore) Get(objName string) (bool, interface{})

func (*ObjectMapStore) GetAllKeys 

func (o *ObjectMapStore) GetAllKeys() []string

func (*ObjectMapStore) GetAllObjectNames 

func (o *ObjectMapStore) GetAllObjectNames() map[string]interface{}

func (*ObjectMapStore) IsInfraSettingMapped 

func (o *ObjectMapStore) IsInfraSettingMapped(infrasetting string) bool

type ObjectStore 

type ObjectStore struct {
	NSObjectMap map[string]*ObjectMapStore
	NSLock      sync.RWMutex
}

func NewObjectStore 

func NewObjectStore() *ObjectStore

func (*ObjectStore) DeleteNSStore 

func (store *ObjectStore) DeleteNSStore(nsName string) bool

func (*ObjectStore) GetAllNamespaces 

func (store *ObjectStore) GetAllNamespaces() []string

func (*ObjectStore) GetNSStore 

func (store *ObjectStore) GetNSStore(nsName string) *ObjectMapStore

type PodLBSvcLister 

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

PodLBSvcLister stores list of services of type LB for a pod.

func SharedPodToLBSvcLister 

func SharedPodToLBSvcLister() *PodLBSvcLister

func (*PodLBSvcLister) Delete 

func (a *PodLBSvcLister) Delete(key string)

func (*PodLBSvcLister) Get 

func (a *PodLBSvcLister) Get(key string) (bool, interface{})

func (*PodLBSvcLister) GetAll 

func (a *PodLBSvcLister) GetAll() interface{}

func (*PodLBSvcLister) Save 

func (a *PodLBSvcLister) Save(key string, val interface{})

type PodSvcLister 

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

PodSvcLister stores list of services for a pod. For all these services, the Pod acts a backend through matching selector

func SharedPodToSvcLister 

func SharedPodToSvcLister() *PodSvcLister

func (*PodSvcLister) Delete 

func (a *PodSvcLister) Delete(key string)

func (*PodSvcLister) Get 

func (a *PodSvcLister) Get(key string) (bool, interface{})

func (*PodSvcLister) GetAll 

func (a *PodSvcLister) GetAll() interface{}

func (*PodSvcLister) Save 

func (a *PodSvcLister) Save(key string, val interface{})

type ResourceVersionLister 

type ResourceVersionLister struct {
	ResourceVerStore *ObjectMapStore
}

func SharedResourceVerInstanceLister 

func SharedResourceVerInstanceLister() *ResourceVersionLister

func (*ResourceVersionLister) Delete 

func (a *ResourceVersionLister) Delete(resName string)

func (*ResourceVersionLister) Get 

func (a *ResourceVersionLister) Get(resName string) (bool, interface{})

func (*ResourceVersionLister) GetAll 

func (a *ResourceVersionLister) GetAll() interface{}

func (*ResourceVersionLister) Save 

func (a *ResourceVersionLister) Save(vsName string, resVer interface{})

type RouteIngrhost 

type RouteIngrhost struct {
	Hostname       string
	InsecurePolicy string // none, redirect, allow
	SecurePolicy   string // edge, reencrypt, passthrough
	Paths          []string
	PathSvc        map[string][]string //list of services for a path, used for alternate backend
}

stores path/policies for a hostname policies can be of various types for both secure and insecure hosts

type SecretHostNameNSCache 

type SecretHostNameNSCache struct {
	SecretLock sync.RWMutex
	// contains filtered or unexported fields
}

func (*SecretHostNameNSCache) DecrementSecretToHostNameMapping 

func (v *SecretHostNameNSCache) DecrementSecretToHostNameMapping(secretName string, hostName string) []string

func (*SecretHostNameNSCache) DeleteSecretToHostNameMapping 

func (v *SecretHostNameNSCache) DeleteSecretToHostNameMapping(secretName string) bool

func (*SecretHostNameNSCache) GetSecretToHostname 

func (v *SecretHostNameNSCache) GetSecretToHostname(secretName string) (bool, []string)

func (*SecretHostNameNSCache) UpdateSecretToHostNameMapping 

func (v *SecretHostNameNSCache) UpdateSecretToHostNameMapping(secretName string, hostName string)

type SecretIngNSCache 

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

func (*SecretIngNSCache) DeleteIngToSecretMapping 

func (v *SecretIngNSCache) DeleteIngToSecretMapping(ingName string) bool

func (*SecretIngNSCache) GetIngToSecret 

func (v *SecretIngNSCache) GetIngToSecret(ingName string) (bool, []string)

func (*SecretIngNSCache) UpdateIngToSecretMapping 

func (v *SecretIngNSCache) UpdateIngToSecretMapping(ingName string, secretList []string)

type SvcGWLister 

type SvcGWLister struct {
	SvcGWLock sync.RWMutex

	// gwclass -> [ns1/gw1, ns1/gw2, ns2/gw3]
	GwClassGWStore *ObjectMapStore

	// nsX/gw1 -> gwclass
	GwGwClassStore *ObjectMapStore

	// the protocol and port mapped here are of the gateway listener config
	// that has the appropriate labels
	// nsX/gw1 -> [proto1/port1, proto2/port2]
	GwListenersStore *ObjectMapStore

	// ns1/svc -> nsX/gw1
	SvcGWStore *ObjectMapStore

	// the protocol and port mapped here are of the service
	// nsX/gw1 -> {proto1/port1: ns1/svc1, proto2/port2: ns2/svc2, ...}
	GwSvcsStore *ObjectMapStore
}

func ServiceGWLister 

func ServiceGWLister() *SvcGWLister

func (*SvcGWLister) DeleteGWListeners 

func (v *SvcGWLister) DeleteGWListeners(gateway string) bool

func (*SvcGWLister) GetGWListeners 

func (v *SvcGWLister) GetGWListeners(gateway string) (bool, []string)

Gateway <-> Listeners

func (*SvcGWLister) GetGWclassToGateways 

func (v *SvcGWLister) GetGWclassToGateways(gwclass string) (bool, []string)

Gateway <-> GatewayClass

func (*SvcGWLister) GetGatewayToGWclass 

func (v *SvcGWLister) GetGatewayToGWclass(gateway string) (bool, string)

func (*SvcGWLister) GetGwToSvcs 

func (v *SvcGWLister) GetGwToSvcs(gateway string) (bool, map[string][]string)

func (*SvcGWLister) GetSvcToGw 

func (v *SvcGWLister) GetSvcToGw(service string) (bool, string)

func (*SvcGWLister) RemoveGatewayGWclassMappings 

func (v *SvcGWLister) RemoveGatewayGWclassMappings(gateway string) bool

func (*SvcGWLister) RemoveGatewayMappings 

func (v *SvcGWLister) RemoveGatewayMappings(gateway, service string) bool

func (*SvcGWLister) UpdateGWListeners 

func (v *SvcGWLister) UpdateGWListeners(gateway string, listeners []string)

func (*SvcGWLister) UpdateGatewayGWclassMappings 

func (v *SvcGWLister) UpdateGatewayGWclassMappings(gateway, gwclass string)

func (*SvcGWLister) UpdateGatewayMappings 

func (v *SvcGWLister) UpdateGatewayMappings(gateway string, svcListener map[string][]string, service string)

type SvcLister 

type SvcLister struct {
	SISvcStore *ObjectStore
	// contains filtered or unexported fields
}

func OshiftRouteSvcLister 

func OshiftRouteSvcLister() *SvcLister

func SharedMultiClusterIngressSvcLister 

func SharedMultiClusterIngressSvcLister() *SvcLister

func SharedSvcLister 

func SharedSvcLister() *SvcLister

func (*SvcLister) IngressMappings 

func (v *SvcLister) IngressMappings(ns string) *SvcNSCache

func (*SvcLister) MultiClusterIngressMappings 

func (v *SvcLister) MultiClusterIngressMappings(ns string) *SvcNSCache

type SvcNSCache 

type SvcNSCache struct {
	IngressLock sync.RWMutex
	IngNSCache
	SecretIngNSCache
	IngHostCache
	SecretHostNameNSCache
	IngClassNSCache
	// contains filtered or unexported fields
}

func (*SvcNSCache) AddIngressToSecretsMappings 

func (v *SvcNSCache) AddIngressToSecretsMappings(secretNS, ingName, secretName string)

func (*SvcNSCache) AddSecretsToIngressMappings 

func (v *SvcNSCache) AddSecretsToIngressMappings(ingressNS, ingName, secretName string)

func (*SvcNSCache) DeleteClassToIngMapping 

func (v *SvcNSCache) DeleteClassToIngMapping(className string) bool

func (*SvcNSCache) DeleteSIToSvcMapping 

func (c *SvcNSCache) DeleteSIToSvcMapping(siName string) bool

func (*SvcNSCache) DeleteSecretToIngMapping 

func (v *SvcNSCache) DeleteSecretToIngMapping(secretName string) bool

func (*SvcNSCache) DeleteSvcToIngMapping 

func (v *SvcNSCache) DeleteSvcToIngMapping(svcName string) bool

func (*SvcNSCache) DeleteSvcToSIMapping 

func (c *SvcNSCache) DeleteSvcToSIMapping(svcName string) bool

func (*SvcNSCache) GetClassToIng 

func (v *SvcNSCache) GetClassToIng(className string) (bool, []string)

func (*SvcNSCache) GetSIToSvc 

func (c *SvcNSCache) GetSIToSvc(siName string) (bool, []string)

func (*SvcNSCache) GetSecretToIng 

func (v *SvcNSCache) GetSecretToIng(secretName string) (bool, []string)

func (*SvcNSCache) GetSvcToIng 

func (v *SvcNSCache) GetSvcToIng(svcName string) (bool, []string)

func (*SvcNSCache) GetSvcToSI 

func (c *SvcNSCache) GetSvcToSI(svcName string) (bool, []string)

func (*SvcNSCache) RemoveIngressClassMappings 

func (v *SvcNSCache) RemoveIngressClassMappings(ingNSName string)

func (*SvcNSCache) RemoveIngressMappings 

func (v *SvcNSCache) RemoveIngressMappings(ingName string) []string

func (*SvcNSCache) RemoveIngressSecretMappings 

func (v *SvcNSCache) RemoveIngressSecretMappings(ingNSName string)

func (*SvcNSCache) RemoveSvcFromIngressMappings 

func (v *SvcNSCache) RemoveSvcFromIngressMappings(ingName string, svcName string)

func (*SvcNSCache) UpdateClassToIngMapping 

func (v *SvcNSCache) UpdateClassToIngMapping(className string, ingressList []string)

func (*SvcNSCache) UpdateIngressClassMappings 

func (v *SvcNSCache) UpdateIngressClassMappings(ingName string, ingClass string)

func (*SvcNSCache) UpdateIngressMappings 

func (v *SvcNSCache) UpdateIngressMappings(ingName string, svcName string)

func (*SvcNSCache) UpdateSIToSvcMapping 

func (c *SvcNSCache) UpdateSIToSvcMapping(siName string, svcList []string)

func (*SvcNSCache) UpdateSecretToIngMapping 

func (v *SvcNSCache) UpdateSecretToIngMapping(secretName string, ingressList []string)

func (*SvcNSCache) UpdateSvcToIngMapping 

func (v *SvcNSCache) UpdateSvcToIngMapping(svcName string, ingressList []string)

func (*SvcNSCache) UpdateSvcToSIMapping 

func (c *SvcNSCache) UpdateSvcToSIMapping(svcName string, siList []string)

type SvcPodLister 

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

SvcPodLister stores list of pods for a service with matching label selector

func SharedSvcToPodLister 

func SharedSvcToPodLister() *SvcPodLister

func (*SvcPodLister) Delete 

func (a *SvcPodLister) Delete(key string)

func (*SvcPodLister) Get 

func (a *SvcPodLister) Get(key string) (bool, interface{})

func (*SvcPodLister) GetAll 

func (a *SvcPodLister) GetAll() interface{}

func (*SvcPodLister) Save 

func (a *SvcPodLister) Save(key string, val interface{})

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.