Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 1,315 for _obj (0.2 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top