Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for DecodeContinue (0.14 sec)

  1. staging/src/k8s.io/apiserver/pkg/storage/continue_test.go

    	for _, tt := range tests {
    		t.Run(tt.name, func(t *testing.T) {
    			gotFromKey, gotRv, err := DecodeContinue(tt.args.continueValue, tt.args.keyPrefix)
    			if !errors.Is(err, tt.wantErr) {
    				t.Errorf("decodeContinue() error = %v, wantErr %v", err, tt.wantErr)
    				return
    			}
    			if gotFromKey != tt.wantFromKey {
    				t.Errorf("decodeContinue() gotFromKey = %v, want %v", gotFromKey, tt.wantFromKey)
    			}
    			if gotRv != tt.wantRv {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 31 17:30:02 UTC 2022
    - 3.5K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apiserver/pkg/storage/continue.go

    	APIVersion      string `json:"v"`
    	ResourceVersion int64  `json:"rv"`
    	StartKey        string `json:"start"`
    }
    
    // DecodeContinue transforms an encoded predicate from into a versioned struct.
    // TODO: return a typed error that instructs clients that they must relist
    func DecodeContinue(continueValue, keyPrefix string) (fromKey string, rv int64, err error) {
    	data, err := base64.RawURLEncoding.DecodeString(continueValue)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 31 17:30:02 UTC 2022
    - 3.5K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apiserver/pkg/storage/etcd3/store.go

    	}
    
    	newItemFunc := getNewItemFunc(listObj, v)
    
    	var continueRV, withRev int64
    	var continueKey string
    	if opts.Recursive && len(opts.Predicate.Continue) > 0 {
    		continueKey, continueRV, err = storage.DecodeContinue(opts.Predicate.Continue, keyPrefix)
    		if err != nil {
    			return apierrors.NewBadRequest(fmt.Sprintf("invalid continue token: %v", err))
    		}
    		preparedKey = continueKey
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 10 11:56:42 UTC 2024
    - 35.2K bytes
    - Viewed (0)
  4. staging/src/k8s.io/apiserver/pkg/storage/testing/store_tests.go

    		t.Fatalf("Unable to get second page: %v", err)
    	}
    	if len(out.Continue) != 0 {
    		t.Fatalf("Unexpected continuation token set")
    	}
    	key, rv, err := storage.DecodeContinue(continueFromSecondItem, "/pods")
    	t.Logf("continue token was %d %s %v", rv, key, err)
    	expectNoDiff(t, "incorrect second page", []example.Pod{*preset[1].storedObj, *preset[2].storedObj}, out.Items)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 11 12:45:33 UTC 2024
    - 91.4K bytes
    - Viewed (0)
Back to top