Functions — github.com/Demonware/balanced

hub / github.com/Demonware/balanced / functions

Functions408 in github.com/Demonware/balanced

⨍ Functions 408◇ Types & classes 65

↓ 90 callersMethodInfof

(format string, args ...interface{})

pkg/util/logger.go:4

↓ 61 callersMethodID

()

cmd/tunnel-controller/hostpod.go:36

↓ 55 callersFunctionNewService

(kubeService *api.Service, portSpec api.ServicePort, opts ...ServiceOption)

pkg/apis/balanced/v1alpha1/service.go:68

↓ 50 callersMethodID

()

pkg/apis/balanced/v1alpha1/service.go:93

↓ 33 callersMethodAddress

()

pkg/apis/balanced/v1alpha1/service.go:109

↓ 31 callersMethodString

()

pkg/health/check.go:30

↓ 26 callersMethodAdd

(svc *Service, handlers ...ServiceOnChangeHandler)

pkg/apis/balanced/v1alpha1/map_service_mgr.go:132

↓ 26 callersMethodService

()

pkg/apis/balanced/v1alpha1/endpoint.go:82

↓ 24 callersFunctionexportGaugeMetric

(gauge *prometheus.GaugeVec, value float64, lvs ...string)

cmd/ipvs-controller/metrics.go:372

↓ 21 callersFunctionNewMapServiceManager

(logger util.Logger)

pkg/apis/balanced/v1alpha1/map_service_mgr.go:20

↓ 17 callersMethodEXPECT

EXPECT returns an object that allows the caller to indicate expected use

mocks/mock_service_mgr.go:32

↓ 17 callersMethodTargetRef

()

pkg/apis/balanced/v1alpha1/endpoint.go:106

↓ 16 callersFunctionNewEndpoint

(kubeEndpoints *api.Endpoints, kubeEndpointAddress *api.EndpointAddress, kubeEndpointPort *api.EndpointPort, o

pkg/apis/balanced/v1alpha1/endpoint.go:56

↓ 16 callersFunctionReadiness

(ready bool)

pkg/apis/balanced/v1alpha1/endpoint.go:21

↓ 15 callersMethodUpsertEndpoints

UpsertEndpoints : will only insert or update endpoints that are a child of this Service, ignore the rest

pkg/apis/balanced/v1alpha1/service.go:290

↓ 14 callersMethodPort

()

pkg/apis/balanced/v1alpha1/service.go:113

↓ 13 callersMethodKubeAPIV1Service

()

pkg/apis/balanced/v1alpha1/service.go:105

↓ 13 callersFunctionNewController

( kubeClient kubernetes.Interface, s coreinformer.ServiceInformer, e coreinformer.EndpointsInformer, additio

pkg/watcher/controller.go:289

↓ 13 callersMethodRun

(workers uint)

pkg/watcher/controller.go:59

↓ 11 callersFunctionNewVIPReconciler

(client clientset.Interface, ipPoolName *string, cidr *net.IPNet, s coreinformer.ServiceInformer, eventRecord

cmd/vip-allocation-controller/reconciler.go:37

↓ 11 callersMethodSet

(h *HostPod)

cmd/tunnel-controller/cache.go:18

↓ 10 callersMethodAdd

(e *Endpoint, handlers ...EndpointOnChangeHandler)

pkg/apis/balanced/v1alpha1/service.go:205

↓ 9 callersFunctionNewNamedLogger

(name string, level glog.Level)

pkg/util/named_logger.go:12

↓ 8 callersMethodAdd

(svc *Service, handlers ...ServiceOnChangeHandler)

pkg/apis/balanced/v1alpha1/service_mgr.go:13

↓ 8 callersMethodGet

(svcID string)

pkg/apis/balanced/v1alpha1/service_mgr.go:10

↓ 8 callersMethodList

()

pkg/apis/balanced/v1alpha1/service_mgr.go:11

↓ 8 callersFunctionNewHostPod

(pod *api.Pod)

cmd/tunnel-controller/hostpod.go:26

↓ 8 callersFunctionNewIpvsReconciler

(cidrs []*net.IPNet, s cache.SharedIndexInformer, eventRecorder record.EventRecorder, sm v1alpha1.ServiceMana

cmd/ipvs-controller/reconciler.go:36

↓ 8 callersMethodPod

()

cmd/tunnel-controller/hostpod.go:104

↓ 8 callersMethodSet

(svc *v1alpha1.Service)

cmd/tunnel-controller/hostpod.go:51

↓ 8 callersMethodwith

(f func())

pkg/apis/balanced/v1alpha1/map_service_mgr.go:275

↓ 7 callersMethodAssignVIPIfValidService

(prevSvc *v1alpha1.Service, svc *v1alpha1.Service)

cmd/vip-allocation-controller/reconciler.go:85

↓ 7 callersMethodContainerID

ContainerID: find first running container ID from normal containers and fallback to initContainers

cmd/tunnel-controller/hostpod.go:96

↓ 7 callersFunctionConvertKubeAPIV1EndpointsToEndpoints

ConvertKubeAPIV1EndpointsToEndpoints translates kubernetes endpoints objects to balanced endpoints

pkg/apis/balanced/v1alpha1/endpoint.go:29

↓ 7 callersMethodConvertServiceToIpvsService

(svc *v1alpha1.Service)

cmd/ipvs-controller/reconciler.go:423

↓ 7 callersMethodExists

(svc *Service)

pkg/apis/balanced/v1alpha1/service_mgr.go:5

↓ 7 callersMethodProtocol

()

pkg/apis/balanced/v1alpha1/service.go:121

↓ 7 callersMethodisValidIPAddress

(svc *v1alpha1.Service)

cmd/ipvs-controller/reconciler.go:107

↓ 7 callersMethodsyncServiceManager

(key string)

pkg/watcher/controller.go:221

↓ 6 callersMethodList

()

pkg/apis/balanced/v1alpha1/map_service_mgr.go:100

↓ 6 callersMethodPortName

()

pkg/apis/balanced/v1alpha1/service.go:117

↓ 6 callersMethodRemove

(svc *Service, handlers ...ServiceOnChangeHandler)

pkg/apis/balanced/v1alpha1/service_mgr.go:15

↓ 6 callersMethodSetService

(svc *Service)

pkg/apis/balanced/v1alpha1/endpoint.go:77

↓ 6 callersMethodwith

(f func())

pkg/apis/balanced/v1alpha1/service.go:355

↓ 6 callersFunctionwithIpvsHandle

(f func(*ipvs.Handle) error)

cmd/ipvs-controller/reconciler.go:460

↓ 5 callersMethodAddresses

()

cmd/tunnel-controller/hostpod.go:70

↓ 5 callersMethodAnnotations

()

pkg/apis/balanced/v1alpha1/service.go:147

↓ 5 callersMethodHasChanged

(h *HostPod)

cmd/tunnel-controller/cache.go:53

↓ 5 callersMethodIsTargetPod

()

pkg/apis/balanced/v1alpha1/endpoint.go:118

↓ 5 callersMethodKubeAPIV1ServiceName

()

pkg/apis/balanced/v1alpha1/service.go:101

↓ 5 callersMethodListServicesWithAddress

()

pkg/apis/balanced/v1alpha1/service_mgr.go:12

↓ 5 callersMethodReady

()

pkg/apis/balanced/v1alpha1/endpoint.go:129

↓ 5 callersMethodRegisterCheck

(c ...HealthCheck)

pkg/health/manager.go:15

↓ 5 callersMethodResolveByKubeMetaNamespaceKey

ResolveByKubeMetaNamespaceKey : finds all Services with the same Kubernetes Service Object Key

pkg/apis/balanced/v1alpha1/service_mgr.go:7

↓ 5 callersMethodTargetRefString

()

pkg/apis/balanced/v1alpha1/endpoint.go:110

↓ 5 callersMethodgetIpvsScheduler

(svc *v1alpha1.Service)

cmd/ipvs-controller/reconciler.go:410

↓ 5 callersMethodinformerHasSyncedFuncs

()

pkg/watcher/controller.go:45

↓ 5 callersFunctionisValidEndpoint

(e *v1alpha1.Endpoint)

cmd/ipvs-controller/reconciler.go:403

↓ 4 callersFunctionConvertEndpointToIpvsDestination

(endpoint *v1alpha1.Endpoint)

cmd/ipvs-controller/reconciler.go:389

↓ 4 callersMethodEquals

(svc *Service)

pkg/apis/balanced/v1alpha1/service.go:140

↓ 4 callersMethodFreeIPs

()

cmd/vip-allocation-controller/reconciler.go:225

↓ 4 callersMethodKubeAPIV1Endpoints

()

pkg/apis/balanced/v1alpha1/endpoint.go:90

↓ 4 callersMethodList

()

pkg/apis/balanced/v1alpha1/service.go:190

↓ 4 callersFunctionLoadKernelModule

(name string)

pkg/util/main.go:157

↓ 4 callersFunctionMain

(f MainFunc, cfg interface{})

pkg/util/main.go:41

↓ 4 callersFunctionNewEventRecorder

(client clientset.Interface, componentName string)

pkg/util/events.go:12

↓ 4 callersFunctionNewGenericHealthCheck

(name string, period time.Duration)

pkg/health/check.go:23

↓ 4 callersFunctionNewMockServiceManager

NewMockServiceManager creates a new mock instance

mocks/mock_service_mgr.go:25

↓ 4 callersMethodNodeName

()

pkg/apis/balanced/v1alpha1/endpoint.go:125

↓ 4 callersMethodProtoNumber

()

pkg/apis/balanced/v1alpha1/service.go:125

↓ 4 callersMethodResolveByKubeMetaNamespaceKey

ResolveByKubeMetaNamespaceKey : finds all Services with the same Kubernetes Service Object Key

pkg/apis/balanced/v1alpha1/map_service_mgr.go:39

↓ 4 callersMethodUpdate

(svc *Service, handlers ...ServiceOnChangeHandler)

pkg/apis/balanced/v1alpha1/service_mgr.go:14

↓ 4 callersMethodUpdate

(svc *Service, handlers ...ServiceOnChangeHandler)

pkg/apis/balanced/v1alpha1/map_service_mgr.go:154

↓ 4 callersMethodUpdateServicesRecursively

UpdateServicesRecursively will add Service to SM if not already exist and its Endpoints, otherwise, it will update the existing Service in the SM alon

pkg/apis/balanced/v1alpha1/map_service_mgr.go:250

↓ 4 callersMethodaddKeyToWorkQueue

(key string)

pkg/watcher/controller.go:279

↓ 4 callersFunctioncontainerIDString

(containerID *string)

cmd/tunnel-controller/cache.go:67

↓ 4 callersMethoddeleteEndpointsNotSupplied

(endpoints []*Endpoint, handlers ...EndpointOnChangeHandler)

pkg/apis/balanced/v1alpha1/service.go:327

↓ 4 callersMethodexistingIPs

()

cmd/vip-allocation-controller/reconciler.go:172

↓ 4 callersMethodexists

(e *Endpoint)

pkg/apis/balanced/v1alpha1/service.go:169

↓ 4 callersMethodexists

(svc *Service)

pkg/apis/balanced/v1alpha1/map_service_mgr.go:33

↓ 4 callersFunctiongetServiceManager

()

cmd/vip-allocation-controller/reconciler_test.go:355

↓ 4 callersMethodipPoolName

()

cmd/vip-allocation-controller/reconciler.go:57

↓ 4 callersMethodisIPinCIDRs

(ip net.IP)

cmd/ipvs-controller/reconciler.go:98

↓ 4 callersFunctionisValidEndpoint

(hostname string, e *v1alpha1.Endpoint)

cmd/tunnel-controller/reconciler.go:61

↓ 3 callersFunctionConvertKubeAPIV1ServiceToServices

ConvertKubeAPIV1ServiceToServices assumes a kubeService with Service Type: LoadBalancer

pkg/apis/balanced/v1alpha1/service.go:55

↓ 3 callersMethodDelete

(h *HostPod)

cmd/tunnel-controller/cache.go:17

↓ 3 callersFunctionDifference

Difference returns the elements in a that aren't in b

pkg/util/main.go:143

↓ 3 callersFunctionGetDummyVipInterface

()

pkg/util/iface.go:26

↓ 3 callersMethodGetPID

(string)

pkg/pidresolver/pidresolver.go:6

↓ 3 callersMethodIsChildEndpoint

(e *Endpoint)

pkg/apis/balanced/v1alpha1/service.go:151

↓ 3 callersMethodRemove

(svc *Service, handlers ...ServiceOnChangeHandler)

pkg/apis/balanced/v1alpha1/map_service_mgr.go:188

↓ 3 callersMethodRemoveByID

(svcID string, handlers ...ServiceOnChangeHandler)

pkg/apis/balanced/v1alpha1/map_service_mgr.go:210

↓ 3 callersMethodRemoveExistingServicesNoLongerCurrent

RemoveExistingServicesNoLongerCurrent removes existing services that are managed by the MapServiceManager that are no longer in existence in the real

pkg/apis/balanced/v1alpha1/service_mgr.go:9

↓ 3 callersMethodRemoveServicesRecursively

RemoveServicesRecursively remove Endpoints of a Service first before removal

pkg/apis/balanced/v1alpha1/map_service_mgr.go:232

↓ 3 callersMethodResolverType

()

pkg/pidresolver/pidresolver.go:7

↓ 3 callersMethodUpdate

(e *Endpoint, handlers ...EndpointOnChangeHandler)

pkg/apis/balanced/v1alpha1/service.go:229

↓ 3 callersMethodUpdatePod

(pod *api.Pod)

cmd/tunnel-controller/hostpod.go:40

↓ 3 callersMethodUpdateServicesRecursively

UpdateServicesRecursively will add Service to SM if not already exist and its Endpoints, otherwise, it will update the existing Service in the SM alon

pkg/apis/balanced/v1alpha1/service_mgr.go:21

↓ 3 callersMethodallIPs

allIPs return a slice of IP strings within the CIDR

cmd/vip-allocation-controller/reconciler.go:185

↓ 3 callersFunctionconvertNetIPToStringSlice

(ips []net.IP)

cmd/tunnel-controller/cache.go:92

next →1–100 of 408, ranked by callers