- Sort Score
- Result 10 results
- Languages All
Results 101 - 110 of 249 for perfunc (0.25 sec)
-
src/runtime/crash_unix_test.go
// and two blockOnSystemStackInternal's. userFunc := "testPanicSystemstackInternal" sysFunc := "blockOnSystemStackInternal" nUser := bytes.Count(tb, []byte(userFunc)) nSys := bytes.Count(tb, []byte(sysFunc)) if nUser != 2 || nSys != 2 { t.Fatalf("want %d user stack frames in %s and %d system stack frames in %s, got %d and %d:\n%s", 2, userFunc, 2, sysFunc, nUser, nSys, string(tb)) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Oct 12 20:11:47 UTC 2023 - 9.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/etcd3/store.go
pathPrefix += "/" } w := &watcher{ client: c, codec: codec, newFunc: newFunc, groupResource: groupResource, versioner: versioner, transformer: transformer, } if newFunc == nil { w.objectType = "<unknown>" } else { w.objectType = reflect.TypeOf(newFunc()).String() } s := &store{ client: c, codec: codec,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 10 11:56:42 UTC 2024 - 35.2K bytes - Viewed (0) -
pkg/controller/bootstrap/tokencleaner.go
return } go wait.UntilWithContext(ctx, tc.worker, 10*time.Second) <-ctx.Done() } func (tc *TokenCleaner) enqueueSecrets(obj interface{}) { key, err := controller.KeyFunc(obj) if err != nil { utilruntime.HandleError(err) return } tc.queue.Add(key) } // worker runs a thread that dequeues secrets, handles them, and marks them done.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 6.3K bytes - Viewed (0) -
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) -
staging/src/k8s.io/apiserver/pkg/authentication/token/cache/cached_token_authenticator_test.go
b.Run("has audiences", func(b *testing.B) { var key string for n := 0; n < b.N; n++ { key = keyFunc(hashPool, auds, jwtToken) } bKey = key }) b.Run("nil audiences", func(b *testing.B) { var key string for n := 0; n < b.N; n++ { key = keyFunc(hashPool, nil, jwtToken) } bKey = key }) } func TestSharedLookup(t *testing.T) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jul 03 16:16:51 UTC 2023 - 20.3K bytes - Viewed (0) -
internal/jwt/parser.go
func ParseWithClaims(tokenStr string, claims *MapClaims, fn func(*MapClaims) ([]byte, error)) error { // Key lookup function has to be provided. if fn == nil { // keyFunc was not provided, return error. return jwtgo.NewValidationError("no Keyfunc was provided.", jwtgo.ValidationErrorUnverifiable) } bufp := base64BufPool.Get().(*[]byte) defer base64BufPool.Put(bufp) tokenBuf := base64BufPool.Get().(*[]byte)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue May 09 07:53:08 UTC 2023 - 13.9K 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) -
pkg/registry/resource/resourceclaim/storage/storage.go
} // NewREST returns a RESTStorage object that will work against ResourceClaims. func NewREST(optsGetter generic.RESTOptionsGetter) (*REST, *StatusREST, error) { store := &genericregistry.Store{ NewFunc: func() runtime.Object { return &resource.ResourceClaim{} }, NewListFunc: func() runtime.Object { return &resource.ResourceClaimList{} }, PredicateFunc: resourceclaim.Match,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Nov 18 10:11:16 UTC 2022 - 3.8K bytes - Viewed (0)