v1alpha1

package
v0.0.1 Latest Latest
Warning

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

 Go to latest Published: Jun 25, 2024 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Overview

Package v1alpha1 contains API Schema definitions for the localstorage v1alpha1 API group +k8s:deepcopy-gen=package,register +groupName=datastore.io

Package v1alpha1 contains v1alpha1 API versions.

This file ensures Go source parsers acknowledge the v1alpha1 package and any child packages. It can be removed if any other Go source files are added to this package.

Package v1alpha1 contains API Schema definitions for the localstorage v1alpha1 API group +k8s:deepcopy-gen=package,register +groupName=datastore.io

Index

Constants

View Source 
const (
	DataSourceTypeMinIO   = "minio"
	DataSourceTypeAWSS3   = "aws-s3"
	DataSourceTypeNFS     = "nfs"
	DataSourceTypeFTP     = "ftp"
	DataSourceTypeUnknown = "unknown"
)
View Source 
const (
	DataSourceConnectionCheckInterval = 1 * time.Minute
)

Variables

View Source 
var (
	// SchemeGroupVersion is group version used to register these objects
	SchemeGroupVersion = schema.GroupVersion{Group: "datastore.io", Version: "v1alpha1"}

	// SchemeBuilder is used to add go types to the GroupVersionKind scheme for Local Storage Member
	SchemeBuilder = &scheme.Builder{GroupVersion: SchemeGroupVersion}
)
View Source 
var AddToSchemes runtime.SchemeBuilder

AddToSchemes may be used to add all resources defined in the project to a Scheme for Local Storage Member

Functions

func AddToScheme 

func AddToScheme(s *runtime.Scheme) error

AddToScheme adds all Resources to the Scheme for Local Storage Member

func Kind 

func Kind(kind string) schema.GroupKind

Kind takes an unqualified kind and returns back 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 BaseModel 

type BaseModel struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   BaseModelSpec   `json:"spec,omitempty"`
	Status BaseModelStatus `json:"status,omitempty"`
}

BaseModel is the Schema for the basemodels API +kubebuilder:subresource:status +kubebuilder:resource:path=basemodels,scope=Namespaced,shortName=bm

func (*BaseModel) DeepCopy 

func (in *BaseModel) DeepCopy() *BaseModel

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

func (*BaseModel) DeepCopyInto 

func (in *BaseModel) DeepCopyInto(out *BaseModel)

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

func (*BaseModel) DeepCopyObject 

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

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

type BaseModelList 

type BaseModelList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []BaseModel `json:"items"`
}

BaseModelList contains a list of BaseModel

func (*BaseModelList) DeepCopy 

func (in *BaseModelList) DeepCopy() *BaseModelList

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

func (*BaseModelList) DeepCopyInto 

func (in *BaseModelList) DeepCopyInto(out *BaseModelList)

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

func (*BaseModelList) DeepCopyObject 

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

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

type BaseModelSpec 

type BaseModelSpec struct {
	ModelFileName string `json:"modelName"`

	// +kubebuilder:default:=minio
	Proto string     `json:"proto"`
	MinIO *MinIOSpec `json:"minio,omitempty"`
	NFS   *NFSSpec   `json:"nfs,omitempty"`
	FTP   *FTPSpec   `json:"ftp,omitempty"`
	HTTP  *HTTPSpec  `json:"http,omitempty"`
}

BaseModelSpec defines the desired state of BaseModel

func (*BaseModelSpec) DeepCopy 

func (in *BaseModelSpec) DeepCopy() *BaseModelSpec

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

func (*BaseModelSpec) DeepCopyInto 

func (in *BaseModelSpec) DeepCopyInto(out *BaseModelSpec)

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

type BaseModelStatus 

type BaseModelStatus struct {
}

BaseModelStatus defines the observed state of BaseModel

func (*BaseModelStatus) DeepCopy 

func (in *BaseModelStatus) DeepCopy() *BaseModelStatus

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

func (*BaseModelStatus) DeepCopyInto 

func (in *BaseModelStatus) DeepCopyInto(out *BaseModelStatus)

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

type Checkpoint 

type Checkpoint struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   CheckpointSpec   `json:"spec,omitempty"`
	Status CheckpointStatus `json:"status,omitempty"`
}

Checkpoint is the Schema for the checkpoints API +kubebuilder:subresource:status +kubebuilder:resource:path=checkpoints,scope=Namespaced,shortName=ckpt

func (*Checkpoint) DeepCopy 

func (in *Checkpoint) DeepCopy() *Checkpoint

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

func (*Checkpoint) DeepCopyInto 

func (in *Checkpoint) DeepCopyInto(out *Checkpoint)

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

func (*Checkpoint) DeepCopyObject 

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

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

type CheckpointBackup 

type CheckpointBackup struct {
	// +kubebuilder:default:=minio
	Proto string     `json:"proto"`
	MinIO *MinIOSpec `json:"minio,omitempty"`
}

func (*CheckpointBackup) DeepCopy 

func (in *CheckpointBackup) DeepCopy() *CheckpointBackup

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

func (*CheckpointBackup) DeepCopyInto 

func (in *CheckpointBackup) DeepCopyInto(out *CheckpointBackup)

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

type CheckpointList 

type CheckpointList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []Checkpoint `json:"items"`
}

CheckpointList contains a list of Checkpoint

func (*CheckpointList) DeepCopy 

func (in *CheckpointList) DeepCopy() *CheckpointList

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

func (*CheckpointList) DeepCopyInto 

func (in *CheckpointList) DeepCopyInto(out *CheckpointList)

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

func (*CheckpointList) DeepCopyObject 

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

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

type CheckpointRecord 

type CheckpointRecord struct {
	Name      string `json:"name"`
	NodeName  string `json:"node"`
	Checksum  string `json:"checksum"`
	DirOnHost string `json:"hostdir"`
	// +kubebuilder:default:=false
	BackedUp    bool         `json:"backedup"`
	Size        string       `json:"size"`
	CreateTime  *metav1.Time `json:"created"`
	ExpiredTime *metav1.Time `json:"expired,omitempty"`
}

func (*CheckpointRecord) DeepCopy 

func (in *CheckpointRecord) DeepCopy() *CheckpointRecord

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

func (*CheckpointRecord) DeepCopyInto 

func (in *CheckpointRecord) DeepCopyInto(out *CheckpointRecord)

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

type CheckpointSpec 

type CheckpointSpec struct {

	// +kubebuilder:default:=2
	RetainCount int64 `json:"retain"`

	Backup *CheckpointBackup `json:"backup,omitempty"`
}

CheckpointSpec defines the desired state of Checkpoint

func (*CheckpointSpec) DeepCopy 

func (in *CheckpointSpec) DeepCopy() *CheckpointSpec

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

func (*CheckpointSpec) DeepCopyInto 

func (in *CheckpointSpec) DeepCopyInto(out *CheckpointSpec)

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

type CheckpointStatus 

type CheckpointStatus struct {
	Records []*CheckpointRecord `json:"records"`
}

CheckpointStatus defines the observed state of Checkpoint

func (*CheckpointStatus) DeepCopy 

func (in *CheckpointStatus) DeepCopy() *CheckpointStatus

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

func (*CheckpointStatus) DeepCopyInto 

func (in *CheckpointStatus) DeepCopyInto(out *CheckpointStatus)

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

type DataLoadRequest 

type DataLoadRequest struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   DataLoadRequestSpec   `json:"spec,omitempty"`
	Status DataLoadRequestStatus `json:"status,omitempty"`
}

DataLoadRequest is the Schema for the dataloadrequests API +kubebuilder:subresource:status +kubebuilder:resource:path=dataloadrequests,scope=Namespaced,shortName=dlr +kubebuilder:printcolumn:JSONPath=".spec.dataSet",name=DataSet,type=string +kubebuilder:printcolumn:JSONPath=".spec.subDir",name=SubDir,type=string +kubebuilder:printcolumn:JSONPath=".metadata.creationTimestamp",name=Age,type=date

func (*DataLoadRequest) DeepCopy 

func (in *DataLoadRequest) DeepCopy() *DataLoadRequest

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

func (*DataLoadRequest) DeepCopyInto 

func (in *DataLoadRequest) DeepCopyInto(out *DataLoadRequest)

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

func (*DataLoadRequest) DeepCopyObject 

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

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

type DataLoadRequestList 

type DataLoadRequestList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []DataLoadRequest `json:"items"`
}

DataLoadRequestList contains a list of DataLoadRequest

func (*DataLoadRequestList) DeepCopy 

func (in *DataLoadRequestList) DeepCopy() *DataLoadRequestList

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

func (*DataLoadRequestList) DeepCopyInto 

func (in *DataLoadRequestList) DeepCopyInto(out *DataLoadRequestList)

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

func (*DataLoadRequestList) DeepCopyObject 

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

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

type DataLoadRequestSpec 

type DataLoadRequestSpec struct {

	// indicate if the request is for all or not
	// +kubebuilder:default:=true
	IsGlobal bool `json:"isGlobal"`
	// name of the node who will loads the data, and it works only when isglobal is false
	Node string `json:"node,omitempty"`

	// name of the dataSet source
	DataSet string `json:"dataSet"`
	SubDir  string `json:"subDir,omitempty"`
	DstDir  string `json:"dstDir,omitempty"`
}

DataLoadRequestSpec defines the desired state of DataLoadRequest

func (*DataLoadRequestSpec) DeepCopy 

func (in *DataLoadRequestSpec) DeepCopy() *DataLoadRequestSpec

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

func (*DataLoadRequestSpec) DeepCopyInto 

func (in *DataLoadRequestSpec) DeepCopyInto(out *DataLoadRequestSpec)

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

type DataLoadRequestStatus 

type DataLoadRequestStatus struct {

	// when a node finishes the data loading, record it here
	ReadyNodes []string `json:"readyNodes"`
	// State of the operation, e.g. submitted, started, completed, abort, ...
	State State `json:"state,omitempty"`
}

DataLoadRequestStatus defines the observed state of DataLoadRequest

func (*DataLoadRequestStatus) DeepCopy 

func (in *DataLoadRequestStatus) DeepCopy() *DataLoadRequestStatus

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

func (*DataLoadRequestStatus) DeepCopyInto 

func (in *DataLoadRequestStatus) DeepCopyInto(out *DataLoadRequestStatus)

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

type DataSet 

type DataSet struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   DataSetSpec   `json:"spec,omitempty"`
	Status DataSetStatus `json:"status,omitempty"`
}

DataSet is the Schema for the DataSets API +kubebuilder:subresource:status +kubebuilder:resource:path=datasets,scope=Namespaced,shortName=dsrc +kubebuilder:printcolumn:JSONPath=".spec.type",name=Type,type=string +kubebuilder:printcolumn:JSONPath=".status.lastRefreshTime",name=LastRefreshTime,type=date +kubebuilder:printcolumn:JSONPath=".spec.refresh",name=Refresh,type=boolean,priority=1 +kubebuilder:printcolumn:JSONPath=".status.refreshCount",name=RefreshCount,type=integer,priority=1 +kubebuilder:printcolumn:JSONPath=".status.connected",name=Connected,type=boolean +kubebuilder:printcolumn:JSONPath=".metadata.creationTimestamp",name=Age,type=date +kubebuilder:printcolumn:JSONPath=".status.error",name=Error,type=string

func (*DataSet) DeepCopy 

func (in *DataSet) DeepCopy() *DataSet

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

func (*DataSet) DeepCopyInto 

func (in *DataSet) DeepCopyInto(out *DataSet)

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

func (*DataSet) DeepCopyObject 

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

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

type DataSetList 

type DataSetList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []DataSet `json:"items"`
}

DataSetList contains a list of DataSet

func (*DataSetList) DeepCopy 

func (in *DataSetList) DeepCopy() *DataSetList

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

func (*DataSetList) DeepCopyInto 

func (in *DataSetList) DeepCopyInto(out *DataSetList)

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

func (*DataSetList) DeepCopyObject 

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

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

type DataSetSpec 

type DataSetSpec struct {

	// type of data source
	// +kubebuilder:validation:Enum:=minio;aws-s3;nfs;ftp;unknown
	// +kubebuilder:default:=unknown
	Type string `json:"type"`

	MinIO *MinIOSpec `json:"minio,omitempty"`

	NFS *NFSSpec `json:"nfs,omitempty"`

	FTP *FTPSpec `json:"ftp,omitempty"`

	CapacityBytes int64 `json:"capacityBytes,omitempty"`

	// indicate if refresh data or not
	// +kubebuilder:default:=true
	Refresh bool `json:"refresh"`
}

DataSetSpec defines the desired state of DataSet

func (*DataSetSpec) DeepCopy 

func (in *DataSetSpec) DeepCopy() *DataSetSpec

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

func (*DataSetSpec) DeepCopyInto 

func (in *DataSetSpec) DeepCopyInto(out *DataSetSpec)

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

type DataSetStatus 

type DataSetStatus struct {

	// is the data source connected or accessible?
	// +kubebuilder:default:=false
	Connected bool `json:"connected"`

	// how many time the data of backend have been refreshed
	// +kubebuilder:default:=0
	RefreshCount int `json:"refreshCount"`

	// last time to refresh the data from the backend
	LastRefreshTimestamp *metav1.Time `json:"lastRefreshTime,omitempty"`

	// any error message
	Error string `json:"error,omitempty"`
}

DataSetStatus defines the observed state of DataSet

func (*DataSetStatus) DeepCopy 

func (in *DataSetStatus) DeepCopy() *DataSetStatus

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

func (*DataSetStatus) DeepCopyInto 

func (in *DataSetStatus) DeepCopyInto(out *DataSetStatus)

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

type FTPSpec 

type FTPSpec struct {
	Endpoint string `json:"endpoint,omitempty"`
	// +kubebuilder:default:=/
	Dir           string `json:"dir"`
	LoginUser     string `json:"user"`
	LoginPassword string `json:"password"`
}

func (*FTPSpec) DeepCopy 

func (in *FTPSpec) DeepCopy() *FTPSpec

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

func (*FTPSpec) DeepCopyInto 

func (in *FTPSpec) DeepCopyInto(out *FTPSpec)

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

type HTTPSpec 

type HTTPSpec struct {
	Url string `json:"url"`
}

func (*HTTPSpec) DeepCopy 

func (in *HTTPSpec) DeepCopy() *HTTPSpec

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

func (*HTTPSpec) DeepCopyInto 

func (in *HTTPSpec) DeepCopyInto(out *HTTPSpec)

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

type MinIOSpec 

type MinIOSpec struct {
	Endpoint  string `json:"endpoint,omitempty"`
	Region    string `json:"region,omitempty"`
	Bucket    string `json:"bucket"`
	Prefix    string `json:"prefix,omitempty"`
	SecretKey string `json:"secretKey"`
	AccessKey string `json:"accessKey"`
}

func (*MinIOSpec) DeepCopy 

func (in *MinIOSpec) DeepCopy() *MinIOSpec

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

func (*MinIOSpec) DeepCopyInto 

func (in *MinIOSpec) DeepCopyInto(out *MinIOSpec)

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

type NFSSpec 

type NFSSpec struct {
	Endpoint string `json:"endpoint,omitempty"`
	Export   string `json:"export"`
	// +kubebuilder:default:=.
	RootDir string `json:"rootdir"`
}

func (*NFSSpec) DeepCopy 

func (in *NFSSpec) DeepCopy() *NFSSpec

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

func (*NFSSpec) DeepCopyInto 

func (in *NFSSpec) DeepCopyInto(out *NFSSpec)

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

type SSHSpec 

type SSHSpec struct {
	Node string `json:"node,omitempty"`
	// +kubebuilder:default:=22
	Port          int64  `json:"port"`
	Dir           string `json:"dir"`
	LoginUser     string `json:"user"`
	LoginPassword string `json:"password"`
}

func (*SSHSpec) DeepCopy 

func (in *SSHSpec) DeepCopy() *SSHSpec

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

func (*SSHSpec) DeepCopyInto 

func (in *SSHSpec) DeepCopyInto(out *SSHSpec)

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

type State 

type State string
const (
	OperationStateStart       State = "Submitted"
	OperationStateCompleted   State = "Completed"
	OperationStateToBeAborted State = "ToBeAborted"
	OperationStateAborting    State = "Cancelled"
	OperationStateAborted     State = "Aborted"
	OperationStateFailed      State = "Failed"
)

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.