appmanager

package

Go to main page

Versions in this module

v2

v2.16.1

Apr 22, 2024

v2.16.0

Mar 14, 2024

Changes in this version

+ type PodList []*v1.Pod

+ func (pods PodList) Len() int

+ func (pods PodList) Less(i, j int) bool

+ func (pods PodList) Swap(i, j int)

v2.15.1

Jan 17, 2024

Changes in this version

+ const OVNK8sNodeIPAnnotation3

v2.15.0

Nov 15, 2023

Changes in this version

+ const OVNK8sNodeIPAnnotation2

type Params

+ StaticRouteNodeCIDR string

v2.14.0

Sep 6, 2023

Changes in this version

+ type IngressList []*netv1.Ingress

+ func (slice IngressList) Len() int

+ func (slice IngressList) Less(i, j int) bool

+ func (slice IngressList) Swap(i, j int)

type Manager

+ func (appMgr *Manager) AddNodeInformer(resyncPeriod time.Duration) error

v2.13.1

May 31, 2023

v2.13.0

May 31, 2023

Changes in this version

+ const CILIUM_K8S

+ const CiliumK8sNodeSubnetAnnotation12

+ const CiliumK8sNodeSubnetAnnotation13

+ const OVNK8sNodeIPAnnotation

+ const OVNK8sNodeSubnetAnnotation

+ const OVN_K8S

+ var OSCPCoreServices = map[string]bool

type Params

+ CiliumTunnelName string

+ OrchestrationCNI string

+ StaticRoutingMode bool

v2.12.1

Apr 4, 2023

v2.12.0

Mar 2, 2023

v2.11.1

Jan 6, 2023

Changes in this version

+ const CCCLAgent

+ const Configmaps

+ const Endpoints

+ const F5RouterName

+ const IngressClasses

+ const Ingresses

+ const NPLPodAnnotation

+ const NPLSvcAnnotation

+ const Namespaces

+ const Nodes

+ const Pod

+ const Routes

+ const Secrets

+ const Services

+ var K8SCoreServices = map[string]bool

+ func CheckFlag(list []string, searchString string) bool

+ func RegisterBigIPSchemaTypes()

+ func RemoveUnReferredHealthMonitors(rsCfg *ResourceConfig, fullPoolName string, monitors AnnotationHealthMonitors)

+ func RemoveUnusedHealthMonitors(rsCfg *ResourceConfig)

+ type BigIPv4FormatChecker struct

+ func (f BigIPv4FormatChecker) IsFormat(input interface{}) bool

+ type BigIPv6FormatChecker struct

+ func (f BigIPv6FormatChecker) IsFormat(input interface{}) bool

+ type EventNotifier struct

+ func NewEventNotifier(bfunc NewBroadcasterFunc) *EventNotifier

+ func (en *EventNotifier) CreateNotifierForNamespace(namespace string, coreIntf corev1.CoreV1Interface) *NamespaceEventNotifier

+ func (en *EventNotifier) DeleteNotifierForNamespace(namespace string)

+ func (en *EventNotifier) GetNotifierForNamespace(namespace string) *NamespaceEventNotifier

+ type FwdRuleMap map[string]bool

+ type HostFwdRuleMap map[string]FwdRuleMap

+ type Manager struct

+ AgentCIS cisAgent.CISAgentInterface

+ AgentName string

+ DynamicNS bool

+ K8sVersion string

+ TeemData *teem.TeemsData

+ WatchedNS WatchedNamespaces

+ func NewManager(params *Params) *Manager

+ func (appMgr *Manager) AddNamespace(namespace string, cfgMapSelector labels.Selector, resyncPeriod time.Duration) error

+ func (appMgr *Manager) AddNamespaceLabelInformer(labelSelector labels.Selector, resyncPeriod time.Duration) error

+ func (appMgr *Manager) GetAllWatchedNamespaces() []string

+ func (appMgr *Manager) GetNamespaceLabelInformer() cache.SharedIndexInformer

+ func (appMgr *Manager) GetPodsForService(namespace, serviceName string) []*v1.Pod

+ func (appMgr *Manager) GetServicesForPod(pod *v1.Pod) []*v1.Service

+ func (appMgr *Manager) GetWatchedNamespaces() []string

+ func (appMgr *Manager) GetWatchedNamespacesLockless() []string

+ func (appMgr *Manager) HandleTranslateAddress(sKey serviceQueueKey, stats *vsSyncStats)

+ func (appMgr *Manager) IsNodePort() bool

+ func (appMgr *Manager) ProcessNodeUpdate(obj interface{})

+ func (appMgr *Manager) Run(stopCh <-chan struct{})

+ func (appMgr *Manager) UseNodeInternal() bool

+ type NPLAnnoations []NPLAnnotation

+ type NPLAnnotation struct

+ NodeIP string

+ NodePort int32

+ PodPort int32

+ type NamespaceEventNotifier struct

+ func (nen *NamespaceEventNotifier) RecordEvent(obj runtime.Object, eventType, reason, message string)

+ type NamespaceEventNotifierMap map[string]*NamespaceEventNotifier

+ type NewBroadcasterFunc func() record.EventBroadcaster

+ type Node struct

+ Addr string

+ Name string

+ type NodeList []v1.Node

+ func (nodes NodeList) Len() int

+ func (nodes NodeList) Less(i, j int) bool

+ func (nodes NodeList) Swap(i, j int)

+ type Params struct

+ AgRspChan chan interface{}

+ Agent string

+ ConfigWriter writer.Writer

+ DefaultIngIP string

+ DefaultRouteDomain int

+ DgPath string

+ EventChan chan interface{}

+ HubMode bool

+ IngressClass string

+ IsNodePort bool

+ KubeClient kubernetes.Interface

+ ManageConfigMaps bool

+ ManageIngress bool

+ ManageIngressClassOnly bool

+ NodeLabelSelector string

+ PoolMemberType string

+ ProcessAgentLabels func(map[string]string, string, string) bool

+ ResolveIngress string

+ RouteClientV1 routeclient.RouteV1Interface

+ RouteConfig RouteConfig

+ SchemaLocal string

+ SchemaLocalPath string

+ TrustedCertsCfgmap string

+ UseNodeInternal bool

+ UseSecrets bool

+ UserAgent string

+ VXLANMode string

+ VXLANName string

+ VsSnatPoolName string

+ type ProcessedHostPath struct

+ type ResourceMap map[int32][]*ResourceConfig

+ type RouteConfig struct

+ ClientSSL string

+ HttpVs string

+ HttpsVs string

+ RouteLabel string

+ RouteVSAddr string

+ ServerSSL string

+ type RouteList []*routeapi.Route

+ func (slice RouteList) Len() int

+ func (slice RouteList) Less(i, j int) bool

+ func (slice RouteList) Swap(i, j int)

+ type RoutesMap map[string][]string

+ type ServiceFwdRuleMap map[serviceQueueKey]HostFwdRuleMap

+ func NewServiceFwdRuleMap() ServiceFwdRuleMap

+ func (sfrm ServiceFwdRuleMap) AddEntry(ns, svc, host, path string)

+ func (sfrm ServiceFwdRuleMap) AddToDataGroup(dgMap DataGroupNamespaceMap)

+ type SvcEndPointsCache struct

+ type WatchedNamespaces struct

+ NamespaceLabel string

+ Namespaces []string

Other modules containing this package

github.com/F5Networks/k8s-bigip-ctlr

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL