MCPcopy Create free account

hub / github.com/Demonware/balanced / functions

Functions408 in github.com/Demonware/balanced

↓ 3 callersFunctionendpointInIpvsDestinations
(dests []*ipvs.Destination, e *v1alpha1.Endpoint)
cmd/ipvs-controller/reconciler.go:440
↓ 3 callersMethodexecutePostSyncHandlers
()
pkg/watcher/controller.go:205
↓ 3 callersMethodgetHostPodFromPod
getHostPodFromPod: side effect of adding to hostPods map if not exists
cmd/tunnel-controller/reconciler.go:82
↓ 3 callersFunctiongetLoadBalancerIP
(kubeService *api.Service)
pkg/apis/balanced/v1alpha1/service.go:43
↓ 3 callersFunctionhasIdenticalElements
hasIdenticalElements: returns true if all elements in x are in y and vice versa, without comparing order
cmd/tunnel-controller/cache.go:76
↓ 3 callersMethodhasInformersSynced
(hasSyncedFuncs []cache.InformerSynced)
pkg/watcher/controller.go:196
↓ 3 callersMethodhasIpvsServiceChanged
(iSvc *ipvs.Service, svc *v1alpha1.Service)
cmd/ipvs-controller/reconciler.go:433
↓ 3 callersFunctionisValidServiceLoadBalancer
(svc *api.Service)
pkg/watcher/controller.go:118
↓ 3 callersFunctionlogCurrentNetworkNamespace
()
cmd/tunnel-controller/tunnelconfigurator.go:275
↓ 3 callersMethodmatchingEndpoints
(svc *api.Service)
pkg/watcher/controller.go:103
↓ 3 callersMethodpopulateServiceManager
()
pkg/watcher/controller.go:125
↓ 3 callersMethodupsertServiceHandler
(svc *v1alpha1.Service)
cmd/ipvs-controller/reconciler.go:138
↓ 2 callersFunctionAddIPtoInterface
(ip net.IP, iface netlink.Link)
pkg/util/iface.go:49
↓ 2 callersFunctionDeleteNonSuppliedIPsFromInterface
(addresses []net.IP, iface netlink.Link)
pkg/util/iface.go:98
↓ 2 callersMethodExists
(e *Endpoint)
pkg/apis/balanced/v1alpha1/service.go:162
↓ 2 callersMethodExists
(svc *Service)
pkg/apis/balanced/v1alpha1/map_service_mgr.go:27
↓ 2 callersMethodExport
()
pkg/metrics/publisher.go:28
↓ 2 callersMethodGet
(endpointID string)
pkg/apis/balanced/v1alpha1/service.go:174
↓ 2 callersMethodGet
(svcID string)
pkg/apis/balanced/v1alpha1/map_service_mgr.go:84
↓ 2 callersMethodHealthy
()
pkg/health/check.go:12
↓ 2 callersMethodID
()
pkg/apis/balanced/v1alpha1/endpoint.go:70
↓ 2 callersMethodIsValidPod
()
cmd/tunnel-controller/hostpod.go:78
↓ 2 callersMethodKubeAPIV1EndpointsName
()
pkg/apis/balanced/v1alpha1/endpoint.go:86
↓ 2 callersMethodListServicesWithAddress
()
pkg/apis/balanced/v1alpha1/map_service_mgr.go:115
↓ 2 callersFunctionNewContainerdPIDResolver
(runtimeEndpoint string)
pkg/pidresolver/containerd.go:15
↓ 2 callersFunctionNewThreadsafeHostPodCache
()
cmd/tunnel-controller/cache.go:26
↓ 2 callersMethodRemove
(e *Endpoint, handlers ...EndpointOnChangeHandler)
pkg/apis/balanced/v1alpha1/service.go:267
↓ 2 callersMethodRemove
(svc *v1alpha1.Service)
cmd/tunnel-controller/hostpod.go:66
↓ 2 callersMethodRemoveServicesRecursively
RemoveServicesRecursively remove Endpoints of a Service first before removal
pkg/apis/balanced/v1alpha1/service_mgr.go:18
↓ 2 callersMethodTargetPort
TargetPort resolves target port using endpoint information
pkg/apis/balanced/v1alpha1/service.go:85
↓ 2 callersMethodUpdateEndpoints
UpdateEndpoints : will insert or update endpoints similarly to UpsertEndpoints, but will remove children that do not exist in endpoints slice
pkg/apis/balanced/v1alpha1/service.go:314
↓ 2 callersFunctionacquireFromSpecifiedIPs
acquireFromSpecifiedIP attempts to acquire from the list of user-specified IP addresses from the pool for allocation the first IP from the list that m
cmd/vip-allocation-controller/reconciler.go:137
↓ 2 callersFunctiondockerPIDResolverFactory
()
cmd/tunnel-controller/pidresolver.go:32
↓ 2 callersFunctionfirstRunningContainerID
(containerStatuses []api.ContainerStatus)
cmd/tunnel-controller/hostpod.go:108
↓ 2 callersMethodget
(svcID string)
pkg/apis/balanced/v1alpha1/map_service_mgr.go:91
↓ 2 callersFunctiongetStrRef
(str string)
cmd/vip-allocation-controller/reconciler_test.go:50
↓ 2 callersFunctionhasIpvsDestinationChanged
(iE *ipvs.Destination, e *v1alpha1.Endpoint)
cmd/ipvs-controller/reconciler.go:449
↓ 2 callersMethodisEqualAddress
(svc *Service)
pkg/apis/balanced/v1alpha1/service.go:129
↓ 2 callersMethodisEqualTarget
(endpoint *Endpoint)
pkg/apis/balanced/v1alpha1/endpoint.go:133
↓ 2 callersMethodisSelectedPool
(svc *v1alpha1.Service)
cmd/vip-allocation-controller/reconciler.go:64
↓ 2 callersFunctionnoLongerExistentServiceKeys
(currentServices []*Service, existingServices []*Service)
pkg/apis/balanced/v1alpha1/map_service_mgr.go:57
↓ 2 callersMethodpodFromEndpoint
(e *v1alpha1.Endpoint)
cmd/tunnel-controller/reconciler.go:71
↓ 2 callersMethodremove
(svc *Service)
pkg/apis/balanced/v1alpha1/map_service_mgr.go:201
↓ 2 callersMethodupsertEndpointHandler
(e *v1alpha1.Endpoint)
cmd/ipvs-controller/reconciler.go:197
↓ 2 callersMethodupsertEndpointHandler
(e *v1alpha1.Endpoint)
cmd/tunnel-controller/reconciler.go:99
↓ 1 callersMethodAddress
()
pkg/apis/balanced/v1alpha1/endpoint.go:94
↓ 1 callersMethodDelete
(h *HostPod)
cmd/tunnel-controller/cache.go:34
↓ 1 callersFunctionDeleteIPfromInterface
(ip net.IP, iface netlink.Link)
pkg/util/iface.go:74
↓ 1 callersFunctionGetNetAddrsfromInterface
(iface netlink.Link)
pkg/util/iface.go:94
↓ 1 callersMethodHasChanged
(h *HostPod)
cmd/tunnel-controller/cache.go:19
↓ 1 callersMethodHeartBeat
()
pkg/health/check.go:34
↓ 1 callersFunctionNewCRIPIDResolver
(runtimeEndpoint string)
pkg/pidresolver/cri.go:25
↓ 1 callersFunctionNewDockerPIDResolver
(docker dockerclient.APIClient)
pkg/pidresolver/docker.go:27
↓ 1 callersFunctionNewDummyMetricsExporter
()
cmd/dummy-controller/metrics.go:12
↓ 1 callersFunctionNewDummyPIDResolver
(pid int)
pkg/pidresolver/dummy.go:11
↓ 1 callersFunctionNewDummyReconciler
(s coreinformer.ServiceInformer, eventRecorder record.EventRecorder, sm *v1alpha1.MapServiceManager)
cmd/dummy-controller/reconciler.go:17
↓ 1 callersFunctionNewDynamicPIDResolver
(resolvers ...PIDResolver)
pkg/pidresolver/dynamic.go:17
↓ 1 callersFunctionNewHealthManager
(c ...HealthCheck)
pkg/health/manager.go:7
↓ 1 callersFunctionNewHealthPublisher
(bindAddr string, path string, port string, healthManager *HealthManager)
pkg/health/publisher.go:54
↓ 1 callersFunctionNewIpvsMetricsExporter
NewIpvsMetricsExporter : instantiates MetricsExporter
cmd/ipvs-controller/metrics.go:180
↓ 1 callersFunctionNewMetricsPublisher
(bindAddr string, path string, port string, publishInterval time.Duration)
pkg/metrics/publisher.go:70
↓ 1 callersFunctionNewTunnelMetricsExporter
()
cmd/tunnel-controller/metrics.go:12
↓ 1 callersFunctionNewTunnelReconciler
( hostname string, podInformer coreinformer.PodInformer, serviceManager v1alpha1.ServiceManager, tunnelCon
cmd/tunnel-controller/reconciler.go:27
↓ 1 callersFunctionNewVIPMetricsExporter
()
cmd/vip-allocation-controller/metrics.go:29
↓ 1 callersMethodPort
()
pkg/apis/balanced/v1alpha1/endpoint.go:102
↓ 1 callersMethodRegister
(metricsExporter MetricsExporter)
pkg/metrics/publisher.go:23
↓ 1 callersMethodRemoveExistingServicesNoLongerCurrent
RemoveExistingServicesNoLongerCurrent removes existing services that are managed by the MapServiceManager that are no longer in existence in the real
pkg/apis/balanced/v1alpha1/map_service_mgr.go:73
↓ 1 callersMethodSet
(h *HostPod)
cmd/tunnel-controller/cache.go:38
↓ 1 callersMethodStatus
()
pkg/health/manager.go:20
↓ 1 callersFunctionSysctl
sysctl sets the named sysctl to the value specified and returns its original value as a string. Note that this cannot be used if a sysctl component in
pkg/util/sysctl.go:23
↓ 1 callersFunctionUpdateIptables
(ipt *iptables.IPTables, addrs []net.IP, mss int)
cmd/tunnel-controller/tunnelconfigurator.go:209
↓ 1 callersMethodadd
(e *Endpoint)
pkg/apis/balanced/v1alpha1/service.go:218
↓ 1 callersMethodadd
(svc *Service)
pkg/apis/balanced/v1alpha1/map_service_mgr.go:145
↓ 1 callersMethodaddEndpointHandler
(e *v1alpha1.Endpoint)
cmd/dummy-controller/reconciler.go:64
↓ 1 callersMethodaddServiceHandler
(svc *v1alpha1.Service)
cmd/dummy-controller/reconciler.go:39
↓ 1 callersMethodallocateLoadbalancerIP
(svc *v1alpha1.Service, ipAddr string)
cmd/vip-allocation-controller/reconciler.go:148
↓ 1 callersFunctioncleanupIptables
(ipt *iptables.IPTables, addrs []net.IP, mss int)
cmd/tunnel-controller/tunnelconfigurator.go:167
↓ 1 callersMethodcleanupOrphanedIPAddresses
()
cmd/ipvs-controller/reconciler.go:313
↓ 1 callersMethodcleanupOrphanedIpvsDestinations
(svc *v1alpha1.Service)
cmd/ipvs-controller/reconciler.go:361
↓ 1 callersMethodcleanupOrphanedIpvsServices
()
cmd/ipvs-controller/reconciler.go:333
↓ 1 callersMethodconfigure
(*HostPod)
cmd/tunnel-controller/tunnelconfigurator.go:28
↓ 1 callersMethoddeleteEndpointHandler
(e *v1alpha1.Endpoint)
cmd/ipvs-controller/reconciler.go:250
↓ 1 callersMethoddeleteEndpointHandler
(e *v1alpha1.Endpoint)
cmd/tunnel-controller/reconciler.go:113
↓ 1 callersMethoddeleteEndpointHandler
(prevE *v1alpha1.Endpoint)
cmd/dummy-controller/reconciler.go:72
↓ 1 callersMethoddeleteIpvsService
(svc *v1alpha1.Service)
cmd/ipvs-controller/reconciler.go:78
↓ 1 callersMethoddeleteServiceHandler
(prevSvc *v1alpha1.Service)
cmd/ipvs-controller/reconciler.go:155
↓ 1 callersMethoddeleteServiceHandler
(prevSvc *v1alpha1.Service)
cmd/dummy-controller/reconciler.go:47
↓ 1 callersFunctionendpointID
(d *ipvs.Destination)
cmd/ipvs-controller/metrics.go:229
↓ 1 callersFunctionensureIptables
(ipNets []*net.IPNet)
cmd/ipvs-host-controller/main.go:39
↓ 1 callersMethodexecuteHealthCheck
()
pkg/watcher/controller.go:215
↓ 1 callersMethodget
(endpointID string)
pkg/apis/balanced/v1alpha1/service.go:181
↓ 1 callersMethodgetRuntimeClient
()
pkg/pidresolver/cri.go:31
↓ 1 callersFunctioninc
http://play.golang.org/p/m8TNTtygK0
cmd/vip-allocation-controller/reconciler.go:207
↓ 1 callersFunctioniptablesRunFunc
(ipNets []*net.IPNet)
cmd/ipvs-host-controller/main.go:53
↓ 1 callersFunctionipvsServiceID
(s *v1alpha1.Service)
cmd/ipvs-controller/metrics.go:223
↓ 1 callersFunctionisValidDefaultScheduler
()
cmd/ipvs-controller/main.go:129
↓ 1 callersMethodlist
()
pkg/apis/balanced/v1alpha1/service.go:197
↓ 1 callersMethodlist
()
pkg/apis/balanced/v1alpha1/map_service_mgr.go:107
↓ 1 callersMethodlistServicesWithAddress
()
pkg/apis/balanced/v1alpha1/map_service_mgr.go:122
↓ 1 callersFunctionloadConfig
(path string, cfg interface{})
pkg/util/main.go:48
← previousnext →101–200 of 408, ranked by callers