MCPcopy Create free account

hub / github.com/openelb/openelb / functions

Functions689 in github.com/openelb/openelb

⨍ Functions 689◇ Types & classes 188
↓ 1 callersFunctionSetupBgpPeerReconciler
(bgpServer *bgpd.Bgp, mgr ctrl.Manager)
pkg/speaker/bgp/bgppeer_controller.go:207
↓ 1 callersFunctionSetupServiceReconciler
(mgr ctrl.Manager)
pkg/controllers/lb/controller.go:263
↓ 1 callersMethodSetupWebhookWithManager
(mgr ctrl.Manager)
api/v1alpha2/eip_types.go:282
↓ 1 callersFunctionSetupWithManager
(mgr ctrl.Manager)
pkg/controllers/ipam/controller.go:34
↓ 1 callersMethodSetupWithManager
(mgr ctrl.Manager)
pkg/controllers/lb/controller.go:71
↓ 1 callersMethodSetupWithManager
(mgr ctrl.Manager)
pkg/speaker/bgp/bgpconf_controller.go:209
↓ 1 callersMethodSetupWithManager
(mgr ctrl.Manager)
pkg/speaker/bgp/bgppeer_controller.go:180
↓ 1 callersMethodStart
()
pkg/util/iprange/range.go:27
↓ 1 callersMethodString
()
pkg/nettool/iptables/interface.go:30
↓ 1 callersMethodToGoBgpGlobalConf
()
api/v1alpha2/bgpconf_types.go:98
↓ 1 callersMethodToGoBgpPeer
()
api/v1alpha2/bgppeer_types.go:208
↓ 1 callersMethodUnregisterIPRange
(string)
pkg/speaker/layer2/announcer.go:17
↓ 1 callersMethodUpdate
Update edits the BgpConf object in the kubernetes cluster.
pkg/server/internal/handler/bgpconf.go:22
↓ 1 callersMethodUpdate
Update edits the BgpPeer object in the kubernetes cluster.
pkg/server/internal/handler/bgppeer.go:23
↓ 1 callersFunctionUpdateBGPSessionMetrics
(peerIP, node string, state, updateTotal float64)
pkg/metrics/metrics.go:160
↓ 1 callersFunctionUpdateEipMetrics
(eipName string, total, used, svcCount float64)
pkg/metrics/metrics.go:118
↓ 1 callersFunctionUpdateGratuitousSentMetrics
(ip string)
pkg/metrics/metrics.go:136
↓ 1 callersFunctionUpdateRequestsReceivedMetrics
(ip string)
pkg/metrics/metrics.go:143
↓ 1 callersFunctionUpdateResponsesSentMetrics
(ip string)
pkg/metrics/metrics.go:140
↓ 1 callersMethodValidate
()
cmd/controller/app/options/options.go:22
↓ 1 callersMethodValidate
()
cmd/speaker/app/options/options.go:30
↓ 1 callersMethodValidate
()
cmd/apiserver/app/options/options.go:22
↓ 1 callersMethodVersion
Version returns the IP version for an IP, or 0 if the IP is not valid.
pkg/util/net/ip.go:56
↓ 1 callersFunctionWaitForBGPEstablished
(timeout time.Duration, bgpClient *GobgpClient, num int)
test/e2e/framework/bgp.go:322
↓ 1 callersFunctionWaitForRouterNum
(timeout time.Duration, ip string, bgpClient *GobgpClient, num int)
test/e2e/framework/bgp.go:308
↓ 1 callersFunctionWaitServicePresentFitWith
WaitServicePresentFitWith wait service present on cluster sync with fit func.
test/e2e/framework/service.go:14
↓ 1 callersMethodWrite
(p []byte)
pkg/speaker/layer2/log.go:35
↓ 1 callersMethodaddMultiRoutes
(ip string, prefix uint32, nexthops []string)
pkg/speaker/bgp/bgp/path.go:212
↓ 1 callersMethodassignGlobalpolicy
(ctx context.Context, bgpServer *server.BgpServer, a *config.ApplyPolicyConfig)
pkg/speaker/bgp/bgp/policy.go:51
↓ 1 callersMethodassignIPFromEip
(allocate *svcRecord, eip *networkv1alpha2.Eip)
pkg/controllers/ipam/ipam.go:68
↓ 1 callersMethodconstructRelease
(info info)
pkg/controllers/ipam/ipam.go:400
↓ 1 callersMethoddeleteMultiRoutes
(ip string, prefix uint32, nexthops []string)
pkg/speaker/bgp/bgp/path.go:225
↓ 1 callersFunctionfindOpenELBSpeaker
(c clientset.Interface, port int)
test/e2e/bgp/bgp.go:44
↓ 1 callersFunctionfromAPIPath
(path *api.Path)
pkg/speaker/bgp/bgp/path.go:63
↓ 1 callersFunctionfromAPIPath
(path *gobgpapi.Path)
test/e2e/framework/bgp.go:170
↓ 1 callersMethodgetAllocatedEIPInfo
(ctx context.Context, svcInfo string)
pkg/controllers/ipam/ipam.go:150
↓ 1 callersMethodgetBgpPeers
()
pkg/speaker/bgp/eventhandler.go:30
↓ 1 callersMethodgetDefaultBgpConf
()
pkg/speaker/bgp/eventhandler.go:20
↓ 1 callersMethodgetDefaultEIP
(ctx context.Context, name string)
pkg/controllers/ipam/ipam.go:330
↓ 1 callersMethodgetEIP
(ctx context.Context, ns string, svcip string, specifyEip string)
pkg/controllers/ipam/ipam.go:279
↓ 1 callersMethodgetEIPBasedOnIP
(ctx context.Context, ip string)
pkg/controllers/ipam/ipam.go:307
↓ 1 callersMethodgetForwardImage
()
pkg/controllers/lb/nodeproxy.go:161
↓ 1 callersMethodgetInterfaces
getInterfaces returns the interface name for the given VIP
pkg/speaker/vip/keepalived.go:146
↓ 1 callersMethodgetNodeNextHop
(node corev1.Node)
pkg/speaker/bgp/bgp/path.go:202
↓ 1 callersMethodgetNodeSha256Bytes
getNodeSha256Bytes returns the sha256 hash of the node names
pkg/speaker/vip/keepalived.go:156
↓ 1 callersFunctiongetPathIdentifier
(nexthop string)
pkg/speaker/bgp/bgp/path.go:21
↓ 1 callersFunctiongetPodInfoService
(ns, eipName string)
test/e2e/controller/ipam.go:77
↓ 1 callersMethodgetPolicyConfigMap
(ctx context.Context, bgpConf *v1alpha2.BgpConf)
pkg/speaker/bgp/bgpconf_controller.go:131
↓ 1 callersMethodgetProxyImage
()
pkg/controllers/lb/nodeproxy.go:175
↓ 1 callersMethodgetServiceNodes
(ctx context.Context, ip, svcs string)
pkg/speaker/manager.go:338
↓ 1 callersMethodgetSvcEIPUsed
todo: annotions
pkg/speaker/manager.go:329
↓ 1 callersMethodgratuitous
(ip, nodeIP net.IP)
pkg/speaker/layer2/arp_announer.go:184
↓ 1 callersMethodisNodeInList
isNodeInList returns true if the node is in the nodes list
pkg/speaker/vip/keepalived.go:171
↓ 1 callersFunctionisProxyResc
(obj metav1.Object)
pkg/controllers/lb/nodeproxy.go:24
↓ 1 callersMethodisSpeakerConfigUpdate
update speaker configurate protocol change or interface change
pkg/speaker/manager.go:181
↓ 1 callersFunctionisV4RangeValid
(start, end net.IP)
pkg/util/iprange/parse.go:117
↓ 1 callersFunctionisV6RangeValid
(start, end net.IP)
pkg/util/iprange/parse.go:121
↓ 1 callersMethodjoinMembers
()
pkg/speaker/layer2/memberlist.go:55
↓ 1 callersFunctionlog
(level string, format string, args ...interface{})
test/e2e/framework/log.go:14
↓ 1 callersFunctionlogWithLevel
(lvl string, keyvals []interface{})
pkg/speaker/layer2/log.go:51
↓ 1 callersFunctionneedRelease
(svc *v1.Service)
pkg/controllers/ipam/ipam.go:259
↓ 1 callersMethodneedUpdate
()
pkg/controllers/ipam/ipam.go:184
↓ 1 callersFunctionnewAPIPolicyFromTableStruct
(p *Policy)
pkg/speaker/bgp/bgp/table/table.go:259
↓ 1 callersFunctionnewAPIPrefixFromConfigStruct
(c Prefix)
pkg/speaker/bgp/bgp/config/util.go:75
↓ 1 callersFunctionnewARPAnnouncer
(ifi *net.Interface)
pkg/speaker/layer2/arp_announer.go:95
↓ 1 callersFunctionnewAnnouncer
(iface *net.Interface, v4 bool)
pkg/speaker/layer2/announcer.go:21
↓ 1 callersMethodnewForwardCtn
(name string)
pkg/controllers/lb/nodeproxy.go:235
↓ 1 callersFunctionnewKeepalivedLogPiper
newKeepalivedLogPiper creates a writer that parses and logs log messages written by Keepalived.
pkg/speaker/vip/keepalived.go:324
↓ 1 callersMethodnewProxyCtn
(svc *corev1.Service)
pkg/controllers/lb/nodeproxy.go:220
↓ 1 callersMethodnewProxyCtnEnvArgs
The only env variable is `PROXY_ARGS` `PROXY_ARGS` is 4-tuple parameters split by space: <SVC_IP POD_PORT SVC_PORT SVC_PROTO>
pkg/controllers/lb/nodeproxy.go:191
↓ 1 callersMethodnewProxyCtnPorts
(ports *[]corev1.ServicePort)
pkg/controllers/lb/nodeproxy.go:209
↓ 1 callersMethodnewProxyDe
(svc *corev1.Service)
pkg/controllers/lb/nodeproxy.go:65
↓ 1 callersMethodnewProxyDs
(svc *corev1.Service)
pkg/controllers/lb/nodeproxy.go:75
↓ 1 callersMethodnewProxyRescAnno
(svc *corev1.Service)
pkg/controllers/lb/nodeproxy.go:85
↓ 1 callersFunctionnodeAddrChange
When Node addr changed, system should update all OpenELB services
pkg/controllers/lb/eventhandler.go:54
↓ 1 callersFunctionnowStamp
()
test/e2e/framework/log.go:10
↓ 1 callersFunctionparseMaskLength
(prefix, mask string)
pkg/speaker/bgp/bgp/config/util.go:89
↓ 1 callersFunctionparseSubnetMask
(s string)
pkg/util/iprange/parse.go:96
↓ 1 callersMethodprocessRequest
()
pkg/speaker/layer2/arp_announer.go:269
↓ 1 callersFunctionrandStringRunes
(n int)
pkg/test/util.go:46
↓ 1 callersFunctionreadRequestBody
readRequestBody reads the request body and unmarshals it into the given object.
pkg/server/internal/lib/endpoints.go:19
↓ 1 callersMethodreconcileNP
(svc *corev1.Service)
pkg/controllers/lb/nodeproxy.go:429
↓ 1 callersMethodreconcileNPDelete
Called when OpenELB NodeProxy Service was deleted
pkg/controllers/lb/nodeproxy.go:391
↓ 1 callersMethodreconcileNPNormal
Main procedure for OpenELB NodeProxy
pkg/controllers/lb/nodeproxy.go:247
↓ 1 callersMethodreconfigPeers
()
pkg/speaker/bgp/bgpconf_controller.go:168
↓ 1 callersMethodregisterAnnouncer
(eipName string, netif *net.Interface, r iprange.Range)
pkg/speaker/layer2/memberlist.go:169
↓ 1 callersMethodreleaseIPFromEip
look up by key in IPAMRequest
pkg/controllers/ipam/ipam.go:124
↓ 1 callersMethodreloadLayer2Speaker
(req ctrl.Request)
pkg/speaker/eip_controller.go:81
↓ 1 callersMethodremoveEip
(ctx context.Context, e *networkv1alpha2.Eip)
pkg/controllers/ipam/controller.go:156
↓ 1 callersMethodresolveIP
(nodeIP net.IP)
pkg/speaker/layer2/arp_announer.go:147
↓ 1 callersMethodrun
(ctx context.Context)
pkg/speaker/bgp/bgpconf_controller.go:344
↓ 1 callersMethodrun
(ctx context.Context)
pkg/speaker/bgp/bgppeer_controller.go:166
↓ 1 callersMethodsetMac
(ip string, mac net.HardwareAddr)
pkg/speaker/layer2/arp_announer.go:84
↓ 1 callersFunctionsubexps
(line []byte)
pkg/speaker/layer2/log.go:18
↓ 1 callersFunctionsvcName
(rescName, svcNs string)
pkg/controllers/lb/nodeproxy.go:33
↓ 1 callersMethodsyncEip
(ctx context.Context, e *networkv1alpha2.Eip)
pkg/controllers/ipam/controller.go:122
↓ 1 callersMethodtoConfig
()
pkg/speaker/bgp/bgp/table/table.go:72
↓ 1 callersFunctiontoStatementApi
(s *config.Statement)
pkg/speaker/bgp/bgp/table/table.go:87
↓ 1 callersMethodunregisterAllAnnouncers
()
pkg/speaker/layer2/memberlist.go:208
↓ 1 callersMethodunregisterAnnouncer
(eipName, netifName string)
pkg/speaker/layer2/memberlist.go:190
← previousnext →301–400 of 689, ranked by callers