Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 77 for newPoset (0.25 sec)

  1. 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)
  2. pkg/test/framework/operations.go

    	rtMu.Lock()
    	defer rtMu.Unlock()
    
    	if rt == nil {
    		panic("call to scope without running the test framework")
    	}
    
    	return rt.newRootContext(test, goTest, label.NewSet(labels...))
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Jun 29 21:19:48 UTC 2020
    - 1.4K bytes
    - Viewed (0)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. pkg/registry/apps/deployment/strategy.go

    // and should not be modified by the user.
    func (deploymentStrategy) GetResetFields() map[fieldpath.APIVersion]*fieldpath.Set {
    	fields := map[fieldpath.APIVersion]*fieldpath.Set{
    		"apps/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: Fri Dec 16 21:07:13 UTC 2022
    - 8.2K bytes
    - Viewed (0)
  10. pkg/registry/core/persistentvolumeclaim/strategy.go

    // and should not be modified by the user.
    func (persistentvolumeclaimStrategy) GetResetFields() map[fieldpath.APIVersion]*fieldpath.Set {
    	fields := map[fieldpath.APIVersion]*fieldpath.Set{
    		"v1": fieldpath.NewSet(
    			fieldpath.MakePathOrDie("status"),
    		),
    	}
    
    	return fields
    }
    
    // PrepareForCreate 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 09 20:58:25 UTC 2022
    - 7.8K bytes
    - Viewed (0)
Back to top