- Sort Score
- Result 10 results
- Languages All
Results 1 - 8 of 8 for OnServiceCIDRsChanged (0.31 sec)
-
pkg/proxy/metaproxier/meta_proxier.go
proxier.ipv6Proxier.OnNodeSynced() } // OnServiceCIDRsChanged is called whenever a change is observed // in any of the ServiceCIDRs, and provides complete list of service cidrs. func (proxier *metaProxier) OnServiceCIDRsChanged(cidrs []string) { proxier.ipv4Proxier.OnServiceCIDRsChanged(cidrs) proxier.ipv6Proxier.OnServiceCIDRsChanged(cidrs)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Jan 21 14:28:37 UTC 2024 - 5.9K bytes - Viewed (0) -
pkg/proxy/config/config.go
// notifications about ServiceCIDR object changes. type ServiceCIDRHandler interface { // OnServiceCIDRsChanged is called whenever a change is observed // in any of the ServiceCIDRs, and provides complete list of service cidrs. OnServiceCIDRsChanged(cidrs []string) } // ServiceCIDRConfig tracks a set of service configurations. type ServiceCIDRConfig struct {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 22 05:08:41 UTC 2024 - 15.1K bytes - Viewed (0) -
pkg/proxy/kubemark/hollow_proxy.go
func (*FakeProxier) OnEndpointSliceDelete(slice *discoveryv1.EndpointSlice) {} func (*FakeProxier) OnEndpointSlicesSynced() {} func (*FakeProxier) OnServiceCIDRsChanged(_ []string) {} func NewHollowProxy( nodeName string, client clientset.Interface, eventClient v1core.EventsGetter, broadcaster events.EventBroadcaster,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 22 05:08:41 UTC 2024 - 2.9K bytes - Viewed (0) -
pkg/proxy/nftables/proxier.go
// called and the state is fully propagated to local cache. func (proxier *Proxier) OnNodeSynced() { } // OnServiceCIDRsChanged is called whenever a change is observed // in any of the ServiceCIDRs, and provides complete list of service cidrs. func (proxier *Proxier) OnServiceCIDRsChanged(cidrs []string) { proxier.mu.Lock() defer proxier.mu.Unlock() cidrsForProxier := make([]string, 0)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jun 08 13:48:54 UTC 2024 - 55.5K bytes - Viewed (0) -
pkg/proxy/winkernel/proxier.go
proxier.mu.Unlock() // Sync unconditionally - this is called once per lifetime. proxier.syncProxyRules() } // OnServiceCIDRsChanged is called whenever a change is observed // in any of the ServiceCIDRs, and provides complete list of service cidrs. func (proxier *Proxier) OnServiceCIDRsChanged(_ []string) {} func (proxier *Proxier) cleanupAllPolicies() { for svcName, svc := range proxier.svcPortMap {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 13:25:06 UTC 2024 - 59K bytes - Viewed (0) -
pkg/proxy/iptables/proxier.go
// called and the state is fully propagated to local cache. func (proxier *Proxier) OnNodeSynced() { } // OnServiceCIDRsChanged is called whenever a change is observed // in any of the ServiceCIDRs, and provides complete list of service cidrs. func (proxier *Proxier) OnServiceCIDRsChanged(_ []string) {} // portProtoHash takes the ServicePortName and protocol for a service
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 21 14:39:54 UTC 2024 - 65.1K bytes - Viewed (0) -
pkg/proxy/nftables/proxier_test.go
func TestProxier_OnServiceCIDRsChanged(t *testing.T) { var proxier *Proxier proxier = &Proxier{ipFamily: v1.IPv4Protocol} proxier.OnServiceCIDRsChanged([]string{"172.30.0.0/16", "fd00:10:96::/112"}) assert.Equal(t, proxier.serviceCIDRs, "172.30.0.0/16") proxier.OnServiceCIDRsChanged([]string{"172.30.0.0/16", "172.50.0.0/16", "fd00:10:96::/112", "fd00:172:30::/112"}) assert.Equal(t, proxier.serviceCIDRs, "172.30.0.0/16,172.50.0.0/16")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Apr 27 01:31:57 UTC 2024 - 173.5K bytes - Viewed (0) -
pkg/proxy/ipvs/proxier.go
// called and the state is fully propagated to local cache. func (proxier *Proxier) OnNodeSynced() { } // OnServiceCIDRsChanged is called whenever a change is observed // in any of the ServiceCIDRs, and provides complete list of service cidrs. func (proxier *Proxier) OnServiceCIDRsChanged(_ []string) {} // This is where all of the ipvs calls happen. func (proxier *Proxier) syncProxyRules() { proxier.mu.Lock()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Apr 28 15:51:23 UTC 2024 - 77.7K bytes - Viewed (0)