- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 86 for perfunc (0.14 sec)
-
staging/src/k8s.io/apiserver/pkg/storage/etcd3/watcher_test.go
enableWatchList bool expectedErr error }{ { name: "no newFunc provided", setupFn: func(opts *setupOptions) { opts.newFunc = nil }, requestOpts: storage.ListOptions{ProgressNotify: true}, expectedErr: apierrors.NewInternalError(errors.New("progressNotify for watch is unsupported by the etcd storage because no newFunc was provided")), }, } for _, scenario := range scenarios {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 12.3K bytes - Viewed (1) -
pkg/controller/statefulset/stateful_set_test.go
} else if expectedKey, _ := controller.KeyFunc(set1); expectedKey != key { t.Errorf("expected StatefulSet key %s found %s", expectedKey, key) } ssc.queue.Done(key) ssc.addPod(logger, pod2) key, done = ssc.queue.Get() if key == "" || done { t.Error("failed to enqueue StatefulSet") } else if expectedKey, _ := controller.KeyFunc(set2); expectedKey != key {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 33.1K bytes - Viewed (0) -
pkg/controller/replicaset/replica_set.go
key, err := controller.KeyFunc(rs) if err != nil { utilruntime.HandleError(fmt.Errorf("couldn't get key for object %#v: %v", rs, err)) return } rsc.queue.Add(key) } func (rsc *ReplicaSetController) enqueueRSAfter(rs *apps.ReplicaSet, duration time.Duration) { key, err := controller.KeyFunc(rs) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 33.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/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)