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
↓ 1 callers
Function
parseCidrs
(cidrsStr string)
cmd/ipvs-controller/main.go:35
↓ 1 callers
Function
parseCidrs
(cidrsStr string)
cmd/ipvs-host-controller/main.go:26
↓ 1 callers
Function
pidResolver
(config pidresolver.ConfigResolver, resolverType pidresolver.ResolverType)
cmd/tunnel-controller/pidresolver.go:11
↓ 1 callers
Method
processNextItem
()
pkg/watcher/controller.go:171
↓ 1 callers
Method
randomFreeIP
()
cmd/vip-allocation-controller/reconciler.go:239
↓ 1 callers
Function
realMain
(f MainFunc, cfg interface{})
pkg/util/main.go:56
↓ 1 callers
Function
realMain
()
cmd/ipvs-host-controller/main.go:69
↓ 1 callers
Method
remove
(e *Endpoint)
pkg/apis/balanced/v1alpha1/service.go:280
↓ 1 callers
Function
requestedIPs
requestedIPs returns a slice of valid IP addresses specified by the user through the use of an annotation
cmd/vip-allocation-controller/reconciler.go:71
↓ 1 callers
Function
setNetworkNamespaceIgnoreError
(handle netns.NsHandle)
cmd/tunnel-controller/tunnelconfigurator.go:268
↓ 1 callers
Method
setupSignalHandler
()
pkg/watcher/controller.go:84
↓ 1 callers
Method
spewServiceManager
spewServiceManager: used for debugging state of the Service Manager
pkg/watcher/controller.go:99
↓ 1 callers
Method
syncTunnelEndpoints
()
cmd/tunnel-controller/reconciler.go:163
↓ 1 callers
Function
sysctlByComponents
sysctlByComponents sets the sysctl specified by the individual components to the value specified and returns its original value as a string.
pkg/util/sysctl.go:30
↓ 1 callers
Function
tunnelConfigurator
(resolverType pidresolver.ResolverType, eventRecorder record.EventRecorder, pidResolver pidresolver.PIDResolve
cmd/tunnel-controller/main.go:33
↓ 1 callers
Function
tunnelMTU
(mainIfaceMTU int)
cmd/tunnel-controller/tunnelconfigurator.go:163
↓ 1 callers
Method
update
(e *Endpoint)
pkg/apis/balanced/v1alpha1/service.go:249
↓ 1 callers
Method
update
(svc *Service)
pkg/apis/balanced/v1alpha1/map_service_mgr.go:170
↓ 1 callers
Method
updateEndpointHandler
(prevE *v1alpha1.Endpoint, e *v1alpha1.Endpoint)
cmd/dummy-controller/reconciler.go:68
↓ 1 callers
Method
updateHostPods
()
cmd/tunnel-controller/reconciler.go:139
↓ 1 callers
Method
updateServiceHandler
(prevSvc *v1alpha1.Service, svc *v1alpha1.Service)
cmd/dummy-controller/reconciler.go:43
↓ 1 callers
Method
upsertIpvsService
(svc *v1alpha1.Service)
cmd/ipvs-controller/reconciler.go:48
↓ 1 callers
Method
withRuntimeClient
(f func(pb.RuntimeServiceClient) error)
pkg/pidresolver/cri.go:52
Method
Add
Add mocks base method
mocks/mock_service_mgr.go:37
Method
Add
Add indicates an expected call of Add
mocks/mock_service_mgr.go:48
Method
ChecksHandler
(w http.ResponseWriter, req *http.Request)
pkg/health/publisher.go:28
Method
CleanupOrphanedIpvs
CleanupOrphanedIpvs : cleans up IPVS services and destinations this controller does not track, but still belongs in its CIDR
cmd/ipvs-controller/reconciler.go:290
Function
EnsureIptables
(ipt *iptables.IPTables, ipNets []*net.IPNet)
pkg/util/ipvs/ipvs.go:76
Function
EnsureSysctlSettings
()
pkg/util/ipvs/ipvs.go:57
Method
Equals
(endpoint *Endpoint)
pkg/apis/balanced/v1alpha1/endpoint.go:144
Method
Exists
Exists mocks base method
mocks/mock_service_mgr.go:54
Method
Exists
Exists indicates an expected call of Exists
mocks/mock_service_mgr.go:61
Method
Export
()
pkg/metrics/exporter.go:4
Method
Export
()
cmd/vip-allocation-controller/metrics.go:40
Method
Export
Export : exports metrics every cycle
cmd/ipvs-controller/metrics.go:237
Method
Export
()
cmd/tunnel-controller/metrics.go:20
Method
Export
()
cmd/dummy-controller/metrics.go:20
Method
Get
Get mocks base method
mocks/mock_service_mgr.go:66
Method
Get
Get indicates an expected call of Get
mocks/mock_service_mgr.go:74
Function
GetFunctionName
(i interface{})
pkg/util/main.go:138
Method
GetPID
(containerID string)
pkg/pidresolver/cri.go:64
Method
GetPID
(containerID string)
pkg/pidresolver/containerd.go:22
Method
GetPID
(containerID string)
pkg/pidresolver/docker.go:35
Method
GetPID
(containerID string)
pkg/pidresolver/dynamic.go:31
Method
GetPID
(containerID string)
pkg/pidresolver/dummy.go:16
Method
HealthHandler
(w http.ResponseWriter, req *http.Request)
pkg/health/publisher.go:18
Method
Healthy
()
pkg/health/check.go:41
Method
Healthy
()
pkg/health/manager.go:31
Method
ID
()
pkg/util/ipvs/ipvs.go:37
Method
ID
()
pkg/util/ipvs/ipvs.go:48
Method
Infof
(format string, args ...interface{})
pkg/util/named_logger.go:19
Method
List
List mocks base method
mocks/mock_service_mgr.go:79
Method
List
List indicates an expected call of List
mocks/mock_service_mgr.go:86
Method
ListServicesWithAddress
ListServicesWithAddress mocks base method
mocks/mock_service_mgr.go:91
Method
ListServicesWithAddress
ListServicesWithAddress indicates an expected call of ListServicesWithAddress
mocks/mock_service_mgr.go:98
Function
LoadIpvsSchedulerKernelModulesIfExist
()
pkg/util/ipvs/ipvs.go:122
Function
NewIpvsDestination
(dst *ipvs.Destination)
pkg/util/ipvs/ipvs.go:53
Function
NewIpvsService
(svc *ipvs.Service)
pkg/util/ipvs/ipvs.go:33
Method
OnChangeEndpointHandler
(prevE *v1alpha1.Endpoint, e *v1alpha1.Endpoint)
cmd/ipvs-controller/reconciler.go:173
Method
OnChangeEndpointHandler
(prevE *v1alpha1.Endpoint, e *v1alpha1.Endpoint)
cmd/tunnel-controller/reconciler.go:46
Method
OnChangeEndpointHandler
(prevE *v1alpha1.Endpoint, e *v1alpha1.Endpoint)
cmd/dummy-controller/reconciler.go:51
Method
OnChangeServiceHandler
(prevSvc *v1alpha1.Service, svc *v1alpha1.Service)
cmd/ipvs-controller/reconciler.go:120
Method
OnChangeServiceHandler
(prevSvc *v1alpha1.Service, svc *v1alpha1.Service)
cmd/dummy-controller/reconciler.go:25
Method
PortName
()
pkg/apis/balanced/v1alpha1/endpoint.go:98
Method
PostSyncHandler
()
cmd/dummy-controller/reconciler.go:76
Method
RefreshMetrics
()
cmd/vip-allocation-controller/reconciler.go:216
Method
Remove
Remove mocks base method
mocks/mock_service_mgr.go:103
Method
Remove
Remove indicates an expected call of Remove
mocks/mock_service_mgr.go:114
Method
RemoveByID
RemoveByID mocks base method
mocks/mock_service_mgr.go:120
Method
RemoveByID
RemoveByID indicates an expected call of RemoveByID
mocks/mock_service_mgr.go:131
Method
RemoveByID
(svcID string, handlers ...ServiceOnChangeHandler)
pkg/apis/balanced/v1alpha1/service_mgr.go:16
Method
RemoveExistingServicesNoLongerCurrent
RemoveExistingServicesNoLongerCurrent mocks base method
mocks/mock_service_mgr.go:137
Method
RemoveExistingServicesNoLongerCurrent
RemoveExistingServicesNoLongerCurrent indicates an expected call of RemoveExistingServicesNoLongerCurrent
mocks/mock_service_mgr.go:148
Method
RemoveServicesRecursively
RemoveServicesRecursively mocks base method
mocks/mock_service_mgr.go:154
Method
RemoveServicesRecursively
RemoveServicesRecursively indicates an expected call of RemoveServicesRecursively
mocks/mock_service_mgr.go:161
Method
ResolveByKubeMetaNamespaceKey
ResolveByKubeMetaNamespaceKey mocks base method
mocks/mock_service_mgr.go:166
Method
ResolveByKubeMetaNamespaceKey
ResolveByKubeMetaNamespaceKey indicates an expected call of ResolveByKubeMetaNamespaceKey
mocks/mock_service_mgr.go:174
Method
ResolverType
()
pkg/pidresolver/cri.go:92
Method
ResolverType
()
pkg/pidresolver/containerd.go:27
Method
ResolverType
()
pkg/pidresolver/docker.go:73
Method
ResolverType
()
pkg/pidresolver/dynamic.go:42
Method
ResolverType
()
pkg/pidresolver/dummy.go:20
Method
Run
(stopc <-chan struct{})
pkg/metrics/publisher.go:39
Method
Run
(stopc <-chan struct{})
pkg/health/publisher.go:33
Method
SetupTest
()
pkg/apis/balanced/v1alpha1/map_service_mgr_test.go:30
Method
SetupTest
()
pkg/apis/balanced/v1alpha1/service_test.go:29
Method
SetupTest
()
pkg/apis/balanced/v1alpha1/endpoint_test.go:23
Method
SetupTest
()
pkg/watcher/controller_test.go:35
Method
SetupTest
()
cmd/vip-allocation-controller/reconciler_test.go:36
Method
SetupTest
()
cmd/ipvs-controller/reconciler_test.go:34
Method
SetupTest
()
cmd/tunnel-controller/reconciler_test.go:20
Method
SetupTest
()
cmd/tunnel-controller/hostpod_test.go:24
Method
SetupTest
()
cmd/tunnel-controller/cache_test.go:18
Method
Sync
()
cmd/tunnel-controller/reconciler.go:130
Method
TestAcquireFromSpecifiedIPs
()
cmd/vip-allocation-controller/reconciler_test.go:54
Method
TestAdd
()
pkg/apis/balanced/v1alpha1/map_service_mgr_test.go:328
Method
TestAdd
()
pkg/apis/balanced/v1alpha1/service_test.go:448
Method
TestAddKeyToWorkQueue
()
pkg/watcher/controller_test.go:426
Method
TestAddress
()
pkg/apis/balanced/v1alpha1/service_test.go:250
Method
TestAddress
()
pkg/apis/balanced/v1alpha1/endpoint_test.go:231
← previous
next →
201–300 of 408, ranked by callers