- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 46 for IPv4Protocol (0.47 sec)
-
cmd/kube-proxy/app/server.go
func detectNodeIPs(ctx context.Context, rawNodeIPs []net.IP, bindAddress string) (v1.IPFamily, map[v1.IPFamily]net.IP) { logger := klog.FromContext(ctx) primaryFamily := v1.IPv4Protocol nodeIPs := map[v1.IPFamily]net.IP{ v1.IPv4Protocol: net.IPv4(127, 0, 0, 1), v1.IPv6Protocol: net.IPv6loopback, } if len(rawNodeIPs) > 0 { if !netutils.IsIPv4(rawNodeIPs[0]) { primaryFamily = v1.IPv6Protocol
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Apr 26 13:27:41 UTC 2024 - 46.8K bytes - Viewed (0) -
pkg/registry/core/service/storage/storage.go
} // otherFamily returns the non-selected IPFamily. This assumes the input is // valid. func otherFamily(fam api.IPFamily) api.IPFamily { if fam == api.IPv4Protocol { return api.IPv6Protocol } return api.IPv4Protocol } var ( _ rest.ShortNamesProvider = &REST{} _ rest.CategoriesProvider = &REST{} )
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 11 13:09:33 UTC 2024 - 22.3K bytes - Viewed (0) -
pkg/registry/core/service/ipallocator/bitmap_test.go
free int released string outOfRange []string alreadyAllocated string }{ { name: "IPv4", cidr: "192.168.1.0/24", family: api.IPv4Protocol, free: 254, released: "192.168.1.5", outOfRange: []string{ "192.168.0.1", // not in 192.168.1.0/24 "192.168.1.0", // reserved (base address) "192.168.1.255", // reserved (broadcast address)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jan 25 20:32:40 UTC 2023 - 21.1K bytes - Viewed (0) -
pkg/registry/core/service/ipallocator/controller/repairip.go
} } } r.muTree.Lock() defer r.muTree.Unlock() r.tree = tree return nil } func newIPAddress(name string, svc *v1.Service) *networkingv1alpha1.IPAddress { family := string(v1.IPv4Protocol) if netutils.IsIPv6String(name) { family = string(v1.IPv6Protocol) } return &networkingv1alpha1.IPAddress{ ObjectMeta: metav1.ObjectMeta{ Name: name, Labels: map[string]string{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 24.7K bytes - Viewed (0) -
pkg/proxy/conntrack/cleanup_test.go
// provide our own implementation of that interface, or else use a // proxy.ServiceChangeTracker to construct them and fill in the map for us. sct := proxy.NewServiceChangeTracker(nil, v1.IPv4Protocol, nil, nil) svc := &v1.Service{ ObjectMeta: metav1.ObjectMeta{ Name: "cleanup-test", Namespace: "test", }, Spec: v1.ServiceSpec{ ClusterIP: testClusterIP,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jan 15 18:09:05 UTC 2024 - 7.6K bytes - Viewed (0) -
pkg/apis/core/validation/validation_test.go
s.Spec.IPFamilies = []core.IPFamily{core.IPv4Protocol, core.IPv6Protocol} }, numErrs: 0, }, { name: "invalid, service with 2+ ipFamilies", tweakSvc: func(s *core.Service) { s.Spec.IPFamilyPolicy = &requireDualStack s.Spec.IPFamilies = []core.IPFamily{core.IPv4Protocol, core.IPv6Protocol, core.IPv4Protocol} }, numErrs: 1, }, {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 29 22:40:29 UTC 2024 - 857.7K bytes - Viewed (0) -
pkg/proxy/nftables/proxier.go
initOnly bool, ) (proxy.Provider, error) { // Create an ipv4 instance of the single-stack proxier ipv4Proxier, err := NewProxier(ctx, v1.IPv4Protocol, syncPeriod, minSyncPeriod, masqueradeAll, masqueradeBit, localDetectors[v1.IPv4Protocol], hostname, nodeIPs[v1.IPv4Protocol], recorder, healthzServer, nodePortAddresses, initOnly) if err != nil { return nil, fmt.Errorf("unable to create ipv4 proxier: %v", err) }
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/apis/discovery/types.go
} // AddressType represents the type of address referred to by an endpoint. type AddressType string const ( // AddressTypeIPv4 represents an IPv4 Address. AddressTypeIPv4 = AddressType(api.IPv4Protocol) // AddressTypeIPv6 represents an IPv6 Address. AddressTypeIPv6 = AddressType(api.IPv6Protocol) // AddressTypeFQDN represents a FQDN. AddressTypeFQDN = AddressType("FQDN") )
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 16 21:38:06 UTC 2023 - 7.5K bytes - Viewed (0) -
pkg/registry/core/service/ipallocator/ipallocator.go
} // TODO: use the utils/net function once is available size := hostsPerNetwork(cidr) var family api.IPFamily if netutils.IsIPv6CIDR(cidr) { family = api.IPv6Protocol } else { family = api.IPv4Protocol } // Caching the first, offset and last addresses allows to optimize // the search loops by using the netip.Addr iterator instead // of having to do conversions with IP addresses.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 31 21:05:04 UTC 2023 - 17K bytes - Viewed (0) -
pkg/controller/endpoint/endpoints_controller_test.go
var oldTriggerTimeString = triggerTime.Add(-time.Hour).Format(time.RFC3339Nano) var ipv4only = []v1.IPFamily{v1.IPv4Protocol} var ipv6only = []v1.IPFamily{v1.IPv6Protocol} var ipv4ipv6 = []v1.IPFamily{v1.IPv4Protocol, v1.IPv6Protocol} var ipv6ipv4 = []v1.IPFamily{v1.IPv6Protocol, v1.IPv4Protocol} func testPod(namespace string, id int, nPorts int, isReady bool, ipFamilies []v1.IPFamily) *v1.Pod { p := &v1.Pod{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 26 06:51:56 UTC 2024 - 87.7K bytes - Viewed (0)