- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 25 for deepCopy (0.2 sec)
-
tests/integration/ambient/baseline_test.go
} } t.NewSubTest("simple deny").Run(func(t framework.TestContext) { opt = opt.DeepCopy() opt.HTTP.Path = "/deny" opt.Check = CheckDeny overrideCheck(&opt) src.CallOrFail(t, opt) }) t.NewSubTest("simple allow").Run(func(t framework.TestContext) { opt = opt.DeepCopy() opt.HTTP.Path = "/allowed" opt.Check = check.OK() overrideCheck(&opt)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 12 00:07:28 UTC 2024 - 78.4K bytes - Viewed (0) -
cmd/kubeadm/app/apis/kubeadm/v1beta3/conversion.go
func Convert_kubeadm_JoinConfiguration_To_v1beta3_JoinConfiguration(in *kubeadm.JoinConfiguration, out *JoinConfiguration, s conversion.Scope) error { // Migrate the discovery timeout. out.Discovery.Timeout = in.Timeouts.Discovery.DeepCopy() return autoConvert_kubeadm_JoinConfiguration_To_v1beta3_JoinConfiguration(in, out, s) } // Convert_v1beta3_JoinConfiguration_To_kubeadm_JoinConfiguration converts a public JoinConfiguration to a private JoinConfiguration.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 13 06:41:07 UTC 2024 - 8.3K bytes - Viewed (0) -
cmd/kubeadm/app/apis/kubeadm/v1beta4/conversion.go
err := autoConvert_v1beta4_JoinConfiguration_To_kubeadm_JoinConfiguration(in, out, s) out.Discovery.Timeout = in.Timeouts.Discovery.DeepCopy() return err } // Convert_kubeadm_Discovery_To_v1beta4_Discovery is required because there is no Discovery.Timeout in v1beta4
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 13 06:41:07 UTC 2024 - 3.5K bytes - Viewed (0) -
pkg/scheduler/framework/types.go
PendingPlugins sets.Set[string] // Whether the Pod is scheduling gated (by PreEnqueuePlugins) or not. Gated bool } // DeepCopy returns a deep copy of the QueuedPodInfo object. func (pqi *QueuedPodInfo) DeepCopy() *QueuedPodInfo { return &QueuedPodInfo{ PodInfo: pqi.PodInfo.DeepCopy(), Timestamp: pqi.Timestamp, Attempts: pqi.Attempts,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 19:28:17 UTC 2024 - 36.7K bytes - Viewed (0) -
pilot/pkg/model/endpointshards.go
pn, f := portMap[ep.ServicePortName] if !f { continue } portNum = pn } res[portNum] = append(res[portNum], ep) } } return res } func (es *EndpointShards) DeepCopy() *EndpointShards { es.RLock() defer es.RUnlock() res := &EndpointShards{ Shards: make(map[ShardKey][]*IstioEndpoint, len(es.Shards)), ServiceAccounts: es.ServiceAccounts.Copy(), }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 04:34:37 UTC 2024 - 15.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher_whitebox_test.go
{Type: watch.Added, Object: pod1.DeepCopy()}, {Type: watch.Modified, Object: pod2.DeepCopy()}, {Type: watch.Modified, Object: pod3.DeepCopy()}, {Type: watch.Deleted, Object: pod4.DeepCopy()}, } fooEvents := []watch.Event{ {Type: watch.Added, Object: pod1.DeepCopy()}, {Type: watch.Modified, Object: pod2.DeepCopy()}, {Type: watch.Deleted, Object: pod2DeletedAt3.DeepCopy()}, } barEvents := []watch.Event{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 10:12:02 UTC 2024 - 82.9K bytes - Viewed (0) -
pkg/scheduler/internal/queue/scheduling_queue_test.go
} var updatedPods = make([]*v1.Pod, len(pods)) updatedPods[0] = pods[0].DeepCopy() updatedPods[1] = pods[1].DeepCopy() updatedPods[3] = pods[3].DeepCopy() tests := []struct { name string podsToAdd []*v1.Pod expectedMapAfterAdd map[string]*framework.QueuedPodInfo
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 13:26:09 UTC 2024 - 146.9K bytes - Viewed (0) -
pilot/pkg/model/destination_rule.go
} // Deep copy destination rule, to prevent mutate it later when merge with a new one. // This can happen when there are more than one destination rule of same host in one namespace. copied := mdr.rule.DeepCopy() mdr.rule = &copied mdr.from = append(mdr.from, destRuleConfig.NamespacedName()) mergedRule := copied.Spec.(*networking.DestinationRule) existingSubset := sets.String{}
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 07:22:29 UTC 2024 - 6.1K bytes - Viewed (0) -
pkg/kubelet/kubelet_pods.go
cResourceCopy := c.Resources.DeepCopy() // for both requests and limits, we only compare the cpu, memory and ephemeralstorage // which are included in convertToAPIContainerStatuses deleteCustomResourceFromResourceRequirements(cResourceCopy) csResourceCopy := cs.Resources.DeepCopy() if csResourceCopy != nil && !cmp.Equal(*cResourceCopy, *csResourceCopy) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 101.2K bytes - Viewed (0) -
pkg/kubelet/kubelet_test.go
}, } cpu800mMem800MPodSpec := cpu500mMem500MPodSpec.DeepCopy() cpu800mMem800MPodSpec.Containers[0].Resources.Requests = v1.ResourceList{v1.ResourceCPU: cpu800m, v1.ResourceMemory: mem800M} cpu800mPodSpec := cpu500mMem500MPodSpec.DeepCopy() cpu800mPodSpec.Containers[0].Resources.Requests = v1.ResourceList{v1.ResourceCPU: cpu800m} mem800MPodSpec := cpu500mMem500MPodSpec.DeepCopy()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 106.9K bytes - Viewed (0)