Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 25 for deepCopy (0.2 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top