- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 86 for perfunc (0.31 sec)
-
pkg/controller/resourcequota/resource_quota_controller.go
func (rq *Controller) enqueueResourceQuota(logger klog.Logger, obj interface{}) { key, err := controller.KeyFunc(obj) if err != nil { logger.Error(err, "Couldn't get key", "object", obj) return } rq.queue.Add(key) } func (rq *Controller) addQuota(logger klog.Logger, obj interface{}) { key, err := controller.KeyFunc(obj) if err != nil { logger.Error(err, "Couldn't get key", "object", obj) return }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 21.3K bytes - Viewed (0) -
pkg/kubelet/token/token_manager_test.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 04 00:16:47 UTC 2022 - 16.2K bytes - Viewed (0) -
pkg/controller/ttlafterfinished/ttlafterfinished_controller.go
logger.V(4).Info("Add job to cleanup", "job", klog.KObj(job)) key, err := controller.KeyFunc(job) if err != nil { utilruntime.HandleError(fmt.Errorf("couldn't get key for object %#v: %v", job, err)) return } tc.queue.Add(key) } func (tc *Controller) enqueueAfter(job *batch.Job, after time.Duration) { key, err := controller.KeyFunc(job) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 07 23:59:28 UTC 2024 - 10.4K bytes - Viewed (0) -
pkg/controller/endpoint/endpoints_controller.go
key, err := controller.KeyFunc(obj) if err != nil { utilruntime.HandleError(fmt.Errorf("Couldn't get key for object %+v: %v", obj, err)) return } e.queue.Add(key) } // onServiceDelete removes the Service Selector from the cache and queues the Service for processing. func (e *Controller) onServiceDelete(obj interface{}) { key, err := controller.KeyFunc(obj) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 26.3K bytes - Viewed (0) -
pkg/controller/testutil/test_utils.go
"k8s.io/kubernetes/pkg/api/legacyscheme" api "k8s.io/kubernetes/pkg/apis/core" "k8s.io/utils/clock" testingclock "k8s.io/utils/clock/testing" jsonpatch "gopkg.in/evanphx/json-patch.v4" ) var ( keyFunc = cache.DeletionHandlingMetaNamespaceKeyFunc ) // FakeNodeHandler is a fake implementation of NodesInterface and NodeInterface. It // allows test cases to have fine-grained control over mock behaviors. We also need
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 28 08:48:22 UTC 2024 - 15.6K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/text/cases/map.go
} ) func makeUpper(t language.Tag, o options) transform.SpanningTransformer { _, i, _ := matcher.Match(t) f := upperFunc[i].upper if f == nil { return undUpper } return &simpleCaser{f: f, span: upperFunc[i].span} } func makeLower(t language.Tag, o options) transform.SpanningTransformer { _, i, _ := matcher.Match(t) f := lowerFunc[i] if f == nil {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 24 13:01:26 UTC 2024 - 22.7K bytes - Viewed (0) -
pkg/controller/deployment/deployment_controller.go
key, err := controller.KeyFunc(deployment) if err != nil { utilruntime.HandleError(fmt.Errorf("couldn't get key for object %#v: %v", deployment, err)) return } dc.queue.Add(key) } func (dc *DeploymentController) enqueueRateLimited(deployment *apps.Deployment) { key, err := controller.KeyFunc(deployment) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 24.2K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/third_party/forked/golang/reflect/deep_equal.go
return err } } return nil } // AddFunc uses func as an equality function: it must take // two parameters of the same type, and return a boolean. func (e Equalities) AddFunc(eqFunc interface{}) error { fv := reflect.ValueOf(eqFunc) ft := fv.Type() if ft.Kind() != reflect.Func { return fmt.Errorf("expected func, got: %v", ft) } if ft.NumIn() != 2 { return fmt.Errorf("expected two 'in' params, got: %v", ft) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jul 20 17:18:42 UTC 2022 - 10.8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/etcd3/store_test.go
func (r *clientRecorder) GetReadsAndReset() uint64 { return atomic.SwapUint64(&r.reads, 0) } type setupOptions struct { client func(testing.TB) *clientv3.Client codec runtime.Codec newFunc func() runtime.Object newListFunc func() runtime.Object prefix string resourcePrefix string groupResource schema.GroupResource transformer value.Transformer
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 11 12:45:33 UTC 2024 - 26.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/storagebackend/factory/etcd3.go
compactor.refs-- if compactor.refs == 0 { compactor.cancel() compactor.client.Close() delete(compactors, key) } }, nil } func newETCD3Storage(c storagebackend.ConfigForResource, newFunc, newListFunc func() runtime.Object, resourcePrefix string) (storage.Interface, DestroyFunc, error) { stopCompactor, err := startCompactorOnce(c.Transport, c.CompactionInterval) if err != nil { return nil, nil, err }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 07:56:39 UTC 2024 - 15.1K bytes - Viewed (0)