Versions in this module Expand all Collapse all v1 v1.6.1 May 4, 2021 Changes in this version + const NodeRoleKey + const NodeRoleValue + type CachePod struct + Spec v1.PodSpec + type CommonResourceEventHandler struct + func NewCommonResourceEventHandler(events chan watch.Event) *CommonResourceEventHandler + func (c *CommonResourceEventHandler) OnAdd(obj interface{}) + func (c *CommonResourceEventHandler) OnDelete(obj interface{}) + func (c *CommonResourceEventHandler) OnUpdate(oldObj, newObj interface{}) + type ConfigMapManager struct + func NewConfigMapManager(si cache.SharedIndexInformer) (*ConfigMapManager, error) + func (cmm *ConfigMapManager) Events() chan watch.Event + type EndpointsManager struct + func NewEndpointsManager(si cache.SharedIndexInformer) (*EndpointsManager, error) + func (sm *EndpointsManager) Events() chan watch.Event + type LocationCache struct + EdgeNodes sync.Map + func (lc *LocationCache) AddOrUpdateEndpoints(endpoints v1.Endpoints) + func (lc *LocationCache) AddOrUpdatePod(pod v1.Pod) + func (lc *LocationCache) ConfigMapNodes(namespace, name string) (nodes []string) + func (lc *LocationCache) DeleteConfigMap(namespace, name string) + func (lc *LocationCache) DeleteEndpoints(endpoints v1.Endpoints) + func (lc *LocationCache) DeleteNode(nodeName string) + func (lc *LocationCache) DeleteSecret(namespace, name string) + func (lc *LocationCache) GetAllEndpoints() []v1.Endpoints + func (lc *LocationCache) GetNodeStatus(nodeName string) (string, bool) + func (lc *LocationCache) IsEdgeNode(nodeName string) bool + func (lc *LocationCache) IsEndpointsUpdated(new v1.Endpoints) bool + func (lc *LocationCache) PodConfigMapsAndSecrets(pod v1.Pod) (configMaps, secrets []string) + func (lc *LocationCache) SecretNodes(namespace, name string) (nodes []string) + func (lc *LocationCache) UpdateEdgeNode(nodeName string, status string) + type Manager interface + Events func() chan watch.Event + type NodesManager struct + func NewNodesManager(si cache.SharedIndexInformer) (*NodesManager, error) + func (nm *NodesManager) Events() chan watch.Event + type PodManager struct + func NewPodManager(si cache.SharedIndexInformer) (*PodManager, error) + func (pm *PodManager) Events() chan watch.Event + type RuleEndpointManager struct + func NewRuleEndpointManager(si cache.SharedIndexInformer) (*RuleEndpointManager, error) + func (rem *RuleEndpointManager) Events() chan watch.Event + type RuleManager struct + func NewRuleManager(si cache.SharedIndexInformer) (*RuleManager, error) + func (rm *RuleManager) Events() chan watch.Event + type SecretManager struct + func NewSecretManager(si cache.SharedIndexInformer) (*SecretManager, error) + func (sm *SecretManager) Events() chan watch.Event + type ServiceManager struct + func NewServiceManager(si cache.SharedIndexInformer) (*ServiceManager, error) + func (sm *ServiceManager) Events() chan watch.Event