- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 129 for netutils (0.28 sec)
-
pkg/proxy/winkernel/proxier_test.go
"k8s.io/apimachinery/pkg/types" "k8s.io/apimachinery/pkg/util/intstr" "k8s.io/kubernetes/pkg/proxy" "k8s.io/kubernetes/pkg/proxy/healthcheck" fakehcn "k8s.io/kubernetes/pkg/proxy/winkernel/testing" netutils "k8s.io/utils/net" "k8s.io/utils/ptr" ) const ( testHostName = "test-hostname" testNetwork = "TestNetwork" ipAddress = "10.0.0.1" prefixLen = 24
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Jan 28 14:30:51 UTC 2024 - 30.2K bytes - Viewed (0) -
pkg/kubelet/certificate/kubelet.go
continue } switch address.Type { case v1.NodeHostName: if ip := netutils.ParseIPSloppy(address.Address); ip != nil { seenIPs[address.Address] = true } else { seenDNSNames[address.Address] = true } case v1.NodeExternalIP, v1.NodeInternalIP: if ip := netutils.ParseIPSloppy(address.Address); ip != nil { seenIPs[address.Address] = true }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 06 03:07:16 UTC 2024 - 10.3K bytes - Viewed (0) -
pkg/proxy/iptables/number_generated_rules_test.go
endpointSlices := make([]*discovery.EndpointSlice, nServices) // base parameters basePort := 80 base := netutils.BigForIP(netutils.ParseIPSloppy("10.0.0.1")) // generate a base endpoint slice object baseEp := netutils.BigForIP(netutils.ParseIPSloppy("172.16.0.1")) epPort := 8080 eps := &discovery.EndpointSlice{ ObjectMeta: metav1.ObjectMeta{ Name: "ep",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 21 14:39:54 UTC 2024 - 13.1K bytes - Viewed (0) -
pkg/proxy/apis/config/validation/validation.go
case len(cidrs) == 2: isDual, err := netutils.IsDualStackCIDRStrings(cidrs) if err != nil || !isDual { allErrs = append(allErrs, field.Invalid(newPath.Child("ClusterCIDR"), config.ClusterCIDR, "must be a valid DualStack CIDR (e.g. 10.100.0.0/16,fde4:8dba:82e1::/48)")) } // if we are here means that len(cidrs) == 1, we need to validate it default: if _, _, err := netutils.ParseCIDRSloppy(config.ClusterCIDR); err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 13:25:06 UTC 2024 - 14.6K bytes - Viewed (0) -
pkg/controlplane/reconcilers/lease_test.go
// shutdown apiserver first r.StopReconciling() err = r.RemoveEndpoints(test.serviceName, netutils.ParseIPSloppy(test.ip), test.endpointPorts) if err != nil { t.Errorf("unexpected error remove endpoints: %v", err) } // reconcile endpoints in another goroutine err = r.ReconcileEndpoints(test.serviceName, netutils.ParseIPSloppy(test.ip), test.endpointPorts, false) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Aug 24 09:23:05 UTC 2023 - 28.7K bytes - Viewed (0) -
pkg/proxy/util/localdetector.go
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License. */ package util import ( netutils "k8s.io/utils/net" ) // LocalTrafficDetector generates iptables or nftables rules to detect traffic from local pods. type LocalTrafficDetector interface {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Apr 26 15:34:37 UTC 2024 - 3.6K bytes - Viewed (0) -
cmd/kubeadm/app/componentconfigs/kubeproxy.go
limitations under the License. */ package componentconfigs import ( "github.com/pkg/errors" clientset "k8s.io/client-go/kubernetes" "k8s.io/klog/v2" kubeproxyconfig "k8s.io/kube-proxy/config/v1alpha1" netutils "k8s.io/utils/net" kubeadmapi "k8s.io/kubernetes/cmd/kubeadm/app/apis/kubeadm" kubeadmapiv1 "k8s.io/kubernetes/cmd/kubeadm/app/apis/kubeadm/v1beta3" kubeadmconstants "k8s.io/kubernetes/cmd/kubeadm/app/constants" )
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Oct 20 03:01:30 UTC 2023 - 4.8K bytes - Viewed (0) -
cmd/kubeadm/app/preflight/checks.go
if !IPV4Check && netutils.IsIPv4CIDRString(cidr) { IPV4Check = true } if !IPV6Check && netutils.IsIPv6CIDRString(cidr) { IPV6Check = true } } cidrs = strings.Split(cfg.Networking.PodSubnet, ",") for _, cidr := range cidrs { checks = append(checks, HTTPProxyCIDRCheck{Proto: "https", CIDR: cidr}) if !IPV4Check && netutils.IsIPv4CIDRString(cidr) { IPV4Check = true }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jun 03 11:20:55 UTC 2024 - 39.5K bytes - Viewed (0) -
cmd/kubeadm/app/apis/kubeadm/validation/validation.go
for _, s := range subnets { numAddresses := netutils.RangeSize(s) if numAddresses < minAddrs { allErrs = append(allErrs, field.Invalid(fldPath, s.String(), fmt.Sprintf("subnet with %d address(es) is too small, the minimum is %d", numAddresses, minAddrs))) } // Warn when the subnet is in site-local range - i.e. contains addresses that belong to fec0::/10 _, siteLocalNet, _ := netutils.ParseCIDRSloppy("fec0::/10")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 01 16:01:49 UTC 2024 - 33.4K bytes - Viewed (0) -
cmd/kube-apiserver/app/options/options_test.go
"k8s.io/kubernetes/pkg/controlplane/reconcilers" kubeoptions "k8s.io/kubernetes/pkg/kubeapiserver/options" kubeletclient "k8s.io/kubernetes/pkg/kubelet/client" netutils "k8s.io/utils/net" ) func TestAddFlags(t *testing.T) { fs := pflag.NewFlagSet("addflagstest", pflag.PanicOnError) s := NewServerRunOptions() for _, f := range s.Flags().FlagSets { fs.AddFlagSet(f) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 07 17:57:37 UTC 2024 - 12.7K bytes - Viewed (0)