- Sort Score
- Result 10 results
- Languages All
Results 1 - 4 of 4 for DecodeContinue (0.14 sec)
-
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) -
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) -
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) -
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)