- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 60 for netutils (0.14 sec)
-
pkg/proxy/ipvs/util/ipvs_test.go
Address: netutils.ParseIPSloppy("1.2.3.4"), Port: 3080, }, rsB: &RealServer{ Address: netutils.ParseIPSloppy("1.2.3.4"), Port: 3080, }, equal: true, reason: "All fields equal", }, { rsA: &RealServer{ Address: netutils.ParseIPSloppy("2012::beef"), Port: 3080, }, rsB: &RealServer{ Address: netutils.ParseIPSloppy("2012::beef"),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Dec 19 01:20:51 UTC 2023 - 8K bytes - Viewed (0) -
pkg/registry/core/service/ipallocator/storage/storage_test.go
"k8s.io/kubernetes/pkg/registry/registrytest" netutils "k8s.io/utils/net" ) func newStorage(t *testing.T) (*etcd3testing.EtcdTestServer, ipallocator.Interface, allocator.Interface, storage.Interface, factory.DestroyFunc) { etcdStorage, server := registrytest.NewEtcdStorage(t, "") _, cidr, err := netutils.ParseCIDRSloppy("192.168.1.0/24") if err != nil { t.Fatal(err) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Aug 24 09:23:05 UTC 2023 - 5.9K bytes - Viewed (0) -
pkg/proxy/util/utils.go
func convertToV1IPFamily(ipFamily netutils.IPFamily) v1.IPFamily { switch ipFamily { case netutils.IPv4: return v1.IPv4Protocol case netutils.IPv6: return v1.IPv6Protocol } return v1.IPFamilyUnknown } // OtherIPFamily returns the other ip family func OtherIPFamily(ipFamily v1.IPFamily) v1.IPFamily { if ipFamily == v1.IPv6Protocol { return v1.IPv4Protocol } return v1.IPv6Protocol }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 20 11:57:43 UTC 2024 - 7.4K bytes - Viewed (0) -
pkg/proxy/ipvs/util/testing/fake_test.go
// Add a virtual server vs := &utilipvs.VirtualServer{ Address: netutils.ParseIPSloppy("10.20.30.40"), Port: uint16(80), Protocol: string("TCP"), } rss := []*utilipvs.RealServer{ {Address: netutils.ParseIPSloppy("172.16.2.1"), Port: 8080, Weight: 1}, {Address: netutils.ParseIPSloppy("172.16.2.2"), Port: 8080, Weight: 2}, {Address: netutils.ParseIPSloppy("172.16.2.3"), Port: 8080, Weight: 3}, }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Dec 19 01:20:51 UTC 2023 - 5.6K bytes - Viewed (0) -
pkg/util/node/node_test.go
}, expectIPs: []net.IP{netutils.ParseIPSloppy("1.2.3.4")}, }, { name: "IPv4-only, external-first", addresses: []v1.NodeAddress{ {Type: v1.NodeExternalIP, Address: "4.3.2.1"}, {Type: v1.NodeExternalIP, Address: "4.3.2.2"}, {Type: v1.NodeInternalIP, Address: "1.2.3.4"}, }, expectIPs: []net.IP{netutils.ParseIPSloppy("1.2.3.4")}, }, {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jan 27 23:24:38 UTC 2023 - 7.1K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/config_selfclient_test.go
See the License for the specific language governing permissions and limitations under the License. */ package server import ( "net" "testing" netutils "k8s.io/utils/net" ) func TestLoopbackHostPortIPv4(t *testing.T) { _, ipv6only, err := isIPv6LoopbackSupported() if err != nil { t.Fatalf("fail to enumerate network interface, %s", err) } if ipv6only {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Aug 20 08:42:09 UTC 2021 - 2.7K bytes - Viewed (0) -
pkg/kubelet/certificate/kubelet_test.go
{Type: v1.NodeInternalIP, Address: "3.3.3.3"}, }, wantDNSNames: []string{"hostname-1", "hostname-2", "hostname-3"}, wantIPs: []net.IP{netutils.ParseIPSloppy("1.1.1.1"), netutils.ParseIPSloppy("2.2.2.2"), netutils.ParseIPSloppy("3.3.3.3")}, }, { name: "handle IP and DNS hostnames", addresses: []v1.NodeAddress{ {Type: v1.NodeHostName, Address: "hostname"},
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 06 03:07:40 UTC 2024 - 7.4K bytes - Viewed (0) -
cmd/cloud-controller-manager/nodeipamcontroller.go
_, serviceCIDR, err = netutils.ParseCIDRSloppy(nodeIPAMConfig.ServiceCIDR) if err != nil { klog.ErrorS(err, "Unsuccessful parsing of service CIDR", "CIDR", nodeIPAMConfig.ServiceCIDR) } } if len(strings.TrimSpace(nodeIPAMConfig.SecondaryServiceCIDR)) != 0 { _, secondaryServiceCIDR, err = netutils.ParseCIDRSloppy(nodeIPAMConfig.SecondaryServiceCIDR) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Oct 14 19:06:22 UTC 2023 - 8.9K bytes - Viewed (0) -
pkg/kubeapiserver/options/serving.go
import ( genericoptions "k8s.io/apiserver/pkg/server/options" netutils "k8s.io/utils/net" ) // NewSecureServingOptions gives default values for the kube-apiserver which are not the options wanted by // "normal" API servers running on the platform func NewSecureServingOptions() *genericoptions.SecureServingOptionsWithLoopback { o := genericoptions.SecureServingOptions{ BindAddress: netutils.ParseIPSloppy("0.0.0.0"), BindPort: 6443,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Aug 20 08:42:09 UTC 2021 - 1.3K bytes - Viewed (0) -
pkg/kubeapiserver/options/options.go
"net" utilnet "k8s.io/apimachinery/pkg/util/net" netutils "k8s.io/utils/net" ) // DefaultServiceNodePortRange is the default port range for NodePort services. var DefaultServiceNodePortRange = utilnet.PortRange{Base: 30000, Size: 2768} // DefaultServiceIPCIDR is a CIDR notation of IP range from which to allocate service cluster IPs var DefaultServiceIPCIDR = net.IPNet{IP: netutils.ParseIPSloppy("10.0.0.0"), Mask: net.CIDRMask(24, 32)}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Aug 20 08:42:09 UTC 2021 - 1.1K bytes - Viewed (0)