GroupName is the group name use in this package
const GroupName = "storagemigration.k8s.io"
var (
ErrInvalidLengthGenerated = fmt.Errorf("proto: negative length found during unmarshaling")
ErrIntOverflowGenerated = fmt.Errorf("proto: integer overflow")
ErrUnexpectedEndOfGroupGenerated = fmt.Errorf("proto: unexpected end of group")
)
var (
SchemeBuilder = runtime.NewSchemeBuilder(addKnownTypes)
AddToScheme = localSchemeBuilder.AddToScheme
)
SchemeGroupVersion is group version used to register these objects
var SchemeGroupVersion = schema.GroupVersion{Group: GroupName, Version: "v1alpha1"}
func Kind(kind string) schema.GroupKind
Kind takes an unqualified kind and returns a Group qualified GroupKind
func Resource(resource string) schema.GroupResource
Resource takes an unqualified resource and returns a Group qualified GroupResource
The names of the group, the version, and the resource.
type GroupVersionResource struct {
// The name of the group.
Group string `json:"group,omitempty" protobuf:"bytes,1,opt,name=group"`
// The name of the version.
Version string `json:"version,omitempty" protobuf:"bytes,2,opt,name=version"`
// The name of the resource.
Resource string `json:"resource,omitempty" protobuf:"bytes,3,opt,name=resource"`
}
func (in *GroupVersionResource) DeepCopy() *GroupVersionResource
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new GroupVersionResource.
func (in *GroupVersionResource) DeepCopyInto(out *GroupVersionResource)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*GroupVersionResource) Descriptor() ([]byte, []int)
func (m *GroupVersionResource) Marshal() (dAtA []byte, err error)
func (m *GroupVersionResource) MarshalTo(dAtA []byte) (int, error)
func (m *GroupVersionResource) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*GroupVersionResource) ProtoMessage()
func (m *GroupVersionResource) Reset()
func (m *GroupVersionResource) Size() (n int)
func (this *GroupVersionResource) String() string
func (GroupVersionResource) SwaggerDoc() map[string]string
func (m *GroupVersionResource) Unmarshal(dAtA []byte) error
func (m *GroupVersionResource) XXX_DiscardUnknown()
func (m *GroupVersionResource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (m *GroupVersionResource) XXX_Merge(src proto.Message)
func (m *GroupVersionResource) XXX_Size() int
func (m *GroupVersionResource) XXX_Unmarshal(b []byte) error
Describes the state of a migration at a certain point.
type MigrationCondition struct {
// Type of the condition.
Type MigrationConditionType `json:"type" protobuf:"bytes,1,opt,name=type,casttype=MigrationConditionType"`
// Status of the condition, one of True, False, Unknown.
Status corev1.ConditionStatus `json:"status" protobuf:"bytes,2,opt,name=status,casttype=k8s.io/api/core/v1.ConditionStatus"`
// The last time this condition was updated.
// +optional
LastUpdateTime metav1.Time `json:"lastUpdateTime,omitempty" protobuf:"bytes,3,opt,name=lastUpdateTime"`
// The reason for the condition's last transition.
// +optional
Reason string `json:"reason,omitempty" protobuf:"bytes,4,opt,name=reason"`
// A human readable message indicating details about the transition.
// +optional
Message string `json:"message,omitempty" protobuf:"bytes,5,opt,name=message"`
}
func (in *MigrationCondition) DeepCopy() *MigrationCondition
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new MigrationCondition.
func (in *MigrationCondition) DeepCopyInto(out *MigrationCondition)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*MigrationCondition) Descriptor() ([]byte, []int)
func (m *MigrationCondition) Marshal() (dAtA []byte, err error)
func (m *MigrationCondition) MarshalTo(dAtA []byte) (int, error)
func (m *MigrationCondition) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MigrationCondition) ProtoMessage()
func (m *MigrationCondition) Reset()
func (m *MigrationCondition) Size() (n int)
func (this *MigrationCondition) String() string
func (MigrationCondition) SwaggerDoc() map[string]string
func (m *MigrationCondition) Unmarshal(dAtA []byte) error
func (m *MigrationCondition) XXX_DiscardUnknown()
func (m *MigrationCondition) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (m *MigrationCondition) XXX_Merge(src proto.Message)
func (m *MigrationCondition) XXX_Size() int
func (m *MigrationCondition) XXX_Unmarshal(b []byte) error
type MigrationConditionType string
const (
// Indicates that the migration is running.
MigrationRunning MigrationConditionType = "Running"
// Indicates that the migration has completed successfully.
MigrationSucceeded MigrationConditionType = "Succeeded"
// Indicates that the migration has failed.
MigrationFailed MigrationConditionType = "Failed"
)
StorageVersionMigration represents a migration of stored data to the latest storage version.
type StorageVersionMigration struct {
metav1.TypeMeta `json:",inline"`
// Standard object metadata.
// More info: https://git.k8s.io/community/contributors/devel/sig-architecture/api-conventions.md#metadata
// +optional
metav1.ObjectMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`
// Specification of the migration.
// +optional
Spec StorageVersionMigrationSpec `json:"spec,omitempty" protobuf:"bytes,2,opt,name=spec"`
// Status of the migration.
// +optional
Status StorageVersionMigrationStatus `json:"status,omitempty" protobuf:"bytes,3,opt,name=status"`
}
func (in *StorageVersionMigration) APILifecycleDeprecated() (major, minor int)
APILifecycleDeprecated is an autogenerated function, returning the release in which the API struct was or will be deprecated as int versions of major and minor for comparison. It is controlled by "k8s:prerelease-lifecycle-gen:deprecated" tags in types.go or "k8s:prerelease-lifecycle-gen:introduced" plus three minor.
func (in *StorageVersionMigration) APILifecycleIntroduced() (major, minor int)
APILifecycleIntroduced is an autogenerated function, returning the release in which the API struct was introduced as int versions of major and minor for comparison. It is controlled by "k8s:prerelease-lifecycle-gen:introduced" tags in types.go.
func (in *StorageVersionMigration) APILifecycleRemoved() (major, minor int)
APILifecycleRemoved is an autogenerated function, returning the release in which the API is no longer served as int versions of major and minor for comparison. It is controlled by "k8s:prerelease-lifecycle-gen:removed" tags in types.go or "k8s:prerelease-lifecycle-gen:deprecated" plus three minor.
func (in *StorageVersionMigration) DeepCopy() *StorageVersionMigration
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StorageVersionMigration.
func (in *StorageVersionMigration) DeepCopyInto(out *StorageVersionMigration)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (in *StorageVersionMigration) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (*StorageVersionMigration) Descriptor() ([]byte, []int)
func (m *StorageVersionMigration) Marshal() (dAtA []byte, err error)
func (m *StorageVersionMigration) MarshalTo(dAtA []byte) (int, error)
func (m *StorageVersionMigration) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*StorageVersionMigration) ProtoMessage()
func (m *StorageVersionMigration) Reset()
func (m *StorageVersionMigration) Size() (n int)
func (this *StorageVersionMigration) String() string
func (StorageVersionMigration) SwaggerDoc() map[string]string
func (m *StorageVersionMigration) Unmarshal(dAtA []byte) error
func (m *StorageVersionMigration) XXX_DiscardUnknown()
func (m *StorageVersionMigration) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (m *StorageVersionMigration) XXX_Merge(src proto.Message)
func (m *StorageVersionMigration) XXX_Size() int
func (m *StorageVersionMigration) XXX_Unmarshal(b []byte) error
StorageVersionMigrationList is a collection of storage version migrations.
type StorageVersionMigrationList struct {
metav1.TypeMeta `json:",inline"`
// Standard list metadata
// More info: https://git.k8s.io/community/contributors/devel/sig-architecture/api-conventions.md#metadata
// +optional
metav1.ListMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`
// Items is the list of StorageVersionMigration
// +patchMergeKey=type
// +patchStrategy=merge
// +listType=map
// +listMapKey=type
Items []StorageVersionMigration `json:"items" listType:"map" listMapKey:"type" patchStrategy:"merge" patchMergeKey:"type" protobuf:"bytes,2,rep,name=items"`
}
func (in *StorageVersionMigrationList) APILifecycleDeprecated() (major, minor int)
APILifecycleDeprecated is an autogenerated function, returning the release in which the API struct was or will be deprecated as int versions of major and minor for comparison. It is controlled by "k8s:prerelease-lifecycle-gen:deprecated" tags in types.go or "k8s:prerelease-lifecycle-gen:introduced" plus three minor.
func (in *StorageVersionMigrationList) APILifecycleIntroduced() (major, minor int)
APILifecycleIntroduced is an autogenerated function, returning the release in which the API struct was introduced as int versions of major and minor for comparison. It is controlled by "k8s:prerelease-lifecycle-gen:introduced" tags in types.go.
func (in *StorageVersionMigrationList) APILifecycleRemoved() (major, minor int)
APILifecycleRemoved is an autogenerated function, returning the release in which the API is no longer served as int versions of major and minor for comparison. It is controlled by "k8s:prerelease-lifecycle-gen:removed" tags in types.go or "k8s:prerelease-lifecycle-gen:deprecated" plus three minor.
func (in *StorageVersionMigrationList) DeepCopy() *StorageVersionMigrationList
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StorageVersionMigrationList.
func (in *StorageVersionMigrationList) DeepCopyInto(out *StorageVersionMigrationList)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (in *StorageVersionMigrationList) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (*StorageVersionMigrationList) Descriptor() ([]byte, []int)
func (m *StorageVersionMigrationList) Marshal() (dAtA []byte, err error)
func (m *StorageVersionMigrationList) MarshalTo(dAtA []byte) (int, error)
func (m *StorageVersionMigrationList) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*StorageVersionMigrationList) ProtoMessage()
func (m *StorageVersionMigrationList) Reset()
func (m *StorageVersionMigrationList) Size() (n int)
func (this *StorageVersionMigrationList) String() string
func (StorageVersionMigrationList) SwaggerDoc() map[string]string
func (m *StorageVersionMigrationList) Unmarshal(dAtA []byte) error
func (m *StorageVersionMigrationList) XXX_DiscardUnknown()
func (m *StorageVersionMigrationList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (m *StorageVersionMigrationList) XXX_Merge(src proto.Message)
func (m *StorageVersionMigrationList) XXX_Size() int
func (m *StorageVersionMigrationList) XXX_Unmarshal(b []byte) error
Spec of the storage version migration.
type StorageVersionMigrationSpec struct {
// The resource that is being migrated. The migrator sends requests to
// the endpoint serving the resource.
// Immutable.
Resource GroupVersionResource `json:"resource" protobuf:"bytes,1,opt,name=resource"`
// The token used in the list options to get the next chunk of objects
// 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"`
}
func (in *StorageVersionMigrationSpec) DeepCopy() *StorageVersionMigrationSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StorageVersionMigrationSpec.
func (in *StorageVersionMigrationSpec) DeepCopyInto(out *StorageVersionMigrationSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*StorageVersionMigrationSpec) Descriptor() ([]byte, []int)
func (m *StorageVersionMigrationSpec) Marshal() (dAtA []byte, err error)
func (m *StorageVersionMigrationSpec) MarshalTo(dAtA []byte) (int, error)
func (m *StorageVersionMigrationSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*StorageVersionMigrationSpec) ProtoMessage()
func (m *StorageVersionMigrationSpec) Reset()
func (m *StorageVersionMigrationSpec) Size() (n int)
func (this *StorageVersionMigrationSpec) String() string
func (StorageVersionMigrationSpec) SwaggerDoc() map[string]string
func (m *StorageVersionMigrationSpec) Unmarshal(dAtA []byte) error
func (m *StorageVersionMigrationSpec) XXX_DiscardUnknown()
func (m *StorageVersionMigrationSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (m *StorageVersionMigrationSpec) XXX_Merge(src proto.Message)
func (m *StorageVersionMigrationSpec) XXX_Size() int
func (m *StorageVersionMigrationSpec) XXX_Unmarshal(b []byte) error
Status of the storage version migration.
type StorageVersionMigrationStatus struct {
// The latest available observations of the migration's current state.
// +patchMergeKey=type
// +patchStrategy=merge
// +listType=map
// +listMapKey=type
// +optional
Conditions []MigrationCondition `json:"conditions,omitempty" patchStrategy:"merge" patchMergeKey:"type" protobuf:"bytes,1,rep,name=conditions"`
// ResourceVersion to compare with the GC cache for performing the migration.
// This is the current resource version of given group, version and resource when
// kube-controller-manager first observes this StorageVersionMigration resource.
ResourceVersion string `json:"resourceVersion,omitempty" protobuf:"bytes,2,opt,name=resourceVersion"`
}
func (in *StorageVersionMigrationStatus) DeepCopy() *StorageVersionMigrationStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StorageVersionMigrationStatus.
func (in *StorageVersionMigrationStatus) DeepCopyInto(out *StorageVersionMigrationStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*StorageVersionMigrationStatus) Descriptor() ([]byte, []int)
func (m *StorageVersionMigrationStatus) Marshal() (dAtA []byte, err error)
func (m *StorageVersionMigrationStatus) MarshalTo(dAtA []byte) (int, error)
func (m *StorageVersionMigrationStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*StorageVersionMigrationStatus) ProtoMessage()
func (m *StorageVersionMigrationStatus) Reset()
func (m *StorageVersionMigrationStatus) Size() (n int)
func (this *StorageVersionMigrationStatus) String() string
func (StorageVersionMigrationStatus) SwaggerDoc() map[string]string
func (m *StorageVersionMigrationStatus) Unmarshal(dAtA []byte) error
func (m *StorageVersionMigrationStatus) XXX_DiscardUnknown()
func (m *StorageVersionMigrationStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (m *StorageVersionMigrationStatus) XXX_Merge(src proto.Message)
func (m *StorageVersionMigrationStatus) XXX_Size() int
func (m *StorageVersionMigrationStatus) XXX_Unmarshal(b []byte) error