Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 60 of 154 for perfunc (1.13 sec)

  1. pkg/kube/kclient/client.go

    						for _, c := range ic.registeredHandlers {
    							c.handler.OnDelete(item)
    						}
    					}
    				}
    			}
    		})
    	}
    }
    
    // keyFunc is the internal API key function that returns "namespace"/"name" or
    // "name" if "namespace" is empty
    func keyFunc(name, namespace string) string {
    	if len(namespace) == 0 {
    		return name
    	}
    	return namespace + "/" + name
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri May 17 07:14:28 UTC 2024
    - 13K bytes
    - Viewed (0)
  2. src/go/types/object.go

    	origin      *Func // if non-nil, the Func from which this one was instantiated
    }
    
    // NewFunc returns a new function with the given signature, representing
    // the function's type.
    func NewFunc(pos token.Pos, pkg *Package, name string, sig *Signature) *Func {
    	var typ Type
    	if sig != nil {
    		typ = sig
    	} else {
    		// Don't store a (typed) nil *Signature.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue May 07 20:08:23 UTC 2024
    - 20.1K bytes
    - Viewed (0)
  3. pkg/kubelet/eviction/eviction_manager.go

    func (m *managerImpl) Start(diskInfoProvider DiskInfoProvider, podFunc ActivePodsFunc, podCleanedUpFunc PodCleanedUpFunc, monitoringInterval time.Duration) {
    	thresholdHandler := func(message string) {
    		klog.InfoS(message)
    		m.synchronize(diskInfoProvider, podFunc)
    	}
    	if m.config.KernelMemcgNotification {
    		for _, threshold := range m.config.Thresholds {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Mar 27 18:55:56 UTC 2024
    - 24.6K bytes
    - Viewed (0)
  4. staging/src/k8s.io/apiserver/pkg/storage/etcd3/watcher.go

    	if opts.Recursive && !strings.HasSuffix(key, "/") {
    		key += "/"
    	}
    	if opts.ProgressNotify && w.newFunc == nil {
    		return nil, apierrors.NewInternalError(errors.New("progressNotify for watch is unsupported by the etcd storage because no newFunc was provided"))
    	}
    	startWatchRV, err := w.getStartWatchResourceVersion(ctx, rev, opts)
    	if err != nil {
    		return nil, err
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Sep 25 10:26:38 UTC 2023
    - 18.9K bytes
    - Viewed (0)
  5. src/cmd/compile/internal/typecheck/stmt.go

    	}
    
    	Stmts(n.Body)
    }
    
    // tcReturn typechecks an ORETURN node.
    func tcReturn(n *ir.ReturnStmt) ir.Node {
    	if ir.CurFunc == nil {
    		base.FatalfAt(n.Pos(), "return outside function")
    	}
    
    	typecheckargs(n)
    	if len(n.Results) != 0 {
    		typecheckaste(ir.ORETURN, nil, false, ir.CurFunc.Type().Results(), n.Results, func() string { return "return argument" })
    	}
    	return n
    }
    
    // select
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Nov 20 15:10:54 UTC 2023
    - 17.8K bytes
    - Viewed (0)
  6. pkg/controller/deployment/deployment_controller_test.go

    		t.Fatalf("queue.Len() = %v, want %v", got, want)
    	}
    	key, done := dc.queue.Get()
    	if key == "" || done {
    		t.Fatalf("failed to enqueue controller for rs %v", rs1.Name)
    	}
    	expectedKey, _ := controller.KeyFunc(d1)
    	if got, want := key, expectedKey; got != want {
    		t.Errorf("queue.Get() = %v, want %v", got, want)
    	}
    
    	dc.addReplicaSet(logger, rs2)
    	if got, want := dc.queue.Len(), 1; got != want {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 32.5K bytes
    - Viewed (0)
  7. tensorflow/compiler/mlir/tensorflow/transforms/annotate_parameter_replication.cc

            mirrored_replicate_args.insert(
                mlir::cast<IntegerAttr>(mirrored_index).getInt());
          }
        }
        auto func =
            llvm::cast<func::FuncOp>(m.lookupSymbol(cluster_func.getFunc()));
        for (auto entry : llvm::enumerate(cluster_func.getOperands())) {
          auto operand = SkipIdentityAndReadVariable(entry.value());
          auto block_arg = mlir::dyn_cast<BlockArgument>(operand);
    Registered: Sun Jun 16 05:45:23 UTC 2024
    - Last Modified: Thu Apr 25 16:01:03 UTC 2024
    - 4.1K bytes
    - Viewed (0)
  8. src/cmd/compile/internal/types2/object.go

    	origin      *Func // if non-nil, the Func from which this one was instantiated
    }
    
    // NewFunc returns a new function with the given signature, representing
    // the function's type.
    func NewFunc(pos syntax.Pos, pkg *Package, name string, sig *Signature) *Func {
    	var typ Type
    	if sig != nil {
    		typ = sig
    	} else {
    		// Don't store a (typed) nil *Signature.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue May 07 20:08:23 UTC 2024
    - 20.1K bytes
    - Viewed (0)
  9. pkg/registry/networking/servicecidr/storage/storage.go

    	*genericregistry.Store
    }
    
    // NewREST returns a RESTStorage object that will work against service CIDRs.
    func NewREST(optsGetter generic.RESTOptionsGetter) (*REST, *StatusREST, error) {
    	store := &genericregistry.Store{
    		NewFunc:                   func() runtime.Object { return &networking.ServiceCIDR{} },
    		NewListFunc:               func() runtime.Object { return &networking.ServiceCIDRList{} },
    		DefaultQualifiedResource:  networking.Resource("servicecidrs"),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Oct 31 21:05:04 UTC 2023
    - 3.9K bytes
    - Viewed (0)
  10. pkg/controller/disruption/disruption_test.go

    )
    
    type pdbStates map[string]policy.PodDisruptionBudget
    
    var alwaysReady = func() bool { return true }
    
    func (ps *pdbStates) Set(ctx context.Context, pdb *policy.PodDisruptionBudget) error {
    	key, err := controller.KeyFunc(pdb)
    	if err != nil {
    		return err
    	}
    	(*ps)[key] = *pdb.DeepCopy()
    	return nil
    }
    
    func (ps *pdbStates) Get(key string) policy.PodDisruptionBudget {
    	return (*ps)[key]
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 50K bytes
    - Viewed (0)
Back to top