Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 69 for newPoset (0.17 sec)

  1. pkg/test/framework/label/labels.go

    	// IPv4 indicates a test is only compatible with IPv4 clusters.
    	// Any usage of this should have an associated GitHub issue to make it compatible with IPv6
    	IPv4 Instance = "ipv4"
    )
    
    var all = NewSet(
    	Postsubmit,
    	CustomSetup,
    	IPv4)
    
    // Find the label with the given name
    func Find(name string) (Instance, bool) {
    	candidate := Instance(name)
    	if _, ok := all[candidate]; ok {
    		return candidate, true
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Nov 18 17:08:05 UTC 2021
    - 1.3K bytes
    - Viewed (0)
  2. pkg/registry/resource/podschedulingcontext/strategy.go

    // status.
    func (podSchedulingStrategy) GetResetFields() map[fieldpath.APIVersion]*fieldpath.Set {
    	fields := map[fieldpath.APIVersion]*fieldpath.Set{
    		"resource.k8s.io/v1alpha2": fieldpath.NewSet(
    			fieldpath.MakePathOrDie("status"),
    		),
    	}
    
    	return fields
    }
    
    func (podSchedulingStrategy) PrepareForCreate(ctx context.Context, obj runtime.Object) {
    	scheduling := obj.(*resource.PodSchedulingContext)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Mar 05 20:39:24 UTC 2024
    - 5.6K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apimachinery/pkg/util/managedfields/internal/fields.go

    )
    
    // EmptyFields represents a set with no paths
    // It looks like metav1.Fields{Raw: []byte("{}")}
    var EmptyFields = func() metav1.FieldsV1 {
    	f, err := SetToFields(*fieldpath.NewSet())
    	if err != nil {
    		panic("should never happen")
    	}
    	return f
    }()
    
    // FieldsToSet creates a set paths from an input trie of fields
    func FieldsToSet(f metav1.FieldsV1) (s fieldpath.Set, err error) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Mar 08 21:44:00 UTC 2023
    - 1.3K bytes
    - Viewed (0)
  4. cni/pkg/ipset/ipset.go

    // doesn't support creating `list:set` types yet (is in main branch tho).
    // So this will actually create 2 underlying ipsets, one for v4 and one for v6
    func NewIPSet(name string, v6 bool, deps NetlinkIpsetDeps) (IPSet, error) {
    	var err error
    	set := IPSet{
    		V4Name: fmt.Sprintf(V4Name, name),
    		Deps:   deps,
    		Prefix: name,
    	}
    	err = deps.ipsetIPHashCreate(set.V4Name, false)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Apr 30 22:24:38 UTC 2024
    - 3.9K bytes
    - Viewed (0)
  5. pkg/registry/apps/statefulset/strategy.go

    // and should not be modified by the user.
    func (statefulSetStrategy) GetResetFields() map[fieldpath.APIVersion]*fieldpath.Set {
    	fields := map[fieldpath.APIVersion]*fieldpath.Set{
    		"apps/v1": fieldpath.NewSet(
    			fieldpath.MakePathOrDie("status"),
    		),
    	}
    
    	return fields
    }
    
    // PrepareForCreate clears the status of an StatefulSet before creation.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Nov 08 15:48:10 UTC 2022
    - 8.8K bytes
    - Viewed (0)
  6. pkg/monitoring/base.go

    	attrs := make([]attribute.KeyValue, 0, len(bm.attrs)+len(labelValues))
    	attrs = append(attrs, bm.attrs...)
    	for _, v := range labelValues {
    		attrs = append(attrs, v.keyValue)
    	}
    
    	set := attribute.NewSet(attrs...)
    	return attrs, set
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Jul 17 20:25:52 UTC 2023
    - 1.7K bytes
    - Viewed (0)
  7. pkg/registry/core/persistentvolume/strategy.go

    // and should not be modified by the user.
    func (persistentvolumeStrategy) GetResetFields() map[fieldpath.APIVersion]*fieldpath.Set {
    	fields := map[fieldpath.APIVersion]*fieldpath.Set{
    		"v1": fieldpath.NewSet(
    			fieldpath.MakePathOrDie("status"),
    		),
    	}
    
    	return fields
    }
    
    // ResetBeforeCreate clears the Status field which is not allowed to be set by end users on creation.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Nov 01 03:58:36 UTC 2023
    - 7.6K bytes
    - Viewed (0)
  8. pkg/registry/core/node/strategy.go

    // and should not be modified by the user.
    func (nodeStrategy) GetResetFields() map[fieldpath.APIVersion]*fieldpath.Set {
    	fields := map[fieldpath.APIVersion]*fieldpath.Set{
    		"v1": fieldpath.NewSet(
    			fieldpath.MakePathOrDie("status"),
    		),
    	}
    
    	return fields
    }
    
    // AllowCreateOnUpdate is false for nodes.
    func (nodeStrategy) AllowCreateOnUpdate() bool {
    	return false
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Mar 13 23:06:39 UTC 2024
    - 9K bytes
    - Viewed (0)
  9. pkg/monitoring/derived_gauge.go

    	d.mu.Lock()
    	defer d.mu.Unlock()
    	lv := slices.Map(labelValues, func(e LabelValue) attribute.KeyValue {
    		return e.keyValue
    	})
    	as := attribute.NewSet(lv...)
    	d.attrs[as] = valueFn
    	return d
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Jul 17 20:25:52 UTC 2023
    - 1.9K bytes
    - Viewed (0)
  10. cni/pkg/install/kubeconfig_test.go

    	}
    	// Write out a kubeconfig with one cert
    	result, err = createKubeConfig(newCfg)
    	if err != nil {
    		t.Fatalf("did not expect failure: %v", err)
    	}
    	goldenNewFilepath := "testdata/kubeconfig-newhost"
    	testutils.CompareContent(t, []byte(result.Full), goldenNewFilepath)
    }
    
    func TestCheckNoExistingKubeConfig(t *testing.T) {
    	tmp := t.TempDir()
    	os.WriteFile(filepath.Join(tmp, "token"), []byte(saToken), 0o644)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri May 17 21:52:29 UTC 2024
    - 5.1K bytes
    - Viewed (0)
Back to top