Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 12 for resources2 (0.16 sec)

  1. pilot/pkg/xds/delta.go

    	originalW := w
    	// If delta is set, client is requesting new resources or removing old ones. We should just generate the
    	// new resources it needs, rather than the entire set of known resources.
    	// Note: we do not need to account for unsubscribed resources as these are handled by parent removal;
    	// See https://www.envoyproxy.io/docs/envoy/latest/api-docs/xds_protocol#deleting-resources.
    	// This means if there are only removals, we will not respond.
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Jun 14 04:34:37 UTC 2024
    - 25.6K bytes
    - Viewed (0)
  2. pkg/kubelet/kubelet_test.go

    	resourceQuantity0 := *resource.NewQuantity(int64(0), resource.DecimalSI)
    	resourceQuantity1 := *resource.NewQuantity(int64(1), resource.DecimalSI)
    	resourceQuantity2 := *resource.NewQuantity(int64(2), resource.DecimalSI)
    	resourceQuantityInvalid := *resource.NewQuantity(int64(-1), resource.DecimalSI)
    	allowedPodQuantity := *resource.NewQuantity(int64(10), resource.DecimalSI)
    	nodes := []*v1.Node{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 106.9K bytes
    - Viewed (0)
  3. pkg/kubelet/kuberuntime/kuberuntime_manager_test.go

    	assert.NoError(t, err)
    
    	cpu100m := resource.MustParse("100m")
    	cpu150m := resource.MustParse("150m")
    	cpu200m := resource.MustParse("200m")
    	cpu250m := resource.MustParse("250m")
    	cpu300m := resource.MustParse("300m")
    	cpu350m := resource.MustParse("350m")
    	mem100M := resource.MustParse("100Mi")
    	mem150M := resource.MustParse("150Mi")
    	mem200M := resource.MustParse("200Mi")
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 96K bytes
    - Viewed (0)
  4. pkg/kubelet/kubelet_pods.go

    				limits[v1.ResourceCPU] = cStatus.Resources.CPULimit.DeepCopy()
    			} else {
    				determineResource(v1.ResourceCPU, container.Resources.Limits, oldStatus.Resources.Limits, limits)
    			}
    			if cStatus.Resources != nil && cStatus.Resources.MemoryLimit != nil {
    				limits[v1.ResourceMemory] = cStatus.Resources.MemoryLimit.DeepCopy()
    			} else {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 101.2K bytes
    - Viewed (0)
  5. pkg/kubelet/kubelet.go

    	for _, c := range pod.Spec.Containers {
    		if cs, ok := podutil.GetContainerStatus(podStatus.ContainerStatuses, c.Name); ok {
    			if cs.Resources == nil {
    				continue
    			}
    			if !cmp.Equal(c.Resources.Limits, cs.Resources.Limits) || !cmp.Equal(cs.AllocatedResources, cs.Resources.Requests) {
    				return true
    			}
    		}
    	}
    	return false
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 126.1K bytes
    - Viewed (0)
  6. pkg/config/analysis/analyzers/analyzers_test.go

    	}
    
    	// Include resources from test files
    	err := sa.AddTestReaderKubeSource(files)
    	if err != nil {
    		return nil, fmt.Errorf("error setting up file kube source on testcase %s: %v", tc.name, err)
    	}
    
    	// Include default resources
    	err = sa.AddDefaultResources()
    	if err != nil {
    		return nil, fmt.Errorf("error adding default resources: %v", err)
    	}
    
    	return sa, nil
    }
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Jun 14 07:22:31 UTC 2024
    - 42.6K bytes
    - Viewed (0)
  7. staging/src/k8s.io/apiextensions-apiserver/examples/client-go/pkg/client/clientset/versioned/typed/cr/v1/example.go

    // A group's client should implement this interface.
    type ExamplesGetter interface {
    	Examples(namespace string) ExampleInterface
    }
    
    // ExampleInterface has methods to work with Example resources.
    type ExampleInterface interface {
    	Create(ctx context.Context, example *v1.Example, opts metav1.CreateOptions) (*v1.Example, error)
    	Update(ctx context.Context, example *v1.Example, opts metav1.UpdateOptions) (*v1.Example, error)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 10:52:54 UTC 2024
    - 8.6K bytes
    - Viewed (0)
  8. staging/src/k8s.io/apiextensions-apiserver/pkg/client/clientset/clientset/typed/apiextensions/v1/customresourcedefinition.go

    type CustomResourceDefinitionsGetter interface {
    	CustomResourceDefinitions() CustomResourceDefinitionInterface
    }
    
    // CustomResourceDefinitionInterface has methods to work with CustomResourceDefinition resources.
    type CustomResourceDefinitionInterface interface {
    	Create(ctx context.Context, customResourceDefinition *v1.CustomResourceDefinition, opts metav1.CreateOptions) (*v1.CustomResourceDefinition, error)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 10:52:54 UTC 2024
    - 12K bytes
    - Viewed (0)
  9. staging/src/k8s.io/apiextensions-apiserver/pkg/client/clientset/clientset/typed/apiextensions/v1beta1/customresourcedefinition.go

    type CustomResourceDefinitionsGetter interface {
    	CustomResourceDefinitions() CustomResourceDefinitionInterface
    }
    
    // CustomResourceDefinitionInterface has methods to work with CustomResourceDefinition resources.
    type CustomResourceDefinitionInterface interface {
    	Create(ctx context.Context, customResourceDefinition *v1beta1.CustomResourceDefinition, opts v1.CreateOptions) (*v1beta1.CustomResourceDefinition, error)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 10:52:54 UTC 2024
    - 12.1K bytes
    - Viewed (0)
  10. pilot/pkg/config/kube/crdclient/client.go

    	oldJSON, err := json.Marshal(oldRes)
    	if err != nil {
    		return nil, fmt.Errorf("failed marhsalling original resource: %v", err)
    	}
    	newJSON, err := json.Marshal(modRes)
    	if err != nil {
    		return nil, fmt.Errorf("failed marhsalling modified resource: %v", err)
    	}
    	switch patchType {
    	case types.JSONPatchType:
    		ops, err := jsonpatch.CreatePatch(oldJSON, newJSON)
    		if err != nil {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Jun 14 00:12:28 UTC 2024
    - 13.7K bytes
    - Viewed (0)
Back to top