Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for NewStore (0.09 sec)

  1. pkg/controller/job/backoff_utils.go

    	}
    
    	if ok {
    		err = s.store.Delete(b)
    		if err != nil {
    			return err
    		}
    	}
    
    	return nil
    
    }
    
    func newBackoffStore() *backoffStore {
    	return &backoffStore{
    		store: cache.NewStore(backoffRecordKeyFunc),
    	}
    }
    
    var backoffRecordKeyFunc = func(obj interface{}) (string, error) {
    	if u, ok := obj.(*backoffRecord); ok {
    		return u.key, nil
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Jun 06 07:46:41 UTC 2024
    - 8.3K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apiserver/pkg/storage/etcd3/store_test.go

    	for _, opt := range opts {
    		opt(&setupOpts)
    	}
    	client := setupOpts.client(t)
    	if setupOpts.recorderEnabled {
    		client.KV = &clientRecorder{KV: client.KV}
    	}
    	store := newStore(
    		client,
    		setupOpts.codec,
    		setupOpts.newFunc,
    		setupOpts.newListFunc,
    		setupOpts.prefix,
    		setupOpts.resourcePrefix,
    		setupOpts.groupResource,
    		setupOpts.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)
Back to top