- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 75 for netutils (0.25 sec)
-
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) -
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) -
pkg/controller/servicecidrs/servicecidrs_controller.go
return nil } // Convert netutils.IPFamily to v1.IPFamily // TODO: consolidate helpers // copied from 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
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 18K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/options/serving_test.go
"k8s.io/apimachinery/pkg/version" "k8s.io/apiserver/pkg/server" "k8s.io/client-go/discovery" restclient "k8s.io/client-go/rest" cliflag "k8s.io/component-base/cli/flag" "k8s.io/klog/v2/ktesting" netutils "k8s.io/utils/net" ) func setUp(t *testing.T) server.Config { scheme := runtime.NewScheme() codecs := serializer.NewCodecFactory(scheme) config := server.NewConfig(codecs) return *config }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 09 15:52:39 UTC 2024 - 13.8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/config_test.go
"k8s.io/apiserver/pkg/server/healthz" "k8s.io/client-go/informers" "k8s.io/client-go/kubernetes/fake" "k8s.io/client-go/rest" "k8s.io/component-base/tracing" "k8s.io/klog/v2/ktesting" netutils "k8s.io/utils/net" ) func TestAuthorizeClientBearerTokenNoops(t *testing.T) { // All of these should do nothing (not panic, no side-effects) cfgGens := []func() *rest.Config{ func() *rest.Config { return nil },
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 29 18:59:21 UTC 2024 - 13.1K bytes - Viewed (0) -
cmd/kube-controller-manager/app/core.go
cidrsSplit := strings.Split(strings.TrimSpace(cidrsList), ",") cidrs, err := netutils.ParseCIDRs(cidrsSplit) if err != nil { return nil, false, err } // if cidrs has an error then the previous call will fail // safe to ignore error checking on next call dualstack, _ := netutils.IsDualStackCIDRs(cidrs) return cidrs, dualstack, nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 10 08:42:31 UTC 2024 - 39K bytes - Viewed (0) -
pkg/proxy/util/utils_test.go
limitations under the License. */ package util import ( "net" "reflect" "testing" v1 "k8s.io/api/core/v1" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" "k8s.io/apimachinery/pkg/util/sets" netutils "k8s.io/utils/net" ) func TestValidateWorks(t *testing.T) { if isValidEndpoint("", 0) { t.Errorf("Didn't fail for empty set") } if isValidEndpoint("foobar", 0) { t.Errorf("Didn't fail with invalid port")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 20 11:57:43 UTC 2024 - 17.1K bytes - Viewed (0) -
pkg/registry/core/service/ipallocator/controller/repairip.go
"k8s.io/kubernetes/pkg/api/legacyscheme" "k8s.io/kubernetes/pkg/apis/core/v1/helper" "k8s.io/kubernetes/pkg/registry/core/service/ipallocator" "k8s.io/kubernetes/pkg/util/iptree" "k8s.io/utils/clock" netutils "k8s.io/utils/net" ) const ( // maxRetries is the number of times a service will be retried before it is dropped out of the queue.
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/kubelet/kuberuntime/kuberuntime_sandbox.go
kubecontainer "k8s.io/kubernetes/pkg/kubelet/container" runtimeutil "k8s.io/kubernetes/pkg/kubelet/kuberuntime/util" "k8s.io/kubernetes/pkg/kubelet/util" "k8s.io/kubernetes/pkg/kubelet/util/format" netutils "k8s.io/utils/net" ) // createPodSandbox creates a pod sandbox and returns (podSandBoxID, message, error).
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 29 22:40:29 UTC 2024 - 13.6K bytes - Viewed (0)