Back to godoc.org

Package v1alpha1

v0.0.0-...-afdeb59
Latest Go to latest

The latest major version is .

Published: Jul 3, 2020 | License: Apache-2.0 | Module: github.com/odahu/odahu-flow/packages/operator

Overview

Package v1alpha1 contains API Schema definitions for the odahuflow v1alpha1 API group +kubebuilder:object:generate=true +groupName=odahuflow.odahu.org

Index

Constants

const (
	ModelRouteStateReady      = ModelRouteState("Ready")
	ModelRouteStateProcessing = ModelRouteState("Processing")
	SkipURLValidationKey      = "internal.odahuflow.org.skip_url_validation"
	SkipURLValidationValue    = "true"
)

Variables

var (
	// GroupVersion is group version used to register these objects
	GroupVersion = schema.GroupVersion{Group: "odahuflow.odahu.org", Version: "v1alpha1"}

	// SchemeBuilder is used to add go types to the GroupVersionKind scheme
	SchemeBuilder = &scheme.Builder{GroupVersion: GroupVersion}

	// AddToScheme adds the types in this group-version to the given scheme.
	AddToScheme = SchemeBuilder.AddToScheme
)

type Connection

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

	Spec   ConnectionSpec   `json:"spec,omitempty"`
	Status ConnectionStatus `json:"status,omitempty"`
}

Connection is the Schema for the connections API.

func (*Connection) DeepCopy

func (in *Connection) DeepCopy() *Connection

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

func (*Connection) DeepCopyInto

func (in *Connection) DeepCopyInto(out *Connection)

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

func (*Connection) DeepCopyObject

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

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

type ConnectionList

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

ConnectionList contains a list of Connection.

func (*ConnectionList) DeepCopy

func (in *ConnectionList) DeepCopy() *ConnectionList

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

func (*ConnectionList) DeepCopyInto

func (in *ConnectionList) DeepCopyInto(out *ConnectionList)

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

func (*ConnectionList) DeepCopyObject

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

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

type ConnectionSpec

type ConnectionSpec struct {
	// Required value. Available values:
	//   * s3
	//   * gcs
	//   * azureblob
	//   * git
	//   * docker
	Type ConnectionType `json:"type"`
	// URI. It is required value
	URI string `json:"uri"`
	// AWS region or GCP project
	Region string `json:"region,omitempty"`
	// Username
	Username string `json:"username,omitempty"`
	// Password
	Password string `json:"password,omitempty"`
	// Service account role
	Role string `json:"role,omitempty"`
	// Key ID
	KeyID string `json:"keyID,omitempty"`
	// SSH or service account secret
	KeySecret string `json:"keySecret,omitempty"`
	// SSH public key
	PublicKey string `json:"publicKey,omitempty"`
	// VCS reference
	Reference string `json:"reference,omitempty"`
	// Custom description
	Description string `json:"description,omitempty"`
	// Custom web UI link
	WebUILink string `json:"webUILink,omitempty"`
}

ConnectionSpec defines the desired state of ConnectionName.

func (*ConnectionSpec) DeepCopy

func (in *ConnectionSpec) DeepCopy() *ConnectionSpec

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

func (*ConnectionSpec) DeepCopyInto

func (in *ConnectionSpec) DeepCopyInto(out *ConnectionSpec)

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

type ConnectionStatus

type ConnectionStatus struct {
	// Kubernetes secret name
	SecretName *string `json:"secretName,omitempty"`
	// Kubernetes service account
	ServiceAccountName *string `json:"serviceAccount,omitempty"`
	// Info about create and update
	//CreatedAt *metav1.Time `json:"createdAt,omitempty"`
	//UpdatedAt *metav1.Time `json:"updatedAt,omitempty"`
	Modifiable `json:",inline"`
}

ConnectionStatus defines the observed state of ConnectionName.

func (*ConnectionStatus) DeepCopy

func (in *ConnectionStatus) DeepCopy() *ConnectionStatus

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

func (*ConnectionStatus) DeepCopyInto

func (in *ConnectionStatus) DeepCopyInto(out *ConnectionStatus)

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

type ConnectionType

type ConnectionType string

type DataBindingDir

type DataBindingDir struct {
	// Connection name for data
	Connection string `json:"connName"`
	// Local training path
	LocalPath string `json:"localPath"`
	// Overwrite remote data path in connection
	RemotePath string `json:"remotePath,omitempty"`
}

func (*DataBindingDir) DeepCopy

func (in *DataBindingDir) DeepCopy() *DataBindingDir

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

func (*DataBindingDir) DeepCopyInto

func (in *DataBindingDir) DeepCopyInto(out *DataBindingDir)

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

type EnvironmentVariable

type EnvironmentVariable struct {
	// Name of an environment variable
	Name string `json:"name"`
	// Value of an environment variable
	Value string `json:"value"`
}

func (*EnvironmentVariable) DeepCopy

func (in *EnvironmentVariable) DeepCopy() *EnvironmentVariable

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

func (*EnvironmentVariable) DeepCopyInto

func (in *EnvironmentVariable) DeepCopyInto(out *EnvironmentVariable)

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

type JsonSchema

type JsonSchema struct {
	Properties string   `json:"properties"`
	Required   []string `json:"required,omitempty"`
}

func (*JsonSchema) DeepCopy

func (in *JsonSchema) DeepCopy() *JsonSchema

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

func (*JsonSchema) DeepCopyInto

func (in *JsonSchema) DeepCopyInto(out *JsonSchema)

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

type ModelDeployment

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

	Spec   ModelDeploymentSpec   `json:"spec,omitempty"`
	Status ModelDeploymentStatus `json:"status,omitempty"`
}

ModelDeployment is the Schema for the modeldeployments API +kubebuilder:printcolumn:name="State",type="string",JSONPath=".status.state" +kubebuilder:printcolumn:name="Model image",type="string",JSONPath=".spec.image" +kubebuilder:printcolumn:name="Service URL",type="string",JSONPath=".status.serviceURL" +kubebuilder:printcolumn:name="Available Replicas",type="string",JSONPath=".status.availableReplicas" +kubebuilder:resource:shortName=md

func (*ModelDeployment) DeepCopy

func (in *ModelDeployment) DeepCopy() *ModelDeployment

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

func (*ModelDeployment) DeepCopyInto

func (in *ModelDeployment) DeepCopyInto(out *ModelDeployment)

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

func (*ModelDeployment) DeepCopyObject

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

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

type ModelDeploymentList

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

ModelDeploymentList contains a list of ModelDeployment

func (*ModelDeploymentList) DeepCopy

func (in *ModelDeploymentList) DeepCopy() *ModelDeploymentList

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

func (*ModelDeploymentList) DeepCopyInto

func (in *ModelDeploymentList) DeepCopyInto(out *ModelDeploymentList)

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

func (*ModelDeploymentList) DeepCopyObject

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

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

type ModelDeploymentSpec

type ModelDeploymentSpec struct {
	// Model Docker image
	Image string `json:"image"`
	// Resources for model deployment
	// The same format like k8s uses for pod resources.
	Resources *ResourceRequirements `json:"resources,omitempty"`
	// Annotations for model pods.
	Annotations map[string]string `json:"annotations,omitempty"`
	// Minimum number of pods for model. By default the min replicas parameter equals 0.
	MinReplicas *int32 `json:"minReplicas,omitempty"`
	// Maximum number of pods for model. By default the max replicas parameter equals 1.
	MaxReplicas *int32 `json:"maxReplicas,omitempty"`
	// Initial delay for liveness probe of model pod
	LivenessProbeInitialDelay *int32 `json:"livenessProbeInitialDelay,omitempty"`
	// Initial delay for readiness probe of model pod
	ReadinessProbeInitialDelay *int32 `json:"readinessProbeInitialDelay,omitempty"`
	// Initial delay for readiness probe of model pod
	RoleName *string `json:"roleName,omitempty"`
	// If pulling of your image requires authorization, then you should specify the connection id
	ImagePullConnectionID *string `json:"imagePullConnID,omitempty"`
}

ModelDeploymentSpec defines the desired state of ModelDeployment

func (*ModelDeploymentSpec) DeepCopy

func (in *ModelDeploymentSpec) DeepCopy() *ModelDeploymentSpec

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

func (*ModelDeploymentSpec) DeepCopyInto

func (in *ModelDeploymentSpec) DeepCopyInto(out *ModelDeploymentSpec)

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

type ModelDeploymentState

type ModelDeploymentState string
const (
	ModelDeploymentStateProcessing ModelDeploymentState = "Processing"
	ModelDeploymentStateReady      ModelDeploymentState = "Ready"
	ModelDeploymentStateFailed     ModelDeploymentState = "Failed"
	ModelDeploymentStateDeleting   ModelDeploymentState = "Deleting"
)

type ModelDeploymentStatus

type ModelDeploymentStatus struct {
	// The state of a model deployment.
	//   "Processing" - A model was not deployed. Because some parameters of the
	//                  custom resource are wrong. For example, there is not a model
	//                  image in a Docker registry.
	//   "Ready" - A model was deployed successfully.
	State ModelDeploymentState `json:"state,omitempty"`
	// The model k8s deployment name
	Deployment string `json:"deployment,omitempty"`
	// The model k8s service name
	Service string `json:"service,omitempty"`
	// The model k8s service name
	ServiceURL string `json:"serviceURL,omitempty"`
	// Number of available pods
	AvailableReplicas int32 `json:"availableReplicas"`
	// Expected number of pods under current load
	Replicas int32 `json:"replicas"`
	// Last applied ready knative revision
	LastRevisionName string `json:"lastRevisionName,omitempty"`
	// Time when credentials was updated
	LastCredsUpdatedTime *metav1.Time `json:"lastUpdatedTime,omitempty"`
	// Info about create and update
	//CreatedAt *metav1.Time `json:"createdAt,omitempty"`
	//UpdatedAt *metav1.Time `json:"updatedAt,omitempty"`
	Modifiable `json:",inline"`
}

ModelDeploymentStatus defines the observed state of ModelDeployment

func (*ModelDeploymentStatus) DeepCopy

func (in *ModelDeploymentStatus) DeepCopy() *ModelDeploymentStatus

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

func (*ModelDeploymentStatus) DeepCopyInto

func (in *ModelDeploymentStatus) DeepCopyInto(out *ModelDeploymentStatus)

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

type ModelDeploymentTarget

type ModelDeploymentTarget struct {
	// Model Deployment name
	Name string `json:"mdName"`
	// The proportion of traffic to be forwarded to the Model Deployment.
	Weight *int32 `json:"weight,omitempty"`
}

func (*ModelDeploymentTarget) DeepCopy

func (in *ModelDeploymentTarget) DeepCopy() *ModelDeploymentTarget

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

func (*ModelDeploymentTarget) DeepCopyInto

func (in *ModelDeploymentTarget) DeepCopyInto(out *ModelDeploymentTarget)

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

type ModelIdentity

type ModelIdentity struct {
	// Model name
	Name string `json:"name"`
	// Model version
	Version string `json:"version"`
	// Template of output artifact name
	ArtifactNameTemplate string `json:"artifactNameTemplate,omitempty"`
}

func (*ModelIdentity) DeepCopy

func (in *ModelIdentity) DeepCopy() *ModelIdentity

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

func (*ModelIdentity) DeepCopyInto

func (in *ModelIdentity) DeepCopyInto(out *ModelIdentity)

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

type ModelPackaging

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

	Spec   ModelPackagingSpec   `json:"spec,omitempty"`
	Status ModelPackagingStatus `json:"status,omitempty"`
}

ModelPackaging is the Schema for the modelpackagings API

func (*ModelPackaging) DeepCopy

func (in *ModelPackaging) DeepCopy() *ModelPackaging

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

func (*ModelPackaging) DeepCopyInto

func (in *ModelPackaging) DeepCopyInto(out *ModelPackaging)

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

func (*ModelPackaging) DeepCopyObject

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

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

type ModelPackagingList

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

ModelPackagingList contains a list of ModelPackaging

func (*ModelPackagingList) DeepCopy

func (in *ModelPackagingList) DeepCopy() *ModelPackagingList

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

func (*ModelPackagingList) DeepCopyInto

func (in *ModelPackagingList) DeepCopyInto(out *ModelPackagingList)

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

func (*ModelPackagingList) DeepCopyObject

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

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

type ModelPackagingResult

type ModelPackagingResult struct {
	// Name of a result. It can be docker image, path to s3 artifact and so on
	Name string `json:"name"`
	// Specific value
	Value string `json:"value"`
}

func (*ModelPackagingResult) DeepCopy

func (in *ModelPackagingResult) DeepCopy() *ModelPackagingResult

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

func (*ModelPackagingResult) DeepCopyInto

func (in *ModelPackagingResult) DeepCopyInto(out *ModelPackagingResult)

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

type ModelPackagingSpec

type ModelPackagingSpec struct {
	ArtifactName     *string               `json:"artifactName,omitempty"`
	Type             string                `json:"type"`
	Image            string                `json:"image,omitempty"`
	Arguments        string                `json:"arguments,omitempty"`
	Targets          []Target              `json:"targets,omitempty"`
	Resources        *ResourceRequirements `json:"resources,omitempty"`
	OutputConnection string                `json:"outputConnection,omitempty"`
}

ModelPackagingSpec defines the desired state of ModelPackaging

func (*ModelPackagingSpec) DeepCopy

func (in *ModelPackagingSpec) DeepCopy() *ModelPackagingSpec

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

func (*ModelPackagingSpec) DeepCopyInto

func (in *ModelPackagingSpec) DeepCopyInto(out *ModelPackagingSpec)

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

type ModelPackagingState

type ModelPackagingState string

ModelPackagingState defines current state

const (
	ModelPackagingScheduling       ModelPackagingState = "scheduling"
	ModelPackagingRunning          ModelPackagingState = "running"
	ModelPackagingSucceeded        ModelPackagingState = "succeeded"
	ModelPackagingFailed           ModelPackagingState = "failed"
	ModelPackagingUnknown          ModelPackagingState = "unknown"
	ModelPackagingArtifactNotFound ModelPackagingState = "artifact_not_found"
)

These are the valid statuses of pods.

type ModelPackagingStatus

type ModelPackagingStatus struct {
	// Pod package for name
	PodName string `json:"podName,omitempty"`
	// Model Packaging State
	State ModelPackagingState `json:"state,omitempty"`
	// Pod exit code
	ExitCode *int32 `json:"exitCode,omitempty"`
	// Pod reason
	Reason *string `json:"reason,omitempty"`
	// Pod last log
	Message *string `json:"message,omitempty"`
	// List of packaing results
	Results []ModelPackagingResult `json:"results,omitempty"`
	// Info about create and update
	//CreatedAt *metav1.Time `json:"createdAt,omitempty"`
	//UpdatedAt *metav1.Time `json:"updatedAt,omitempty"`
	Modifiable `json:",inline"`
}

ModelPackagingStatus defines the observed state of ModelPackaging

func (*ModelPackagingStatus) DeepCopy

func (in *ModelPackagingStatus) DeepCopy() *ModelPackagingStatus

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

func (*ModelPackagingStatus) DeepCopyInto

func (in *ModelPackagingStatus) DeepCopyInto(out *ModelPackagingStatus)

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

type ModelRoute

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

	Spec   ModelRouteSpec   `json:"spec,omitempty"`
	Status ModelRouteStatus `json:"status,omitempty"`
}

ModelRoute is the Schema for the modelroutes API +kubebuilder:printcolumn:name="Edge URL",type="string",JSONPath=".status.edgeUrl" +kubebuilder:printcolumn:name="Routes",type="string",JSONPath=".spec.modelDeployments" +kubebuilder:printcolumn:name="Mirror",type="string",JSONPath=".spec.mirror" +kubebuilder:resource:shortName=mr

func (*ModelRoute) DeepCopy

func (in *ModelRoute) DeepCopy() *ModelRoute

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

func (*ModelRoute) DeepCopyInto

func (in *ModelRoute) DeepCopyInto(out *ModelRoute)

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

func (*ModelRoute) DeepCopyObject

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

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

type ModelRouteList

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

ModelRouteList contains a list of ModelRoute

func (*ModelRouteList) DeepCopy

func (in *ModelRouteList) DeepCopy() *ModelRouteList

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

func (*ModelRouteList) DeepCopyInto

func (in *ModelRouteList) DeepCopyInto(out *ModelRouteList)

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

func (*ModelRouteList) DeepCopyObject

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

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

type ModelRouteSpec

type ModelRouteSpec struct {
	// URL prefix for model deployment. For example: /custom/test
	// Prefix must start with slash
	// "/feedback" and "/model" are reserved for internal usage
	URLPrefix string `json:"urlPrefix"`
	// Mirror HTTP traffic to a another Model deployment in addition to forwarding
	// the requests to the model deployments.
	Mirror *string `json:"mirror,omitempty"`
	// A http rule can forward traffic to Model Deployments.
	ModelDeploymentTargets []ModelDeploymentTarget `json:"modelDeployments"`
}

func (*ModelRouteSpec) DeepCopy

func (in *ModelRouteSpec) DeepCopy() *ModelRouteSpec

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

func (*ModelRouteSpec) DeepCopyInto

func (in *ModelRouteSpec) DeepCopyInto(out *ModelRouteSpec)

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

type ModelRouteState

type ModelRouteState string

type ModelRouteStatus

type ModelRouteStatus struct {
	// Full url with prefix to a model deployment service
	EdgeURL string `json:"edgeUrl"`
	// State of Model Route
	State ModelRouteState `json:"state"`
	// Info about create and update
	//CreatedAt *metav1.Time `json:"createdAt,omitempty"`
	//UpdatedAt *metav1.Time `json:"updatedAt,omitempty"`
	Modifiable `json:",inline"`
}

ModelRouteStatus defines the observed state of ModelRoute

func (*ModelRouteStatus) DeepCopy

func (in *ModelRouteStatus) DeepCopy() *ModelRouteStatus

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

func (*ModelRouteStatus) DeepCopyInto

func (in *ModelRouteStatus) DeepCopyInto(out *ModelRouteStatus)

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

type ModelTraining

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

	Spec   ModelTrainingSpec   `json:"spec,omitempty"`
	Status ModelTrainingStatus `json:"status,omitempty"`
}

ModelTraining is the Schema for the modeltrainings API +kubebuilder:printcolumn:name="Status",type="string",JSONPath=".status.state" +kubebuilder:printcolumn:name="Toolchain",type="string",JSONPath=".spec.toolchain" +kubebuilder:printcolumn:name="VCS name",type="string",JSONPath=".spec.vcsName" +kubebuilder:printcolumn:name="Model name",type="string",JSONPath=".spec.model.name" +kubebuilder:printcolumn:name="Model version",type="string",JSONPath=".spec.model.version" +kubebuilder:printcolumn:name="Model image",type="string",JSONPath=".spec.image" +kubebuilder:resource:shortName=mt

func (*ModelTraining) DeepCopy

func (in *ModelTraining) DeepCopy() *ModelTraining

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

func (*ModelTraining) DeepCopyInto

func (in *ModelTraining) DeepCopyInto(out *ModelTraining)

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

func (*ModelTraining) DeepCopyObject

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

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

type ModelTrainingList

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

ModelTrainingList contains a list of ModelTraining

func (*ModelTrainingList) DeepCopy

func (in *ModelTrainingList) DeepCopy() *ModelTrainingList

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

func (*ModelTrainingList) DeepCopyInto

func (in *ModelTrainingList) DeepCopyInto(out *ModelTrainingList)

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

func (*ModelTrainingList) DeepCopyObject

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

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

type ModelTrainingSpec

type ModelTrainingSpec struct {
	// Model Identity
	Model ModelIdentity `json:"model"`
	// IntegrationName of toolchain
	Toolchain string `json:"toolchain"`
	// Custom environment variables that should be set before entrypoint invocation.
	CustomEnvs []EnvironmentVariable `json:"envs,omitempty"`
	// Model training hyperParameters in parameter:value format
	HyperParameters map[string]string `json:"hyperParameters,omitempty"`
	// Directory with model scripts/files in a git repository
	WorkDir string `json:"workDir,omitempty"`
	// Model training file. It can be python\bash script or jupiter notebook
	Entrypoint          string   `json:"entrypoint"`
	EntrypointArguments []string `json:"args,omitempty"`
	// Name of Connection resource. Must exists
	VCSName string `json:"vcsName"`
	// Name of Connection to storage where training output artifact will be stored.
	// Permitted connection types are defined by specific toolchain
	OutputConnection string `json:"outputConnection,omitempty"`
	// Train image
	Image string `json:"image,omitempty"`
	// VCS Reference
	Reference string `json:"reference,omitempty"`
	// Resources for model container
	// The same format like k8s uses for pod resources.
	Resources *ResourceRequirements `json:"resources,omitempty"`
	// Input data for a training
	Data []DataBindingDir `json:"data,omitempty"`
}

ModelTrainingSpec defines the desired state of ModelTraining

func (*ModelTrainingSpec) DeepCopy

func (in *ModelTrainingSpec) DeepCopy() *ModelTrainingSpec

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

func (*ModelTrainingSpec) DeepCopyInto

func (in *ModelTrainingSpec) DeepCopyInto(out *ModelTrainingSpec)

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

type ModelTrainingState

type ModelTrainingState string

ModelTrainingState defines current state

const (
	ModelTrainingScheduling ModelTrainingState = "scheduling"
	ModelTrainingRunning    ModelTrainingState = "running"
	ModelTrainingSucceeded  ModelTrainingState = "succeeded"
	ModelTrainingFailed     ModelTrainingState = "failed"
	ModelTrainingUnknown    ModelTrainingState = "unknown"
)

These are the valid statuses of pods.

type ModelTrainingStatus

type ModelTrainingStatus struct {
	// Pod package for name
	PodName string `json:"podName,omitempty"`
	// Model Packaging State
	State ModelTrainingState `json:"state,omitempty"`
	// Pod exit code
	ExitCode *int32 `json:"exitCode,omitempty"`
	// Pod reason
	Reason *string `json:"reason,omitempty"`
	// Pod last log
	Message *string `json:"message,omitempty"`
	// List of training results
	Artifacts []TrainingResult `json:"artifacts,omitempty"`
	// Info about create and update
	//CreatedAt *metav1.Time `json:"createdAt,omitempty"`
	//UpdatedAt *metav1.Time `json:"updatedAt,omitempty"`
	Modifiable `json:",inline"`
}

ModelTrainingStatus defines the observed state of ModelTraining

func (*ModelTrainingStatus) DeepCopy

func (in *ModelTrainingStatus) DeepCopy() *ModelTrainingStatus

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

func (*ModelTrainingStatus) DeepCopyInto

func (in *ModelTrainingStatus) DeepCopyInto(out *ModelTrainingStatus)

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

type Modifiable

type Modifiable struct {
	CreatedAt *metav1.Time `json:"createdAt,omitempty"`
	UpdatedAt *metav1.Time `json:"updatedAt,omitempty"`
}

func (*Modifiable) DeepCopy

func (in *Modifiable) DeepCopy() *Modifiable

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

func (*Modifiable) DeepCopyInto

func (in *Modifiable) DeepCopyInto(out *Modifiable)

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

type PackagingIntegration

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

	Spec   PackagingIntegrationSpec   `json:"spec,omitempty"`
	Status PackagingIntegrationStatus `json:"status,omitempty"`
}

PackagingIntegration is the Schema for the packagingintegrations API

func (*PackagingIntegration) DeepCopy

func (in *PackagingIntegration) DeepCopy() *PackagingIntegration

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

func (*PackagingIntegration) DeepCopyInto

func (in *PackagingIntegration) DeepCopyInto(out *PackagingIntegration)

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

func (*PackagingIntegration) DeepCopyObject

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

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

type PackagingIntegrationList

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

PackagingIntegrationList contains a list of PackagingIntegration

func (*PackagingIntegrationList) DeepCopy

func (in *PackagingIntegrationList) DeepCopy() *PackagingIntegrationList

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

func (*PackagingIntegrationList) DeepCopyInto

func (in *PackagingIntegrationList) DeepCopyInto(out *PackagingIntegrationList)

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

func (*PackagingIntegrationList) DeepCopyObject

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

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

type PackagingIntegrationSpec

type PackagingIntegrationSpec struct {
	Entrypoint   string           `json:"entrypoint"`
	DefaultImage string           `json:"defaultImage,omitempty"`
	Privileged   bool             `json:"privileged,omitempty"`
	Schema       SchemaValidation `json:"schema"`
}

PackagingIntegrationSpec defines the desired state of PackagingIntegration

func (*PackagingIntegrationSpec) DeepCopy

func (in *PackagingIntegrationSpec) DeepCopy() *PackagingIntegrationSpec

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

func (*PackagingIntegrationSpec) DeepCopyInto

func (in *PackagingIntegrationSpec) DeepCopyInto(out *PackagingIntegrationSpec)

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

type PackagingIntegrationStatus

type PackagingIntegrationStatus struct {
	// Info about create and update
	//CreatedAt *metav1.Time `json:"createdAt,omitempty"`
	//UpdatedAt *metav1.Time `json:"updatedAt,omitempty"`
	Modifiable `json:",inline"`
}

PackagingIntegrationStatus defines the observed state of PackagingIntegration

func (*PackagingIntegrationStatus) DeepCopy

func (in *PackagingIntegrationStatus) DeepCopy() *PackagingIntegrationStatus

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

func (*PackagingIntegrationStatus) DeepCopyInto

func (in *PackagingIntegrationStatus) DeepCopyInto(out *PackagingIntegrationStatus)

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

func (*PackagingIntegrationStatus) Scan

func (piStatus *PackagingIntegrationStatus) Scan(value interface{}) error

func (PackagingIntegrationStatus) Value

func (piStatus PackagingIntegrationStatus) Value() (driver.Value, error)

type ResourceList

type ResourceList struct {
	// Read more about GPU resource here https://kubernetes.io/docs/tasks/manage-gpus/scheduling-gpus/#using-device-plugins
	GPU *string `json:"gpu,omitempty"`
	// Read more about CPU resource here https://kubernetes.io/docs/concepts/configuration/manage-compute-resources-container/#meaning-of-cpu
	CPU *string `json:"cpu,omitempty"`
	// Read more about memory resource here https://kubernetes.io/docs/concepts/configuration/manage-compute-resources-container/#meaning-of-memory
	Memory *string `json:"memory,omitempty"`
}

func (*ResourceList) DeepCopy

func (in *ResourceList) DeepCopy() *ResourceList

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

func (*ResourceList) DeepCopyInto

func (in *ResourceList) DeepCopyInto(out *ResourceList)

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

type ResourceRequirements

type ResourceRequirements struct {
	// Limits describes the maximum amount of compute resources allowed.
	Limits *ResourceList `json:"limits,omitempty"`
	// Requests describes the minimum amount of compute resources required.
	Requests *ResourceList `json:"requests,omitempty"`
}

func (*ResourceRequirements) DeepCopy

func (in *ResourceRequirements) DeepCopy() *ResourceRequirements

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

func (*ResourceRequirements) DeepCopyInto

func (in *ResourceRequirements) DeepCopyInto(out *ResourceRequirements)

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

type SchemaValidation

type SchemaValidation struct {
	Targets   []TargetSchema `json:"targets,omitempty"`
	Arguments JsonSchema     `json:"arguments"`
}

func (*SchemaValidation) DeepCopy

func (in *SchemaValidation) DeepCopy() *SchemaValidation

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

func (*SchemaValidation) DeepCopyInto

func (in *SchemaValidation) DeepCopyInto(out *SchemaValidation)

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

type Target

type Target struct {
	Name           string `json:"name"`
	ConnectionName string `json:"connectionName"`
}

func (*Target) DeepCopy

func (in *Target) DeepCopy() *Target

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

func (*Target) DeepCopyInto

func (in *Target) DeepCopyInto(out *Target)

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

type TargetSchema

type TargetSchema struct {
	Name            string   `json:"name"`
	ConnectionTypes []string `json:"connectionTypes"`
	Default         string   `json:"default"`
	Required        bool     `json:"required"`
}

func (*TargetSchema) DeepCopy

func (in *TargetSchema) DeepCopy() *TargetSchema

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

func (*TargetSchema) DeepCopyInto

func (in *TargetSchema) DeepCopyInto(out *TargetSchema)

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

type ToolchainIntegration

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

	Spec   ToolchainIntegrationSpec   `json:"spec,omitempty"`
	Status ToolchainIntegrationStatus `json:"status,omitempty"`
}

ToolchainIntegration is the Schema for the toolchainintegrations API

func (*ToolchainIntegration) DeepCopy

func (in *ToolchainIntegration) DeepCopy() *ToolchainIntegration

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

func (*ToolchainIntegration) DeepCopyInto

func (in *ToolchainIntegration) DeepCopyInto(out *ToolchainIntegration)

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

func (*ToolchainIntegration) DeepCopyObject

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

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

type ToolchainIntegrationList

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

ToolchainIntegrationList contains a list of ToolchainIntegration

func (*ToolchainIntegrationList) DeepCopy

func (in *ToolchainIntegrationList) DeepCopy() *ToolchainIntegrationList

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

func (*ToolchainIntegrationList) DeepCopyInto

func (in *ToolchainIntegrationList) DeepCopyInto(out *ToolchainIntegrationList)

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

func (*ToolchainIntegrationList) DeepCopyObject

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

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

type ToolchainIntegrationSpec

type ToolchainIntegrationSpec struct {
	// Path to binary which starts a training process
	Entrypoint string `json:"entrypoint"`
	// Default training Docker image
	DefaultImage string `json:"defaultImage"`
	// Additional environments for a training process
	AdditionalEnvironments map[string]string `json:"additionalEnvironments,omitempty"`
}

ToolchainIntegrationSpec defines the desired state of ToolchainIntegration

func (*ToolchainIntegrationSpec) DeepCopy

func (in *ToolchainIntegrationSpec) DeepCopy() *ToolchainIntegrationSpec

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

func (*ToolchainIntegrationSpec) DeepCopyInto

func (in *ToolchainIntegrationSpec) DeepCopyInto(out *ToolchainIntegrationSpec)

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

func (*ToolchainIntegrationSpec) Scan

func (tiSpec *ToolchainIntegrationSpec) Scan(value interface{}) error

func (ToolchainIntegrationSpec) Value

func (tiSpec ToolchainIntegrationSpec) Value() (driver.Value, error)

type ToolchainIntegrationStatus

type ToolchainIntegrationStatus struct {
	// Info about create and update
	//CreatedAt *metav1.Time `json:"createdAt,omitempty"`
	//UpdatedAt *metav1.Time `json:"updatedAt,omitempty"`
	Modifiable `json:",inline"`
}

ToolchainIntegrationStatus defines the observed state of ToolchainIntegration

func (*ToolchainIntegrationStatus) DeepCopy

func (in *ToolchainIntegrationStatus) DeepCopy() *ToolchainIntegrationStatus

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

func (*ToolchainIntegrationStatus) DeepCopyInto

func (in *ToolchainIntegrationStatus) DeepCopyInto(out *ToolchainIntegrationStatus)

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

func (*ToolchainIntegrationStatus) Scan

func (tiStatus *ToolchainIntegrationStatus) Scan(value interface{}) error

func (ToolchainIntegrationStatus) Value

func (tiStatus ToolchainIntegrationStatus) Value() (driver.Value, error)

type TrainingResult

type TrainingResult struct {
	// Mlflow run ID
	RunID string `json:"runId"`
	// Trained artifact name
	ArtifactName string `json:"artifactName"`
	// VCS commit
	CommitID string `json:"commitID"`
}

func (*TrainingResult) DeepCopy

func (in *TrainingResult) DeepCopy() *TrainingResult

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

func (*TrainingResult) DeepCopyInto

func (in *TrainingResult) DeepCopyInto(out *TrainingResult)

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

Package Files

Documentation was rendered with GOOS=linux and GOARCH=amd64.

Jump to identifier

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to identifier