v1alpha1

package
v0.31.3 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Nov 21, 2024 License: Apache-2.0 Imports: 11 Imported by: 24

Documentation

Index

Constants

View Source
const GroupName = "storagemigration.k8s.io"

GroupName is the group name use in this package

Variables

View Source
var (
	ErrInvalidLengthGenerated        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowGenerated          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupGenerated = fmt.Errorf("proto: unexpected end of group")
)
View Source
var (
	SchemeBuilder = runtime.NewSchemeBuilder(addKnownTypes)

	AddToScheme = localSchemeBuilder.AddToScheme
)
View Source
var SchemeGroupVersion = schema.GroupVersion{Group: GroupName, Version: "v1alpha1"}

SchemeGroupVersion is group version used to register these objects

Functions

func Kind

func Kind(kind string) schema.GroupKind

Kind takes an unqualified kind and returns a Group qualified GroupKind

func Resource

func Resource(resource string) schema.GroupResource

Resource takes an unqualified resource and returns a Group qualified GroupResource

Types

type GroupVersionResource

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"`
}

The names of the group, the version, and the resource.

func (*GroupVersionResource) DeepCopy

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new GroupVersionResource.

func (*GroupVersionResource) DeepCopyInto

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

func (*GroupVersionResource) Descriptor() ([]byte, []int)

func (*GroupVersionResource) Marshal

func (m *GroupVersionResource) Marshal() (dAtA []byte, err error)

func (*GroupVersionResource) MarshalTo

func (m *GroupVersionResource) MarshalTo(dAtA []byte) (int, error)

func (*GroupVersionResource) MarshalToSizedBuffer

func (m *GroupVersionResource) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GroupVersionResource) ProtoMessage

func (*GroupVersionResource) ProtoMessage()

func (*GroupVersionResource) Reset

func (m *GroupVersionResource) Reset()

func (*GroupVersionResource) Size

func (m *GroupVersionResource) Size() (n int)

func (*GroupVersionResource) String

func (this *GroupVersionResource) String() string

func (GroupVersionResource) SwaggerDoc

func (GroupVersionResource) SwaggerDoc() map[string]string

func (*GroupVersionResource) Unmarshal

func (m *GroupVersionResource) Unmarshal(dAtA []byte) error

func (*GroupVersionResource) XXX_DiscardUnknown

func (m *GroupVersionResource) XXX_DiscardUnknown()

func (*GroupVersionResource) XXX_Marshal

func (m *GroupVersionResource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GroupVersionResource) XXX_Merge

func (m *GroupVersionResource) XXX_Merge(src proto.Message)

func (*GroupVersionResource) XXX_Size

func (m *GroupVersionResource) XXX_Size() int

func (*GroupVersionResource) XXX_Unmarshal

func (m *GroupVersionResource) XXX_Unmarshal(b []byte) error

type MigrationCondition

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"`
}

Describes the state of a migration at a certain point.

func (*MigrationCondition) DeepCopy

func (in *MigrationCondition) DeepCopy() *MigrationCondition

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new MigrationCondition.

func (*MigrationCondition) DeepCopyInto

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

func (*MigrationCondition) Descriptor() ([]byte, []int)

func (*MigrationCondition) Marshal

func (m *MigrationCondition) Marshal() (dAtA []byte, err error)

func (*MigrationCondition) MarshalTo

func (m *MigrationCondition) MarshalTo(dAtA []byte) (int, error)

func (*MigrationCondition) MarshalToSizedBuffer

func (m *MigrationCondition) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MigrationCondition) ProtoMessage

func (*MigrationCondition) ProtoMessage()

func (*MigrationCondition) Reset

func (m *MigrationCondition) Reset()

func (*MigrationCondition) Size

func (m *MigrationCondition) Size() (n int)

func (*MigrationCondition) String

func (this *MigrationCondition) String() string

func (MigrationCondition) SwaggerDoc

func (MigrationCondition) SwaggerDoc() map[string]string

func (*MigrationCondition) Unmarshal

func (m *MigrationCondition) Unmarshal(dAtA []byte) error

func (*MigrationCondition) XXX_DiscardUnknown

func (m *MigrationCondition) XXX_DiscardUnknown()

func (*MigrationCondition) XXX_Marshal

func (m *MigrationCondition) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MigrationCondition) XXX_Merge

func (m *MigrationCondition) XXX_Merge(src proto.Message)

func (*MigrationCondition) XXX_Size

func (m *MigrationCondition) XXX_Size() int

func (*MigrationCondition) XXX_Unmarshal

func (m *MigrationCondition) XXX_Unmarshal(b []byte) error

type MigrationConditionType

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"
)

type StorageVersionMigration

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"`
}

StorageVersionMigration represents a migration of stored data to the latest storage version.

func (*StorageVersionMigration) APILifecycleDeprecated

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 (*StorageVersionMigration) APILifecycleIntroduced

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 (*StorageVersionMigration) APILifecycleRemoved

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 (*StorageVersionMigration) DeepCopy

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StorageVersionMigration.

func (*StorageVersionMigration) DeepCopyInto

func (in *StorageVersionMigration) DeepCopyInto(out *StorageVersionMigration)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*StorageVersionMigration) DeepCopyObject

func (in *StorageVersionMigration) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*StorageVersionMigration) Descriptor

func (*StorageVersionMigration) Descriptor() ([]byte, []int)

func (*StorageVersionMigration) Marshal

func (m *StorageVersionMigration) Marshal() (dAtA []byte, err error)

func (*StorageVersionMigration) MarshalTo

func (m *StorageVersionMigration) MarshalTo(dAtA []byte) (int, error)

func (*StorageVersionMigration) MarshalToSizedBuffer

func (m *StorageVersionMigration) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*StorageVersionMigration) ProtoMessage

func (*StorageVersionMigration) ProtoMessage()

func (*StorageVersionMigration) Reset

func (m *StorageVersionMigration) Reset()

func (*StorageVersionMigration) Size

func (m *StorageVersionMigration) Size() (n int)

func (*StorageVersionMigration) String

func (this *StorageVersionMigration) String() string

func (StorageVersionMigration) SwaggerDoc

func (StorageVersionMigration) SwaggerDoc() map[string]string

func (*StorageVersionMigration) Unmarshal

func (m *StorageVersionMigration) Unmarshal(dAtA []byte) error

func (*StorageVersionMigration) XXX_DiscardUnknown

func (m *StorageVersionMigration) XXX_DiscardUnknown()

func (*StorageVersionMigration) XXX_Marshal

func (m *StorageVersionMigration) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StorageVersionMigration) XXX_Merge

func (m *StorageVersionMigration) XXX_Merge(src proto.Message)

func (*StorageVersionMigration) XXX_Size

func (m *StorageVersionMigration) XXX_Size() int

func (*StorageVersionMigration) XXX_Unmarshal

func (m *StorageVersionMigration) XXX_Unmarshal(b []byte) error

type StorageVersionMigrationList

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"`
}

StorageVersionMigrationList is a collection of storage version migrations.

func (*StorageVersionMigrationList) APILifecycleDeprecated

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 (*StorageVersionMigrationList) APILifecycleIntroduced

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 (*StorageVersionMigrationList) APILifecycleRemoved

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 (*StorageVersionMigrationList) DeepCopy

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StorageVersionMigrationList.

func (*StorageVersionMigrationList) DeepCopyInto

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*StorageVersionMigrationList) DeepCopyObject

func (in *StorageVersionMigrationList) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*StorageVersionMigrationList) Descriptor

func (*StorageVersionMigrationList) Descriptor() ([]byte, []int)

func (*StorageVersionMigrationList) Marshal

func (m *StorageVersionMigrationList) Marshal() (dAtA []byte, err error)

func (*StorageVersionMigrationList) MarshalTo

func (m *StorageVersionMigrationList) MarshalTo(dAtA []byte) (int, error)

func (*StorageVersionMigrationList) MarshalToSizedBuffer

func (m *StorageVersionMigrationList) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*StorageVersionMigrationList) ProtoMessage

func (*StorageVersionMigrationList) ProtoMessage()

func (*StorageVersionMigrationList) Reset

func (m *StorageVersionMigrationList) Reset()

func (*StorageVersionMigrationList) Size

func (m *StorageVersionMigrationList) Size() (n int)

func (*StorageVersionMigrationList) String

func (this *StorageVersionMigrationList) String() string

func (StorageVersionMigrationList) SwaggerDoc

func (StorageVersionMigrationList) SwaggerDoc() map[string]string

func (*StorageVersionMigrationList) Unmarshal

func (m *StorageVersionMigrationList) Unmarshal(dAtA []byte) error

func (*StorageVersionMigrationList) XXX_DiscardUnknown

func (m *StorageVersionMigrationList) XXX_DiscardUnknown()

func (*StorageVersionMigrationList) XXX_Marshal

func (m *StorageVersionMigrationList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StorageVersionMigrationList) XXX_Merge

func (m *StorageVersionMigrationList) XXX_Merge(src proto.Message)

func (*StorageVersionMigrationList) XXX_Size

func (m *StorageVersionMigrationList) XXX_Size() int

func (*StorageVersionMigrationList) XXX_Unmarshal

func (m *StorageVersionMigrationList) XXX_Unmarshal(b []byte) error

type StorageVersionMigrationSpec

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"`
}

Spec of the storage version migration.

func (*StorageVersionMigrationSpec) DeepCopy

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StorageVersionMigrationSpec.

func (*StorageVersionMigrationSpec) DeepCopyInto

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*StorageVersionMigrationSpec) Descriptor

func (*StorageVersionMigrationSpec) Descriptor() ([]byte, []int)

func (*StorageVersionMigrationSpec) Marshal

func (m *StorageVersionMigrationSpec) Marshal() (dAtA []byte, err error)

func (*StorageVersionMigrationSpec) MarshalTo

func (m *StorageVersionMigrationSpec) MarshalTo(dAtA []byte) (int, error)

func (*StorageVersionMigrationSpec) MarshalToSizedBuffer

func (m *StorageVersionMigrationSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*StorageVersionMigrationSpec) ProtoMessage

func (*StorageVersionMigrationSpec) ProtoMessage()

func (*StorageVersionMigrationSpec) Reset

func (m *StorageVersionMigrationSpec) Reset()

func (*StorageVersionMigrationSpec) Size

func (m *StorageVersionMigrationSpec) Size() (n int)

func (*StorageVersionMigrationSpec) String

func (this *StorageVersionMigrationSpec) String() string

func (StorageVersionMigrationSpec) SwaggerDoc

func (StorageVersionMigrationSpec) SwaggerDoc() map[string]string

func (*StorageVersionMigrationSpec) Unmarshal

func (m *StorageVersionMigrationSpec) Unmarshal(dAtA []byte) error

func (*StorageVersionMigrationSpec) XXX_DiscardUnknown

func (m *StorageVersionMigrationSpec) XXX_DiscardUnknown()

func (*StorageVersionMigrationSpec) XXX_Marshal

func (m *StorageVersionMigrationSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StorageVersionMigrationSpec) XXX_Merge

func (m *StorageVersionMigrationSpec) XXX_Merge(src proto.Message)

func (*StorageVersionMigrationSpec) XXX_Size

func (m *StorageVersionMigrationSpec) XXX_Size() int

func (*StorageVersionMigrationSpec) XXX_Unmarshal

func (m *StorageVersionMigrationSpec) XXX_Unmarshal(b []byte) error

type StorageVersionMigrationStatus

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"`
}

Status of the storage version migration.

func (*StorageVersionMigrationStatus) DeepCopy

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StorageVersionMigrationStatus.

func (*StorageVersionMigrationStatus) DeepCopyInto

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*StorageVersionMigrationStatus) Descriptor

func (*StorageVersionMigrationStatus) Descriptor() ([]byte, []int)

func (*StorageVersionMigrationStatus) Marshal

func (m *StorageVersionMigrationStatus) Marshal() (dAtA []byte, err error)

func (*StorageVersionMigrationStatus) MarshalTo

func (m *StorageVersionMigrationStatus) MarshalTo(dAtA []byte) (int, error)

func (*StorageVersionMigrationStatus) MarshalToSizedBuffer

func (m *StorageVersionMigrationStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*StorageVersionMigrationStatus) ProtoMessage

func (*StorageVersionMigrationStatus) ProtoMessage()

func (*StorageVersionMigrationStatus) Reset

func (m *StorageVersionMigrationStatus) Reset()

func (*StorageVersionMigrationStatus) Size

func (m *StorageVersionMigrationStatus) Size() (n int)

func (*StorageVersionMigrationStatus) String

func (this *StorageVersionMigrationStatus) String() string

func (StorageVersionMigrationStatus) SwaggerDoc

func (StorageVersionMigrationStatus) SwaggerDoc() map[string]string

func (*StorageVersionMigrationStatus) Unmarshal

func (m *StorageVersionMigrationStatus) Unmarshal(dAtA []byte) error

func (*StorageVersionMigrationStatus) XXX_DiscardUnknown

func (m *StorageVersionMigrationStatus) XXX_DiscardUnknown()

func (*StorageVersionMigrationStatus) XXX_Marshal

func (m *StorageVersionMigrationStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StorageVersionMigrationStatus) XXX_Merge

func (m *StorageVersionMigrationStatus) XXX_Merge(src proto.Message)

func (*StorageVersionMigrationStatus) XXX_Size

func (m *StorageVersionMigrationStatus) XXX_Size() int

func (*StorageVersionMigrationStatus) XXX_Unmarshal

func (m *StorageVersionMigrationStatus) XXX_Unmarshal(b []byte) error

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL