- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 56 for parseAddrs (0.13 sec)
-
pkg/controller/servicecidrs/servicecidrs_controller.go
managedBy, ok := ip.Labels[networkingapiv1alpha1.LabelManagedBy] if !ok || managedBy != ipallocator.ControllerName { return []string{} } address, err := netip.ParseAddr(ip.Name) if err != nil { // This should not happen, the IPAddress object validates // the name is a valid IPAddress return []string{} } c.muTree.Lock() defer c.muTree.Unlock()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 18K bytes - Viewed (0) -
pkg/test/framework/components/istio/ingress.go
hosts, ports := c.AddressesForPort(discoveryPort) var addrs []netip.AddrPort if hosts == nil { return []netip.AddrPort{{}} } for i, host := range hosts { ip, err := netip.ParseAddr(host) if err != nil { return []netip.AddrPort{} } addrs = append(addrs, netip.AddrPortFrom(ip, uint16(ports[i]))) } return addrs }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Feb 29 17:13:34 UTC 2024 - 8K bytes - Viewed (0) -
cmd/kubeadm/app/apis/kubeadm/validation/validation.go
// ValidateIPNetFromString validates network portion of ip address func ValidateIPNetFromString(subnetStr string, minAddrs int64, fldPath *field.Path) field.ErrorList { allErrs := field.ErrorList{} subnets, err := netutils.ParseCIDRs(strings.Split(subnetStr, ",")) if err != nil { allErrs = append(allErrs, field.Invalid(fldPath, subnetStr, "couldn't parse subnet")) return allErrs } switch { // if DualStack only 2 CIDRs allowed
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 01 16:01:49 UTC 2024 - 33.4K bytes - Viewed (0) -
pkg/config/security/security.go
if strings.Contains(v, "/") { if _, err := netip.ParsePrefix(v); err != nil { errs = multierror.Append(errs, fmt.Errorf("bad CIDR range (%s): %v", v, err)) } } else { if _, err := netip.ParseAddr(v); err != nil { errs = multierror.Append(errs, fmt.Errorf("bad IP address (%s)", v)) } } } return errs.ErrorOrNil() } func ValidatePorts(ports []string) error {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 07 04:43:34 UTC 2024 - 9.4K bytes - Viewed (0) -
src/net/netip/netip_pkg_test.go
errstr: "zone must be a non-empty string", }, { ip: "%eth0", errstr: "missing IPv6 address", }, } for _, test := range tests { t.Run(test.ip, func(t *testing.T) { _, err := ParseAddr(test.ip) if err == nil { t.Fatal("no error") } if _, ok := err.(parseAddrError); !ok { t.Errorf("error type is %T, want parseIPError", err) } if test.errstr == "" {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Feb 02 15:37:19 UTC 2023 - 9K bytes - Viewed (0) -
pilot/cmd/pilot-agent/app/cmd.go
proxyArgs.Type = model.NodeType(args[0]) if !model.IsApplicationNodeType(proxyArgs.Type) { return fmt.Errorf("Invalid proxy Type: " + string(proxyArgs.Type)) } } podIP, _ := netip.ParseAddr(options.InstanceIPVar.Get()) // protobuf encoding of IP_ADDRESS type if podIP.IsValid() { // The first one must be the pod ip as we pick the first ip as pod ip in istiod. proxyArgs.IPAddresses = []string{podIP.String()}
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 16 22:12:28 UTC 2024 - 11.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/cel/library/ip.go
// so that we can share the common logic of rejecting IP addresses // that contain zones or are IPv4-mapped IPv6 addresses. func parseIPAddr(raw string) (netip.Addr, error) { addr, err := netip.ParseAddr(raw) if err != nil { return netip.Addr{}, fmt.Errorf("IP Address %q parse error during conversion from string: %v", raw, err) } if addr.Zone() != "" {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Dec 15 11:02:34 UTC 2023 - 9.8K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/ambient/ambientindex_serviceentry_test.go
// entry s.assertWorkloads(t, s.addrXdsName("240.240.23.45"), workloadapi.WorkloadStatus_HEALTHY, "pod1", "name1") } func parseIP(ip string) []byte { addr, err := netip.ParseAddr(ip) if err != nil { return nil } return addr.AsSlice()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Mar 27 03:01:04 UTC 2024 - 12.9K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/ambient/waypoints.go
ServiceAccounts: slices.Sort(serviceAccounts), } } func getGatewayAddrs(gw *v1beta1.Gateway) []netip.Addr { // Currently, we only look at one address. Probably this should be made more robust ip, err := netip.ParseAddr(gw.Status.Addresses[0].Value) if err == nil { return []netip.Addr{ip} } log.Errorf("Unable to parse IP address in status of %v/%v/%v", gvk.KubernetesGateway, gw.Namespace, gw.Name) return nil
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 12 18:02:28 UTC 2024 - 11.1K bytes - Viewed (0) -
src/net/cgo_unix.go
// Local database various depends on implementation const ( nameinfoLen = 64 maxNameinfoLen = 4096 ) func cgoLookupPTR(ctx context.Context, addr string) (names []string, err error) { ip, err := netip.ParseAddr(addr) if err != nil { return nil, &DNSError{Err: "invalid address", Name: addr} } sa, salen := cgoSockaddr(IP(ip.AsSlice()), ip.Zone()) if sa == nil {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Sun Apr 14 18:23:45 UTC 2024 - 11.4K bytes - Viewed (0)