- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 288 for devnode (0.12 sec)
-
staging/src/k8s.io/apimachinery/pkg/runtime/serializer/cbor/internal/modes/decode.go
ByteStringToTime: cbor.ByteStringToTimeAllowed, }.DecMode() if err != nil { panic(err) } return decode }() // DecodeLax is derived from Decode, but does not complain about unknown fields in the input. var DecodeLax cbor.DecMode = func() cbor.DecMode { opts := Decode.DecOptions() opts.ExtraReturnErrors &^= cbor.ExtraDecErrorUnknownField // clear bit dm, err := opts.DecMode() if err != nil { panic(err) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jun 10 14:03:36 UTC 2024 - 3.9K bytes - Viewed (0) -
src/encoding/json/decode.go
rv := reflect.ValueOf(v) if rv.Kind() != reflect.Pointer || rv.IsNil() { return &InvalidUnmarshalError{reflect.TypeOf(v)} } d.scan.reset() d.scanWhile(scanSkipSpace) // We decode rv not rv.Elem because the Unmarshaler interface // test must be applied at the top level of the value. err := d.value(rv) if err != nil { return d.addErrorContext(err) } return d.savedError }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 00:18:55 UTC 2024 - 35.3K bytes - Viewed (0) -
cmd/erasure-decode.go
} // If we cannot decode, just return read quorum error. return nil, fmt.Errorf("%w (offline-disks=%d/%d)", errErasureReadQuorum, disksNotFound, len(p.readers)) } // Decode reads from readers, reconstructs data if needed and writes the data to the writer. // A set of preferred drives can be supplied. In that case they will be used and the data reconstructed.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue May 21 14:36:21 UTC 2024 - 9.4K bytes - Viewed (0) -
pkg/controller/tainteviction/taint_eviction_test.go
}, oldNode: testutil.NewNode("node1"), newNode: addTaintsToNode(testutil.NewNode("node1"), "testTaint1", "taint1", []int{1}), expectDelete: true, }, { description: "Added tolerated taint", pods: []corev1.Pod{ *addToleration(testutil.NewPod("pod1", "node1"), 1, 100), }, oldNode: testutil.NewNode("node1"),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 25 14:24:16 UTC 2024 - 31.3K bytes - Viewed (0) -
pkg/scheduler/eventhandlers.go
} func nodeLabelsChanged(newNode *v1.Node, oldNode *v1.Node) bool { return !equality.Semantic.DeepEqual(oldNode.GetLabels(), newNode.GetLabels()) } func nodeTaintsChanged(newNode *v1.Node, oldNode *v1.Node) bool { return !equality.Semantic.DeepEqual(newNode.Spec.Taints, oldNode.Spec.Taints) } func nodeConditionsChanged(newNode *v1.Node, oldNode *v1.Node) bool {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 21:21:04 UTC 2024 - 24K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/interpodaffinity/plugin_test.go
name string pod *v1.Pod oldNode, newNode *v1.Node expectedHint framework.QueueingHint }{ { name: "add a new node with matched pod affinity topologyKey", pod: st.MakePod().Name("p").PodAffinityIn("service", "zone", []string{"securityscan", "value2"}, st.PodAffinityWithRequiredReq).Obj(), newNode: st.MakeNode().Name("node-a").Label("zone", "zone1").Obj(),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Apr 12 03:08:44 UTC 2024 - 9.7K bytes - Viewed (0) -
src/runtime/tracemap.go
// much activity, or the map gets big and races to insert on // the same node are much less likely. if newNode == nil { newNode = tab.newTraceMapNode(data, size, hash, tab.seq.Add(1)) } if m.CompareAndSwapNoWB(nil, unsafe.Pointer(newNode)) { return newNode.id, true } // Reload n. Because pointers are only stored once, // we must have lost the race, and therefore n is not nil
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Apr 15 17:03:35 UTC 2024 - 4.5K bytes - Viewed (0) -
src/cmd/go/internal/work/action.go
func (b *Builder) VetAction(mode, depMode BuildMode, p *load.Package) *Action { a := b.vetAction(mode, depMode, p) a.VetxOnly = false return a } func (b *Builder) vetAction(mode, depMode BuildMode, p *load.Package) *Action { // Construct vet action. a := b.cacheAction("vet", p, func() *Action { a1 := b.CompileAction(mode|ModeVetOnly, depMode, p) // vet expects to be able to import "fmt".
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Apr 18 15:39:17 UTC 2024 - 32.7K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/runtime/serializer/cbor/internal/modes/decode_test.go
name: "case-insensitive match treated as unknown field", modes: []cbor.DecMode{modes.Decode}, in: hex("a1614101"), // {"A": 1} into: struct { A int `json:"a"` }{}, assertOnError: assertIdenticalError(&cbor.UnknownFieldError{Index: 0}), }, { name: "case-insensitive match ignored in lax mode", modes: []cbor.DecMode{modes.DecodeLax}, in: hex("a1614101"), // {"A": 1} into: struct {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 22 18:43:10 UTC 2024 - 25.6K bytes - Viewed (0) -
src/cmd/go/internal/fsys/fsys.go
overlay[from] = &node{actualFilePath: to} // Add parent directory nodes to overlay structure. childNode := overlay[from] for { dirNode := overlay[dir] if dirNode == nil || dirNode.isDeleted() { dirNode = &node{children: make(map[string]*node)} overlay[dir] = dirNode } if childNode.isDeleted() { // Only create one parent for a deleted file: // the directory only conditionally exists if
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Jun 06 18:35:34 UTC 2024 - 22.7K bytes - Viewed (0)