Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for TestListContinuation (0.2 sec)

  1. staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher_test.go

    }
    
    func checkStorageCalls(t *testing.T, pageSize, estimatedProcessedObjects uint64) {
    	// No-op function for now, since cacher passes pagination calls to underlying storage.
    }
    
    func TestListContinuation(t *testing.T) {
    	ctx, cacher, terminate := testSetup(t)
    	t.Cleanup(terminate)
    	storagetesting.RunTestListContinuation(ctx, t, cacher, checkStorageCalls)
    }
    
    func TestListPaginationRareObject(t *testing.T) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 10:12:02 UTC 2024
    - 17K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apiserver/pkg/storage/etcd3/store_test.go

    				sum += currLimit
    				estimatedGetCalls++
    			}
    		}
    		if reads := recorder.GetReadsAndReset(); reads != estimatedGetCalls {
    			t.Errorf("unexpected reads: %d", reads)
    		}
    	}
    }
    
    func TestListContinuation(t *testing.T) {
    	ctx, store, etcdClient := testSetup(t, withRecorder())
    	validation := checkStorageCallsInvariants(
    		store.transformer.(*storagetesting.PrefixTransformer), etcdClient.KV.(*clientRecorder))
    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