v1alpha1

package
v0.30.0 Latest Latest
Warning

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

 Go to latest Published: Apr 17, 2024 License: Apache-2.0 Imports: 11 Imported by: 14

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 

func (in *GroupVersionResource) DeepCopy() *GroupVersionResource

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 

func (in *StorageVersionMigration) DeepCopy() *StorageVersionMigration

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 

func (in *StorageVersionMigrationList) DeepCopy() *StorageVersionMigrationList

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

func (*StorageVersionMigrationList) DeepCopyInto 

func (in *StorageVersionMigrationList) DeepCopyInto(out *StorageVersionMigrationList)

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 

func (in *StorageVersionMigrationSpec) DeepCopy() *StorageVersionMigrationSpec

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

func (*StorageVersionMigrationSpec) DeepCopyInto 

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 

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 

func (in *StorageVersionMigrationStatus) DeepCopy() *StorageVersionMigrationStatus

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

func (*StorageVersionMigrationStatus) DeepCopyInto 

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 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.