Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 9 of 9 for ParsePortRange (0.11 sec)

  1. staging/src/k8s.io/apimachinery/pkg/util/net/port_range.go

    // pflag.Value interface.
    func (*PortRange) Type() string {
    	return "portRange"
    }
    
    // ParsePortRange parses a string of the form "min-max", inclusive at both
    // ends, and initializes a new PortRange from it.
    func ParsePortRange(value string) (*PortRange, error) {
    	pr := &PortRange{}
    	err := pr.Set(value)
    	if err != nil {
    		return nil, err
    	}
    	return pr, nil
    }
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Aug 10 01:27:56 UTC 2020
    - 3.4K bytes
    - Viewed (0)
  2. pkg/registry/core/service/portallocator/allocator_test.go

    	err = r.Snapshot(&dst)
    	if err != nil {
    		t.Fatal(err)
    	}
    
    	pr2, err := net.ParsePortRange(dst.Range)
    	if err != nil {
    		t.Fatal(err)
    	}
    
    	if pr.String() != pr2.String() {
    		t.Fatalf("mismatched networks: %s : %s", pr, pr2)
    	}
    
    	otherPr, err := net.ParsePortRange("200-300")
    	if err != nil {
    		t.Fatal(err)
    	}
    	_, err = NewInMemory(*otherPr)
    	if err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 08 07:15:02 UTC 2024
    - 14K bytes
    - Viewed (0)
  3. pkg/registry/core/service/portallocator/operation_test.go

    package portallocator
    
    import (
    	"testing"
    
    	"k8s.io/apimachinery/pkg/util/net"
    )
    
    // TestDryRunAllocate tests the Allocate function in dry run mode
    func TestDryRunAllocate(t *testing.T) {
    	pr, err := net.ParsePortRange("10000-10200")
    	if err != nil {
    		t.Fatal(err)
    	}
    
    	// Allocate some ports before calling
    	previouslyAllocated := []int{10000, 10010, 10020}
    	r, err := NewInMemory(*pr)
    	if err != nil {
    		t.Fatal(err)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Aug 15 23:44:12 UTC 2021
    - 3.1K bytes
    - Viewed (0)
  4. pkg/registry/core/service/portallocator/controller/repair_test.go

    }
    
    func TestRepair(t *testing.T) {
    	clearMetrics()
    	fakeClient := fake.NewSimpleClientset()
    	registry := &mockRangeRegistry{
    		item: &api.RangeAllocation{Range: "100-200"},
    	}
    	pr, _ := net.ParsePortRange(registry.item.Range)
    	r := NewRepair(0, fakeClient.CoreV1(), fakeClient.EventsV1(), *pr, registry)
    
    	if err := r.runOnce(); err != nil {
    		t.Fatal(err)
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Sep 30 15:46:06 UTC 2023
    - 10.6K bytes
    - Viewed (0)
  5. pkg/proxy/ipvs/ipset/ipset.go

    	return false
    }
    
    // parsePortRange parse the begin and end port from a raw string(format: a-b).  beginPort <= endPort
    // in the return value.
    func parsePortRange(portRange string) (beginPort int, endPort int, err error) {
    	if len(portRange) == 0 {
    		portRange = DefaultPortRange
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Dec 19 01:20:51 UTC 2023
    - 17.1K bytes
    - Viewed (0)
  6. pkg/util/flag/flags.go

    type PortRangeVar struct {
    	Val *string
    }
    
    // Set sets the flag value
    func (v PortRangeVar) Set(s string) error {
    	if _, err := utilnet.ParsePortRange(s); err != nil {
    		return fmt.Errorf("%q is not a valid port range: %v", s, err)
    	}
    	if v.Val == nil {
    		// it's okay to panic here since this is programmer error
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jul 19 03:30:46 UTC 2022
    - 7.8K bytes
    - Viewed (0)
  7. pkg/registry/core/service/portallocator/allocator.go

    	})
    }
    
    // NewFromSnapshot allocates a PortAllocator and initializes it from a snapshot.
    func NewFromSnapshot(snap *api.RangeAllocation) (*PortAllocator, error) {
    	pr, err := net.ParsePortRange(snap.Range)
    	if err != nil {
    		return nil, err
    	}
    	r, err := NewInMemory(*pr)
    	if err != nil {
    		return nil, err
    	}
    	if err := r.Restore(*pr, snap.Data); err != nil {
    		return nil, err
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 08 07:15:02 UTC 2024
    - 7.4K bytes
    - Viewed (0)
  8. pkg/proxy/apis/config/validation/validation.go

    				allErrs = append(allErrs, field.Invalid(newPath.Child("ClusterCIDR"), config.ClusterCIDR, "must be a valid CIDR block (e.g. 10.100.0.0/16 or fde4:8dba:82e1::/48)"))
    			}
    		}
    	}
    
    	if _, err := utilnet.ParsePortRange(config.PortRange); err != nil {
    		allErrs = append(allErrs, field.Invalid(newPath.Child("PortRange"), config.PortRange, "must be a valid port range (e.g. 300-2000)"))
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 18 13:25:06 UTC 2024
    - 14.6K bytes
    - Viewed (0)
  9. pkg/proxy/ipvs/ipset/ipset_test.go

    		},
    		{ // case[13]
    			portRange: "-1--8",
    			expectErr: true,
    			desc:      "port number can not be negative value",
    		},
    	}
    	for i := range testCases {
    		begin, end, err := parsePortRange(testCases[i].portRange)
    		if err != nil {
    			if !testCases[i].expectErr {
    				t.Errorf("case [%d]: unexpected err: %v, desc: %s", i, err, testCases[i].desc)
    			}
    			continue
    		}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Dec 19 01:20:51 UTC 2023
    - 41.5K bytes
    - Viewed (0)
Back to top