Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for ParsePortRange (0.12 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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