- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 157 for netutils (0.33 sec)
-
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) -
cmd/kubeadm/app/util/apiclient/init_dryrun.go
// We can't handle this event return false, nil, nil } _, svcSubnet, err := netutils.ParseCIDRSloppy(idr.serviceSubnet) if err != nil { return true, nil, errors.Wrapf(err, "error parsing CIDR %q", idr.serviceSubnet) } internalAPIServerVirtualIP, err := netutils.GetIndexedIP(svcSubnet, 1) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 01 07:17:50 UTC 2023 - 5.3K bytes - Viewed (0) -
cmd/kubeadm/app/phases/certs/renewal/manager_test.go
"crypto/x509" "crypto/x509/pkix" "fmt" "net" "os" "path/filepath" "reflect" "testing" "time" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" certutil "k8s.io/client-go/util/cert" netutils "k8s.io/utils/net" kubeadmapi "k8s.io/kubernetes/cmd/kubeadm/app/apis/kubeadm" kubeadmconstants "k8s.io/kubernetes/cmd/kubeadm/app/constants" kubeadmutil "k8s.io/kubernetes/cmd/kubeadm/app/util"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 01 16:01:49 UTC 2024 - 13.9K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/cmd/server/options/options.go
"k8s.io/apiserver/pkg/util/openapi" "k8s.io/apiserver/pkg/util/proxy" "k8s.io/apiserver/pkg/util/webhook" scheme "k8s.io/client-go/kubernetes/scheme" corev1 "k8s.io/client-go/listers/core/v1" netutils "k8s.io/utils/net" ) const defaultEtcdPathPrefix = "/registry/apiextensions.kubernetes.io" // CustomResourceDefinitionsServerOptions describes the runtime options of an apiextensions-apiserver.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 07 17:57:37 UTC 2024 - 6K bytes - Viewed (0) -
pkg/controlplane/apiserver/options/options_test.go
auditbuffered "k8s.io/apiserver/plugin/pkg/audit/buffered" audittruncate "k8s.io/apiserver/plugin/pkg/audit/truncate" cliflag "k8s.io/component-base/cli/flag" "k8s.io/component-base/logs" "k8s.io/component-base/metrics" netutils "k8s.io/utils/net" kubeoptions "k8s.io/kubernetes/pkg/kubeapiserver/options" ) func TestAddFlags(t *testing.T) { fs := pflag.NewFlagSet("addflagstest", pflag.PanicOnError) s := NewOptions()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 07 17:57:37 UTC 2024 - 10.7K bytes - Viewed (0) -
pkg/proxy/serviceport.go
*/ package proxy import ( "fmt" "net" v1 "k8s.io/api/core/v1" "k8s.io/klog/v2" apiservice "k8s.io/kubernetes/pkg/api/v1/service" proxyutil "k8s.io/kubernetes/pkg/proxy/util" netutils "k8s.io/utils/net" ) // ServicePort is an interface which abstracts information about a service. type ServicePort interface { // String returns service string. An example format can be: `IP:Port/Protocol`.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jan 09 08:17:56 UTC 2024 - 10.7K bytes - Viewed (0) -
cmd/kube-proxy/app/server.go
func checkBadIPConfig(s *ProxyServer, dualStackSupported bool) (err error, fatal bool) { var errors []error var badFamily netutils.IPFamily if s.PrimaryIPFamily == v1.IPv4Protocol { badFamily = netutils.IPv6 } else { badFamily = netutils.IPv4 } var clusterType string if dualStackSupported { clusterType = fmt.Sprintf("%s-primary", s.PrimaryIPFamily) } else {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Apr 26 13:27:41 UTC 2024 - 46.8K bytes - Viewed (0)