- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 1,315 for _obj (0.05 sec)
-
pkg/controller/volume/pvcprotection/pvc_protection_controller.go
} } } func (*Controller) parsePod(obj interface{}) *v1.Pod { if obj == nil { return nil } pod, ok := obj.(*v1.Pod) if !ok { tombstone, ok := obj.(cache.DeletedFinalStateUnknown) if !ok { utilruntime.HandleError(fmt.Errorf("couldn't get object from tombstone %#v", obj)) return nil } pod, ok = tombstone.Obj.(*v1.Pod) if !ok {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 14K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/runtime/converter_test.go
testCases := []struct { data string obj interface{} err error }{ { data: "{\"da\":[3.5,4,\"3.0\",null]}", obj: &D{}, }, { data: "{\"ea\":[3.5,4,\"3.0\",null]}", obj: &E{}, }, { data: "{\"ea\":[null,null,null]}", obj: &E{}, }, { data: "{\"ea\":[[],[null]]}", obj: &E{}, }, {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 11 16:02:13 UTC 2023 - 22.9K bytes - Viewed (0) -
test/finprofiled.go
var totalBytes int64 for _, p := range prof { bytes := p.AllocBytes - p.FreeBytes nobj := p.AllocObjects - p.FreeObjects if nobj == 0 { // There may be a record that has had all of its objects // freed. That's fine. Avoid a divide-by-zero and skip. continue } size := bytes / nobj if size == tinyBlockSize { totalBytes += bytes } }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Nov 16 05:48:00 UTC 2023 - 2.1K bytes - Viewed (0) -
pkg/controller/disruption/disruption.go
// resync. if !ok { tombstone, ok := obj.(cache.DeletedFinalStateUnknown) if !ok { logger.Error(nil, "Couldn't get object from tombstone", "obj", obj) return } pod, ok = tombstone.Obj.(*v1.Pod) if !ok { logger.Error(nil, "Tombstone contained object that is not a pod", "obj", obj) return } } logger.V(4).Info("DeletePod called on pod", "pod", klog.KObj(pod)) pdb := dc.getPdbForPod(logger, pod)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 36.1K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/nodeunschedulable/node_unschedulable.go
return framework.Queue, nil } // TODO: also check if the original node meets the pod's requestments once preCheck is completely removed. // See: https://github.com/kubernetes/kubernetes/issues/110175 logger.V(5).Info("node was created or updated, but it doesn't make this pod schedulable", "pod", klog.KObj(pod), "node", klog.KObj(modifiedNode))
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Dec 16 12:50:11 UTC 2023 - 3.9K bytes - Viewed (0) -
pkg/controller/volume/persistentvolume/pv_controller_base.go
func (ctrl *PersistentVolumeController) enqueueWork(ctx context.Context, queue workqueue.TypedInterface[string], obj interface{}) { // Beware of "xxx deleted" events logger := klog.FromContext(ctx) if unknown, ok := obj.(cache.DeletedFinalStateUnknown); ok && unknown.Obj != nil { obj = unknown.Obj } objName, err := controller.KeyFunc(obj) if err != nil { logger.Error(err, "Failed to get key from object") return }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 10 08:42:31 UTC 2024 - 29.5K bytes - Viewed (0) -
src/cmd/internal/obj/stringer.go
continue } if first { fmt.Fprintf(out, "\tobj.A_ARCHSPECIFIC: %q,\n", sub[1]) first = false } else { fmt.Fprintf(out, "\t%q,\n", sub[1]) } } fmt.Fprintln(out, "}") if s.Err() != nil { log.Fatal(err) } } const header = `// Code generated by stringer -i %s -o %s -p %s; DO NOT EDIT. package %s import "cmd/internal/obj" var Anames = []string{
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Oct 19 23:33:27 UTC 2023 - 2.2K bytes - Viewed (0) -
src/cmd/go/alldocs.go
// // If a package argument is given or the -i or -r flag is set, // clean removes the following files from each of the // source directories corresponding to the import paths: // // _obj/ old object directory, left from Makefiles // _test/ old test directory, left from Makefiles // _testmain.go old gotest file, left from Makefiles // test.out old test log, left from Makefiles
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 11 16:54:28 UTC 2024 - 142.4K bytes - Viewed (0) -
pkg/controller/endpointslicemirroring/endpointslicemirroring_controller.go
endpoints := obj.(*v1.Endpoints) if endpoints == nil { utilruntime.HandleError(fmt.Errorf("onEndpointsAdd() expected type v1.Endpoints, got %T", obj)) return } if !c.shouldMirror(endpoints) { logger.V(5).Info("Skipping mirroring", "endpoints", klog.KObj(endpoints)) return } c.queueEndpoints(obj) } // onEndpointsUpdate queues a sync for the relevant Endpoints resource.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 06 23:18:31 UTC 2024 - 20.1K bytes - Viewed (0) -
pkg/proxy/node.go
"node", klog.KObj(node), "newPodCIDRs", podCIDRs, "oldPODCIDRs", n.podCIDRs) klog.FlushAndExit(klog.ExitFlushTimeout, 1) } } // OnNodeDelete is a handler for Node deletes. func (n *NodePodCIDRHandler) OnNodeDelete(node *v1.Node) { n.logger.Error(nil, "Current Node is being deleted", "node", klog.KObj(node)) } // OnNodeSynced is a handler for Node syncs.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 22 05:08:41 UTC 2024 - 3.5K bytes - Viewed (0)