- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 42 for PodCIDRs (0.12 sec)
-
pkg/apis/core/v1/conversion_test.go
// core to v1 testInputs := []core.NodeSpec{ { PodCIDRs: []string{"10.0.0.0/24", "10.0.1.0/24"}, }, { PodCIDRs: nil, }, { PodCIDRs: []string{"10.0.0.0/24"}, }, { PodCIDRs: []string{"ace:cab:deca::/8"}, }, { PodCIDRs: []string{"10.0.0.0/24", "ace:cab:deca::/8"}, }, { PodCIDRs: []string{"ace:cab:deca::/8", "10.0.0.0/24"}, }, }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 10 05:34:15 UTC 2023 - 21.7K bytes - Viewed (0) -
pkg/proxy/node.go
n.mu.Lock() defer n.mu.Unlock() podCIDRs := node.Spec.PodCIDRs // initialize podCIDRs if len(n.podCIDRs) == 0 && len(podCIDRs) > 0 { n.logger.Info("Setting current PodCIDRs", "podCIDRs", podCIDRs) n.podCIDRs = podCIDRs return } if !reflect.DeepEqual(n.podCIDRs, podCIDRs) { n.logger.Error(nil, "Using NodeCIDR LocalDetector mode, current PodCIDRs are different than previous PodCIDRs, restarting",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 22 05:08:41 UTC 2024 - 3.5K bytes - Viewed (0) -
pkg/controller/nodeipam/ipam/range_allocator_test.go
if len(updatedNode.Spec.PodCIDRs) == 0 { continue // not assigned yet } //match for podCIDRIdx, expectedPodCIDR := range tc.expectedAllocatedCIDR { if updatedNode.Spec.PodCIDRs[podCIDRIdx] != expectedPodCIDR { t.Errorf("%v: Unable to find allocated CIDR %v, found updated Nodes with CIDRs: %v", tc.description, expectedPodCIDR, updatedNode.Spec.PodCIDRs) break } } } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 10:06:15 UTC 2024 - 25.2K bytes - Viewed (0) -
staging/src/k8s.io/client-go/applyconfigurations/core/v1/nodespec.go
// WithPodCIDRs adds the given value to the PodCIDRs field in the declarative configuration // and returns the receiver, so that objects can be build by chaining "With" function invocations. // If called multiple times, values provided by each call will be appended to the PodCIDRs field. func (b *NodeSpecApplyConfiguration) WithPodCIDRs(values ...string) *NodeSpecApplyConfiguration { for i := range values { b.PodCIDRs = append(b.PodCIDRs, values[i]) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 04 18:31:34 UTC 2021 - 4.7K bytes - Viewed (0) -
pkg/apis/core/v1/conversion.go
return err } // If both fields (v1.PodCIDRs and v1.PodCIDR) are provided and differ, then PodCIDR is authoritative for compatibility with older clients if (len(in.PodCIDR) > 0 && len(in.PodCIDRs) > 0) && (in.PodCIDR != in.PodCIDRs[0]) { out.PodCIDRs = []string{in.PodCIDR} } // at the this point, autoConvert copied v1.PodCIDRs -> core.PodCIDRs
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Apr 19 22:30:55 UTC 2024 - 19K bytes - Viewed (0) -
cmd/kube-proxy/app/server_linux_test.go
fakeWatch.Delete(oldNode) // set the PodCIDRs on the new node fakeWatch.Modify(updatedNode) }() got, err := waitForPodCIDR(ctx, client, node.Name) if err != nil { t.Errorf("waitForPodCIDR() unexpected error %v", err) return } if !reflect.DeepEqual(got.Spec.PodCIDRs, expected) { t.Errorf("waitForPodCIDR() got %v expected to be %v ", got.Spec.PodCIDRs, expected) } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Apr 28 15:51:23 UTC 2024 - 21.9K bytes - Viewed (0) -
pkg/controller/nodeipam/ipam/range_allocator.go
return r.ReleaseCIDR(logger, node) } return r.AllocateOrOccupyCIDR(ctx, node) } // marks node.PodCIDRs[...] as used in allocator's tracked cidrSet func (r *rangeAllocator) occupyCIDRs(node *v1.Node) error { if len(node.Spec.PodCIDRs) == 0 { return nil } for idx, cidr := range node.Spec.PodCIDRs { _, podCIDR, err := netutils.ParseCIDRSloppy(cidr) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 10:06:15 UTC 2024 - 16.2K bytes - Viewed (0) -
pkg/proxy/node_test.go
}, } for _, tt := range tests { t.Run(tt.name, func(t *testing.T) { n := &NodePodCIDRHandler{ podCIDRs: tt.oldNodePodCIDRs, } node := &v1.Node{ ObjectMeta: metav1.ObjectMeta{ Name: "test-node", ResourceVersion: "1", }, Spec: v1.NodeSpec{ PodCIDRs: tt.newNodePodCIDRs, }, } defer func() { r := recover() if r == nil && tt.expectPanic {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Sep 10 16:50:29 UTC 2023 - 3.5K bytes - Viewed (0) -
pkg/controller/nodeipam/ipam/doc.go
// the CIDRAllocatorType): // - RangeAllocator is an allocator that assigns PodCIDRs to nodes and works // in conjunction with the RouteController to configure the network to get // connectivity. // - CloudAllocator is an allocator that synchronizes PodCIDRs from IP // ranges assignments from the underlying cloud platform.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 26 17:14:05 UTC 2022 - 1.4K bytes - Viewed (0) -
pkg/registry/core/node/strategy_test.go
"Node", NodeToSelectableFields(&api.Node{}), nil, ) } // helper creates a NodeNode with a set of PodCIDRs, Spec.ConfigSource, Status.Config func makeNode(podCIDRs []string, addSpecDynamicConfig bool, addStatusDynamicConfig bool) *api.Node { node := &api.Node{ Spec: api.NodeSpec{ PodCIDRs: podCIDRs, }, } if addSpecDynamicConfig { node.Spec.ConfigSource = &api.NodeConfigSource{} }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 12 15:48:03 UTC 2023 - 9.7K bytes - Viewed (0)