- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 22 for PortRange (0.16 sec)
-
pkg/registry/core/service/portallocator/controller/repair.go
) // See ipallocator/controller/repair.go; this is a copy for ports. type Repair struct { interval time.Duration serviceClient corev1client.ServicesGetter portRange net.PortRange alloc rangeallocation.RangeRegistry leaks map[int]int // counter per leaked port broadcaster events.EventBroadcaster recorder events.EventRecorder }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Sep 30 15:46:06 UTC 2023 - 10.4K bytes - Viewed (0) -
pkg/registry/core/service/portallocator/allocator.go
} type PortAllocator struct { portRange net.PortRange alloc allocator.Interface // metrics is a metrics recorder that can be disabled metrics metricsRecorderInterface } // PortAllocator implements Interface and Snapshottable var _ Interface = &PortAllocator{} // New creates a PortAllocator over a net.PortRange, calling allocatorFactory to construct the backing store.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 08 07:15:02 UTC 2024 - 7.4K bytes - Viewed (0) -
pkg/registry/core/service/portallocator/allocator_test.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 08 07:15:02 UTC 2024 - 14K bytes - Viewed (0) -
pkg/proxy/ipvs/ipset/ipset_test.go
func Test_validatePortRange(t *testing.T) { testCases := []struct { portRange string expectErr bool desc string }{ { // case[0] portRange: "a-b", expectErr: true, desc: "invalid port number", }, { // case[1] portRange: "1-2", expectErr: false, desc: "valid", }, { // case[2] portRange: "90-1", expectErr: false,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Dec 19 01:20:51 UTC 2023 - 41.5K bytes - Viewed (0) -
pkg/proxy/ipvs/ipset/ipset.go
func validatePortRange(portRange string) error { strs := strings.Split(portRange, "-") if len(strs) != 2 { return fmt.Errorf("invalid PortRange: %q", portRange) } for i := range strs { num, err := strconv.Atoi(strs[i]) if err != nil { return fmt.Errorf("invalid PortRange: %q", portRange) } if num < 0 { return fmt.Errorf("invalid PortRange: %q", portRange) } } return nil
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Dec 19 01:20:51 UTC 2023 - 17.1K bytes - Viewed (0) -
cmd/ftp-server.go
if serverDebugLog { fmt.Printf("%s < %d %s\n", sessionID, code, message) } } func startFTPServer(args []string) { var ( port int publicIP string portRange string tlsPrivateKey string tlsPublicCert string ) var err error for _, arg := range args { tokens := strings.SplitN(arg, "=", 2) if len(tokens) != 2 {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sat Mar 09 03:07:08 UTC 2024 - 4.8K bytes - Viewed (0) -
pkg/proxy/apis/config/scheme/testdata/KubeProxyConfiguration/roundtrip/default/v1alpha1.yaml
verbosity: 0 metricsBindAddress: 127.0.0.1:10249 mode: "" nftables: masqueradeAll: false masqueradeBit: 14 minSyncPeriod: 1s syncPeriod: 30s nodePortAddresses: null oomScoreAdj: -999 portRange: "" showHiddenMetricsForVersion: "" winkernel: enableDSR: false forwardHealthCheckVip: false networkName: "" rootHnsEndpointName: ""
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jan 17 12:50:03 UTC 2024 - 1.4K bytes - Viewed (0) -
pkg/proxy/apis/config/v1alpha1/zz_generated.conversion.go
if err := Convert_v1alpha1_KubeProxyConntrackConfiguration_To_config_KubeProxyConntrackConfiguration(&in.Conntrack, &out.Conntrack, s); err != nil { return err } out.ConfigSyncPeriod = in.ConfigSyncPeriod out.PortRange = in.PortRange return nil } // Convert_v1alpha1_KubeProxyConfiguration_To_config_KubeProxyConfiguration is an autogenerated conversion function.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 31 21:33:53 UTC 2023 - 22.3K bytes - Viewed (0) -
cmd/kube-apiserver/app/options/validation_test.go
} }) } } func makeOptionsWithPort(kubernetesServiceNodePort int, base int, size int) *ServerRunOptions { var portRange = utilnet.PortRange{ Base: base, Size: size, } return &ServerRunOptions{ Extra: Extra{ ServiceNodePortRange: portRange, KubernetesServiceNodePort: kubernetesServiceNodePort, }, } } func TestValidateMaxCIDRRange(t *testing.T) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 11.4K bytes - Viewed (0) -
pkg/registry/core/service/portallocator/storage/storage_test.go
d() server.Terminate(t) } return server, storage, backing, s, destroyFunc } func validNewRangeAllocation() *api.RangeAllocation { portRange := fmt.Sprintf("%d-%d", basePortRange, basePortRange+sizePortRange-1) return &api.RangeAllocation{ Range: portRange, } } func key() string { return "/ranges/servicenodeports" }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 08 07:15:02 UTC 2024 - 8.1K bytes - Viewed (0)