- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 19 for continuetoken (0.33 sec)
-
staging/src/k8s.io/api/storagemigration/v1alpha1/types.go
// to migrate. When the .status.conditions indicates the migration is // "Running", users can use this token to check the progress of the // migration. // +optional ContinueToken string `json:"continueToken,omitempty" protobuf:"bytes,2,opt,name=continueToken"` // TODO: consider recording the storage version hash when the migration // is created. It can avoid races. } // The names of the group, the version, and the resource.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 08 04:18:56 UTC 2024 - 5.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/continue.go
) // continueToken is a simple structured object for encoding the state of a continue token. // TODO: if we change the version of the encoded from, we can't start encoding the new version // until all other servers are upgraded (i.e. we need to support rolling schema) // This is a public API struct and cannot change. type continueToken struct { APIVersion string `json:"v"`
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/api/testdata/HEAD/storagemigration.k8s.io.v1alpha1.StorageVersionMigration.json
"subresource": "subresourceValue" } ] }, "spec": { "resource": { "group": "groupValue", "version": "versionValue", "resource": "resourceValue" }, "continueToken": "continueTokenValue" }, "status": { "conditions": [ { "type": "typeValue", "status": "statusValue", "lastUpdateTime": "2003-01-01T01:01:01Z",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 08 04:18:56 UTC 2024 - 1.6K bytes - Viewed (0) -
staging/src/k8s.io/api/testdata/HEAD/storagemigration.k8s.io.v1alpha1.StorageVersionMigration.yaml
blockOwnerDeletion: true controller: true kind: kindValue name: nameValue uid: uidValue resourceVersion: resourceVersionValue selfLink: selfLinkValue uid: uidValue spec: continueToken: continueTokenValue resource: group: groupValue resource: resourceValue version: versionValue status: conditions: - lastUpdateTime: "2003-01-01T01:01:01Z" message: messageValue
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 08 04:18:56 UTC 2024 - 1.2K bytes - Viewed (0) -
pkg/apis/storagemigration/v1alpha1/zz_generated.conversion.go
if err := Convert_v1alpha1_GroupVersionResource_To_storagemigration_GroupVersionResource(&in.Resource, &out.Resource, s); err != nil { return err } out.ContinueToken = in.ContinueToken return nil } // Convert_v1alpha1_StorageVersionMigrationSpec_To_storagemigration_StorageVersionMigrationSpec is an autogenerated conversion function.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 08 04:18:56 UTC 2024 - 16K bytes - Viewed (0) -
staging/src/k8s.io/api/testdata/v1.30.0/storagemigration.k8s.io.v1alpha1.StorageVersionMigration.json
"subresource": "subresourceValue" } ] }, "spec": { "resource": { "group": "groupValue", "version": "versionValue", "resource": "resourceValue" }, "continueToken": "continueTokenValue" }, "status": { "conditions": [ { "type": "typeValue", "status": "statusValue", "lastUpdateTime": "2003-01-01T01:01:01Z",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 08:52:25 UTC 2024 - 1.6K bytes - Viewed (0) -
staging/src/k8s.io/api/testdata/v1.30.0/storagemigration.k8s.io.v1alpha1.StorageVersionMigration.yaml
blockOwnerDeletion: true controller: true kind: kindValue name: nameValue uid: uidValue resourceVersion: resourceVersionValue selfLink: selfLinkValue uid: uidValue spec: continueToken: continueTokenValue resource: group: groupValue resource: resourceValue version: versionValue status: conditions: - lastUpdateTime: "2003-01-01T01:01:01Z" message: messageValue
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 08:52:25 UTC 2024 - 1.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/continue_test.go
package storage import ( "encoding/base64" "encoding/json" "errors" "testing" ) func encodeContinueOrDie(apiVersion string, resourceVersion int64, nextKey string) string { out, err := json.Marshal(&continueToken{APIVersion: apiVersion, ResourceVersion: resourceVersion, StartKey: nextKey}) if err != nil { panic(err) } return base64.RawURLEncoding.EncodeToString(out) } func Test_decodeContinue(t *testing.T) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 31 17:30:02 UTC 2022 - 3.5K bytes - Viewed (0) -
pkg/apis/storagemigration/types.go
// to migrate. When the .status.conditions indicates the migration is // "Running", users can use this token to check the progress of the // migration. // +optional ContinueToken string // TODO: consider recording the storage version hash when the migration // is created. It can avoid races. } // The names of the group, the version, and the resource. type GroupVersionResource struct {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 08 04:18:56 UTC 2024 - 4.1K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/etcd3/errors.go
return handleCompactedErrorForPaging(continueKey, keyPrefix) } return errors.NewResourceExpired(expired) } return err } func handleCompactedErrorForPaging(continueKey, keyPrefix string) error { // continueToken.ResoureVersion=-1 means that the apiserver can // continue the list at the latest resource version. We don't use rv=0 // for this purpose to distinguish from a bad token that has empty rv.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 11 15:59:41 UTC 2022 - 2.5K bytes - Viewed (0)