- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 170 for netutils (0.2 sec)
-
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) -
cluster/images/etcd/migrate/integration_test.go
"crypto/x509/pkix" "encoding/pem" "flag" "fmt" "math/big" "net" "os" "path/filepath" "strings" "sync" "testing" "time" "github.com/blang/semver/v4" "k8s.io/klog/v2" netutils "k8s.io/utils/net" ) var ( testSupportedVersions = mustParseSupportedVersions([]string{"3.0.17", "3.1.12"}) testVersionPrevious = &EtcdVersion{semver.MustParse("3.0.17")}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Mar 28 07:33:23 UTC 2022 - 11.4K bytes - Viewed (0) -
pkg/proxy/conntrack/cleanup.go
*/ package conntrack import ( v1 "k8s.io/api/core/v1" "k8s.io/apimachinery/pkg/util/sets" "k8s.io/klog/v2" "k8s.io/kubernetes/pkg/proxy" proxyutil "k8s.io/kubernetes/pkg/proxy/util" netutils "k8s.io/utils/net" ) // CleanStaleEntries takes care of flushing stale conntrack entries for services and endpoints. func CleanStaleEntries(ct Interface, svcPortMap proxy.ServicePortMap,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jan 15 18:09:05 UTC 2024 - 5.2K bytes - Viewed (0) -
pkg/registry/core/service/ipallocator/controller/repair.go
api "k8s.io/kubernetes/pkg/apis/core" "k8s.io/kubernetes/pkg/apis/core/v1/helper" "k8s.io/kubernetes/pkg/registry/core/rangeallocation" "k8s.io/kubernetes/pkg/registry/core/service/ipallocator" netutils "k8s.io/utils/net" ) // Repair is a controller loop that periodically examines all service ClusterIP allocations // and logs any errors, and then sets the compacted and accurate list of all allocated IPs. // // Handles:
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Sep 30 15:46:06 UTC 2023 - 13.8K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/net/http.go
parts := strings.Split(hdrForwardedFor, ",") for _, part := range parts { ip := netutils.ParseIPSloppy(strings.TrimSpace(part)) if ip != nil { srcIPs = append(srcIPs, ip) } } } // Try the X-Real-Ip header. hdrRealIp := hdr.Get("X-Real-Ip") if hdrRealIp != "" { ip := netutils.ParseIPSloppy(hdrRealIp)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Mar 05 00:08:58 UTC 2022 - 20.8K bytes - Viewed (0) -
pkg/controlplane/controller/kubernetesservice/controller_test.go
v1informers "k8s.io/client-go/informers/core/v1" "k8s.io/client-go/kubernetes/fake" v1listers "k8s.io/client-go/listers/core/v1" core "k8s.io/client-go/testing" "k8s.io/client-go/tools/cache" netutils "k8s.io/utils/net" ) func TestCreateOrUpdateMasterService(t *testing.T) { singleStack := corev1.IPFamilyPolicySingleStack ns := metav1.NamespaceDefault om := func(name string) metav1.ObjectMeta {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jul 13 10:41:06 UTC 2023 - 15.3K 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/util/webhook/client.go
"k8s.io/apimachinery/pkg/runtime/serializer" utilerrors "k8s.io/apimachinery/pkg/util/errors" "k8s.io/apiserver/pkg/util/x509metrics" "k8s.io/client-go/rest" "k8s.io/utils/lru" netutils "k8s.io/utils/net" ) const ( defaultCacheSize = 200 ) // ClientConfig defines parameters required for creating a hook client. type ClientConfig struct { Name string URL string
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jan 04 09:09:10 UTC 2024 - 7.3K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/validation/validation.go
limitations under the License. */ package validation import ( "fmt" "math" "regexp" "strings" "unicode" "k8s.io/apimachinery/pkg/util/validation/field" netutils "k8s.io/utils/net" ) const qnameCharFmt string = "[A-Za-z0-9]" const qnameExtCharFmt string = "[-A-Za-z0-9_.]" const qualifiedNameFmt string = "(" + qnameCharFmt + qnameExtCharFmt + "*)?" + qnameCharFmt
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 16:08:43 UTC 2024 - 19K bytes - Viewed (0) -
pkg/controller/nodeipam/ipam/sync/sync_test.go
"k8s.io/klog/v2" "k8s.io/klog/v2/ktesting" "k8s.io/kubernetes/pkg/controller/nodeipam/ipam/cidrset" "k8s.io/kubernetes/pkg/controller/nodeipam/ipam/test" netutils "k8s.io/utils/net" v1 "k8s.io/api/core/v1" ) var ( _, clusterCIDRRange, _ = netutils.ParseCIDRSloppy("10.1.0.0/16") ) type fakeEvent struct { nodeName string reason string } type fakeAPIs struct { aliasRange *net.IPNet
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jul 05 23:39:52 UTC 2023 - 7.6K bytes - Viewed (0)