Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 19 for continuetoken (0.18 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top