Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/Demonware/balanced
/ functions
Functions
408 in github.com/Demonware/balanced
⨍
Functions
408
◇
Types & classes
65
↓ 3 callers
Function
endpointInIpvsDestinations
(dests []*ipvs.Destination, e *v1alpha1.Endpoint)
cmd/ipvs-controller/reconciler.go:440
↓ 3 callers
Method
executePostSyncHandlers
()
pkg/watcher/controller.go:205
↓ 3 callers
Method
getHostPodFromPod
getHostPodFromPod: side effect of adding to hostPods map if not exists
cmd/tunnel-controller/reconciler.go:82
↓ 3 callers
Function
getLoadBalancerIP
(kubeService *api.Service)
pkg/apis/balanced/v1alpha1/service.go:43
↓ 3 callers
Function
hasIdenticalElements
hasIdenticalElements: returns true if all elements in x are in y and vice versa, without comparing order
cmd/tunnel-controller/cache.go:76
↓ 3 callers
Method
hasInformersSynced
(hasSyncedFuncs []cache.InformerSynced)
pkg/watcher/controller.go:196
↓ 3 callers
Method
hasIpvsServiceChanged
(iSvc *ipvs.Service, svc *v1alpha1.Service)
cmd/ipvs-controller/reconciler.go:433
↓ 3 callers
Function
isValidServiceLoadBalancer
(svc *api.Service)
pkg/watcher/controller.go:118
↓ 3 callers
Function
logCurrentNetworkNamespace
()
cmd/tunnel-controller/tunnelconfigurator.go:275
↓ 3 callers
Method
matchingEndpoints
(svc *api.Service)
pkg/watcher/controller.go:103
↓ 3 callers
Method
populateServiceManager
()
pkg/watcher/controller.go:125
↓ 3 callers
Method
upsertServiceHandler
(svc *v1alpha1.Service)
cmd/ipvs-controller/reconciler.go:138
↓ 2 callers
Function
AddIPtoInterface
(ip net.IP, iface netlink.Link)
pkg/util/iface.go:49
↓ 2 callers
Function
DeleteNonSuppliedIPsFromInterface
(addresses []net.IP, iface netlink.Link)
pkg/util/iface.go:98
↓ 2 callers
Method
Exists
(e *Endpoint)
pkg/apis/balanced/v1alpha1/service.go:162
↓ 2 callers
Method
Exists
(svc *Service)
pkg/apis/balanced/v1alpha1/map_service_mgr.go:27
↓ 2 callers
Method
Export
()
pkg/metrics/publisher.go:28
↓ 2 callers
Method
Get
(endpointID string)
pkg/apis/balanced/v1alpha1/service.go:174
↓ 2 callers
Method
Get
(svcID string)
pkg/apis/balanced/v1alpha1/map_service_mgr.go:84
↓ 2 callers
Method
Healthy
()
pkg/health/check.go:12
↓ 2 callers
Method
ID
()
pkg/apis/balanced/v1alpha1/endpoint.go:70
↓ 2 callers
Method
IsValidPod
()
cmd/tunnel-controller/hostpod.go:78
↓ 2 callers
Method
KubeAPIV1EndpointsName
()
pkg/apis/balanced/v1alpha1/endpoint.go:86
↓ 2 callers
Method
ListServicesWithAddress
()
pkg/apis/balanced/v1alpha1/map_service_mgr.go:115
↓ 2 callers
Function
NewContainerdPIDResolver
(runtimeEndpoint string)
pkg/pidresolver/containerd.go:15
↓ 2 callers
Function
NewThreadsafeHostPodCache
()
cmd/tunnel-controller/cache.go:26
↓ 2 callers
Method
Remove
(e *Endpoint, handlers ...EndpointOnChangeHandler)
pkg/apis/balanced/v1alpha1/service.go:267
↓ 2 callers
Method
Remove
(svc *v1alpha1.Service)
cmd/tunnel-controller/hostpod.go:66
↓ 2 callers
Method
RemoveServicesRecursively
RemoveServicesRecursively remove Endpoints of a Service first before removal
pkg/apis/balanced/v1alpha1/service_mgr.go:18
↓ 2 callers
Method
TargetPort
TargetPort resolves target port using endpoint information
pkg/apis/balanced/v1alpha1/service.go:85
↓ 2 callers
Method
UpdateEndpoints
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 callers
Function
acquireFromSpecifiedIPs
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 callers
Function
dockerPIDResolverFactory
()
cmd/tunnel-controller/pidresolver.go:32
↓ 2 callers
Function
firstRunningContainerID
(containerStatuses []api.ContainerStatus)
cmd/tunnel-controller/hostpod.go:108
↓ 2 callers
Method
get
(svcID string)
pkg/apis/balanced/v1alpha1/map_service_mgr.go:91
↓ 2 callers
Function
getStrRef
(str string)
cmd/vip-allocation-controller/reconciler_test.go:50
↓ 2 callers
Function
hasIpvsDestinationChanged
(iE *ipvs.Destination, e *v1alpha1.Endpoint)
cmd/ipvs-controller/reconciler.go:449
↓ 2 callers
Method
isEqualAddress
(svc *Service)
pkg/apis/balanced/v1alpha1/service.go:129
↓ 2 callers
Method
isEqualTarget
(endpoint *Endpoint)
pkg/apis/balanced/v1alpha1/endpoint.go:133
↓ 2 callers
Method
isSelectedPool
(svc *v1alpha1.Service)
cmd/vip-allocation-controller/reconciler.go:64
↓ 2 callers
Function
noLongerExistentServiceKeys
(currentServices []*Service, existingServices []*Service)
pkg/apis/balanced/v1alpha1/map_service_mgr.go:57
↓ 2 callers
Method
podFromEndpoint
(e *v1alpha1.Endpoint)
cmd/tunnel-controller/reconciler.go:71
↓ 2 callers
Method
remove
(svc *Service)
pkg/apis/balanced/v1alpha1/map_service_mgr.go:201
↓ 2 callers
Method
upsertEndpointHandler
(e *v1alpha1.Endpoint)
cmd/ipvs-controller/reconciler.go:197
↓ 2 callers
Method
upsertEndpointHandler
(e *v1alpha1.Endpoint)
cmd/tunnel-controller/reconciler.go:99
↓ 1 callers
Method
Address
()
pkg/apis/balanced/v1alpha1/endpoint.go:94
↓ 1 callers
Method
Delete
(h *HostPod)
cmd/tunnel-controller/cache.go:34
↓ 1 callers
Function
DeleteIPfromInterface
(ip net.IP, iface netlink.Link)
pkg/util/iface.go:74
↓ 1 callers
Function
GetNetAddrsfromInterface
(iface netlink.Link)
pkg/util/iface.go:94
↓ 1 callers
Method
HasChanged
(h *HostPod)
cmd/tunnel-controller/cache.go:19
↓ 1 callers
Method
HeartBeat
()
pkg/health/check.go:34
↓ 1 callers
Function
NewCRIPIDResolver
(runtimeEndpoint string)
pkg/pidresolver/cri.go:25
↓ 1 callers
Function
NewDockerPIDResolver
(docker dockerclient.APIClient)
pkg/pidresolver/docker.go:27
↓ 1 callers
Function
NewDummyMetricsExporter
()
cmd/dummy-controller/metrics.go:12
↓ 1 callers
Function
NewDummyPIDResolver
(pid int)
pkg/pidresolver/dummy.go:11
↓ 1 callers
Function
NewDummyReconciler
(s coreinformer.ServiceInformer, eventRecorder record.EventRecorder, sm *v1alpha1.MapServiceManager)
cmd/dummy-controller/reconciler.go:17
↓ 1 callers
Function
NewDynamicPIDResolver
(resolvers ...PIDResolver)
pkg/pidresolver/dynamic.go:17
↓ 1 callers
Function
NewHealthManager
(c ...HealthCheck)
pkg/health/manager.go:7
↓ 1 callers
Function
NewHealthPublisher
(bindAddr string, path string, port string, healthManager *HealthManager)
pkg/health/publisher.go:54
↓ 1 callers
Function
NewIpvsMetricsExporter
NewIpvsMetricsExporter : instantiates MetricsExporter
cmd/ipvs-controller/metrics.go:180
↓ 1 callers
Function
NewMetricsPublisher
(bindAddr string, path string, port string, publishInterval time.Duration)
pkg/metrics/publisher.go:70
↓ 1 callers
Function
NewTunnelMetricsExporter
()
cmd/tunnel-controller/metrics.go:12
↓ 1 callers
Function
NewTunnelReconciler
( hostname string, podInformer coreinformer.PodInformer, serviceManager v1alpha1.ServiceManager, tunnelCon
cmd/tunnel-controller/reconciler.go:27
↓ 1 callers
Function
NewVIPMetricsExporter
()
cmd/vip-allocation-controller/metrics.go:29
↓ 1 callers
Method
Port
()
pkg/apis/balanced/v1alpha1/endpoint.go:102
↓ 1 callers
Method
Register
(metricsExporter MetricsExporter)
pkg/metrics/publisher.go:23
↓ 1 callers
Method
RemoveExistingServicesNoLongerCurrent
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 callers
Method
Set
(h *HostPod)
cmd/tunnel-controller/cache.go:38
↓ 1 callers
Method
Status
()
pkg/health/manager.go:20
↓ 1 callers
Function
Sysctl
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 callers
Function
UpdateIptables
(ipt *iptables.IPTables, addrs []net.IP, mss int)
cmd/tunnel-controller/tunnelconfigurator.go:209
↓ 1 callers
Method
add
(e *Endpoint)
pkg/apis/balanced/v1alpha1/service.go:218
↓ 1 callers
Method
add
(svc *Service)
pkg/apis/balanced/v1alpha1/map_service_mgr.go:145
↓ 1 callers
Method
addEndpointHandler
(e *v1alpha1.Endpoint)
cmd/dummy-controller/reconciler.go:64
↓ 1 callers
Method
addServiceHandler
(svc *v1alpha1.Service)
cmd/dummy-controller/reconciler.go:39
↓ 1 callers
Method
allocateLoadbalancerIP
(svc *v1alpha1.Service, ipAddr string)
cmd/vip-allocation-controller/reconciler.go:148
↓ 1 callers
Function
cleanupIptables
(ipt *iptables.IPTables, addrs []net.IP, mss int)
cmd/tunnel-controller/tunnelconfigurator.go:167
↓ 1 callers
Method
cleanupOrphanedIPAddresses
()
cmd/ipvs-controller/reconciler.go:313
↓ 1 callers
Method
cleanupOrphanedIpvsDestinations
(svc *v1alpha1.Service)
cmd/ipvs-controller/reconciler.go:361
↓ 1 callers
Method
cleanupOrphanedIpvsServices
()
cmd/ipvs-controller/reconciler.go:333
↓ 1 callers
Method
configure
(*HostPod)
cmd/tunnel-controller/tunnelconfigurator.go:28
↓ 1 callers
Method
deleteEndpointHandler
(e *v1alpha1.Endpoint)
cmd/ipvs-controller/reconciler.go:250
↓ 1 callers
Method
deleteEndpointHandler
(e *v1alpha1.Endpoint)
cmd/tunnel-controller/reconciler.go:113
↓ 1 callers
Method
deleteEndpointHandler
(prevE *v1alpha1.Endpoint)
cmd/dummy-controller/reconciler.go:72
↓ 1 callers
Method
deleteIpvsService
(svc *v1alpha1.Service)
cmd/ipvs-controller/reconciler.go:78
↓ 1 callers
Method
deleteServiceHandler
(prevSvc *v1alpha1.Service)
cmd/ipvs-controller/reconciler.go:155
↓ 1 callers
Method
deleteServiceHandler
(prevSvc *v1alpha1.Service)
cmd/dummy-controller/reconciler.go:47
↓ 1 callers
Function
endpointID
(d *ipvs.Destination)
cmd/ipvs-controller/metrics.go:229
↓ 1 callers
Function
ensureIptables
(ipNets []*net.IPNet)
cmd/ipvs-host-controller/main.go:39
↓ 1 callers
Method
executeHealthCheck
()
pkg/watcher/controller.go:215
↓ 1 callers
Method
get
(endpointID string)
pkg/apis/balanced/v1alpha1/service.go:181
↓ 1 callers
Method
getRuntimeClient
()
pkg/pidresolver/cri.go:31
↓ 1 callers
Function
inc
http://play.golang.org/p/m8TNTtygK0
cmd/vip-allocation-controller/reconciler.go:207
↓ 1 callers
Function
iptablesRunFunc
(ipNets []*net.IPNet)
cmd/ipvs-host-controller/main.go:53
↓ 1 callers
Function
ipvsServiceID
(s *v1alpha1.Service)
cmd/ipvs-controller/metrics.go:223
↓ 1 callers
Function
isValidDefaultScheduler
()
cmd/ipvs-controller/main.go:129
↓ 1 callers
Method
list
()
pkg/apis/balanced/v1alpha1/service.go:197
↓ 1 callers
Method
list
()
pkg/apis/balanced/v1alpha1/map_service_mgr.go:107
↓ 1 callers
Method
listServicesWithAddress
()
pkg/apis/balanced/v1alpha1/map_service_mgr.go:122
↓ 1 callers
Function
loadConfig
(path string, cfg interface{})
pkg/util/main.go:48
← previous
next →
101–200 of 408, ranked by callers