- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 154 for perfunc (1.13 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)