Search Options

Results per page
Sort
Preferred Languages
Advance

Results 61 - 70 of 77 for newPoset (0.25 sec)

  1. pkg/registry/batch/job/strategy.go

    // and should not be modified by the user.
    func (jobStrategy) GetResetFields() map[fieldpath.APIVersion]*fieldpath.Set {
    	fields := map[fieldpath.APIVersion]*fieldpath.Set{
    		"batch/v1": fieldpath.NewSet(
    			fieldpath.MakePathOrDie("status"),
    		),
    	}
    
    	return fields
    }
    
    // PrepareForCreate clears the status of a job before creation.
    func (jobStrategy) PrepareForCreate(ctx context.Context, obj runtime.Object) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 08 16:43:24 UTC 2024
    - 18.4K bytes
    - Viewed (0)
  2. cmd/kubeadm/app/discovery/token/token.go

    	token, err := bootstraptokenv1.NewBootstrapTokenString(cfg.BootstrapToken.Token)
    	if err != nil {
    		return nil, err
    	}
    
    	// Load the CACertHashes into a pubkeypin.Set
    	pubKeyPins := pubkeypin.NewSet()
    	if err = pubKeyPins.Allow(cfg.BootstrapToken.CACertHashes...); err != nil {
    		return nil, errors.Wrap(err, "invalid discovery token CA certificate hash")
    	}
    
    	// Make sure the interval is not bigger than the duration
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Jan 14 13:07:56 UTC 2024
    - 10.1K bytes
    - Viewed (0)
  3. pkg/monitoring/monitortest/test.go

    	kvs := []attribute.KeyValue{}
    	for _, lv := range row.Label {
    		kvs = append(kvs, attribute.String(*lv.Name, *lv.Value))
    	}
    	key := metricKey{
    		name:  *metric.Name,
    		attrs: attribute.NewSet(kvs...),
    	}
    	return key
    }
    
    type Compare func(any) error
    
    func DoesNotExist(any) error {
    	// special case logic in the Assert
    	return nil
    }
    
    func Exactly(v float64) func(any) error {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Sep 13 16:04:48 UTC 2023
    - 7.2K bytes
    - Viewed (0)
  4. pkg/apis/resource/validation/validation.go

    			// but not added.
    			if resourceClaim.DeletionTimestamp != nil || resourceClaim.Status.DeallocationRequested {
    				oldSet := sets.New(oldClaim.Status.ReservedFor...)
    				newSet := sets.New(resourceClaim.Status.ReservedFor...)
    				newItems := newSet.Difference(oldSet)
    				if len(newItems) > 0 {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 07 09:18:10 UTC 2024
    - 28.3K bytes
    - Viewed (0)
  5. maven-core/src/main/java/org/apache/maven/project/DefaultProjectBuilder.java

                    throw new RuntimeException(e);
                }
            }
    
            private <T> Set<T> concat(Set<T> set, T elem) {
                Set<T> newSet = new HashSet<>(set);
                newSet.add(elem);
                return newSet;
            }
    
            @SuppressWarnings("checkstyle:parameternumber")
            private InterimResult build(
                    Map<File, MavenProject> projectIndex,
    Registered: Wed Jun 12 09:55:16 UTC 2024
    - Last Modified: Mon May 13 16:34:29 UTC 2024
    - 57.1K bytes
    - Viewed (0)
  6. staging/src/k8s.io/apimachinery/pkg/util/managedfields/internal/capmanagers_test.go

    		"",
    		func(m internal.Manager) internal.Manager {
    			return internal.NewCapManagersManager(m, 3)
    		})
    
    	set := func(fields ...string) *metav1.FieldsV1 {
    		s := fieldpath.NewSet()
    		for _, f := range fields {
    			s.Insert(fieldpath.MakePathOrDie(f))
    		}
    		b, err := s.ToJSON()
    		if err != nil {
    			panic(fmt.Sprintf("error building ManagedFieldsEntry for test: %v", err))
    		}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Mar 08 21:44:00 UTC 2023
    - 10.1K bytes
    - Viewed (0)
  7. pkg/kubelet/kubelet_node_status.go

    		newCMAAnnotation, newSet = node.Annotations[volutil.ControllerManagedAttachAnnotation]
    	)
    
    	if newCMAAnnotation == existingCMAAnnotation {
    		return false
    	}
    
    	// If the just-constructed node and the existing node do
    	// not have the same value, update the existing node with
    	// the correct value of the annotation.
    	if !newSet {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 31.1K bytes
    - Viewed (0)
  8. pkg/registry/core/pod/strategy.go

    // and should not be modified by the user.
    func (podStrategy) GetResetFields() map[fieldpath.APIVersion]*fieldpath.Set {
    	fields := map[fieldpath.APIVersion]*fieldpath.Set{
    		"v1": fieldpath.NewSet(
    			fieldpath.MakePathOrDie("status"),
    		),
    	}
    
    	return fields
    }
    
    // PrepareForCreate clears fields that are not allowed to be set by end users on creation.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 07 17:51:48 UTC 2024
    - 29.8K bytes
    - Viewed (0)
  9. pkg/test/framework/testcontext.go

    	}
    	return tmp
    }
    
    func (c *testContext) newChildContext(test *testImpl) *testContext {
    	return newTestContext(test, test.goTest, c.suite, c.scope, label.NewSet(test.labels...))
    }
    
    func (c *testContext) NewSubTest(name string) Test {
    	if c.test == nil {
    		panic(fmt.Sprintf("Attempting to create subtest %s from a TestContext with no associated Test", name))
    	}
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Apr 08 22:02:59 UTC 2024
    - 11.4K bytes
    - Viewed (0)
  10. staging/src/k8s.io/apiextensions-apiserver/pkg/registry/customresource/strategy.go

    	fields := map[fieldpath.APIVersion]*fieldpath.Set{}
    
    	if a.status != nil {
    		fields[fieldpath.APIVersion(a.kind.GroupVersion().String())] = fieldpath.NewSet(
    			fieldpath.MakePathOrDie("status"),
    		)
    	}
    
    	return fields
    }
    
    // PrepareForCreate clears the status of a CustomResource before creation.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Feb 28 21:22:34 UTC 2024
    - 14.9K bytes
    - Viewed (0)
Back to top