v1alpha1

package
v0.7.11 Latest Latest
Warning

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

 Go to latest Published: Aug 16, 2024 License: Apache-2.0 Imports: 22 Imported by: 1

Documentation

Overview

+groupName=catalog.modela.ai +kubebuilder:object:generate=true

Index

Constants

View Source 
const (
	ControlPort         int = 8080
	StoragePort         int = 8090
	DataPort            int = 8070
	PublisherPort       int = 8050
	TrainerPort         int = 8060
	PredictorPort       int = 8040
	BatchPredictionPort int = 8030
)
View Source 
const (
	LabJobRunnerRole        string = "lab-job-runner"
	LabJobRunnerSa          string = "lab-job-sa"
	LabJobRunnerRoleBinding string = "lab-job-runner-binding"

	DataProductJobRunnerRole        string = "dataproduct-job-runner"
	DataProductJobRunnerSa          string = "dataproduct-job-sa"
	DataProductJobRunnerRoleBinding string = "dataproduct-job-runner-binding"

	ServingSiteJobRunnerRole        string = "servingsite-job-runner"
	ServingSiteJobRunnerSa          string = "servingsite-job-sa"
	ServingSiteJobRunnerRoleBinding string = "servingsite-job-runner-binding"

	PredictorRole string = "predictor"
)
View Source 
const (
	VersionLabelKey    = "modela.ai/version"
	RunVersionLabelKey = "modela.ai/run-version"
	TriggerLabelKey    = "modela.ai/trigger"

	// catalog group
	AlgorithmLabelKey       = "modela.ai/algorithm"
	CloudLabelKey           = "modela.ai/cloud"
	ManagedImageLabelKey    = "modela.ai/managedimage"
	MLFrameworkLabelKey     = "modela.ai/mlframework"
	PretrainedModelLabelKey = "modela.ai/pretrainedmodel"
	PublicDatasetLabelKey   = "modela.ai/publicdataset"
	WorkloadClassLabelKey   = "modela.ai/workloadclass"

	// data group
	DataPipelineLabelKey       = "modela.ai/datapipline"
	DataPipeleRunLabelKey      = "modela.ai/datapipelinerun"
	DataProductLabelKey        = "modela.ai/dataproduct"
	DataProductVersionLabelKey = "modela.ai/dataproductversion"
	DatasetLabelKey            = "modela.ai/dataset"
	DatasetSnapshotLabelKey    = "modela.ai/datasetsnapshot"
	DatasourceLabelKey         = "modela.ai/datasource"
	EntityLabelKey             = "modela.ai/entity"
	FeatureHistogramLabelKey   = "modela.ai/featurehistorgram"
	FeatureGroupLabelKey       = "modela.ai/featuregroup"
	RecipeLabelKey             = "modela.ai/recipe"
	RecipeRunLabelKey          = "modela.ai/reciperun"
	SnapshotVersionLabelKey    = "modela.ai/snapshot-version"

	// Inference
	DataAppLabelKey       = "modela.ai/dataapp"
	PredictionLabelKey    = "modela.ai/prediction"
	PredictionRunLabelKey = "modela.ai/predictionrun"
	PredictorLabelKey     = "modela.ai/predictor"

	AccountLabelKey       = "modela.ai/account"
	AlertLabelKey         = "modela.ai/alert"
	ApiTokenLabelKey      = "modela.ai/apitoken"
	AttachmentLabelKey    = "modela.ai/attachment"
	CommitLabelKey        = "modela.ai/commit"
	ConnectionLabelKey    = "modela.ai/connection"
	LabLabelKey           = "modela.ai/lab"
	LicenseLabelKey       = "modela.ai/license"
	NotifierLabelKey      = "modela.ai/notifier"
	ServingSiteLabelKey   = "modela.ai/servingsite"
	TenantLabelKey        = "modela.ai/tenant"
	UserClassLabelKey     = "modela.ai/userclass"
	VirtualBucketLabelKey = "modela.ai/virtualbucket"

	ObjectRefNamespaceLabelKey = "modela.ai/object-ref-namespace"
	ObjectRefNameLabelKey      = "modela.ai/object-ref-name"

	// Team
	PostmortemLabelKey = "modela.ai/postmortem"
	ReviewLabelKey     = "modela.ai/review"
	RunbookLabelKey    = "modela.ai/runbook"
	TodoLabelKey       = "modela.ai/todo"

	// Training
	ModelLabelKey         = "modela.ai/model"
	ReportLabelKey        = "modela.ai/report"
	StudyLabelKey         = "modela.ai/study"
	StudyRunLabelKey      = "modela.ai/studyrun"
	TaskLabelKey          = "modela.ai/task"
	ModelClassLabelKey    = "modela.ai/modelclass"
	ModelClassRunLabelKey = "modela.ai/modelclassrun"
	JobLabelKey           = "kubernetes.io/job"
	OwnerKindLabelKey     = "modela.ai/owner-kind"
	OwnerLabelKey         = "modela.ai/owner"

	// GenAI
	KnowledgeBaseLabelKey = "modela.ai/knowledgebase"
	LLMServerLabelKey     = "modela.ai/llmserver"
	APIKeyGroupLabelKey   = "modela.ai/apikeygroup"

	ModelRoleLabelKey    = "modela.ai/role"
	ModelVersionLabelKey = "modela.ai/modelversion"

	ComponentLabelKey = "app.kubernetes.io/component"

	BranchLabelKey  = "branch"
	RoleLabelKey    = "labels"
	ChangedLabelKey = "changed"
)
View Source 
const (
	FileDataLocationType DataLocationType = iota
	DatabaseDataLocationType
	WebDataLocationType
	ResourceDataLocationType
	InvalidDataLocationType

	PublicDatasetResourceLocationKind   ResourceLocationKind = "PublicDataset"
	DatasetSnapshotResourceLocationKind ResourceLocationKind = "DatasetSnapshot"
)
View Source 
const CurrentVersion = "catalog.modela.ai/v1alpha1"
View Source 
const (
	ReasonFailed = "Failed"
)

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   = SchemeBuilder.AddToScheme
)
View Source 
var SchemeGroupVersion = schema.GroupVersion{Group: catalog.GroupName, Version: "v1alpha1"}

SchemeGroupVersion is group version used to register these objects

Functions

func AddKnownTypes 

func AddKnownTypes(scheme *k8sruntime.Scheme) error

Adds the list of known types to api.Scheme.

func IsBinaryClassification 

func IsBinaryClassification(task MLTask) bool

func IsMultiClass 

func IsMultiClass(task MLTask) bool

func IsMultiWorkerTaskFailed added in v0.5.187 

func IsMultiWorkerTaskFailed(results []WorkerRunResult, task TaskName, totalWorkers int32) bool

func IsRegression 

func IsRegression(task MLTask) bool

func IsWorkerDone added in v0.5.187 

func IsWorkerDone(results []WorkerRunResult, task TaskName, workerID int32) bool

func IsWorkerFailed added in v0.5.187 

func IsWorkerFailed(results []WorkerRunResult, task TaskName, workerID int32) bool

func IsWorkersFinished added in v0.5.187 

func IsWorkersFinished(results []WorkerRunResult, task TaskName, totalWorkers int32) bool

Check if all the workers finished thier task

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 AccessType 

type AccessType string

AccessType define how client reach the predictor +kubebuilder:validation:Enum="cluster-ip";"node-port";"load-balancer";"ingress" 

const (
	// Use cluster port if the predictor is an internal micro service
	ClusterIPAccessType AccessType = "cluster-ip"
	// Use node port if the predictor can be accessed from outside the cluster
	NodePortAccessType AccessType = "node-port"
	// Use load balancer if the predictor can be accessed from outside the cluster
	LoadBalancerAccessType AccessType = "load-balancer"
	// Use ingress if the predictor should register with an ingress
	IngressAccessType AccessType = "ingress"
)

type AccountPermissions added in v0.6.252 

type AccountPermissions struct {
	// The name of the Account receiving the permissions
	AccountName string `json:"accountName,omitempty" protobuf:"bytes,1,opt,name=accountName"`
	// Roles contains a list of User Role Classes that will be bound to the Account
	Roles []v1.LocalObjectReference `json:"roles,omitempty" protobuf:"bytes,2,rep,name=roles"`
}

AccountPermissions specifies the User Role Classes of an individual Account

func (*AccountPermissions) DeepCopy added in v0.6.252 

func (in *AccountPermissions) DeepCopy() *AccountPermissions

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

func (*AccountPermissions) DeepCopyInto added in v0.6.252 

func (in *AccountPermissions) DeepCopyInto(out *AccountPermissions)

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

func (*AccountPermissions) Descriptor added in v0.6.252 

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

func (*AccountPermissions) Marshal added in v0.6.252 

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

func (*AccountPermissions) MarshalTo added in v0.6.252 

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

func (*AccountPermissions) MarshalToSizedBuffer added in v0.6.252 

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

func (*AccountPermissions) ProtoMessage added in v0.6.252 

func (*AccountPermissions) ProtoMessage()

func (*AccountPermissions) Reset added in v0.6.252 

func (m *AccountPermissions) Reset()

func (*AccountPermissions) Size added in v0.6.252 

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

func (*AccountPermissions) String added in v0.6.252 

func (this *AccountPermissions) String() string

func (*AccountPermissions) Unmarshal added in v0.6.252 

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

func (*AccountPermissions) XXX_DiscardUnknown added in v0.6.252 

func (m *AccountPermissions) XXX_DiscardUnknown()

func (*AccountPermissions) XXX_Marshal added in v0.6.252 

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

func (*AccountPermissions) XXX_Merge added in v0.6.252 

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

func (*AccountPermissions) XXX_Size added in v0.6.252 

func (m *AccountPermissions) XXX_Size() int

func (*AccountPermissions) XXX_Unmarshal added in v0.6.252 

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

type Aggregate 

type Aggregate string

The Aggregate unit +kubebuilder:validation:Enum="min";"max";"mean";"median";"sum";"stddev";"var";"none" 

const (
	AggregateMin    Aggregate = "min"
	AggregateMax    Aggregate = "max"
	AggregateMean   Aggregate = "mean"
	AggregateMedian Aggregate = "median"
	AggregateSum    Aggregate = "sum"
	AggregateStddev Aggregate = "stddev"
	AggregateVar    Aggregate = "var"
	AggregateNone   Aggregate = "none"
)

type Algorithm 

type Algorithm struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`
	Spec              AlgorithmSpec `json:"spec" protobuf:"bytes,2,opt,name=spec"`
}

+genclient +kubebuilder:object:root=true +kubebuilder:resource:path=algorithms,singular=algorithm,shortName="alg",categories={catalog,modela,all} +kubebuilder:storageversion +kubebuilder:printcolumn:name="Framework",type="string",JSONPath=".spec.frameworkName",description="ML Framework name" +kubebuilder:printcolumn:name="Docs",type="string",JSONPath=".spec.url",description="" +kubebuilder:printcolumn:name="Task",type="string",JSONPath=".spec.task",description="ML task name" +kubebuilder:printcolumn:name="Age",type=date,JSONPath=`.metadata.creationTimestamp` Algorithm define the metadata about a machine learning algorithm.

func (*Algorithm) DeepCopy 

func (in *Algorithm) DeepCopy() *Algorithm

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

func (*Algorithm) DeepCopyInto 

func (in *Algorithm) DeepCopyInto(out *Algorithm)

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

func (*Algorithm) DeepCopyObject 

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

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

func (*Algorithm) Default 

func (alg *Algorithm) Default()

func (*Algorithm) Descriptor 

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

func (*Algorithm) Marshal 

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

func (*Algorithm) MarshalTo 

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

func (*Algorithm) MarshalToSizedBuffer 

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

func (*Algorithm) ProtoMessage 

func (*Algorithm) ProtoMessage()

func (*Algorithm) RepEntry 

func (alg *Algorithm) RepEntry() (string, error)

func (*Algorithm) RepPath 

func (alg *Algorithm) RepPath(root string) (string, error)

Return the on disk rep location

func (*Algorithm) Reset 

func (m *Algorithm) Reset()

func (*Algorithm) Size 

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

func (*Algorithm) String 

func (this *Algorithm) String() string

func (*Algorithm) Unmarshal 

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

func (Algorithm) Validate 

func (alg Algorithm) Validate() (bool, field.ErrorList)

func (*Algorithm) ValidateCreate 

func (alg *Algorithm) ValidateCreate() error

ValidateCreate implements webhook.Validator so a webhook will be registered for the type

func (*Algorithm) ValidateDelete 

func (alg *Algorithm) ValidateDelete() error

func (*Algorithm) ValidateUpdate 

func (alg *Algorithm) ValidateUpdate(old runtime.Object) error

ValidateUpdate implements webhook.Validator so a webhook will be registered for the type

func (*Algorithm) XXX_DiscardUnknown 

func (m *Algorithm) XXX_DiscardUnknown()

func (*Algorithm) XXX_Marshal 

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

func (*Algorithm) XXX_Merge 

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

func (*Algorithm) XXX_Size 

func (m *Algorithm) XXX_Size() int

func (*Algorithm) XXX_Unmarshal 

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

type AlgorithmList 

type AlgorithmList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`
	Items           []Algorithm `json:"items" protobuf:"bytes,2,rep,name=items"`
}

+kubebuilder:object:root=true AlgorithmList contains a list of Algorithm

func (*AlgorithmList) DeepCopy 

func (in *AlgorithmList) DeepCopy() *AlgorithmList

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

func (*AlgorithmList) DeepCopyInto 

func (in *AlgorithmList) DeepCopyInto(out *AlgorithmList)

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

func (*AlgorithmList) DeepCopyObject 

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

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

func (*AlgorithmList) Descriptor 

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

func (*AlgorithmList) Marshal 

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

func (*AlgorithmList) MarshalTo 

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

func (*AlgorithmList) MarshalToSizedBuffer 

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

func (*AlgorithmList) ProtoMessage 

func (*AlgorithmList) ProtoMessage()

func (*AlgorithmList) Reset 

func (m *AlgorithmList) Reset()

func (*AlgorithmList) Size 

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

func (*AlgorithmList) String 

func (this *AlgorithmList) String() string

func (*AlgorithmList) Unmarshal 

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

func (*AlgorithmList) XXX_DiscardUnknown 

func (m *AlgorithmList) XXX_DiscardUnknown()

func (*AlgorithmList) XXX_Marshal 

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

func (*AlgorithmList) XXX_Merge 

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

func (*AlgorithmList) XXX_Size 

func (m *AlgorithmList) XXX_Size() int

func (*AlgorithmList) XXX_Unmarshal 

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

type AlgorithmSpec 

type AlgorithmSpec struct {
	// FrameworkName is a reference to library
	// +kubebuilder:validation:Required
	// +required
	FrameworkName string `json:"frameworkName,omitempty" protobuf:"bytes,1,opt,name=frameworkName"`
	// Description is the description of the algorithm
	// +kubebuilder:default:=""
	// +kubebuilder:validation:Optional
	Description *string `json:"description,omitempty" protobuf:"bytes,2,opt,name=description"`
	// URL is a url to the html page describing the algorithm
	// +kubebuilder:default:=""
	// +kubebuilder:validation:Optional
	URL *string `json:"url,omitempty" protobuf:"bytes,3,opt,name=url"`
	// Task is the machine learning task (binary classification / regression)
	// +kubebuilder:validation:Optional
	Tasks []MLTask `json:"tasks" protobuf:"bytes,4,rep,name=tasks"`
	// Sparse indicate if this algorithm can deal with sparse data
	// +kubebuilder:default:=false
	// +kubebuilder:validation:Optional
	Sparse *bool `json:"sparse,omitempty" protobuf:"varint,5,opt,name=sparse"`
	// IntegerParameters is the list of integer hyper parameter ranges.
	// +kubebuilder:validation:Optional
	Ranges []ParameterRange `json:"ranges,omitempty" protobuf:"bytes,6,rep,name=ranges"`
}

AlgorithmSpec describes the attributes of an machine learning algorithm

func (*AlgorithmSpec) DeepCopy 

func (in *AlgorithmSpec) DeepCopy() *AlgorithmSpec

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

func (*AlgorithmSpec) DeepCopyInto 

func (in *AlgorithmSpec) DeepCopyInto(out *AlgorithmSpec)

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

func (*AlgorithmSpec) Descriptor 

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

func (*AlgorithmSpec) Marshal 

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

func (*AlgorithmSpec) MarshalTo 

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

func (*AlgorithmSpec) MarshalToSizedBuffer 

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

func (*AlgorithmSpec) ProtoMessage 

func (*AlgorithmSpec) ProtoMessage()

func (*AlgorithmSpec) Reset 

func (m *AlgorithmSpec) Reset()

func (*AlgorithmSpec) Size 

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

func (*AlgorithmSpec) String 

func (this *AlgorithmSpec) String() string

func (*AlgorithmSpec) Unmarshal 

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

func (*AlgorithmSpec) XXX_DiscardUnknown 

func (m *AlgorithmSpec) XXX_DiscardUnknown()

func (*AlgorithmSpec) XXX_Marshal 

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

func (*AlgorithmSpec) XXX_Merge 

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

func (*AlgorithmSpec) XXX_Size 

func (m *AlgorithmSpec) XXX_Size() int

func (*AlgorithmSpec) XXX_Unmarshal 

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

type AssertionType added in v0.4.934 

type AssertionType string

type AudioFeaturizer 

type AudioFeaturizer string

type AuthMethod added in v0.5.261 

type AuthMethod string

+kubebuilder:validation:Enum="api-token";"jwt-token";"none" 

const (
	ApiToken  AuthMethod = "api-token"
	JwtToken  AuthMethod = "jwt-token"
	NoneToken AuthMethod = "none"
)

type CategoricalEncoding 

type CategoricalEncoding string

+kubebuilder:validation:Enum="one-hot-encoding";"one-hot-encoding-top-categories";"ordinal-encoding";"count-encoding";"target-encoding";"weight-of-evidence-encoding";"binary-encoding";"label-encoding";"hash-encoding";"catboost-encoding";"loo-encoding";"no-encoding";"auto";"none" 

const (
	OneHotEncoding      CategoricalEncoding = "one-hot-encoding"
	OneHotEncoderTop    CategoricalEncoding = "one-hot-encoding-top-categories"
	OrdinalEncoding     CategoricalEncoding = "ordinal-encoding"
	CountEncoding       CategoricalEncoding = "count-encoding"
	TargetEncoding      CategoricalEncoding = "target-encoding"
	WoERatioEncoding    CategoricalEncoding = "weight-of-evidence-encoding"
	BinaryEncoding      CategoricalEncoding = "binary-encoding"
	LabelEncoding       CategoricalEncoding = "label-encoding"
	HashEncoding        CategoricalEncoding = "hash-encoding"
	CatboostEncoding    CategoricalEncoding = "catboost-encoding"
	LeaveOneOutEncoding CategoricalEncoding = "loo-encoding"
	NoEncoding          CategoricalEncoding = "no-encoding"
	AutoEncoding        CategoricalEncoding = "auto"
	NoneEncoding        CategoricalEncoding = "none"
)

func ParseCategoricalEncoding 

func ParseCategoricalEncoding(name string) CategoricalEncoding

type ClassicEstimatorName 

type ClassicEstimatorName string
const (
	// Regression
	KNeighborsRegressor           ClassicEstimatorName = "knn-regressor"
	RidgeRegressor                ClassicEstimatorName = "ridge-regressor"
	LassoRegressor                ClassicEstimatorName = "lasso-regressor"
	AdaBoostRegressor             ClassicEstimatorName = "ada-boost-regressor"
	DecisionTreeRegressor         ClassicEstimatorName = "decision-tree-regressor"
	ExtraTreeRegressor            ClassicEstimatorName = "extra-tree-regressor"
	LinearSvr                     ClassicEstimatorName = "linear-svr"
	Svr                           ClassicEstimatorName = "svr"
	PassiveArressiveRegressor     ClassicEstimatorName = "passive-agressive-regressor"
	SGDRegressor                  ClassicEstimatorName = "sgd-regressor"
	GradientBoostingRegressor     ClassicEstimatorName = "gradient-boosting-regressor"
	HistGradientBoostingRegressor ClassicEstimatorName = "hist-gradient-boosting-regressor"
	RandomForestRegressor         ClassicEstimatorName = "random-forest-regressor"
	XGBRegressor                  ClassicEstimatorName = "xgb-regressor"
	CatBoostRegressor             ClassicEstimatorName = "catboost-regressor"
	LightGbmRegressor             ClassicEstimatorName = "lightgbm-regressor"
	ElasticNetRegressor           ClassicEstimatorName = "elasticnet-regressor"
	DNNRegressor                  ClassicEstimatorName = "dnn-regressor"
	LinearRegressor               ClassicEstimatorName = "linear-regressor"

	// Robust regressor
	HuberRegressor    ClassicEstimatorName = "huber-regression"
	RUNSACRegressor   ClassicEstimatorName = "runsac-regression"
	TheilSenRegressor ClassicEstimatorName = "theilsend-regressor"

	PoissonRegressor ClassicEstimatorName = "poisson-regression"
	TweedieRegressor ClassicEstimatorName = "tweedie-regression"
	GammaRegressor   ClassicEstimatorName = "gamma-regression"

	// OutlierFilter
	EllipticEnvelope   ClassicEstimatorName = "elliptic-envelope"
	OneClassSVM        ClassicEstimatorName = "one-class-svm"
	IsolationForest    ClassicEstimatorName = "isolation-forest"
	LocalOutlierFactor ClassicEstimatorName = "local-outlier-factor"

	NaiveForecaster      ClassicEstimatorName = "naive-forecaster"
	ExponentialSmoothing ClassicEstimatorName = "exponential-smoothing"
	AutoETS              ClassicEstimatorName = "auto-ets"
	ThetaForecaster      ClassicEstimatorName = "theta-forecaster"
	AutoARIMA            ClassicEstimatorName = "auto-arima"
	ARIMA                ClassicEstimatorName = "arima"
	SARIMAX              ClassicEstimatorName = "sarimax"
	VAR                  ClassicEstimatorName = "var"
	VARMAX               ClassicEstimatorName = "varmax"
	BATS                 ClassicEstimatorName = "bats"
	TBATS                ClassicEstimatorName = "tbats"
	Prophet              ClassicEstimatorName = "prophet"
	GreyKite             ClassicEstimatorName = "greykite"

	// Recommendation
	ALS                         ClassicEstimatorName = "als"
	BayesianPersonalizedRanking ClassicEstimatorName = "bayesian-personalized-ranking"

	// Classifiers
	KNeighborsClassifier ClassicEstimatorName = "knn-classifier"
	AdaBoostClassifier   ClassicEstimatorName = "ada-boost-classifier"
	BernoulliNB          ClassicEstimatorName = "bernoulli-nb"
	GaussianNB           ClassicEstimatorName = "gaussian-nb"
	MultinomialNB        ClassicEstimatorName = "multinomial-nb"

	DecisionTreeClassifier         ClassicEstimatorName = "decision-tree-classifier"
	ExtraTreeClassifier            ClassicEstimatorName = "extra-tree-classifier"
	LinearSVC                      ClassicEstimatorName = "linear-svc"
	SVC                            ClassicEstimatorName = "svc"
	PassiveAggressiveClassifier    ClassicEstimatorName = "passive-aggressive-classifier"
	SGDClassifier                  ClassicEstimatorName = "sgd-classifier"
	LogisticRegression             ClassicEstimatorName = "logistic-regression"
	GradientBoostingClassifier     ClassicEstimatorName = "gradient-boosting-classifier"
	HistGradientBoostingClassifier ClassicEstimatorName = "hist-gradient-boosting-classifier"
	RandomForestClassifier         ClassicEstimatorName = "random-forest-classifier"
	XGBClassifier                  ClassicEstimatorName = "xgboost-classifier"
	RidgeClassifier                ClassicEstimatorName = "ridge-classifier"
	QuadraticDiscriminant          ClassicEstimatorName = "quadratic-discriminant"
	LinearDiscriminant             ClassicEstimatorName = "linear-discriminant"
	LightGBMClassifier             ClassicEstimatorName = "lightgbm-classifier"
	CatBoostClassifier             ClassicEstimatorName = "catboost-classifier"
	StackingEnsemble               ClassicEstimatorName = "stacking-ensemble" // for stacking ensemble
	UnknownEstimatorName           ClassicEstimatorName = "unknown"
	NoneEstimatorName              ClassicEstimatorName = "none"

	// Clustering
	KMeansClustering   ClassicEstimatorName = "kmeans"
	SpectralClustering ClassicEstimatorName = "spectral"
	DBSCANClustering   ClassicEstimatorName = "dbscan"
	OpticsClustering   ClassicEstimatorName = "optics"
	BirchClustering    ClassicEstimatorName = "birch"

	// Meta Estimators
	VotingClassifier   ClassicEstimatorName = "voting-classifier"
	VotingRegressor    ClassicEstimatorName = "voting-regressor"
	StackingClassifier ClassicEstimatorName = "stacking-classifier"
	StackingRegressor  ClassicEstimatorName = "stacking-regressor"
)

type Cloud 

type Cloud struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`
	Spec              CloudSpec `json:"spec" protobuf:"bytes,2,opt,name=spec"`
	//+optional
	Status CloudStatus `json:"status" protobuf:"bytes,3,opt,name=status"`
}

Cloud represent a cloud provider metadata. A cloud contains regions,datacenter,machine classes

func (*Cloud) AddFinalizer 

func (cloud *Cloud) AddFinalizer()

func (*Cloud) DeepCopy 

func (in *Cloud) DeepCopy() *Cloud

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

func (*Cloud) DeepCopyInto 

func (in *Cloud) DeepCopyInto(out *Cloud)

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

func (*Cloud) DeepCopyObject 

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

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

func (*Cloud) Default 

func (cloud *Cloud) Default()

func (*Cloud) Descriptor 

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

func (*Cloud) HasFinalizer 

func (cloud *Cloud) HasFinalizer() bool

func (*Cloud) Marshal 

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

func (*Cloud) MarshalTo 

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

func (*Cloud) MarshalToSizedBuffer 

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

func (*Cloud) ProtoMessage 

func (*Cloud) ProtoMessage()

func (*Cloud) RemoveFinalizer 

func (cloud *Cloud) RemoveFinalizer()

func (*Cloud) Reset 

func (m *Cloud) Reset()

func (*Cloud) Size 

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

func (*Cloud) String 

func (this *Cloud) String() string

func (*Cloud) Unmarshal 

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

func (Cloud) Validate 

func (cloud Cloud) Validate() (bool, field.ErrorList)

func (*Cloud) ValidateCreate 

func (cloud *Cloud) ValidateCreate() error

ValidateCreate implements webhook.Validator so a webhook will be registered for the type

func (*Cloud) ValidateDelete 

func (cloud *Cloud) ValidateDelete() error

func (*Cloud) ValidateUpdate 

func (cloud *Cloud) ValidateUpdate(old runtime.Object) error

ValidateUpdate implements webhook.Validator so a webhook will be registered for the type

func (*Cloud) XXX_DiscardUnknown 

func (m *Cloud) XXX_DiscardUnknown()

func (*Cloud) XXX_Marshal 

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

func (*Cloud) XXX_Merge 

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

func (*Cloud) XXX_Size 

func (m *Cloud) XXX_Size() int

func (*Cloud) XXX_Unmarshal 

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

type CloudList 

type CloudList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`
	Items           []Cloud `json:"items" protobuf:"bytes,2,rep,name=items"`
}

+kubebuilder:object:root=true CloudList contains a list of Cloud

func (*CloudList) DeepCopy 

func (in *CloudList) DeepCopy() *CloudList

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

func (*CloudList) DeepCopyInto 

func (in *CloudList) DeepCopyInto(out *CloudList)

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

func (*CloudList) DeepCopyObject 

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

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

func (*CloudList) Descriptor 

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

func (*CloudList) Marshal 

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

func (*CloudList) MarshalTo 

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

func (*CloudList) MarshalToSizedBuffer 

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

func (*CloudList) ProtoMessage 

func (*CloudList) ProtoMessage()

func (*CloudList) Reset 

func (m *CloudList) Reset()

func (*CloudList) Size 

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

func (*CloudList) String 

func (this *CloudList) String() string

func (*CloudList) Unmarshal 

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

func (*CloudList) XXX_DiscardUnknown 

func (m *CloudList) XXX_DiscardUnknown()

func (*CloudList) XXX_Marshal 

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

func (*CloudList) XXX_Merge 

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

func (*CloudList) XXX_Size 

func (m *CloudList) XXX_Size() int

func (*CloudList) XXX_Unmarshal 

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

type CloudSpec 

type CloudSpec struct {
	// DefaultRegionName is the default region.
	// +kubebuilder:validation:Optional
	DefaultRegionName string `json:"defaultRegionName,omitempty" protobuf:"bytes,1,opt,name=defaultRegionName"`
	// DefaultMachineClassName is the default machine class. Used when allocating new machine on this provider
	// +kubebuilder:validation:Optional
	DefaultMachineClassName string `json:"defaultMachineClassName,omitempty" protobuf:"bytes,2,opt,name=defaultMachineClassName"`
	// DefaultGpuClassName is the default gpu class. Used when allocating new gpu on this provider
	// +kubebuilder:validation:Optional
	DefaultGpuClassName string `json:"defaultGpuClassName,omitempty" protobuf:"bytes,3,opt,name=defaultGpuClassName"`
	// MachineClasses defines the types of machines in this provider
	// +kubebuilder:validation:Optional
	MachineClasses []MachineClass `json:"machineClasses,omitempty" protobuf:"bytes,4,rep,name=machineClasses"`
	// GPUClasses define the type of GPUs offered by this provider
	// +kubebuilder:validation:Optional
	GpuClasses []GpuClass `json:"gpuClasses,omitempty" protobuf:"bytes,5,rep,name=gpuClasses"`
	// Regions define the type of regions offered by this provider
	// +kubebuilder:validation:Optional
	Regions []Region `json:"regions,omitempty" protobuf:"bytes,6,rep,name=regions"`
}

CloudSpec define the attribute of a single cloud provider (E.g. AWS)

func (*CloudSpec) DeepCopy 

func (in *CloudSpec) DeepCopy() *CloudSpec

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

func (*CloudSpec) DeepCopyInto 

func (in *CloudSpec) DeepCopyInto(out *CloudSpec)

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

func (*CloudSpec) Descriptor 

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

func (*CloudSpec) Marshal 

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

func (*CloudSpec) MarshalTo 

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

func (*CloudSpec) MarshalToSizedBuffer 

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

func (*CloudSpec) ProtoMessage 

func (*CloudSpec) ProtoMessage()

func (*CloudSpec) Reset 

func (m *CloudSpec) Reset()

func (*CloudSpec) Size 

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

func (*CloudSpec) String 

func (this *CloudSpec) String() string

func (*CloudSpec) Unmarshal 

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

func (*CloudSpec) XXX_DiscardUnknown 

func (m *CloudSpec) XXX_DiscardUnknown()

func (*CloudSpec) XXX_Marshal 

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

func (*CloudSpec) XXX_Merge 

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

func (*CloudSpec) XXX_Size 

func (m *CloudSpec) XXX_Size() int

func (*CloudSpec) XXX_Unmarshal 

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

type CloudStatus 

type CloudStatus struct {
	// Machine cost is the costs of
	MachineCosts []MachineClassCost `json:"machineCosts,omitempty" protobuf:"bytes,1,rep,name=machineCosts"`
	// CostSpot is the spot cost of the machine class
	GpuCosts []GpuClassCost `json:"gpuCosts,omitempty" protobuf:"bytes,2,rep,name=gpuCosts"`
}

CloudStatus defines the observed state of Cloud.

func (*CloudStatus) DeepCopy 

func (in *CloudStatus) DeepCopy() *CloudStatus

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

func (*CloudStatus) DeepCopyInto 

func (in *CloudStatus) DeepCopyInto(out *CloudStatus)

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

func (*CloudStatus) Descriptor 

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

func (*CloudStatus) Marshal 

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

func (*CloudStatus) MarshalTo 

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

func (*CloudStatus) MarshalToSizedBuffer 

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

func (*CloudStatus) ProtoMessage 

func (*CloudStatus) ProtoMessage()

func (*CloudStatus) Reset 

func (m *CloudStatus) Reset()

func (*CloudStatus) Size 

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

func (*CloudStatus) String 

func (this *CloudStatus) String() string

func (*CloudStatus) Unmarshal 

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

func (*CloudStatus) XXX_DiscardUnknown 

func (m *CloudStatus) XXX_DiscardUnknown()

func (*CloudStatus) XXX_Marshal 

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

func (*CloudStatus) XXX_Merge 

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

func (*CloudStatus) XXX_Size 

func (m *CloudStatus) XXX_Size() int

func (*CloudStatus) XXX_Unmarshal 

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

type Color 

type Color string

Color defines an implementation-specific color

type CompilerName 

type CompilerName string

+kubebuilder:validation:Enum="tvm";"onyx";"xla";"none" 

const (
	TVMCompilerName  CompilerName = "tvm"
	OnyxCompilerName CompilerName = "onyx"
	XlaCompilerName  CompilerName = "xla"
	NoneCompilerName CompilerName = "none"
)

type CompilerSpec 

type CompilerSpec struct {
	// Enable set the enable to
	// +kubebuilder:default:=false
	// +kubebuilder:validation:Optional
	Enable *bool `json:"enable,omitempty" protobuf:"varint,1,opt,name=enable"`
	// Set one or more targets
	// Enable set the enable to
	// +kubebuilder:default:="none"
	// +kubebuilder:validation:Optional
	Compiler *CompilerName `json:"compiler,omitempty" protobuf:"bytes,2,opt,name=compiler"`
	// Set one or more targets for the compiler
	Targets []HardwareTarget `json:"targets,omitempty" protobuf:"bytes,3,rep,name=targets"`
}

CompilerSpec is used when there is a specification for model compilation

func (*CompilerSpec) DeepCopy 

func (in *CompilerSpec) DeepCopy() *CompilerSpec

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

func (*CompilerSpec) DeepCopyInto 

func (in *CompilerSpec) DeepCopyInto(out *CompilerSpec)

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

func (*CompilerSpec) Descriptor 

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

func (*CompilerSpec) Marshal 

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

func (*CompilerSpec) MarshalTo 

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

func (*CompilerSpec) MarshalToSizedBuffer 

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

func (*CompilerSpec) ProtoMessage 

func (*CompilerSpec) ProtoMessage()

func (*CompilerSpec) Reset 

func (m *CompilerSpec) Reset()

func (*CompilerSpec) Size 

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

func (*CompilerSpec) String 

func (this *CompilerSpec) String() string

func (*CompilerSpec) Unmarshal 

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

func (*CompilerSpec) XXX_DiscardUnknown 

func (m *CompilerSpec) XXX_DiscardUnknown()

func (*CompilerSpec) XXX_Marshal 

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

func (*CompilerSpec) XXX_Merge 

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

func (*CompilerSpec) XXX_Size 

func (m *CompilerSpec) XXX_Size() int

func (*CompilerSpec) XXX_Unmarshal 

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

type ConditionReason 

type ConditionReason string
const (
	Failed             ConditionReason = "Failed"
	Success            ConditionReason = "Success"
	Running            ConditionReason = "Running"
	WaitingForApproval ConditionReason = "WaitingForApproval"
	Approved           ConditionReason = "Approved"
	Denied             ConditionReason = "Denied"
	MissingResources   ConditionReason = "MissingResources"
	NotSaved           ConditionReason = "NotSaved"
)

type ConfusionMatrix 

type ConfusionMatrix struct {
	Rows []ConfusionMatrixRow `json:"rows,omitempty" protobuf:"bytes,1,rep,name=rows"`
}

func (*ConfusionMatrix) DeepCopy 

func (in *ConfusionMatrix) DeepCopy() *ConfusionMatrix

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

func (*ConfusionMatrix) DeepCopyInto 

func (in *ConfusionMatrix) DeepCopyInto(out *ConfusionMatrix)

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

func (*ConfusionMatrix) Descriptor 

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

func (*ConfusionMatrix) Marshal 

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

func (*ConfusionMatrix) MarshalTo 

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

func (*ConfusionMatrix) MarshalToSizedBuffer 

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

func (*ConfusionMatrix) ProtoMessage 

func (*ConfusionMatrix) ProtoMessage()

func (*ConfusionMatrix) Reset 

func (m *ConfusionMatrix) Reset()

func (*ConfusionMatrix) Size 

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

func (*ConfusionMatrix) String 

func (this *ConfusionMatrix) String() string

func (*ConfusionMatrix) Unmarshal 

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

func (*ConfusionMatrix) XXX_DiscardUnknown 

func (m *ConfusionMatrix) XXX_DiscardUnknown()

func (*ConfusionMatrix) XXX_Marshal 

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

func (*ConfusionMatrix) XXX_Merge 

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

func (*ConfusionMatrix) XXX_Size 

func (m *ConfusionMatrix) XXX_Size() int

func (*ConfusionMatrix) XXX_Unmarshal 

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

type ConfusionMatrixRow 

type ConfusionMatrixRow struct {
	T     string  `json:"t,omitempty" protobuf:"bytes,1,opt,name=t"` // True Label
	P     string  `json:"p,omitempty" protobuf:"bytes,2,opt,name=p"` // Predicated Label
	Count int32   `json:"count,omitempty" protobuf:"varint,3,opt,name=count"`
	Pct   float64 `json:"pct,omitempty" protobuf:"bytes,4,opt,name=pct"`
}

func (*ConfusionMatrixRow) DeepCopy 

func (in *ConfusionMatrixRow) DeepCopy() *ConfusionMatrixRow

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

func (*ConfusionMatrixRow) DeepCopyInto 

func (in *ConfusionMatrixRow) DeepCopyInto(out *ConfusionMatrixRow)

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

func (*ConfusionMatrixRow) Descriptor 

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

func (*ConfusionMatrixRow) Marshal 

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

func (*ConfusionMatrixRow) MarshalTo 

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

func (*ConfusionMatrixRow) MarshalToSizedBuffer 

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

func (*ConfusionMatrixRow) ProtoMessage 

func (*ConfusionMatrixRow) ProtoMessage()

func (*ConfusionMatrixRow) Reset 

func (m *ConfusionMatrixRow) Reset()

func (*ConfusionMatrixRow) Size 

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

func (*ConfusionMatrixRow) String 

func (this *ConfusionMatrixRow) String() string

func (*ConfusionMatrixRow) Unmarshal 

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

func (*ConfusionMatrixRow) XXX_DiscardUnknown 

func (m *ConfusionMatrixRow) XXX_DiscardUnknown()

func (*ConfusionMatrixRow) XXX_Marshal 

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

func (*ConfusionMatrixRow) XXX_Merge 

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

func (*ConfusionMatrixRow) XXX_Size 

func (m *ConfusionMatrixRow) XXX_Size() int

func (*ConfusionMatrixRow) XXX_Unmarshal 

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

type ConnectionCategory 

type ConnectionCategory string

+kubebuilder:validation:Enum="general";"cloud";"docker-image-registry";"database";"git";"messaging";"storage"; 

const (
	GeneralConnectionCategory             ConnectionCategory = "general"
	StorageConnectionCategory             ConnectionCategory = "storage"
	CloudProviderConnectionCategory       ConnectionCategory = "cloud"
	DockerImageRegistryConnectionCategory ConnectionCategory = "docker-image-registry"
	DatabaseConnectionCategory            ConnectionCategory = "database"
	GitConnectionCategory                 ConnectionCategory = "git"
	MessagingConnectionCategory           ConnectionCategory = "messaging"
	BrokerConnectionMessage               ConnectionCategory = "message-broker"
	GraphDatabaseConnectionCategory       ConnectionCategory = "graph-database"
	SocialMediaConnectionCategory         ConnectionCategory = "social-media"
)

type ContainerLog added in v0.4.541 

type ContainerLog struct {
	// The name of the Job
	Job string `json:"job,omitempty" protobuf:"bytes,1,rep,name=job"`
	// The container name
	Container string `json:"container,omitempty" protobuf:"bytes,2,rep,name=container"`
	// The path to the log in the bucket
	Key string `json:"key,omitempty" protobuf:"bytes,3,rep,name=key"`
	// The bucket the log was stored in
	Bucket string `json:"bucket,omitempty" protobuf:"bytes,4,rep,name=bucket"`
}

ContainerLog describes the location of logs for a single Job

func (*ContainerLog) DeepCopy added in v0.4.541 

func (in *ContainerLog) DeepCopy() *ContainerLog

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

func (*ContainerLog) DeepCopyInto added in v0.4.541 

func (in *ContainerLog) DeepCopyInto(out *ContainerLog)

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

func (*ContainerLog) Descriptor added in v0.4.541 

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

func (*ContainerLog) Marshal added in v0.4.541 

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

func (*ContainerLog) MarshalTo added in v0.4.541 

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

func (*ContainerLog) MarshalToSizedBuffer added in v0.4.541 

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

func (*ContainerLog) ProtoMessage added in v0.4.541 

func (*ContainerLog) ProtoMessage()

func (*ContainerLog) Reset added in v0.4.541 

func (m *ContainerLog) Reset()

func (*ContainerLog) Size added in v0.4.541 

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

func (*ContainerLog) String added in v0.4.541 

func (this *ContainerLog) String() string

func (*ContainerLog) Unmarshal added in v0.4.541 

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

func (*ContainerLog) XXX_DiscardUnknown added in v0.4.541 

func (m *ContainerLog) XXX_DiscardUnknown()

func (*ContainerLog) XXX_Marshal added in v0.4.541 

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

func (*ContainerLog) XXX_Merge added in v0.4.541 

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

func (*ContainerLog) XXX_Size added in v0.4.541 

func (m *ContainerLog) XXX_Size() int

func (*ContainerLog) XXX_Unmarshal added in v0.4.541 

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

type ContainerLogs added in v0.6.252 

type ContainerLogs []ContainerLog

func (ContainerLogs) Append added in v0.6.252 

func (c ContainerLogs) Append(logs []ContainerLog) ContainerLogs

func (ContainerLogs) DeepCopy added in v0.6.252 

func (in ContainerLogs) DeepCopy() ContainerLogs

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

func (ContainerLogs) DeepCopyInto added in v0.6.252 

func (in ContainerLogs) DeepCopyInto(out *ContainerLogs)

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

type CurvePoint 

type CurvePoint struct {
	X float64 `json:"x,omitempty" protobuf:"bytes,1,opt,name=x"`
	Y float64 `json:"y,omitempty" protobuf:"bytes,2,opt,name=y"`
}

func (*CurvePoint) DeepCopy 

func (in *CurvePoint) DeepCopy() *CurvePoint

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

func (*CurvePoint) DeepCopyInto 

func (in *CurvePoint) DeepCopyInto(out *CurvePoint)

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

func (*CurvePoint) Descriptor 

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

func (*CurvePoint) Marshal 

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

func (*CurvePoint) MarshalTo 

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

func (*CurvePoint) MarshalToSizedBuffer 

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

func (*CurvePoint) ProtoMessage 

func (*CurvePoint) ProtoMessage()

func (*CurvePoint) Reset 

func (m *CurvePoint) Reset()

func (*CurvePoint) Size 

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

func (*CurvePoint) String 

func (this *CurvePoint) String() string

func (*CurvePoint) Unmarshal 

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

func (*CurvePoint) XXX_DiscardUnknown 

func (m *CurvePoint) XXX_DiscardUnknown()

func (*CurvePoint) XXX_Marshal 

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

func (*CurvePoint) XXX_Merge 

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

func (*CurvePoint) XXX_Size 

func (m *CurvePoint) XXX_Size() int

func (*CurvePoint) XXX_Unmarshal 

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

type CvType 

type CvType string

+kubebuilder:validation:Enum="none";"group-kfold";"group-shuffle-split";"kfold";"leave-one-group-out";"leave-p-groups-out";"leave-one-out";"leave-p-out";"predefined-split";"repeated-kfold";"repeated-stratified-k-fold";"shuffle-split";"stratified-k-fold";"stratified-shuffle-split";"stratified-group-k-fold";"time-series-split" 

const (
	CvTypeNone                    CvType = "none"
	CvTypeGroupKFold              CvType = "group-kfold"
	CvTypeGroupShuffleSplit       CvType = "group-shuffle-split"
	CVTypeKFold                   CvType = "kfold"
	CVTypeLeaveOneGroupOut        CvType = "leave-one-group-out"
	CvTypeLeavePGroupsOut         CvType = "leave-p-groups-out"
	CvTypeLeaveOneOut             CvType = "leave-one-out"
	CvTypeLeavePOut               CvType = "leave-p-out"
	CvTypePredefinedSplit         CvType = "predefined-split"
	CvTypeRepeatedKFold           CvType = "repeated-kfold"
	CvTypeRepeatedStratifiedKFold CvType = "repeated-stratified-k-fold"
	CvTypeShuffleSplit            CvType = "shuffle-split"
	CvTypeStratifiedKFold         CvType = "stratified-k-fold"
	CvTypeStratifiedShuffleSplit  CvType = "stratified-shuffle-split"
	CvTypeStratifiedGroupKFold    CvType = "stratified-group-k-fold"
	CvTypeTimeSeriesSplit         CvType = "time-series-split"
)

type DataCenter 

type DataCenter struct {
	// Name is the name of the datacenter
	Name string `json:"name,omitempty" protobuf:"bytes,1,opt,name=name"`
	//Code is the code of the datacenter
	Code string `json:"code,omitempty" protobuf:"bytes,2,opt,name=code"`
}

Datacenter contains the attribute of a specific data center

func (*DataCenter) DeepCopy 

func (in *DataCenter) DeepCopy() *DataCenter

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

func (*DataCenter) DeepCopyInto 

func (in *DataCenter) DeepCopyInto(out *DataCenter)

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

func (*DataCenter) Descriptor 

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

func (*DataCenter) Marshal 

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

func (*DataCenter) MarshalTo 

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

func (*DataCenter) MarshalToSizedBuffer 

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

func (*DataCenter) ProtoMessage 

func (*DataCenter) ProtoMessage()

func (*DataCenter) Reset 

func (m *DataCenter) Reset()

func (*DataCenter) Size 

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

func (*DataCenter) String 

func (this *DataCenter) String() string

func (*DataCenter) Unmarshal 

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

func (*DataCenter) XXX_DiscardUnknown 

func (m *DataCenter) XXX_DiscardUnknown()

func (*DataCenter) XXX_Marshal 

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

func (*DataCenter) XXX_Merge 

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

func (*DataCenter) XXX_Size 

func (m *DataCenter) XXX_Size() int

func (*DataCenter) XXX_Unmarshal 

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

type DataDomain 

type DataDomain string

+kubebuilder:validation:Enum="url";"path";"password";"time";"count";"interval";"nominal";"email";"creditcard";"uuid";"uuid5";"uuid";"base64";"latitude";"longtitude";"dns";"ip4";"ip6";"ssn";"alpha";"alphanumeric";"unknown";"color";"currency";"date";"guid";"hyperlink";"image";"media";"file";"embedding";"record";"useless";"none" 

const (
	DataDomainUrl          DataDomain = "url"
	DataDomainPath         DataDomain = "path"
	DataDomainPassword     DataDomain = "password"
	DataDomainTime         DataDomain = "time"
	DataDomainCount        DataDomain = "count"
	DataDomainInterval     DataDomain = "interval"
	DataDomainNominal      DataDomain = "nominal"
	DataDomainEmail        DataDomain = "email"
	DataDomainCreditCard   DataDomain = "creditCard"
	DataDomainUuid3        DataDomain = "uuid"
	DataDomainUuid5        DataDomain = "uuid5"
	DataDomainUuid         DataDomain = "uuid"
	DataDomainBase64       DataDomain = "base64"
	DataDomainLatitude     DataDomain = "latitude"
	DataDomainLongtitude   DataDomain = "longtitude"
	DataDomainDnsName      DataDomain = "dns"
	DataDomainIp4          DataDomain = "ip4"
	DataDomainIp6          DataDomain = "ip6"
	DataDomainSsn          DataDomain = "ssn"
	DataDomainAlpha        DataDomain = "alpha"
	DataDomainAlphaNumeric DataDomain = "alphanumeric"
	DataDomainUnknown      DataDomain = "unknown"
	DataDomainColor        DataDomain = "color"
	DataDomainCurrency     DataDomain = "currency"
	DataDomainDate         DataDomain = "date"
	DataDomainGuid         DataDomain = "guid"
	DataDomainHyperlink    DataDomain = "hyperlink"
	DataDomainImage        DataDomain = "image"
	DataDomainMedia        DataDomain = "media"
	DataDomainFile         DataDomain = "file"
	DataDomainEmbedding    DataDomain = "embedding"
	DataDomainRecord       DataDomain = "record"
	DataDomainUseless      DataDomain = "useless"
	DataDomainNone         DataDomain = "none"
)

type DataLocation added in v0.6.252 

type DataLocation struct {
	// File specifies the location of a flat-file
	File *FileLocation `json:"file,omitempty" protobuf:"bytes,1,opt,name=file"`
	// Database specifies the location of data within a database
	Database *DatabaseLocation `json:"database,omitempty" protobuf:"bytes,2,opt,name=database"`
	// Web specifies the location of an internet-accessible flat-file
	Web *WebLocation `json:"web,omitempty" protobuf:"bytes,3,opt,name=web"`
	// Resource references another Modela resource that contains data
	Resource *ResourceLocation `json:"resource,omitempty" protobuf:"bytes,4,opt,name=resource"`
}

DataLocation describes the location of an external data source

func (*DataLocation) DeepCopy added in v0.6.252 

func (in *DataLocation) DeepCopy() *DataLocation

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

func (*DataLocation) DeepCopyInto added in v0.6.252 

func (in *DataLocation) DeepCopyInto(out *DataLocation)

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

func (*DataLocation) Descriptor added in v0.6.252 

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

func (*DataLocation) Marshal added in v0.6.252 

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

func (*DataLocation) MarshalTo added in v0.6.252 

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

func (*DataLocation) MarshalToSizedBuffer added in v0.6.252 

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

func (*DataLocation) ProtoMessage added in v0.6.252 

func (*DataLocation) ProtoMessage()

func (*DataLocation) Reset added in v0.6.252 

func (m *DataLocation) Reset()

func (*DataLocation) Size added in v0.6.252 

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

func (*DataLocation) String added in v0.6.252 

func (this *DataLocation) String() string

func (*DataLocation) ToFileLocation added in v0.6.252 

func (location *DataLocation) ToFileLocation() *FileLocation

func (*DataLocation) Type added in v0.6.252 

func (location *DataLocation) Type() DataLocationType

func (*DataLocation) Unmarshal added in v0.6.252 

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

func (*DataLocation) Validate added in v0.6.310 

func (location *DataLocation) Validate(fldPath *field.Path) field.ErrorList

func (*DataLocation) XXX_DiscardUnknown added in v0.6.252 

func (m *DataLocation) XXX_DiscardUnknown()

func (*DataLocation) XXX_Marshal added in v0.6.252 

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

func (*DataLocation) XXX_Merge added in v0.6.252 

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

func (*DataLocation) XXX_Size added in v0.6.252 

func (m *DataLocation) XXX_Size() int

func (*DataLocation) XXX_Unmarshal added in v0.6.252 

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

type DataLocationType added in v0.6.252 

type DataLocationType int

type DataSplitMethod added in v0.4.366 

type DataSplitMethod string

+kubebuilder:validation:Enum="random";"split-column";"time";"random-stratified";"auto";"test-dataset"; 

const (
	DataSplitMethodRandomStratified DataSplitMethod = "random-stratified"
	DataSplitMethodRandom           DataSplitMethod = "random"
	DataSplitMethodSplitColumn      DataSplitMethod = "split-column"
	DataSplitMethodTime             DataSplitMethod = "time"
	DataSplitMethodUseTestDataset   DataSplitMethod = "test-dataset"
	DataSplitAuto                   DataSplitMethod = "auto"
)

type DataTestCase added in v0.4.959 

type DataTestCase struct {
	// If false, this test case is disabled
	// +kubebuilder:validation:Optional
	Enabled *bool `json:"enabled,omitempty" protobuf:"varint,1,opt,name=enabled"`
	// The name of the test case, will be generate if empty by the combination of assertion, entity ref, column name and metric
	Name string `json:"name,omitempty" protobuf:"bytes,2,opt,name=name"`
	// The assertion type
	AssertThat AssertionType `json:"assertThat,omitempty" protobuf:"bytes,3,opt,name=assertThat"`
	// Reference to an entity.
	// +kubebuilder:validation:Optional
	EntityRef v1.ObjectReference `json:"entityRef,omitempty" protobuf:"bytes,4,opt,name=entityRef"`
	// Reference to another entity which is a ref.
	// +kubebuilder:validation:Optional
	CompareToRef v1.ObjectReference `json:"compareToRef,omitempty" protobuf:"bytes,5,opt,name=compareToRef"`
	// If unit test is column test, this is the name of the column
	// +kubebuilder:validation:Optional
	Column *string `json:"column,omitempty" protobuf:"bytes,6,opt,name=column"`
	// The test type
	// The type of the data test
	Type DataTestType `json:"type,omitempty" protobuf:"bytes,7,opt,name=type"`
	// The metric that is used for the test
	// +kubebuilder:validation:Optional
	Metric Metric `json:"metric,omitempty" protobuf:"bytes,8,opt,name=metric"`
	// The expected numerical value
	// +kubebuilder:validation:Optional
	ExpectedValue *float64 `json:"expectedValue,omitempty" protobuf:"bytes,9,opt,name=expectedValue"`
	// The expected value
	// +kubebuilder:validation:Optional
	ExpectedCategory *string `json:"expectedCategory,omitempty" protobuf:"bytes,10,opt,name=expectedCategory"`
	// For range based tests.
	// +kubebuilder:validation:Format=float
	// +kubebuilder:validation:Optional
	Lower *float64 `json:"lower,omitempty" protobuf:"bytes,11,opt,name=lower"`
	// +kubebuilder:validation:Format=float
	// +kubebuilder:validation:Optional
	Upper *float64 `json:"upper,omitempty" protobuf:"bytes,12,opt,name=upper"`
	// Expected set of values,if the assertion
	// +kubebuilder:validation:Optional
	ExpectedSet []string `json:"expectedSet,omitempty" protobuf:"bytes,13,rep,name=expectedSet"`
	// +kubebuilder:validation:Optional
	LowerInclusive *bool `json:"lowerInclusive,omitempty" protobuf:"varint,14,opt,name=lowerInclusive"`
	// +kubebuilder:validation:Optional
	UpperInclusive *bool `json:"upperInclusive,omitempty" protobuf:"varint,15,opt,name=upperInclusive"`
	// Indicates if this validation rule was automatically generated by the system
	// +kubebuilder:validation:Optional
	Generated *bool `json:"generated,omitempty" protobuf:"varint,16,opt,name=generated"`
	// The test case tags, used for filtering.
	// Optional Test Tags
	Tags []string `json:"tags,omitempty" protobuf:"bytes,17,rep,name=tags"`
	// For test that involve two columns (e.g. correlation)
	// +kubebuilder:validation:Optional
	Column2 *string `json:"column2,omitempty" protobuf:"bytes,18,opt,name=column2"`
	// Reference to an entity.
	// +kubebuilder:validation:Optional
	EntityRef2 v1.ObjectReference `json:"entityRef2,omitempty" protobuf:"bytes,19,opt,name=entityRef2"`
	// If unit test is column test, this is the name of the column
	// +kubebuilder:validation:Optional
	Columns []string `json:"columns,omitempty" protobuf:"bytes,20,rep,name=columns"`
	// Filter the filter for this unit test.
	// +kubebuilder:validation:Optional
	FeatureFilter *FeatureFilterType `json:"featureFilter,omitempty" protobuf:"bytes,21,opt,name=featureFilter"`
	// Sql statement to filter the data for this unit test
	// +kubebuilder:validation:Optional
	DataFilter *string `json:"dataFilter,omitempty" protobuf:"bytes,22,opt,name=dataFilter"`
	// Set the reference type for this unit test
	// +kubebuilder:validation:Optional
	ReferenceType *ReferenceDataType `json:"referenceType,omitempty" protobuf:"bytes,23,opt,name=referenceType"`
	// The length of the past if we are comparing to moving avg
	// +kubebuilder:validation:Optional
	Periods *int32 `json:"periods,omitempty" protobuf:"bytes,24,opt,name=periods"`
}

func (*DataTestCase) DeepCopy added in v0.4.959 

func (in *DataTestCase) DeepCopy() *DataTestCase

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

func (*DataTestCase) DeepCopyInto added in v0.4.959 

func (in *DataTestCase) DeepCopyInto(out *DataTestCase)

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

func (*DataTestCase) Descriptor added in v0.4.959 

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

func (*DataTestCase) Marshal added in v0.4.959 

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

func (*DataTestCase) MarshalTo added in v0.4.959 

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

func (*DataTestCase) MarshalToSizedBuffer added in v0.4.959 

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

func (*DataTestCase) ProtoMessage added in v0.4.959 

func (*DataTestCase) ProtoMessage()

func (*DataTestCase) Reset added in v0.4.959 

func (m *DataTestCase) Reset()

func (*DataTestCase) Size added in v0.4.959 

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

func (*DataTestCase) String added in v0.4.959 

func (this *DataTestCase) String() string

func (*DataTestCase) Unmarshal added in v0.4.959 

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

func (*DataTestCase) XXX_DiscardUnknown added in v0.4.959 

func (m *DataTestCase) XXX_DiscardUnknown()

func (*DataTestCase) XXX_Marshal added in v0.4.959 

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

func (*DataTestCase) XXX_Merge added in v0.4.959 

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

func (*DataTestCase) XXX_Size added in v0.4.959 

func (m *DataTestCase) XXX_Size() int

func (*DataTestCase) XXX_Unmarshal added in v0.4.959 

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

type DataTestCaseResult added in v0.4.959 

type DataTestCaseResult struct {
	// The test case name for this result.
	Name string `json:"name" protobuf:"bytes,1,opt,name=name"`
	// Actual observation
	// +kubebuilder:validation:Optional
	Actual Measurement `json:"actual,omitempty" protobuf:"bytes,2,opt,name=actual"`
	// A failure occur on assertion failure
	// +kubebuilder:validation:Optional
	Failure bool `json:"failure,omitempty" protobuf:"varint,3,opt,name=failure"`
	// An error occur if the system cannot execute the test case (e.g. connection error).
	// +kubebuilder:validation:Optional
	Error bool `json:"error,omitempty" protobuf:"varint,4,opt,name=error"`
	// An optional
	// +kubebuilder:validation:Optional
	FailureMsg string `json:"failureMsg,omitempty" protobuf:"bytes,5,opt,name=failureMsg"`
}

Result for a specific case

func (*DataTestCaseResult) DeepCopy added in v0.4.959 

func (in *DataTestCaseResult) DeepCopy() *DataTestCaseResult

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

func (*DataTestCaseResult) DeepCopyInto added in v0.4.959 

func (in *DataTestCaseResult) DeepCopyInto(out *DataTestCaseResult)

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

func (*DataTestCaseResult) Descriptor added in v0.4.959 

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

func (*DataTestCaseResult) Marshal added in v0.4.959 

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

func (*DataTestCaseResult) MarshalTo added in v0.4.959 

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

func (*DataTestCaseResult) MarshalToSizedBuffer added in v0.4.959 

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

func (*DataTestCaseResult) ProtoMessage added in v0.4.959 

func (*DataTestCaseResult) ProtoMessage()

func (*DataTestCaseResult) Reset added in v0.4.959 

func (m *DataTestCaseResult) Reset()

func (*DataTestCaseResult) Size added in v0.4.959 

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

func (*DataTestCaseResult) String added in v0.4.959 

func (this *DataTestCaseResult) String() string

func (*DataTestCaseResult) Unmarshal added in v0.4.959 

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

func (*DataTestCaseResult) XXX_DiscardUnknown added in v0.4.959 

func (m *DataTestCaseResult) XXX_DiscardUnknown()

func (*DataTestCaseResult) XXX_Marshal added in v0.4.959 

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

func (*DataTestCaseResult) XXX_Merge added in v0.4.959 

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

func (*DataTestCaseResult) XXX_Size added in v0.4.959 

func (m *DataTestCaseResult) XXX_Size() int

func (*DataTestCaseResult) XXX_Unmarshal added in v0.4.959 

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

type DataTestType added in v0.5.1 

type DataTestType string
const (
	DataTestTypeMultiDataset DataTestType = "multi-dataset"
	DataTestTypeDataset      DataTestType = "dataset"
	DataTestTypeMultiColumn  DataTestType = "multi-column"
	DataTestTypeColumn       DataTestType = "column"
	DataTestTypeModel        DataTestType = "model"
	DataTestTypeDataDrift    DataTestType = "data-drift"
)

type DataType 

type DataType string

+kubebuilder:validation:Enum="boolean";"datetime";"number";"categorical";"ordinal";"text";"json";"number-list";"categorical-list";"text-list"; 

const (
	DataTypeBoolean         DataType = "boolean"
	DataTypeDateTime        DataType = "datetime"
	DataTypeNumber          DataType = "number"
	DataTypeCategorical     DataType = "categorical"
	DataTypeOrdinal         DataType = "ordinal"
	DataTypeText            DataType = "text"
	DataTypeJson            DataType = "json"
	DataTypeNumberList      DataType = "number-list"
	DataTypeCategoricalList DataType = "categorical-list"
	DataTypeTextList        DataType = "text-list"
)

type DatabaseLocation added in v0.6.310 

type DatabaseLocation struct {
	// The name of the Connection resource used to connect to the database
	// +kubebuilder:validation:Optional
	ConnectionName string `json:"connectionName,omitempty" protobuf:"bytes,1,opt,name=connectionName"`
	// The name of the table to read
	// +kubebuilder:default:=""
	// +kubebuilder:validation:Optional
	Table *string `json:"table,omitempty" protobuf:"bytes,2,opt,name=table"`
	// The SQL statement to execute
	// +kubebuilder:default:=""
	// +kubebuilder:validation:Optional
	Sql *string `json:"sql,omitempty" protobuf:"bytes,3,opt,name=sql"`
}

func (*DatabaseLocation) DeepCopy added in v0.6.310 

func (in *DatabaseLocation) DeepCopy() *DatabaseLocation

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

func (*DatabaseLocation) DeepCopyInto added in v0.6.310 

func (in *DatabaseLocation) DeepCopyInto(out *DatabaseLocation)

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

func (*DatabaseLocation) Descriptor added in v0.6.310 

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

func (*DatabaseLocation) Marshal added in v0.6.310 

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

func (*DatabaseLocation) MarshalTo added in v0.6.310 

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

func (*DatabaseLocation) MarshalToSizedBuffer added in v0.6.310 

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

func (*DatabaseLocation) ProtoMessage added in v0.6.310 

func (*DatabaseLocation) ProtoMessage()

func (*DatabaseLocation) Reset added in v0.6.310 

func (m *DatabaseLocation) Reset()

func (*DatabaseLocation) Size added in v0.6.310 

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

func (*DatabaseLocation) String added in v0.6.310 

func (this *DatabaseLocation) String() string

func (*DatabaseLocation) Unmarshal added in v0.6.310 

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

func (*DatabaseLocation) Validate added in v0.6.310 

func (location *DatabaseLocation) Validate(fldPath *field.Path) field.ErrorList

func (*DatabaseLocation) XXX_DiscardUnknown added in v0.6.310 

func (m *DatabaseLocation) XXX_DiscardUnknown()

func (*DatabaseLocation) XXX_Marshal added in v0.6.310 

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

func (*DatabaseLocation) XXX_Merge added in v0.6.310 

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

func (*DatabaseLocation) XXX_Size added in v0.6.310 

func (m *DatabaseLocation) XXX_Size() int

func (*DatabaseLocation) XXX_Unmarshal added in v0.6.310 

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

type DatasetType 

type DatasetType string

+kubebuilder:validation:Enum="tabular";"image";"nlp";"video";"audio" 

const (
	TabularDatasetType DatasetType = "tabular"
	ImageDatasetType   DatasetType = "image"
	NLPDatasetType     DatasetType = "nlp"
	VideoDatasetType   DatasetType = "video"
	AudioDatasetType   DatasetType = "audio"
)

type DatetimeTransformation added in v0.4.455 

type DatetimeTransformation string

+kubebuilder:validation:Enum="extract-datetime-information";"none";"auto" 

const (
	ExtractDatetimeTransformation DatetimeTransformation = "extract-datetime-information"
	NoneDatetimeTransformation    DatetimeTransformation = "none"
	AutoDatetimeTransformation    DatetimeTransformation = "auto"
)

type DimensionReduction 

type DimensionReduction string

============================================================================== Feature Engineering ============================================================================== +kubebuilder:validation:Enum="pca";"polynomial-features";"rbf-sampler";"fast-ica";"nystroem";"none";"auto" 

const (
	PCADimensionReduction                DimensionReduction = "pca"
	PolynomialFeaturesDimensionReduction DimensionReduction = "polynomial-features"
	RBFSamplerDimensionReduction         DimensionReduction = "rbf-sampler"
	FastIcaDimensionReduction            DimensionReduction = "fast-ica"
	NystroemDimensionReduction           DimensionReduction = "nystroem"
	NoneDimensionReduction               DimensionReduction = "none"
	AutoDimensionReduction               DimensionReduction = "auto"
)

type Discretisation 

type Discretisation string

+kubebuilder:validation:Enum="equal-width-discretisation-";"equal-freq-discretisation";"kbin-discretisation";"kernel-centerer-discretisation";"label-binarizer-discretisation";"multi-label-binarizer-discretisation";"none";"auto" 

const (
	EqualWidthDiscretisation          Discretisation = "equal-width-discretisation-"
	EqualFreqDiscretisation           Discretisation = "equal-freq-discretisation"
	KBinsDiscretisation               Discretisation = "kbin-discretisation"
	KernelCentererDiscretisation      Discretisation = "kernel-centerer-discretisation"
	LabelBinarizerDiscretisation      Discretisation = "label-binarizer-discretisation"
	MultiLabelBinarizerDiscretisation Discretisation = "multi-label-binarizer-discretisation"
	NoneDiscretisation                Discretisation = "none"
	AutoDiscretisation                Discretisation = "auto"
)

type EnsembleType added in v0.4.389 

type EnsembleType string
const (
	VotingEnsembleType EnsembleType = "voting"
	StackEnsembleType  EnsembleType = "stacking"
)

type FeatureFilterType added in v0.5.114 

type FeatureFilterType string
const (
	FeatureFilterAllFeatures       FeatureFilterType = "all-features"
	FeatureFilterImportantFeatures FeatureFilterType = "important-features"
	FeatureFilterFeatureList       FeatureFilterType = "features-list"
	FeatureFilterNumericFeatures   FeatureFilterType = "numeric-features"
	FeatureFilterCatFeatures       FeatureFilterType = "categorical-features"
	FeatureFilterTextFeatures      FeatureFilterType = "text-features"
)

type FeatureSelection 

type FeatureSelection string

+kubebuilder:validation:Enum="drop-features";"drop-constant-features";"drop-duplicated-features";"drop-correlated-features";"mutual-information";"chisquare";"anova";"step-forward";"step-backward";"lasso-regression";"tree-importance";"recursive-feature-elimination";"recursive-feature-addition";"select-percentile";"select-kbest";"select-fpr";"select-fdr";"variance-threshold";"none";"auto" 

const (
	DropFeaturesFeatureSelection      FeatureSelection = "drop-features"
	DropConstantFeatures              FeatureSelection = "drop-constant-features"
	DropDuplicateFeatures             FeatureSelection = "drop-duplicated-features"
	DropCorrelatedFeatures            FeatureSelection = "drop-correlated-features"
	MutualInformationFeatureSelection FeatureSelection = "mutual-information"
	ChiSquareFeatureSelection         FeatureSelection = "chisquare"
	AnovaFeatureSelection             FeatureSelection = "anova"
	StepForwardFeatureSelection       FeatureSelection = "step-forward"
	StepBackwardFeatureSelection      FeatureSelection = "step-backward"
	LassoRegressionFeatureSelection   FeatureSelection = "lasso-regression"
	TreeImportanceFeatureSelection    FeatureSelection = "tree-importance"
	RecursiveFeatureElimination       FeatureSelection = "recursive-feature-elimination"
	RecursiveFeatureAddition          FeatureSelection = "recursive-feature-addition"
	SelectPercentile                  FeatureSelection = "select-percentile"
	SelectKBest                       FeatureSelection = "select-kbest"
	SelectFpr                         FeatureSelection = "select-fpr"
	SelectFdr                         FeatureSelection = "select-fdr"
	VarianceThreshold                 FeatureSelection = "variance-threshold"
	NoneFeatureSelection              FeatureSelection = "none"
	AutoFeatureSelection              FeatureSelection = "auto"
)

type FeatureStoreIngestType added in v0.5.280 

type FeatureStoreIngestType string
const (
	BatchIngestType    FeatureStoreIngestType = "batch"
	StreamIngestType   FeatureStoreIngestType = "stream"
	PushIngestType     FeatureStoreIngestType = "push"
	RequestIngestType  FeatureStoreIngestType = "request"
	OnDemandIngestType FeatureStoreIngestType = "ondemand"
)

type FileEncoding 

type FileEncoding string

+kubebuilder:validation:Enum="utf-8";"latin-1";"utf-16"; 

const (
	FileEncodingUtf8 FileEncoding = "utf-8"
	//iso-8859-1
	FileEncodingLating1 FileEncoding = "latin-1"
	FileEncodingUtf16   FileEncoding = "utf-16"
)

type FileLocation added in v0.6.252 

type FileLocation struct {
	BucketName string `json:"bucketName,omitempty" protobuf:"bytes,1,opt,name=bucketName"`
	Path       string `json:"path,omitempty" protobuf:"bytes,2,opt,name=path"`
}

FileLocation denotes the location of a flat-file, which is the name of a Virtual Bucket and the path within it

func (*FileLocation) DeepCopy added in v0.6.252 

func (in *FileLocation) DeepCopy() *FileLocation

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

func (*FileLocation) DeepCopyInto added in v0.6.252 

func (in *FileLocation) DeepCopyInto(out *FileLocation)

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

func (*FileLocation) Descriptor added in v0.6.252 

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

func (*FileLocation) Hash added in v0.6.252 

func (f *FileLocation) Hash() string

func (*FileLocation) Marshal added in v0.6.252 

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

func (*FileLocation) MarshalTo added in v0.6.252 

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

func (*FileLocation) MarshalToSizedBuffer added in v0.6.252 

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

func (*FileLocation) ProtoMessage added in v0.6.252 

func (*FileLocation) ProtoMessage()

func (*FileLocation) Reset added in v0.6.252 

func (m *FileLocation) Reset()

func (*FileLocation) Size added in v0.6.252 

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

func (*FileLocation) String added in v0.6.252 

func (this *FileLocation) String() string

func (*FileLocation) Unmarshal added in v0.6.252 

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

func (*FileLocation) XXX_DiscardUnknown added in v0.6.252 

func (m *FileLocation) XXX_DiscardUnknown()

func (*FileLocation) XXX_Marshal added in v0.6.252 

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

func (*FileLocation) XXX_Merge added in v0.6.252 

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

func (*FileLocation) XXX_Size added in v0.6.252 

func (m *FileLocation) XXX_Size() int

func (*FileLocation) XXX_Unmarshal added in v0.6.252 

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

type Frequency added in v0.6.252 

type Frequency string

The Horizon unit +kubebuilder:validation:Enum="second";"minute";"hour";"day";"week";"month";"quarter";"year";"multi-year" 

const (
	FreqSeconds    Frequency = "second"
	FreqMinutes    Frequency = "minute"
	FreqHours      Frequency = "hour"
	FreqDays       Frequency = "day"
	FreqWeeks      Frequency = "week"
	FreqMonths     Frequency = "month"
	FreqQtrs       Frequency = "quarter"
	FreqYears      Frequency = "year"
	FreqMultiYears Frequency = "multi-year"
)

type GoalType added in v0.5.479 

type GoalType string
const (
	MaximizeGoalType GoalType = "maximize"
	MinimizeGoalType GoalType = "minimize"
)

type GpuClass 

type GpuClass struct {
	//Code the the code of the gpu class within the data provider
	Code string `json:"code" protobuf:"bytes,1,opt,name=code"`

	RegionName string `json:"regionName" protobuf:"bytes,2,opt,name=regionName"`
	//Vcpu is the number of cores
	// +kubebuilder:validation:Minimum=0
	Vcpu int32 `json:"vcpu,omitempty" protobuf:"varint,3,opt,name=vcpu"`
	//Gpumem is the amount of memory on the gpu
	Gpumem *resource.Quantity `json:"gpumem,omitempty" protobuf:"bytes,4,opt,name=gpumem"`
}

GpuClass define the specific for a machine type of a cloud provider

func (*GpuClass) DeepCopy 

func (in *GpuClass) DeepCopy() *GpuClass

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

func (*GpuClass) DeepCopyInto 

func (in *GpuClass) DeepCopyInto(out *GpuClass)

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

func (*GpuClass) Descriptor 

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

func (*GpuClass) Marshal 

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

func (*GpuClass) MarshalTo 

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

func (*GpuClass) MarshalToSizedBuffer 

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

func (*GpuClass) ProtoMessage 

func (*GpuClass) ProtoMessage()

func (*GpuClass) Reset 

func (m *GpuClass) Reset()

func (*GpuClass) Size 

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

func (*GpuClass) String 

func (this *GpuClass) String() string

func (*GpuClass) Unmarshal 

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

func (*GpuClass) XXX_DiscardUnknown 

func (m *GpuClass) XXX_DiscardUnknown()

func (*GpuClass) XXX_Marshal 

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

func (*GpuClass) XXX_Merge 

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

func (*GpuClass) XXX_Size 

func (m *GpuClass) XXX_Size() int

func (*GpuClass) XXX_Unmarshal 

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

type GpuClassCost 

type GpuClassCost struct {
	// Code is the machine class code
	Code string `json:"code,omitempty" protobuf:"bytes,1,opt,name=code"`

	Region string `json:"region,omitempty" protobuf:"bytes,2,opt,name=region"`
	// CostPerMinute is the cost per minute in dollar of the machine class
	CostPerMinute *resource.Quantity `json:"costPerMinute,omitempty" protobuf:"bytes,3,opt,name=costPerMinute"`
	// CostSpot is the spot cost of the machine class
	CostSpot *resource.Quantity `json:"costSpot,omitempty" protobuf:"bytes,4,opt,name=costSpot"`
}

GpuClassCost contain the current cost of a gpu class in a region

func (*GpuClassCost) DeepCopy 

func (in *GpuClassCost) DeepCopy() *GpuClassCost

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

func (*GpuClassCost) DeepCopyInto 

func (in *GpuClassCost) DeepCopyInto(out *GpuClassCost)

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

func (*GpuClassCost) Descriptor 

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

func (*GpuClassCost) Marshal 

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

func (*GpuClassCost) MarshalTo 

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

func (*GpuClassCost) MarshalToSizedBuffer 

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

func (*GpuClassCost) ProtoMessage 

func (*GpuClassCost) ProtoMessage()

func (*GpuClassCost) Reset 

func (m *GpuClassCost) Reset()

func (*GpuClassCost) Size 

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

func (*GpuClassCost) String 

func (this *GpuClassCost) String() string

func (*GpuClassCost) Unmarshal 

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

func (*GpuClassCost) XXX_DiscardUnknown 

func (m *GpuClassCost) XXX_DiscardUnknown()

func (*GpuClassCost) XXX_Marshal 

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

func (*GpuClassCost) XXX_Merge 

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

func (*GpuClassCost) XXX_Size 

func (m *GpuClassCost) XXX_Size() int

func (*GpuClassCost) XXX_Unmarshal 

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

type HTS added in v0.5.244 

type HTS string

The hierarchical time series. +kubebuilder:validation:Enum="bottom-up";"middle-out";"top-down";"none"; 

const (
	HTSBottomUp  HTS = "bottom-up"
	HTSMiddleOut HTS = "middle-out"
	HTSTopDown   HTS = "top-down"
	HTSNone      HTS = "none"
)

type HardwareTarget 

type HardwareTarget string

+kubebuilder:validation:Enum="amd-epyc-2";"arma-53";"arma-72";"intel-cascade-lake";"intel-broadwell";"intel-skylake";"tesla-v100";"tesla-k80";"t4";"raspberry-pi8-modela-b"; 

const (
	HardwareTargetAMDEPYC2           HardwareTarget = "amd-epyc-2"
	HardwareTargetARMA53             HardwareTarget = "arma-53"
	HardwareTargetARMA72             HardwareTarget = "arma-72"
	HardwareTargetIntelCascadeLake   HardwareTarget = "intel-cascade-lake"
	HardwareTargetIntelBroadwell     HardwareTarget = "intel-broadwell"
	HardwareTargetIntelSkylake       HardwareTarget = "intel-skylake"
	HardwareTargetTeslaV100          HardwareTarget = "tesla-v100"
	HardwareTargetTeslaK80           HardwareTarget = "tesla-k80"
	HardwareTargetT4                 HardwareTarget = "t4"
	HardwareTargetRaspberryPi8MODELB HardwareTarget = "raspberry-pi8-modela-b"
)

type HistogramData added in v0.4.414 

type HistogramData struct {
	// The bins if the histogram describes continous variables
	Bins []float64 `json:"bins,omitempty" protobuf:"bytes,1,rep,name=bins"`
	// The name of the categories, one per bin if this is a categorical histogram
	Categories []string `json:"categories,omitempty" protobuf:"bytes,2,rep,name=categories"`
	// The set of values per bin
	Counts []float64 `json:"counts,omitempty" protobuf:"bytes,3,rep,name=counts"`
	// The number of missing values
	// +kubebuilder:validation:Minimum=0
	Missing int32 `json:"missing,omitempty" protobuf:"varint,4,opt,name=missing"`
	// The number of invalid values
	// +kubebuilder:validation:Minimum=0
	InvalidCount int32 `json:"invalid,omitempty" protobuf:"varint,5,opt,name=invalid"`
}

HistogramData contains the data to construct a histogram image

func (*HistogramData) DeepCopy added in v0.4.414 

func (in *HistogramData) DeepCopy() *HistogramData

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

func (*HistogramData) DeepCopyInto added in v0.4.414 

func (in *HistogramData) DeepCopyInto(out *HistogramData)

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

func (*HistogramData) Descriptor added in v0.4.414 

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

func (*HistogramData) Marshal added in v0.4.414 

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

func (*HistogramData) MarshalTo added in v0.4.414 

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

func (*HistogramData) MarshalToSizedBuffer added in v0.4.414 

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

func (*HistogramData) ProtoMessage added in v0.4.414 

func (*HistogramData) ProtoMessage()

func (*HistogramData) Reset added in v0.4.414 

func (m *HistogramData) Reset()

func (*HistogramData) Size added in v0.4.414 

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

func (*HistogramData) String added in v0.4.414 

func (this *HistogramData) String() string

func (*HistogramData) Unmarshal added in v0.4.414 

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

func (*HistogramData) XXX_DiscardUnknown added in v0.4.414 

func (m *HistogramData) XXX_DiscardUnknown()

func (*HistogramData) XXX_Marshal added in v0.4.414 

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

func (*HistogramData) XXX_Merge added in v0.4.414 

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

func (*HistogramData) XXX_Size added in v0.4.414 

func (m *HistogramData) XXX_Size() int

func (*HistogramData) XXX_Unmarshal added in v0.4.414 

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

type HolidayCountry 

type HolidayCountry string

/ The HolidayCountry unit +kubebuilder:validation:Enum="US";"BR";"ID";"IN";"MY";"VN";"TH";"PH";"PK";"BD";"EG";"CN";"RU";"KR";"BY";"AE";"none"; 

const (
	UnitedState        HolidayCountry = "US"
	Brazil             HolidayCountry = "BR"
	Indonesia          HolidayCountry = "ID"
	India              HolidayCountry = "IN"
	Malaysia           HolidayCountry = "MY"
	Vietnam            HolidayCountry = "VN"
	Thailand           HolidayCountry = "TH"
	Philippines        HolidayCountry = "PH"
	Pakistan           HolidayCountry = "PK"
	Bangladesh         HolidayCountry = "BD"
	Egypt              HolidayCountry = "EG"
	China              HolidayCountry = "CN"
	Russian            HolidayCountry = "RU"
	Korea              HolidayCountry = "KR"
	Belarus            HolidayCountry = "BY"
	UnitedArabEmirates HolidayCountry = "AE"
	NoneHoliday        HolidayCountry = "none"
)

type HyperParameterDataType added in v0.5.395 

type HyperParameterDataType string

+kubebuilder:validation:Enum="float";"int";"categorical"; 

const (
	HyperParameterDataTypeFloat       HyperParameterDataType = "float"
	HyperParameterDataTypeInt         HyperParameterDataType = "int"
	HyperParameterDataTypeCategorical HyperParameterDataType = "categorical"
)

type ImageFeaturizer 

type ImageFeaturizer string

type Images added in v0.4.606 

type Images struct {
	// The image used for data operations
	// +kubebuilder:validation:Optional
	DataImage *string `json:"dataImage,omitempty" protobuf:"bytes,1,opt,name=dataImage"`
}

Images describes the Docker images used internally to perform workloads

func (*Images) DeepCopy added in v0.4.606 

func (in *Images) DeepCopy() *Images

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

func (*Images) DeepCopyInto added in v0.4.606 

func (in *Images) DeepCopyInto(out *Images)

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

func (*Images) Descriptor added in v0.4.606 

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

func (*Images) Marshal added in v0.4.606 

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

func (*Images) MarshalTo added in v0.4.606 

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

func (*Images) MarshalToSizedBuffer added in v0.4.606 

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

func (*Images) ProtoMessage added in v0.4.606 

func (*Images) ProtoMessage()

func (*Images) Reset added in v0.4.606 

func (m *Images) Reset()

func (*Images) Size added in v0.4.606 

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

func (*Images) String added in v0.4.606 

func (this *Images) String() string

func (*Images) Unmarshal added in v0.4.606 

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

func (*Images) XXX_DiscardUnknown added in v0.4.606 

func (m *Images) XXX_DiscardUnknown()

func (*Images) XXX_Marshal added in v0.4.606 

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

func (*Images) XXX_Merge added in v0.4.606 

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

func (*Images) XXX_Size added in v0.4.606 

func (m *Images) XXX_Size() int

func (*Images) XXX_Unmarshal added in v0.4.606 

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

type ImbalanceHandling 

type ImbalanceHandling string

+kubebuilder:validation:Enum="adasyn";"baseline-smote";"kmean-smote";"random-over-sampler";"smote";"smotenc";"svmsmote";"none";"auto";class-weights; 

const (
	ADASYNImbalanceHandling            ImbalanceHandling = "adasyn"
	BorderlineSMOTEImbalanceHandling   ImbalanceHandling = "baseline-smote"
	KMeansSMOTEImbalanceHandling       ImbalanceHandling = "kmean-smote"
	RandomOverSamplerImbalanceHandling ImbalanceHandling = "random-over-sampler"
	SMOTEImbalanceHandling             ImbalanceHandling = "smote"
	SMOTENCImbalanceHandling           ImbalanceHandling = "smotenc"
	SVMSMOTEImbalanceHandling          ImbalanceHandling = "svmsmote"
	ClassWeightsImbalanceHandling      ImbalanceHandling = "class-weights"
	NoneImbalanceHandling              ImbalanceHandling = "none"
	AutoImbalanceHandling              ImbalanceHandling = "auto"
)

type Imputation 

type Imputation string

+kubebuilder:validation:Enum="remove-rows-with-missing-values";"replace-with-mean";"replace-with-median";"replace-with-arbitrary-value";"freq-category-imputation";"add-missing-value-indicator";"knn";"iterative";"mice";"no-imputation";"auto";"none" 

const (
	RemoveRowsWithMissingValuesImputation Imputation = "remove-rows-with-missing-values"
	ReplaceWithMeanImputation             Imputation = "replace-with-mean"
	ReplaceWithMedianImputation           Imputation = "replace-with-median"
	ReplaceWithArbitraryValueImputation   Imputation = "replace-with-arbitrary-value"
	FreqCategoryImputation                Imputation = "freq-category-imputation"
	AddMissingValueIndicatorImputation    Imputation = "add-missing-value-indicator"
	KnnImputation                         Imputation = "knn"
	IterativeImputation                   Imputation = "iterative"
	MICEImputation                        Imputation = "mice"
	AutoImputation                        Imputation = "auto"
	NoneImputation                        Imputation = "none"
)

type LastRunStatus added in v0.4.607 

type LastRunStatus struct {
	// The name of the run
	Name string `json:"name,omitempty" protobuf:"bytes,1,opt,name=name"`
	// The status of the last run
	// +kubebuilder:validation:Optional
	Status string `json:"status,omitempty" protobuf:"bytes,2,opt,name=status"`
	// The time at which the run concluded
	// +kubebuilder:validation:Optional
	CompletedAt *metav1.Time `json:"completedAt,omitempty" protobuf:"bytes,3,opt,name=completedAt"`
	// The duration of the run in seconds
	// +kubebuilder:validation:Optional
	Duration int32 `json:"duration,omitempty" protobuf:"varint,4,opt,name=duration"`
	// In the case of failure, the resource controller which created the run will set this field with a failure reason
	FailureReason *StatusError `json:"failureReason,omitempty" protobuf:"bytes,5,opt,name=failureReason"`
	// In the case of failure, the resource controller which created the run will set this field with a failure message
	FailureMessage *string `json:"failureMessage,omitempty" protobuf:"bytes,6,opt,name=failureMessage"`
}

LastRunStatus describes the status of a single run for a run-based resource (such as a pipeline)

func (*LastRunStatus) DeepCopy added in v0.4.607 

func (in *LastRunStatus) DeepCopy() *LastRunStatus

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

func (*LastRunStatus) DeepCopyInto added in v0.4.607 

func (in *LastRunStatus) DeepCopyInto(out *LastRunStatus)

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

func (*LastRunStatus) Descriptor added in v0.4.607 

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

func (*LastRunStatus) Marshal added in v0.4.607 

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

func (*LastRunStatus) MarshalTo added in v0.4.607 

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

func (*LastRunStatus) MarshalToSizedBuffer added in v0.4.607 

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

func (*LastRunStatus) ProtoMessage added in v0.4.607 

func (*LastRunStatus) ProtoMessage()

func (*LastRunStatus) Reset added in v0.4.607 

func (m *LastRunStatus) Reset()

func (*LastRunStatus) Size added in v0.4.607 

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

func (*LastRunStatus) String added in v0.4.607 

func (this *LastRunStatus) String() string

func (*LastRunStatus) Unmarshal added in v0.4.607 

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

func (*LastRunStatus) XXX_DiscardUnknown added in v0.4.607 

func (m *LastRunStatus) XXX_DiscardUnknown()

func (*LastRunStatus) XXX_Marshal added in v0.4.607 

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

func (*LastRunStatus) XXX_Merge added in v0.4.607 

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

func (*LastRunStatus) XXX_Size added in v0.4.607 

func (m *LastRunStatus) XXX_Size() int

func (*LastRunStatus) XXX_Unmarshal added in v0.4.607 

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

type Lib 

type Lib struct {
	Name    string `json:"name,omitempty" protobuf:"bytes,1,opt,name=frameworks"`
	Version string `json:"version,omitempty" protobuf:"bytes,2,opt,name=version"`
}

func (*Lib) DeepCopy 

func (in *Lib) DeepCopy() *Lib

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

func (*Lib) DeepCopyInto 

func (in *Lib) DeepCopyInto(out *Lib)

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

func (*Lib) Descriptor 

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

func (*Lib) Marshal 

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

func (*Lib) MarshalTo 

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

func (*Lib) MarshalToSizedBuffer 

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

func (*Lib) ProtoMessage 

func (*Lib) ProtoMessage()

func (*Lib) Reset 

func (m *Lib) Reset()

func (*Lib) Size 

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

func (*Lib) String 

func (this *Lib) String() string

func (*Lib) Unmarshal 

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

func (*Lib) XXX_DiscardUnknown 

func (m *Lib) XXX_DiscardUnknown()

func (*Lib) XXX_Marshal 

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

func (*Lib) XXX_Merge 

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

func (*Lib) XXX_Size 

func (m *Lib) XXX_Size() int

func (*Lib) XXX_Unmarshal 

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

type LicenseType 

type LicenseType string

+kubebuilder:validation:Enum="lite";"pro";"enterprise" 

const (
	LiteLicenseType       LicenseType = "lite"
	ProLicenseType        LicenseType = "pro"
	EnterpriseLicenseType LicenseType = "enterprise"
)

type LogLevel added in v0.4.718 

type LogLevel string

The Log level for modela jobs +kubebuilder:validation:Enum="trace";"debug";"info";"error" 

const (
	TraceLogLevel LogLevel = "trace"
	DebugLogLevel LogLevel = "debug"
	InfoLogLevel  LogLevel = "info"
	ErrorLogLevel LogLevel = "error"
)

type Logs 

type Logs []ContainerLog

Logs describes the location of logs produced by workloads associated with a resource

func (Logs) Append added in v0.4.792 

func (logs Logs) Append(newLogs []ContainerLog) Logs

Append the logs only if they are not already exists

func (Logs) DeepCopy 

func (in Logs) DeepCopy() Logs

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

func (Logs) DeepCopyInto 

func (in Logs) DeepCopyInto(out *Logs)

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

type MLFramework 

type MLFramework struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`
	Spec              MLFrameworkSpec `json:"spec" protobuf:"bytes,2,opt,name=spec"`
}

+genclient +kubebuilder:object:root=true +kubebuilder:resource:path=mlframeworks,singular=mlframework,categories={catalog,modela,all} +kubebuilder:storageversion +kubebuilder:printcolumn:name="URL",type="string",JSONPath=".spec.url" +kubebuilder:printcolumn:name="Version",type="string",JSONPath=".spec.version" +kubebuilder:printcolumn:name="Description",type="string",JSONPath=".spec.description" MLFramework define the metadata about a machine learning framework

func (*MLFramework) DeepCopy 

func (in *MLFramework) DeepCopy() *MLFramework

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

func (*MLFramework) DeepCopyInto 

func (in *MLFramework) DeepCopyInto(out *MLFramework)

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

func (*MLFramework) DeepCopyObject 

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

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

func (*MLFramework) Default 

func (framework *MLFramework) Default()

func (*MLFramework) Descriptor 

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

func (*MLFramework) Marshal 

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

func (*MLFramework) MarshalTo 

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

func (*MLFramework) MarshalToSizedBuffer 

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

func (*MLFramework) ProtoMessage 

func (*MLFramework) ProtoMessage()

func (*MLFramework) Reset 

func (m *MLFramework) Reset()

func (*MLFramework) Size 

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

func (*MLFramework) String 

func (this *MLFramework) String() string

func (*MLFramework) Unmarshal 

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

func (*MLFramework) Validate 

func (framework *MLFramework) Validate() (bool, field.ErrorList)

func (*MLFramework) ValidateCreate 

func (framework *MLFramework) ValidateCreate() error

ValidateCreate implements webhook.Validator so a webhook will be registered for the type

func (*MLFramework) ValidateDelete 

func (framework *MLFramework) ValidateDelete() error

func (*MLFramework) ValidateUpdate 

func (framework *MLFramework) ValidateUpdate(old runtime.Object) error

ValidateUpdate implements webhook.Validator so a webhook will be registered for the type

func (*MLFramework) XXX_DiscardUnknown 

func (m *MLFramework) XXX_DiscardUnknown()

func (*MLFramework) XXX_Marshal 

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

func (*MLFramework) XXX_Merge 

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

func (*MLFramework) XXX_Size 

func (m *MLFramework) XXX_Size() int

func (*MLFramework) XXX_Unmarshal 

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

type MLFrameworkList 

type MLFrameworkList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`
	Items           []MLFramework `json:"items" protobuf:"bytes,2,rep,name=items"`
}

+kubebuilder:object:root=true MLFrameworkList contains a list of MLFramework

func (*MLFrameworkList) DeepCopy 

func (in *MLFrameworkList) DeepCopy() *MLFrameworkList

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

func (*MLFrameworkList) DeepCopyInto 

func (in *MLFrameworkList) DeepCopyInto(out *MLFrameworkList)

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

func (*MLFrameworkList) DeepCopyObject 

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

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

func (*MLFrameworkList) Descriptor 

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

func (*MLFrameworkList) Marshal 

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

func (*MLFrameworkList) MarshalTo 

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

func (*MLFrameworkList) MarshalToSizedBuffer 

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

func (*MLFrameworkList) ProtoMessage 

func (*MLFrameworkList) ProtoMessage()

func (*MLFrameworkList) Reset 

func (m *MLFrameworkList) Reset()

func (*MLFrameworkList) Size 

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

func (*MLFrameworkList) String 

func (this *MLFrameworkList) String() string

func (*MLFrameworkList) Unmarshal 

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

func (*MLFrameworkList) XXX_DiscardUnknown 

func (m *MLFrameworkList) XXX_DiscardUnknown()

func (*MLFrameworkList) XXX_Marshal 

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

func (*MLFrameworkList) XXX_Merge 

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

func (*MLFrameworkList) XXX_Size 

func (m *MLFrameworkList) XXX_Size() int

func (*MLFrameworkList) XXX_Unmarshal 

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

type MLFrameworkSpec 

type MLFrameworkSpec struct {
	// URL for the home page of the mlframework
	// +kubebuilder:validation:Optional
	URL string `json:"url,omitempty" protobuf:"bytes,1,opt,name=url"`
	// Comments of the framework
	// +kubebuilder:default =""
	// +kubebuilder:validation:Optional
	Description *string `json:"description,omitempty" protobuf:"bytes,2,opt,name=description"`
	// The current version of the mlframework
	// +kubebuilder:default =""
	// +kubebuilder:validation:Optional
	Version *string `json:"version,omitempty" protobuf:"bytes,3,opt,name=version"`
	// Lang is the framework lang
	// +kubebuilder:validation:Optional
	Lang *string `json:"lang,omitempty" protobuf:"bytes,4,opt,name=lang"`
}

MLFramework is the spec for a specific version of machine learning framework (e.g. tensorflow)

func (*MLFrameworkSpec) DeepCopy 

func (in *MLFrameworkSpec) DeepCopy() *MLFrameworkSpec

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

func (*MLFrameworkSpec) DeepCopyInto 

func (in *MLFrameworkSpec) DeepCopyInto(out *MLFrameworkSpec)

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

func (*MLFrameworkSpec) Descriptor 

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

func (*MLFrameworkSpec) Marshal 

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

func (*MLFrameworkSpec) MarshalTo 

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

func (*MLFrameworkSpec) MarshalToSizedBuffer 

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

func (*MLFrameworkSpec) ProtoMessage 

func (*MLFrameworkSpec) ProtoMessage()

func (*MLFrameworkSpec) Reset 

func (m *MLFrameworkSpec) Reset()

func (*MLFrameworkSpec) Size 

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

func (*MLFrameworkSpec) String 

func (this *MLFrameworkSpec) String() string

func (*MLFrameworkSpec) Unmarshal 

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

func (*MLFrameworkSpec) XXX_DiscardUnknown 

func (m *MLFrameworkSpec) XXX_DiscardUnknown()

func (*MLFrameworkSpec) XXX_Marshal 

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

func (*MLFrameworkSpec) XXX_Merge 

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

func (*MLFrameworkSpec) XXX_Size 

func (m *MLFrameworkSpec) XXX_Size() int

func (*MLFrameworkSpec) XXX_Unmarshal 

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

type MLSubtask added in v0.4.850 

type MLSubtask string

Define NLP sub tasks +kubebuilder:validation:Enum="text-ner";"text-classification";"text-multi-classification";"text-regression";"text-multi-label-classification";"text-conversation";"text-lang-generation";"text-lang-model";"text-multi-modal";"text-ner";"text-qa";"text-summarization";"text-sentence-pair";"text-representation-generation";"text-sentiment-analysis";"text-code-generation";"text-translation";"text-lang-detection";"text-grammar-correction";"text-paraphrasing";"text-intent-classification";"text-semantic-similarity";"text-keyword-extraction";"text-pos";"text-tokenization";"text-lemma";"image-classification";"image-multi-label-classification";"image-object-detection";"image-segmentation";"none" 

const (
	TextNer                        MLSubtask = "text-ner"
	TextClassification             MLSubtask = "text-classification"
	TextMultiClassification        MLSubtask = "text-multi-classification"
	TextRegression                 MLSubtask = "text-regression"
	TextMultiLabelClassification   MLSubtask = "text-multi-label-classification"
	TextConversation               MLSubtask = "text-conversation"
	TextLangGeneration             MLSubtask = "text-lang-generation"
	TextLangModel                  MLSubtask = "text-lang-model"
	TextMultiModalClassification   MLSubtask = "text-multi-modal"
	TextNER                        MLSubtask = "text-ner"
	TextQA                         MLSubtask = "text-qa"
	TextSummarization              MLSubtask = "text-summarization"
	TextSentencePairClassification MLSubtask = "text-sentence-pair"
	TextRepresentationGeneration   MLSubtask = "text-representation-generation"
	TextSentimentAnalysis          MLSubtask = "text-sentiment-analysis"
	TextCodeGeneration             MLSubtask = "text-code-generation"
	TextTranslation                MLSubtask = "text-translation"
	TextLangDetection              MLSubtask = "text-lang-detection"
	TextGrammarCorrection          MLSubtask = "text-grammar-correction"
	TextParaphrasing               MLSubtask = "text-paraphrasing"
	TextIntentClassification       MLSubtask = "text-intent-classification"
	TextSemanticSimilarity         MLSubtask = "text-semantic-similarity"
	TextKeywordExtraction          MLSubtask = "text-keyword-extraction"
	TextPOS                        MLSubtask = "text-pos"
	TextTokenization               MLSubtask = "text-tokenization"
	TextLemmalization              MLSubtask = "text-lemma"

	// Vision
	ImageClassification           MLSubtask = "image-classification"
	ImageMultiLabelClassification MLSubtask = "image-multi-label-classification"
	ImageObjectDetection          MLSubtask = "image-object-detection"
	ImageSegmentation             MLSubtask = "image-segmentation"

	// Video
	VideoActionRecognition MLSubtask = "video-action-recognition"
	VideoClassification    MLSubtask = "video-classification"
	VideoObjectTracking    MLSubtask = "video-object-tracking"

	NoneSubtask MLSubtask = "none"
)

type MLTask 

type MLTask string

MLTask is the machine learning task name +kubebuilder:validation:Enum="binary-classification";"multi-classification";"forecasting";"regression";"clustering";"recommendation";"outlier-detection";"novelty-detection";"auto";"unknown";"partition-forecasting";"monitoring"; 

const (
	BinaryClassification MLTask = "binary-classification"
	MultiClassification  MLTask = "multi-classification"
	NLP                  MLTask = "nlp"
	Vision               MLTask = "vision"
	Video                MLTask = "video"
	Audio                MLTask = "audio"
	Forecasting          MLTask = "forecasting"
	PartitionForecast    MLTask = "partition-forecasting"
	Regression           MLTask = "regression"
	Clustering           MLTask = "clustering"
	Recommendation       MLTask = "recommendation"
	OutlierDetection     MLTask = "outlier-detection"
	NoveltyDetection     MLTask = "novelty-detection"
	TopicModeling        MLTask = "topic-modeling"
	AutoDetectTask       MLTask = "auto"
	MonitorTask          MLTask = "monitoring" // when the dataset is used only for monitoring

	UnknownTask MLTask = "unknown"
)

func (MLTask) IsClassification added in v0.6.252 

func (task MLTask) IsClassification() bool

type MachineClass 

type MachineClass struct {
	//Code the the code of the machine class within the data provider
	Code string `json:"code" protobuf:"bytes,1,opt,name=code"`
	//+optional
	RegionName string `json:"regionName" protobuf:"bytes,2,opt,name=regionName"`
	//Mem is the amount of memory on this machine
	//+optional
	Mem *resource.Quantity `json:"mem" protobuf:"bytes,3,opt,name=mem"`
	//Vcpu is the number of virtual cpus on this machine
	// +kubebuilder:validation:Minimum=0
	//+optional
	Vcpu *int32 `json:"vcpu" protobuf:"varint,4,opt,name=vcpu"`
	//Storage is the amount of storage on this machine class
	//+optional
	Storage string `json:"storage" protobuf:"bytes,5,opt,name=storage"`
}

MachineClass define the specific for a machine type of cloud provider

func (*MachineClass) DeepCopy 

func (in *MachineClass) DeepCopy() *MachineClass

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

func (*MachineClass) DeepCopyInto 

func (in *MachineClass) DeepCopyInto(out *MachineClass)

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

func (*MachineClass) Descriptor 

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

func (*MachineClass) Marshal 

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

func (*MachineClass) MarshalTo 

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

func (*MachineClass) MarshalToSizedBuffer 

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

func (*MachineClass) ProtoMessage 

func (*MachineClass) ProtoMessage()

func (*MachineClass) Reset 

func (m *MachineClass) Reset()

func (*MachineClass) Size 

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

func (*MachineClass) String 

func (this *MachineClass) String() string

func (*MachineClass) Unmarshal 

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

func (*MachineClass) XXX_DiscardUnknown 

func (m *MachineClass) XXX_DiscardUnknown()

func (*MachineClass) XXX_Marshal 

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

func (*MachineClass) XXX_Merge 

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

func (*MachineClass) XXX_Size 

func (m *MachineClass) XXX_Size() int

func (*MachineClass) XXX_Unmarshal 

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

type MachineClassCost 

type MachineClassCost struct {
	// Code is the machine class code
	Code string `json:"code,omitempty" protobuf:"bytes,1,opt,name=code"`
	// Region is the code of the region
	Region string `json:"region,omitempty" protobuf:"bytes,2,opt,name=region"`
	// CostPerMinute is the cost per minute in dollar of the machine class
	CostPerMinute *resource.Quantity `json:"costPerMinute,omitempty" protobuf:"bytes,3,opt,name=costPerMinute"`
	// CostSpot is the spot cost of the machine class
	CostSpot *resource.Quantity `json:"costSpot,omitempty" protobuf:"bytes,4,opt,name=costSpot"`
}

MachineClassCost contain the current cost of a machine class in a region

func (*MachineClassCost) DeepCopy 

func (in *MachineClassCost) DeepCopy() *MachineClassCost

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

func (*MachineClassCost) DeepCopyInto 

func (in *MachineClassCost) DeepCopyInto(out *MachineClassCost)

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

func (*MachineClassCost) Descriptor 

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

func (*MachineClassCost) Marshal 

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

func (*MachineClassCost) MarshalTo 

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

func (*MachineClassCost) MarshalToSizedBuffer 

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

func (*MachineClassCost) ProtoMessage 

func (*MachineClassCost) ProtoMessage()

func (*MachineClassCost) Reset 

func (m *MachineClassCost) Reset()

func (*MachineClassCost) Size 

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

func (*MachineClassCost) String 

func (this *MachineClassCost) String() string

func (*MachineClassCost) Unmarshal 

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

func (*MachineClassCost) XXX_DiscardUnknown 

func (m *MachineClassCost) XXX_DiscardUnknown()

func (*MachineClassCost) XXX_Marshal 

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

func (*MachineClassCost) XXX_Merge 

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

func (*MachineClassCost) XXX_Size 

func (m *MachineClassCost) XXX_Size() int

func (*MachineClassCost) XXX_Unmarshal 

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

type ManagedImage added in v0.4.439 

type ManagedImage struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`
	Spec              ManagedImageSpec `json:"spec" protobuf:"bytes,2,opt,name=spec"`
}

+genclient +kubebuilder:object:root=true +kubebuilder:resource:path=managedimages,singular=managedimage,categories={catalog,modela,all} +kubebuilder:storageversion +kubebuilder:printcolumn:name="URL",type="string",JSONPath=".spec.url" +kubebuilder:printcolumn:name="Version",type="string",JSONPath=".spec.version" +kubebuilder:printcolumn:name="Description",type="string",JSONPath=".spec.description" Managed Images define the metadata about a docker image used during training or serving

func NewManagedImage added in v0.4.439 

func NewManagedImage(ns string, name string, image string) *ManagedImage

func (*ManagedImage) DeepCopy added in v0.4.439 

func (in *ManagedImage) DeepCopy() *ManagedImage

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

func (*ManagedImage) DeepCopyInto added in v0.4.439 

func (in *ManagedImage) DeepCopyInto(out *ManagedImage)

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

func (*ManagedImage) DeepCopyObject added in v0.4.439 

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

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

func (*ManagedImage) Default added in v0.4.439 

func (p *ManagedImage) Default()

func (*ManagedImage) Descriptor added in v0.4.439 

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

func (*ManagedImage) Marshal added in v0.4.439 

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

func (*ManagedImage) MarshalTo added in v0.4.439 

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

func (*ManagedImage) MarshalToSizedBuffer added in v0.4.439 

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

func (*ManagedImage) ProtoMessage added in v0.4.439 

func (*ManagedImage) ProtoMessage()

func (*ManagedImage) Reset added in v0.4.439 

func (m *ManagedImage) Reset()

func (*ManagedImage) Size added in v0.4.439 

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

func (*ManagedImage) String added in v0.4.439 

func (this *ManagedImage) String() string

func (*ManagedImage) URL added in v0.4.485 

func (p *ManagedImage) URL() string

func (*ManagedImage) Unmarshal added in v0.4.439 

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

func (*ManagedImage) Validate added in v0.4.439 

func (image *ManagedImage) Validate() (bool, field.ErrorList)

func (*ManagedImage) ValidateCreate added in v0.4.439 

func (image *ManagedImage) ValidateCreate() error

ValidateCreate implements webhook.Validator so a webhook will be registered for the type

func (*ManagedImage) ValidateDelete added in v0.4.439 

func (image *ManagedImage) ValidateDelete() error

func (*ManagedImage) ValidateUpdate added in v0.4.439 

func (image *ManagedImage) ValidateUpdate(old runtime.Object) error

ValidateUpdate implements webhook.Validator so a webhook will be registered for the type

func (*ManagedImage) XXX_DiscardUnknown added in v0.4.439 

func (m *ManagedImage) XXX_DiscardUnknown()

func (*ManagedImage) XXX_Marshal added in v0.4.439 

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

func (*ManagedImage) XXX_Merge added in v0.4.439 

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

func (*ManagedImage) XXX_Size added in v0.4.439 

func (m *ManagedImage) XXX_Size() int

func (*ManagedImage) XXX_Unmarshal added in v0.4.439 

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

type ManagedImageList added in v0.4.439 

type ManagedImageList struct {
	metav1.TypeMeta `json:",inline" `
	metav1.ListMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`

	Items []ManagedImage `json:"items" protobuf:"bytes,2,rep,name=items"`
}

+kubebuilder:object:root=true ManagedImageList is a list of pretrained models

func (*ManagedImageList) DeepCopy added in v0.4.439 

func (in *ManagedImageList) DeepCopy() *ManagedImageList

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

func (*ManagedImageList) DeepCopyInto added in v0.4.439 

func (in *ManagedImageList) DeepCopyInto(out *ManagedImageList)

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

func (*ManagedImageList) DeepCopyObject added in v0.4.439 

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

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

func (*ManagedImageList) Descriptor added in v0.4.439 

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

func (*ManagedImageList) Marshal added in v0.4.439 

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

func (*ManagedImageList) MarshalTo added in v0.4.439 

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

func (*ManagedImageList) MarshalToSizedBuffer added in v0.4.439 

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

func (*ManagedImageList) ProtoMessage added in v0.4.439 

func (*ManagedImageList) ProtoMessage()

func (*ManagedImageList) Reset added in v0.4.439 

func (m *ManagedImageList) Reset()

func (*ManagedImageList) Size added in v0.4.439 

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

func (*ManagedImageList) String added in v0.4.439 

func (this *ManagedImageList) String() string

func (*ManagedImageList) Unmarshal added in v0.4.439 

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

func (*ManagedImageList) XXX_DiscardUnknown added in v0.4.439 

func (m *ManagedImageList) XXX_DiscardUnknown()

func (*ManagedImageList) XXX_Marshal added in v0.4.439 

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

func (*ManagedImageList) XXX_Merge added in v0.4.439 

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

func (*ManagedImageList) XXX_Size added in v0.4.439 

func (m *ManagedImageList) XXX_Size() int

func (*ManagedImageList) XXX_Unmarshal added in v0.4.439 

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

type ManagedImageRole added in v0.4.513 

type ManagedImageRole string

+kubebuilder:validation:Enum="cloud-proxy";"trainer";"predictor";"dashboard";"workload";"prediction-router";"dataplane";"publisher";"system";"batch-prediction" 

const (
	CloudProxyImageRole       ManagedImageRole = "cloud-proxy"
	PredictorImageRole        ManagedImageRole = "predictor"
	DashboardImageRole        ManagedImageRole = "dashboard"
	WorkloadImageRole         ManagedImageRole = "workload"
	DataPlaneImageRole        ManagedImageRole = "dataplane"
	LLMPlaneImageRole         ManagedImageRole = "llmplane"
	SystemImageRole           ManagedImageRole = "system"
	PredictionRouterImageRole ManagedImageRole = "prediction-router"
)

type ManagedImageSpec added in v0.4.439 

type ManagedImageSpec struct {
	// +kubebuilder:validation:Optional
	Description *string `json:"description,optional" protobuf:"bytes,1,opt,name=description"`
	// The image registry, by default use docker.io
	// +kubebuilder:default ="docker.io"
	// +kubebuilder:validation:Optional
	Registry *string `json:"registry,optional" protobuf:"bytes,2,opt,name=registry"`
	// The image repository. This is a required field
	// +kubebuilder:validation:Required
	Repository string `json:"repository,optional" protobuf:"bytes,3,opt,name=repository"`
	// The image tag. by default this is latest
	// +kubebuilder:default ="latest"
	// +kubebuilder:validation:Optional
	Tag *string `json:"tag,optional" protobuf:"bytes,4,opt,name=tag"`
	// The environment variables to use when the image start
	// +kubebuilder:validation:Optional
	Env []v1.EnvVar `json:"env,optional" protobuf:"bytes,5,rep,name=env"`
	// Is this a gpu image
	// +kubebuilder:default:=false
	// +kubebuilder:validation:Optional
	Gpu *bool `json:"gpu,optional" protobuf:"varint,6,opt,name=gpu"`
	// If true this is an active image that should be used for new training.
	// +kubebuilder:default:=false
	// +kubebuilder:validation:Optional
	Active *bool `json:"active,optional" protobuf:"varint,7,opt,name=active"`
	// Preload the image to the cluster.
	// +kubebuilder:default:=false
	// +kubebuilder:validation:Optional
	Preload *bool `json:"preload,optional" protobuf:"varint,8,opt,name=preload"`
	// Preload the image to the cluster.
	// +kubebuilder:validation:Optional
	ConnectionRef *v1.ObjectReference `json:"connectionRef,optional" protobuf:"bytes,9,opt,name=connectionRef"`
	// The base image for this image.
	// +kubebuilder:default =""
	// +kubebuilder:validation:Optional
	Base *string `json:"base,optional" protobuf:"bytes,10,opt,name=base"`
	// The base image for this image.
	// +kubebuilder:default =""
	// +kubebuilder:validation:Optional
	Role *ManagedImageRole `json:"role,optional" protobuf:"bytes,11,opt,name=role"`
	// The organization maintaining this image
	// +kubebuilder:default ="metaprov"
	// +kubebuilder:validation:Optional
	// Who maintain this image.
	MaintainedBy *string `json:"maintainedBy,optional" protobuf:"bytes,12,opt,name=mantainedBy"`
	// The Image home page in the registry
	// +kubebuilder:default =""
	// +kubebuilder:validation:Optional
	URI *string `json:"uri,optional" protobuf:"bytes,13,opt,name=uri"`
	// List of ml frameworks supported by the data container
	// +kubebuilder:validation:Optional
	Frameworks []string `json:"frameworks,omitempty" protobuf:"bytes,14,rep,name=frameworks"`
	// Libs is the list of python library supported by the data container
	// +kubebuilder:validation:Optional
	Libs []Lib `json:"libs,omitempty" protobuf:"bytes,15,rep,name=libs"`
	// OS is the name of the os
	// +kubebuilder:validation:Optional
	OS string `json:"os,omitempty" protobuf:"bytes,16,opt,name=os"`
	// OSVersion is the version of the os
	// +kubebuilder:validation:Optional
	OSVersion string `json:"osVersion,omitempty" protobuf:"bytes,17,opt,name=osVersion"`
	// If true this is an active image that should be used for new training.
	// +kubebuilder:default:=false
	// +kubebuilder:validation:Optional
	Private *bool `json:"private,optional" protobuf:"varint,18,opt,name=private"`
}

ManagedImageSpec is the desired state of the pretrained model

func (*ManagedImageSpec) DeepCopy added in v0.4.439 

func (in *ManagedImageSpec) DeepCopy() *ManagedImageSpec

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

func (*ManagedImageSpec) DeepCopyInto added in v0.4.439 

func (in *ManagedImageSpec) DeepCopyInto(out *ManagedImageSpec)

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

func (*ManagedImageSpec) Descriptor added in v0.4.439 

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

func (*ManagedImageSpec) Marshal added in v0.4.439 

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

func (*ManagedImageSpec) MarshalTo added in v0.4.439 

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

func (*ManagedImageSpec) MarshalToSizedBuffer added in v0.4.439 

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

func (*ManagedImageSpec) ProtoMessage added in v0.4.439 

func (*ManagedImageSpec) ProtoMessage()

func (*ManagedImageSpec) Reset added in v0.4.439 

func (m *ManagedImageSpec) Reset()

func (*ManagedImageSpec) Size added in v0.4.439 

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

func (*ManagedImageSpec) String added in v0.4.439 

func (this *ManagedImageSpec) String() string

func (*ManagedImageSpec) Unmarshal added in v0.4.439 

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

func (*ManagedImageSpec) XXX_DiscardUnknown added in v0.4.439 

func (m *ManagedImageSpec) XXX_DiscardUnknown()

func (*ManagedImageSpec) XXX_Marshal added in v0.4.439 

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

func (*ManagedImageSpec) XXX_Merge added in v0.4.439 

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

func (*ManagedImageSpec) XXX_Size added in v0.4.439 

func (m *ManagedImageSpec) XXX_Size() int

func (*ManagedImageSpec) XXX_Unmarshal added in v0.4.439 

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

type ManifestLocation added in v0.6.252 

type ManifestLocation struct {
	BucketName string `json:"bucketName,omitempty" protobuf:"bytes,1,opt,name=bucketName"`
	Path       string `json:"path,omitempty" protobuf:"bytes,2,opt,name=path"`
	Generation int64  `json:"generation" protobuf:"bytes,3,opt,name=generation"`
}

ManifestLocation specifies the location of a JSON-serialized custom resource, which includes the name of a Virtual Bucket and a path within it. The generation of the resource is also specified

func (*ManifestLocation) DeepCopy added in v0.6.252 

func (in *ManifestLocation) DeepCopy() *ManifestLocation

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

func (*ManifestLocation) DeepCopyInto added in v0.6.252 

func (in *ManifestLocation) DeepCopyInto(out *ManifestLocation)

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

func (*ManifestLocation) Descriptor added in v0.6.252 

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

func (*ManifestLocation) Hash added in v0.6.252 

func (m *ManifestLocation) Hash() string

func (*ManifestLocation) Marshal added in v0.6.252 

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

func (*ManifestLocation) MarshalTo added in v0.6.252 

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

func (*ManifestLocation) MarshalToSizedBuffer added in v0.6.252 

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

func (*ManifestLocation) ProtoMessage added in v0.6.252 

func (*ManifestLocation) ProtoMessage()

func (*ManifestLocation) Reset added in v0.6.252 

func (m *ManifestLocation) Reset()

func (*ManifestLocation) Size added in v0.6.252 

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

func (*ManifestLocation) String added in v0.6.252 

func (this *ManifestLocation) String() string

func (*ManifestLocation) Unmarshal added in v0.6.252 

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

func (*ManifestLocation) XXX_DiscardUnknown added in v0.6.252 

func (m *ManifestLocation) XXX_DiscardUnknown()

func (*ManifestLocation) XXX_Marshal added in v0.6.252 

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

func (*ManifestLocation) XXX_Merge added in v0.6.252 

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

func (*ManifestLocation) XXX_Size added in v0.6.252 

func (m *ManifestLocation) XXX_Size() int

func (*ManifestLocation) XXX_Unmarshal added in v0.6.252 

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

type Measurement 

type Measurement struct {
	// +kubebuilder:validation:Optional
	Entity v1.ObjectReference `json:"entity,omitempty" protobuf:"bytes,1,opt,name=entity"`
	// +kubebuilder:validation:Optional
	Column *string `json:"column,omitempty" protobuf:"bytes,2,opt,name=column"`
	// The metric type name (e.g. F1 / Accuracy)
	// +kubebuilder:validation:Optional
	Metric *Metric `json:"metric,omitempty" protobuf:"bytes,3,opt,name=metric"`
	// The value of the metric for quantitive observations
	// +kubebuilder:validation:Optional
	Value *float64 `json:"value,omitempty" protobuf:"bytes,4,opt,name=value"`
	// Metric standard diviation for quantative observations.
	// +kubebuilder:validation:Optional
	Stddev *float64 `json:"stddev,omitempty" protobuf:"bytes,5,opt,name=stddev"`
	// If the metric refer to a bool unit, store the bool value
	// +kubebuilder:validation:Optional
	BoolQty *bool `json:"boolQty,omitempty" protobuf:"varint,6,opt,name=boolQty"`
	// If the metric refer to categorical measure,store the category.
	// +kubebuilder:validation:Optional
	Category *string `json:"category,omitempty" protobuf:"bytes,7,opt,name=category"`
	// Capture a set of values.
	// +kubebuilder:validation:Optional
	ValueSet []string `json:"valueSet,omitempty" protobuf:"bytes,8,rep,name=valueSet"`
	// The Time when the observation was taken
	// +kubebuilder:validation:Optional
	TimePoint *metav1.Time `json:"timePoint,omitempty" protobuf:"bytes,9,opt,name=timePoint"`
	// The measurment task type (e.g. train, test, cv, feature)
	// +kubebuilder:validation:Optional
	TaskType *string `json:"taskType,omitempty" protobuf:"bytes,10,opt,name=taskType"`
	// The name of the algorithm that generated this measurment
	// +kubebuilder:validation:Optional
	Algorithm *string `json:"algorithm,omitempty" protobuf:"bytes,11,opt,name=algorithm"`
}

Measurement is a value for a specific metric

func (*Measurement) DeepCopy 

func (in *Measurement) DeepCopy() *Measurement

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

func (*Measurement) DeepCopyInto 

func (in *Measurement) DeepCopyInto(out *Measurement)

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

func (*Measurement) Descriptor 

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

func (*Measurement) Marshal 

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

func (*Measurement) MarshalTo 

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

func (*Measurement) MarshalToSizedBuffer 

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

func (*Measurement) ProtoMessage 

func (*Measurement) ProtoMessage()

func (*Measurement) Reset 

func (m *Measurement) Reset()

func (*Measurement) Size 

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

func (*Measurement) String 

func (this *Measurement) String() string

func (*Measurement) Unmarshal 

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

func (*Measurement) XXX_DiscardUnknown 

func (m *Measurement) XXX_DiscardUnknown()

func (*Measurement) XXX_Marshal 

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

func (*Measurement) XXX_Merge 

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

func (*Measurement) XXX_Size 

func (m *Measurement) XXX_Size() int

func (*Measurement) XXX_Unmarshal 

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

type Metric 

type Metric string
const (
	Accuracy Metric = "accuracy"
	// classification
	AveragePrecision  Metric = "average-precision"
	BalancedAccuracy  Metric = "balanced-accuracy"
	F1Binary          Metric = "f1"
	F1Micro           Metric = "f1-micro"
	F1Macro           Metric = "f1-macro"
	F1Weighted        Metric = "f1-weighted"
	F1Samples         Metric = "f1-samples"
	PrecisionBinary   Metric = "precision"
	PrecisionMicro    Metric = "precision-micro"
	PrecisionMacro    Metric = "precision-macro"
	PrecisionWeighted Metric = "precision-weighted"
	PrecisionSamples  Metric = "precision-samples"
	RecallBinary      Metric = "recall"
	RecallMacro       Metric = "recall-macro"
	RecallMicro       Metric = "recall-micro"
	RecallWeighted    Metric = "recall-weighted"
	RecallSamples     Metric = "recall-samples"
	LogLoss           Metric = "log-loss"
	RocAuc            Metric = "auc"
	RocAucMicro       Metric = "auc-micro"
	RocAucMacro       Metric = "auc-macro"
	RocAucWeighted    Metric = "auc-weighted"
	PRRocAuc          Metric = "pr-auc"
	PRRocAucMicro     Metric = "pr-auc-micro"
	PRRocAucMacro     Metric = "pr-auc-macro"
	PRRocAucWeighted  Metric = "pr-auc-weighted"
	ZeroOne           Metric = "zero-one"
	HammingLoss       Metric = "hamming-loss"
	HingeLoss         Metric = "hinge-loss"
	JacquardScore     Metric = "jacquard-loss"
	MatthewsCorrCoef  Metric = "mcc"
	Fp                Metric = "fp"
	Fn                Metric = "fn"
	Tn                Metric = "tn"
	Tp                Metric = "tp"
	Tpr               Metric = "tpr"
	Fpr               Metric = "fpr"
	Tnr               Metric = "tnr"
	MCC               Metric = "matthews-corr-coef"

	/// Regression
	ExplainedVariance   Metric = "explained-variance"
	MaxError            Metric = "max-error"
	MAE                 Metric = "mae"
	MSE                 Metric = "mse"
	MSLE                Metric = "msle"
	RMSE                Metric = "rmse"
	RMSLE               Metric = "rmsle"
	MedianAbsoluteError Metric = "median-absolute-error"
	R2                  Metric = "r2"
	AdjR2               Metric = "adj-r2"
	MeanPoissonDeviance Metric = "mean_poisson_deviance"
	MeanGammaDeviance   Metric = "mean-gamma-deviance"
	MeanTweedieDeviance Metric = "mean-tweedie-deviance"

	// Forecast specific
	MAPE         Metric = "mape"
	MAZE         Metric = "maze"
	MDAPE        Metric = "mdape" // median absolute percentage error
	SMAPE        Metric = "smape"
	WAPE         Metric = "wape"
	RMSPE        Metric = "rmspe"
	QuantileLoss Metric = "quantile-loss"

	MedianAbsolutePercentError = "mean-absolute-percentage-error"
	MeanPinballLoss            = "mean-pinball-loss"
	MeanTweediaDeviance        = "mean-tweedie-deviance"
	MeanPoissionDeviance       = "mean-possion-deviance"
	D2TweedieScore             = "d2-tweedie-score"
	D2PinballScore             = "d2-pinball-score"
	D2AbsoluteErrorScore       = "d2-absolute-error-score"

	//Clustering
	AdjustedMutualInfoScore   Metric = "adjusted-mutual-info-score"
	AdjustedRandScore         Metric = "adjusted-rand-score"
	CompletenessScore         Metric = "completeness-score"
	FowlkesMallowsScore       Metric = "fowlkes-mallows-score"
	HomogeneityScore          Metric = "homogeneity-score"
	MutualInfoScore           Metric = "mutual-info-score"
	NormalizedMutualInfoScore Metric = "normalized-mutual-info-score"
	VMeasureScore             Metric = "v-measure-score"

	// Infra metrics
	P50Latency                 Metric = "p50-latency"
	P95Latency                 Metric = "p95-latency"
	P99Latency                 Metric = "p99-latency"
	Cpu                        Metric = "cpu"
	Gpu                        Metric = "gpu"
	Mem                        Metric = "mem"
	GpuMem                     Metric = "gpu-mem"
	ReqSec                     Metric = "req-per-sec"
	UncertainPredictionPercent Metric = "uncertain-prediction-percent"

	// Data drift metrics
	TwoSampleKSTest      Metric = "two-sample-ks-test"
	ChiSqrTest           Metric = "chi-squared-test"
	ProportionDifference Metric = "proportion-difference"
	WassersteinDistance  Metric = "wasserstein-distance"
	PSI                  Metric = "psi"
	KLDivergence         Metric = "kl-divergence"
	JSDivergence         Metric = "js-divergence"

	// Bias metrics
	EqualOpportunity                  Metric = "equal-opportunity"
	DemographicParity                 Metric = "demographic-parity"
	EqualOddsTnr                      Metric = "equals-odds-tnr"
	IndividualFairness                Metric = "individual-fairness"
	IndividualFairnessCounterfactuals Metric = "individual-fairness-counter-factuals"

	// Corrolation Metrics
	Pearson       Metric = "pearson"
	CramersV      Metric = "cramers-v"
	RankBiserial  Metric = "rank-biserial"
	PointBiserial Metric = "point-biserial"

	NoneMetric Metric = "none"
)

func (Metric) Compare 

func (metric Metric) Compare(i float64, j float64) bool

Compare two scores in the metrics

func (Metric) IsClassification 

func (metric Metric) IsClassification() bool

func (Metric) IsClustering 

func (metric Metric) IsClustering() bool

func (Metric) IsForecast 

func (metric Metric) IsForecast() bool

func (Metric) IsMultiClass 

func (metric Metric) IsMultiClass() bool

func (Metric) IsRegression 

func (metric Metric) IsRegression() bool

type MetricAggregationPeriod added in v0.7.0 

type MetricAggregationPeriod string

+kubebuilder:validation:Enum="hourly";"daily";"weekly";"monthly" 

const (
	HourlyMetricAggregationPeriod  MetricAggregationPeriod = "hourly"
	DailyMetricAggregationPeriod   MetricAggregationPeriod = "daily"
	WeeklyMetricAggregationPeriod  MetricAggregationPeriod = "weekly"
	MonthlyMetricAggregationPeriod MetricAggregationPeriod = "monthly"
)

type ModalityType 

type ModalityType string

ModalityType define the way that ASHA algorithm divide the data . Since we are using multi modal alg , this parameter define the modality +kubebuilder:validation:Enum="data";"epochs"; 

const (
	DataModalityType   ModalityType = "data"
	EpochsModalityType ModalityType = "epochs"
)

type ModelClassType 

type ModelClassType string

ModelClassType classifies a model by the phase of the Study which created it +kubebuilder:validation:Enum="feature-engineering";"baseline";"search";"ensemble";"test" 

const (
	ModelClassTypeFeatureEngineering ModelClassType = "feature-engineering"
	ModelClassTypeBaseline           ModelClassType = "baseline"
	ModelClassTypeSearch             ModelClassType = "search"
	ModelClassTypeEnsemble           ModelClassType = "ensemble"
	ModelClassTypeTest               ModelClassType = "test"
)

type ModelDeploymentSpec 

type ModelDeploymentSpec struct {
	// The reference to a Model resource which has been packaged
	// +kubebuilder:validation:Required
	// +required
	ModelRef v1.ObjectReference `json:"modelRef,omitempty" protobuf:"bytes,1,opt,name=modelRef"`
	// the port of the model service.
	// +kubebuilder:default:=8080
	// +kubebuilder:validation:Optional
	Port *int32 `json:"port,omitempty" protobuf:"varint,2,opt,name=port"`
	// The minimum percentage (0 through 100) of traffic that will be served by the model
	// +kubebuilder:validation:Maximum=100
	// +kubebuilder:validation:Minimum=0
	// +kubebuilder:default:=100
	// +kubebuilder:validation:Optional
	Traffic *int32 `json:"traffic,omitempty" protobuf:"varint,3,opt,name=traffic"`
	// Role denotes the role of the model, which can be either live or shadow.
	// When a model is deployed as a live model, prediction requests will be served by the model. The chance that the
	// prediction request will be forwarded to the model is determined by Traffic.
	// When a model is deployed as a shadow model, the model will still receive and log prediction requests and results
	// but will not have the result sent back the Predictor
	// +kubebuilder:default:=live
	// +kubebuilder:validation:Optional
	Role ModelRole `json:"role,omitempty" protobuf:"bytes,4,opt,name=role"`
	// The URL of the model server image; applicable when rolling back a model
	ImageName *string `json:"imageName,omitempty" protobuf:"bytes,5,opt,name=imageName"`
	// The reference to the account which approved the model, if applicable
	// +kubebuilder:validation:Optional
	ApprovedBy *v1.ObjectReference `json:"approvedBy,omitempty" protobuf:"bytes,6,opt,name=approvedBy"`
}

ModelDeploymentSpec describes how a single model should be deployed with a Predictor, and how prediction traffic will be routed to the model

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.

func (*ModelDeploymentSpec) Descriptor 

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

func (*ModelDeploymentSpec) Marshal 

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

func (*ModelDeploymentSpec) MarshalTo 

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

func (*ModelDeploymentSpec) MarshalToSizedBuffer 

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

func (*ModelDeploymentSpec) ProtoMessage 

func (*ModelDeploymentSpec) ProtoMessage()

func (*ModelDeploymentSpec) Reset 

func (m *ModelDeploymentSpec) Reset()

func (*ModelDeploymentSpec) Size 

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

func (*ModelDeploymentSpec) String 

func (this *ModelDeploymentSpec) String() string

func (*ModelDeploymentSpec) Unmarshal 

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

func (*ModelDeploymentSpec) XXX_DiscardUnknown 

func (m *ModelDeploymentSpec) XXX_DiscardUnknown()

func (*ModelDeploymentSpec) XXX_Marshal 

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

func (*ModelDeploymentSpec) XXX_Merge 

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

func (*ModelDeploymentSpec) XXX_Size 

func (m *ModelDeploymentSpec) XXX_Size() int

func (*ModelDeploymentSpec) XXX_Unmarshal 

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

type ModelRole added in v0.4.886 

type ModelRole string

+kubebuilder:validation:Enum="live";"shadow";"none" 

const (
	LiveModelRole   ModelRole = "live"
	ShadowModelRole ModelRole = "shadow"
	NoneModelRole   ModelRole = "none"
)

type ModelServingFormat added in v0.4.735 

type ModelServingFormat string
const (
	ProtobufModelServingFormat    ModelServingFormat = "protobuf"
	PickleModelServingFormat      ModelServingFormat = "pickle"
	CloudPickleModelServingFormat ModelServingFormat = "cloudpickle"
	MLLeapModelServingFormat      ModelServingFormat = "mlleap"
	MLModelModelServingFormat     ModelServingFormat = "mlmodel"
	H5ModelServingFormat          ModelServingFormat = "h5"
	OnyxModelServingFormat        ModelServingFormat = "onyx"
	PmmlModelServingFormat        ModelServingFormat = "pmml"
	TorchScriptModelServingFormat ModelServingFormat = "pt"
)

type ModelType 

type ModelType string

ModelType enumerates the possible model types +kubebuilder:validation:Enum="classical";"dnn";"transformer";"chatbot";"rl";"hierarchy"; 

const (
	ClassicalModelType   ModelType = "classical"
	HierarchyModelType   ModelType = "hierarchy" // mainly for time series.
	DNNModelType         ModelType = "dnn"
	TransformerModelType ModelType = "transformer"
	ChatbotModelType     ModelType = "chatbot"
	RLModelType          ModelType = "rl"
)

type NotificationReceiver 

type NotificationReceiver string

+kubebuilder:validation:Enum="email";"hipchat";"pagerduty";"pushover";"slack";"opengenie";"webook";"victorops";"wechat";"msteams" 

const (
	NotificationReceiverEmail     NotificationReceiver = "email"
	NotificationReceiverHipchat   NotificationReceiver = "hipchat"
	NotificationReceiverPageDuty  NotificationReceiver = "pagerduty"
	NotificationReceiverPushOver  NotificationReceiver = "pushover"
	NotificationReceiverSlack     NotificationReceiver = "slack"
	NotificationReceiverOpenGenie NotificationReceiver = "opengenie"
	NotificationReceiverWebhook   NotificationReceiver = "webhook"
	NotificationReceiverVictorOps NotificationReceiver = "victorops"
	NotificationReceiverWechat    NotificationReceiver = "wechat"
	NotificationReceiverMSTeams   NotificationReceiver = "msteams"
)

func (NotificationReceiver) Code 

func (this NotificationReceiver) Code() int32

Needed in order to map to the protobuf

type NotificationSpec 

type NotificationSpec struct {
	// TTL defines the time-to-live for Alerts, in seconds, after which they will be deleted
	// +kubebuilder:default:=3600
	// +kubebuilder:validation:Optional
	TTL *int32 `json:"ttl,omitempty" protobuf:"varint,1,opt,name=ttl"`
	// NotifierName specifies the name of a single Notifier resource which the Alert will be forwarded to
	// +kubebuilder:validation:Optional
	NotifierName *string `json:"notifierName,omitempty" protobuf:"bytes,2,opt,name=notifierName"`
	// Selector defines a map of labels that will be matched to find multiple Notifier resource to forward alerts to
	// +kubebuilder:validation:Optional
	Selector map[string]string `json:"selector,omitempty" protobuf:"bytes,3,opt,name=selector"`
}

NotificationSpec defines the notification configuration for an Alert resource

func (*NotificationSpec) DeepCopy 

func (in *NotificationSpec) DeepCopy() *NotificationSpec

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

func (*NotificationSpec) DeepCopyInto 

func (in *NotificationSpec) DeepCopyInto(out *NotificationSpec)

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

func (*NotificationSpec) Descriptor 

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

func (*NotificationSpec) Marshal 

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

func (*NotificationSpec) MarshalTo 

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

func (*NotificationSpec) MarshalToSizedBuffer 

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

func (*NotificationSpec) ProtoMessage 

func (*NotificationSpec) ProtoMessage()

func (*NotificationSpec) Reset 

func (m *NotificationSpec) Reset()

func (*NotificationSpec) Size 

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

func (*NotificationSpec) String 

func (this *NotificationSpec) String() string

func (*NotificationSpec) Unmarshal 

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

func (*NotificationSpec) XXX_DiscardUnknown 

func (m *NotificationSpec) XXX_DiscardUnknown()

func (*NotificationSpec) XXX_Marshal 

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

func (*NotificationSpec) XXX_Merge 

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

func (*NotificationSpec) XXX_Size 

func (m *NotificationSpec) XXX_Size() int

func (*NotificationSpec) XXX_Unmarshal 

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

type ObjectiveSpec added in v0.5.485 

type ObjectiveSpec struct {
	// The objective metric
	Metric Metric `json:"metric,omitempty" protobuf:"bytes,1,opt,name=metric"`
	// The goal of the objective.
	// +kubebuilder:default:=maximize
	Goal GoalType `json:"goal,omitempty" protobuf:"bytes,2,opt,name=goal"`
}

func (ObjectiveSpec) Compare added in v0.5.485 

func (objective ObjectiveSpec) Compare(i float64, j float64) bool

func (*ObjectiveSpec) DeepCopy added in v0.5.485 

func (in *ObjectiveSpec) DeepCopy() *ObjectiveSpec

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

func (*ObjectiveSpec) DeepCopyInto added in v0.5.485 

func (in *ObjectiveSpec) DeepCopyInto(out *ObjectiveSpec)

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

func (*ObjectiveSpec) Descriptor added in v0.5.485 

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

func (*ObjectiveSpec) Marshal added in v0.5.485 

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

func (*ObjectiveSpec) MarshalTo added in v0.5.485 

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

func (*ObjectiveSpec) MarshalToSizedBuffer added in v0.5.485 

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

func (*ObjectiveSpec) ProtoMessage added in v0.5.485 

func (*ObjectiveSpec) ProtoMessage()

func (*ObjectiveSpec) Reset added in v0.5.485 

func (m *ObjectiveSpec) Reset()

func (*ObjectiveSpec) Size added in v0.5.485 

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

func (*ObjectiveSpec) String added in v0.5.485 

func (this *ObjectiveSpec) String() string

func (*ObjectiveSpec) Unmarshal added in v0.5.485 

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

func (*ObjectiveSpec) XXX_DiscardUnknown added in v0.5.485 

func (m *ObjectiveSpec) XXX_DiscardUnknown()

func (*ObjectiveSpec) XXX_Marshal added in v0.5.485 

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

func (*ObjectiveSpec) XXX_Merge added in v0.5.485 

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

func (*ObjectiveSpec) XXX_Size added in v0.5.485 

func (m *ObjectiveSpec) XXX_Size() int

func (*ObjectiveSpec) XXX_Unmarshal added in v0.5.485 

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

type Op 

type Op string

Op is a relational operator +kubebuilder:validation:Enum="lt";"eq";"gt";"ne";"le";"ge" 

const (
	LTOp Op = "lt"
	EQOp Op = "eq"
	GTOp Op = "gt"
	NEOp Op = "ne" // not equal
	LEOp Op = "le" // less or equal
	GE   Op = "ge" // greater or equal
)

type OutlierAlgorithmName added in v0.4.727 

type OutlierAlgorithmName string
const (
	IsolationForestOutlierAlgorithmName OutlierAlgorithmName = "isolation-forest"
)

type OutlierHandling 

type OutlierHandling string

============================================================================== Outlier Handling ============================================================================== +kubebuilder:validation:Enum="trim-outliers";"winsorizer-outliers";"cap-outliers";"zero-code-outliers";"none";"auto" 

const (
	TrimOutlierHandling       OutlierHandling = "trim-outliers"
	WinsorizerOutlierHandling OutlierHandling = "winsorizer-outliers"
	CapOutlierHandling        OutlierHandling = "cap-outliers"
	ZeroCodeOutlierHandling   OutlierHandling = "zero-code-outliers"
	NoneOutlierHandling       OutlierHandling = "none"
	AutoOutlierHandling       OutlierHandling = "auto"
)

type PRCurve 

type PRCurve struct {
	Values []CurvePoint `json:"values,omitempty" protobuf:"bytes,1,rep,name=values"`
}

func (*PRCurve) DeepCopy 

func (in *PRCurve) DeepCopy() *PRCurve

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

func (*PRCurve) DeepCopyInto 

func (in *PRCurve) DeepCopyInto(out *PRCurve)

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

func (*PRCurve) Descriptor 

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

func (*PRCurve) Marshal 

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

func (*PRCurve) MarshalTo 

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

func (*PRCurve) MarshalToSizedBuffer 

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

func (*PRCurve) ProtoMessage 

func (*PRCurve) ProtoMessage()

func (*PRCurve) Reset 

func (m *PRCurve) Reset()

func (*PRCurve) Size 

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

func (*PRCurve) String 

func (this *PRCurve) String() string

func (*PRCurve) Unmarshal 

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

func (*PRCurve) XXX_DiscardUnknown 

func (m *PRCurve) XXX_DiscardUnknown()

func (*PRCurve) XXX_Marshal 

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

func (*PRCurve) XXX_Merge 

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

func (*PRCurve) XXX_Size 

func (m *PRCurve) XXX_Size() int

func (*PRCurve) XXX_Unmarshal 

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

type ParameterRange added in v0.5.395 

type ParameterRange struct {
	// Name is the name of the hyperparameter
	// +kubebuilder:validation:Optional
	Name string `json:"name,omitempty" protobuf:"bytes,1,opt,name=name"`
	// Type is the datatype of the parameter
	// +kubebuilder:validation:Optional
	Type HyperParameterDataType `json:"type,omitempty" protobuf:"bytes,2,opt,name=type"`
	// Low is the minimum value of the hyperparameter
	// +kubebuilder:validation:Optional
	Low *float64 `json:"low,omitempty" protobuf:"bytes,3,opt,name=low"`
	// High is the maximum value of the hyperparameter
	// +kubebuilder:validation:Optional
	High *float64 `json:"high,omitempty" protobuf:"bytes,4,opt,name=high"`
	// Step for discrete variable.
	// +kubebuilder:validation:Optional
	Step *int32 `json:"step,omitempty" protobuf:"varint,5,opt,name=step"`
	// Log indicates if the scale is logarithmic
	// +kubebuilder:validation:Optional
	Log *bool `json:"log,omitempty" protobuf:"varint,6,opt,name=log"`
	// Set of choices for categorical variable
	// +kubebuilder:validation:Optional
	Choices []string `json:"choices,omitempty" protobuf:"bytes,7,rep,name=choices"`
	// DefaultValue is the default value of the parameter
	// +kubebuilder:validation:Optional
	DefaultValue *float64 `json:"defaultValue,omitempty" protobuf:"varint,8,opt,name=defaultValue"`
	// Default Choice for categorical variable.
	//+kubebuilder:validation:Optional
	DefaultChoice *string `json:"defaultChoice,omitempty" protobuf:"varint,9,opt,name=defaultChoice"`
	// If true this parameter is condition on another parameter value
	//+kubebuilder:validation:Optional
	Conditional *bool `json:"conditional,omitempty" protobuf:"varint,10,opt,name=conditional"`
	// Parent parameter name
	//+kubebuilder:validation:Optional
	Parent *string `json:"parent,omitempty" protobuf:"bytes,11,opt,name=parent"`
	// The parent value in order for this parameter to be active.
	//+kubebuilder:validation:Optional
	ParentValueCat *string `json:"parentValueCat,omitempty" protobuf:"bytes,12,opt,name=parentValueCat"`
	// The parent value in order for this parameter to be active.
	//+kubebuilder:validation:Optional
	ParentValueInteger *int32 `json:"parentValueInteger,omitempty" protobuf:"varint,13,opt,name=parentValueInteger"`
	// The parent value in order for this parameter to be active.
	//+kubebuilder:validation:Optional
	ParentValueFloat *float64 `json:"parentValueFloat,omitempty" protobuf:"bytes,14,opt,name=parentValueFloat"`
}

ParameterRange defines the limits for a single hyperparameter

func (*ParameterRange) DeepCopy added in v0.5.395 

func (in *ParameterRange) DeepCopy() *ParameterRange

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

func (*ParameterRange) DeepCopyInto added in v0.5.395 

func (in *ParameterRange) DeepCopyInto(out *ParameterRange)

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

func (*ParameterRange) Descriptor added in v0.5.395 

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

func (*ParameterRange) Marshal added in v0.5.395 

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

func (*ParameterRange) MarshalTo added in v0.5.395 

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

func (*ParameterRange) MarshalToSizedBuffer added in v0.5.395 

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

func (*ParameterRange) ProtoMessage added in v0.5.395 

func (*ParameterRange) ProtoMessage()

func (*ParameterRange) Reset added in v0.5.395 

func (m *ParameterRange) Reset()

func (*ParameterRange) Size added in v0.5.395 

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

func (*ParameterRange) String added in v0.5.395 

func (this *ParameterRange) String() string

func (*ParameterRange) Unmarshal added in v0.5.395 

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

func (*ParameterRange) XXX_DiscardUnknown added in v0.5.395 

func (m *ParameterRange) XXX_DiscardUnknown()

func (*ParameterRange) XXX_Marshal added in v0.5.395 

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

func (*ParameterRange) XXX_Merge added in v0.5.395 

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

func (*ParameterRange) XXX_Size added in v0.5.395 

func (m *ParameterRange) XXX_Size() int

func (*ParameterRange) XXX_Unmarshal added in v0.5.395 

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

type PermissionsSpec added in v0.4.554 

type PermissionsSpec struct {
	Accounts []AccountPermissions `json:"accounts,omitempty" protobuf:"bytes,1,rep,name=accounts"`
}

PermissionsSpec defines the permissions for one or more accounts

func (*PermissionsSpec) DeepCopy added in v0.4.554 

func (in *PermissionsSpec) DeepCopy() *PermissionsSpec

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

func (*PermissionsSpec) DeepCopyInto added in v0.4.554 

func (in *PermissionsSpec) DeepCopyInto(out *PermissionsSpec)

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

func (*PermissionsSpec) Descriptor added in v0.4.554 

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

func (*PermissionsSpec) Marshal added in v0.4.554 

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

func (*PermissionsSpec) MarshalTo added in v0.4.554 

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

func (*PermissionsSpec) MarshalToSizedBuffer added in v0.4.554 

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

func (*PermissionsSpec) ProtoMessage added in v0.4.554 

func (*PermissionsSpec) ProtoMessage()

func (*PermissionsSpec) Reset added in v0.4.554 

func (m *PermissionsSpec) Reset()

func (*PermissionsSpec) Size added in v0.4.554 

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

func (*PermissionsSpec) String added in v0.4.554 

func (this *PermissionsSpec) String() string

func (*PermissionsSpec) Unmarshal added in v0.4.554 

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

func (*PermissionsSpec) XXX_DiscardUnknown added in v0.4.554 

func (m *PermissionsSpec) XXX_DiscardUnknown()

func (*PermissionsSpec) XXX_Marshal added in v0.4.554 

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

func (*PermissionsSpec) XXX_Merge added in v0.4.554 

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

func (*PermissionsSpec) XXX_Size added in v0.4.554 

func (m *PermissionsSpec) XXX_Size() int

func (*PermissionsSpec) XXX_Unmarshal added in v0.4.554 

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

type PredictionRunReference added in v0.6.252 

type PredictionRunReference struct {
	// The name of the Study which the run belongs to
	Prediction string `json:"prediction,omitempty" protobuf:"bytes,1,opt,name=prediction"`
	// The version of the run to use. If empty, the latest available run will be used
	Version *Version `json:"version,omitempty" protobuf:"varint,2,opt,name=version"`
	// The name of a Prediction Run resource. When specified, takes precedence over Prediction
	Name *string `json:"name,omitempty" protobuf:"varint,3,opt,name=name"`
}

PredictionRunReference defines a reference to a specific run for a Prediction

func (*PredictionRunReference) DeepCopy added in v0.6.252 

func (in *PredictionRunReference) DeepCopy() *PredictionRunReference

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

func (*PredictionRunReference) DeepCopyInto added in v0.6.252 

func (in *PredictionRunReference) DeepCopyInto(out *PredictionRunReference)

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

func (*PredictionRunReference) Descriptor added in v0.6.252 

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

func (*PredictionRunReference) Marshal added in v0.6.252 

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

func (*PredictionRunReference) MarshalTo added in v0.6.252 

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

func (*PredictionRunReference) MarshalToSizedBuffer added in v0.6.252 

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

func (*PredictionRunReference) ProtoMessage added in v0.6.252 

func (*PredictionRunReference) ProtoMessage()

func (*PredictionRunReference) Reset added in v0.6.252 

func (m *PredictionRunReference) Reset()

func (*PredictionRunReference) Size added in v0.6.252 

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

func (*PredictionRunReference) String added in v0.6.252 

func (this *PredictionRunReference) String() string

func (*PredictionRunReference) Unmarshal added in v0.6.252 

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

func (*PredictionRunReference) XXX_DiscardUnknown added in v0.6.252 

func (m *PredictionRunReference) XXX_DiscardUnknown()

func (*PredictionRunReference) XXX_Marshal added in v0.6.252 

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

func (*PredictionRunReference) XXX_Merge added in v0.6.252 

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

func (*PredictionRunReference) XXX_Size added in v0.6.252 

func (m *PredictionRunReference) XXX_Size() int

func (*PredictionRunReference) XXX_Unmarshal added in v0.6.252 

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

type PredictorAccessSpec added in v0.7.0 

type PredictorAccessSpec struct {
	// The port number that will be exposed on the Predictor's Pods to serve prediction traffic through the GRPCInferenceService API.
	// The Kubernetes Service created by the Predictor will expose the port and forward GRPC traffic to the backend pods
	// +kubebuilder:validation:Optional
	// +kubebuilder:validation:Minimum=1024
	// +kubebuilder:validation:Maximum=65535
	// +kubebuilder:validation:Optional
	// +kubebuilder:default:=8080
	Port *int32 `json:"port,omitempty" protobuf:"varint,1,opt,name=port"`
	// The port number that will be exposed on the external address of every node on the cluster, in the case of the
	// Predictor's access type being NodePort. Traffic from the port will be forwarded to the Predictor's backend service
	// +kubebuilder:validation:Minimum=0
	// +kubebuilder:validation:Maximum=65535
	// +kubebuilder:validation:Optional
	NodePort *int32 `json:"nodePort,omitempty" protobuf:"varint,2,opt,name=nodePort"`
	// The auto-generated DNS path where the Predictor service can be accessed. If the access type is ClusterIP, it will
	// be a cluster-internal DNS name (i.e. predictor.default-serving-site.svc.cluster.local). In the case of the Ingress
	// access type, it will be determined by the FQDN of the host ServingSite (i.e. predictor.default-serving-site.your-domain.ai).
	// +kubebuilder:validation:MaxLength=256
	// +kubebuilder:validation:Optional
	// +kubebuilder:default:=""
	Path *string `json:"path,omitempty" protobuf:"bytes,3,opt,name=path"`
	// The Kubernetes-native access method which specifies how the Kubernetes Service created by the Predictor will be exposed.
	// See https://modela.ai/docs/docs/serving/production/#access-method for a detailed description of each access type
	// +kubebuilder:default:="cluster-ip"
	// +kubebuilder:validation:Optional
	AccessType AccessType `json:"accessType,omitempty" protobuf:"bytes,4,opt,name=accessType"`
	// Indicates if the prediction service should expose an additional port to serve the Modela prediction API through HTTP.
	// The port one digit above the number specified by the Port field will be exposed to accept HTTP/1.1 traffic
	// +kubebuilder:default:=false
	// +kubebuilder:validation:Optional
	HTTP *bool `json:"http,omitempty" protobuf:"varint,5,opt,name=http"`
	// +kubebuilder:default:=none
	// +kubebuilder:validation:Optional
	AuthMethod *AuthMethod `json:"authMethod,omitempty" protobuf:"bytes,6,opt,name=authMethod"`
	// ApiKeySecretRef references a Kubernetes Secret containing an API key that must be passed in prediction requests to the Predictor
	// +kubebuilder:validation:Optional
	ApiKeySecretRef *v1.SecretReference `json:"apikeySecretRef,omitempty" protobuf:"bytes,7,opt,name=apikeySecretRef"`
}

func (*PredictorAccessSpec) DeepCopy added in v0.7.0 

func (in *PredictorAccessSpec) DeepCopy() *PredictorAccessSpec

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

func (*PredictorAccessSpec) DeepCopyInto added in v0.7.0 

func (in *PredictorAccessSpec) DeepCopyInto(out *PredictorAccessSpec)

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

func (*PredictorAccessSpec) Descriptor added in v0.7.0 

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

func (*PredictorAccessSpec) Marshal added in v0.7.0 

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

func (*PredictorAccessSpec) MarshalTo added in v0.7.0 

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

func (*PredictorAccessSpec) MarshalToSizedBuffer added in v0.7.0 

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

func (*PredictorAccessSpec) ProtoMessage added in v0.7.0 

func (*PredictorAccessSpec) ProtoMessage()

func (*PredictorAccessSpec) Reset added in v0.7.0 

func (m *PredictorAccessSpec) Reset()

func (*PredictorAccessSpec) Size added in v0.7.0 

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

func (*PredictorAccessSpec) String added in v0.7.0 

func (this *PredictorAccessSpec) String() string

func (*PredictorAccessSpec) Unmarshal added in v0.7.0 

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

func (*PredictorAccessSpec) XXX_DiscardUnknown added in v0.7.0 

func (m *PredictorAccessSpec) XXX_DiscardUnknown()

func (*PredictorAccessSpec) XXX_Marshal added in v0.7.0 

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

func (*PredictorAccessSpec) XXX_Merge added in v0.7.0 

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

func (*PredictorAccessSpec) XXX_Size added in v0.7.0 

func (m *PredictorAccessSpec) XXX_Size() int

func (*PredictorAccessSpec) XXX_Unmarshal added in v0.7.0 

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

type PredictorFormat 

type PredictorFormat string

+kubebuilder:validation:Enum="flask";"grpc";"onyx"; Predictor format represent the API implementation of the model 

const (
	FlaskPredictor PredictorFormat = "flask"
	GrpcPredictor  PredictorFormat = "grpc"
	OnyxPredictor  PredictorFormat = "onyx"
)

type PredictorType added in v0.5.261 

type PredictorType string

+kubebuilder:validation:Enum="online";"batch";"streaming" 

const (
	// Use cluster port if the predictor is an internal micro service
	Online    PredictorType = "online"
	Batch     PredictorType = "batch"
	Streaming PredictorType = "streaming"
)

type PretrainedModel 

type PretrainedModel struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`
	Spec              PretrainedModelSpec `json:"spec" protobuf:"bytes,2,opt,name=spec"`
}

Pretrained model contain the metadata about a pretrained model +kubebuilder:object:root=true

func NewPretrainedModel 

func NewPretrainedModel(ns string, name string, image string) *PretrainedModel

func (*PretrainedModel) DeepCopy 

func (in *PretrainedModel) DeepCopy() *PretrainedModel

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

func (*PretrainedModel) DeepCopyInto 

func (in *PretrainedModel) DeepCopyInto(out *PretrainedModel)

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

func (*PretrainedModel) DeepCopyObject 

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

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

func (*PretrainedModel) Default 

func (p *PretrainedModel) Default()

func (*PretrainedModel) Descriptor 

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

func (*PretrainedModel) Marshal 

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

func (*PretrainedModel) MarshalTo 

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

func (*PretrainedModel) MarshalToSizedBuffer 

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

func (*PretrainedModel) ProtoMessage 

func (*PretrainedModel) ProtoMessage()

func (*PretrainedModel) Reset 

func (m *PretrainedModel) Reset()

func (*PretrainedModel) Size 

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

func (*PretrainedModel) String 

func (this *PretrainedModel) String() string

func (*PretrainedModel) Unmarshal 

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

func (*PretrainedModel) XXX_DiscardUnknown 

func (m *PretrainedModel) XXX_DiscardUnknown()

func (*PretrainedModel) XXX_Marshal 

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

func (*PretrainedModel) XXX_Merge 

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

func (*PretrainedModel) XXX_Size 

func (m *PretrainedModel) XXX_Size() int

func (*PretrainedModel) XXX_Unmarshal 

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

type PretrainedModelList 

type PretrainedModelList struct {
	metav1.TypeMeta `json:",inline" `
	metav1.ListMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`

	Items []PretrainedModel `json:"items" protobuf:"bytes,2,rep,name=items"`
}

+kubebuilder:object:root=true PretrainedModelList is a list of pretrained models

func (*PretrainedModelList) DeepCopy 

func (in *PretrainedModelList) DeepCopy() *PretrainedModelList

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

func (*PretrainedModelList) DeepCopyInto 

func (in *PretrainedModelList) DeepCopyInto(out *PretrainedModelList)

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

func (*PretrainedModelList) DeepCopyObject 

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

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

func (*PretrainedModelList) Descriptor 

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

func (*PretrainedModelList) Marshal 

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

func (*PretrainedModelList) MarshalTo 

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

func (*PretrainedModelList) MarshalToSizedBuffer 

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

func (*PretrainedModelList) ProtoMessage 

func (*PretrainedModelList) ProtoMessage()

func (*PretrainedModelList) Reset 

func (m *PretrainedModelList) Reset()

func (*PretrainedModelList) Size 

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

func (*PretrainedModelList) String 

func (this *PretrainedModelList) String() string

func (*PretrainedModelList) Unmarshal 

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

func (*PretrainedModelList) XXX_DiscardUnknown 

func (m *PretrainedModelList) XXX_DiscardUnknown()

func (*PretrainedModelList) XXX_Marshal 

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

func (*PretrainedModelList) XXX_Merge 

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

func (*PretrainedModelList) XXX_Size 

func (m *PretrainedModelList) XXX_Size() int

func (*PretrainedModelList) XXX_Unmarshal 

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

type PretrainedModelSpec 

type PretrainedModelSpec struct {
	// Image is the docker image of the pretrained model
	Image string `json:"image" protobuf:"bytes,1,opt,name=image"`
}

PretrainedModelSpec is the desired state of the pretrained model

func (*PretrainedModelSpec) DeepCopy 

func (in *PretrainedModelSpec) DeepCopy() *PretrainedModelSpec

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

func (*PretrainedModelSpec) DeepCopyInto 

func (in *PretrainedModelSpec) DeepCopyInto(out *PretrainedModelSpec)

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

func (*PretrainedModelSpec) Descriptor 

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

func (*PretrainedModelSpec) Marshal 

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

func (*PretrainedModelSpec) MarshalTo 

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

func (*PretrainedModelSpec) MarshalToSizedBuffer 

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

func (*PretrainedModelSpec) ProtoMessage 

func (*PretrainedModelSpec) ProtoMessage()

func (*PretrainedModelSpec) Reset 

func (m *PretrainedModelSpec) Reset()

func (*PretrainedModelSpec) Size 

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

func (*PretrainedModelSpec) String 

func (this *PretrainedModelSpec) String() string

func (*PretrainedModelSpec) Unmarshal 

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

func (*PretrainedModelSpec) XXX_DiscardUnknown 

func (m *PretrainedModelSpec) XXX_DiscardUnknown()

func (*PretrainedModelSpec) XXX_Marshal 

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

func (*PretrainedModelSpec) XXX_Merge 

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

func (*PretrainedModelSpec) XXX_Size 

func (m *PretrainedModelSpec) XXX_Size() int

func (*PretrainedModelSpec) XXX_Unmarshal 

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

type PriorityLevel 

type PriorityLevel string

PriorityLevel defines the priority class assigned to a Modela Job +kubebuilder:validation:Enum="low";"medium";"high";"urgent" 

const (
	PriorityLevelLow    PriorityLevel = "low"
	PriorityLevelMedium PriorityLevel = "medium"
	PriorityLevelHigh   PriorityLevel = "high"
	PriorityLevelUrgent PriorityLevel = "urgent"
)

type PromotionType added in v0.5.261 

type PromotionType string

PromotionType defines how a model is promoted to a predictor +kubebuilder:validation:Enum="manual";"best";"latest";"none" 

const (
	ManualPromotion PromotionType = "manual"
	LatestPromotion PromotionType = "latest"
	BestPromotion   PromotionType = "best"
	NonePromotion   PromotionType = "none"
)

type ProviderName 

type ProviderName string

ProviderName is the name of a provider of an external data source 

const (
	// Databases
	AmazonAthenaProviderName   ProviderName = "athena"
	AmazonRedshiftProviderName ProviderName = "redshift"
	ApacheDrillProviderName    ProviderName = "drill"
	ApacheDruid                ProviderName = "druid"
	ApacheHive                 ProviderName = "hive"
	ApacheImpala               ProviderName = "impala"
	ApacheKylin                ProviderName = "kylin"
	ApachePinot                ProviderName = "pinot"
	ApacheSpark                ProviderName = "spark"
	AzureSqlDatabase           ProviderName = "azuresqldatabase"
	GcpBigQuery                ProviderName = "bigquery"
	ApacheCassandra            ProviderName = "cassandra"
	CockroachDB                ProviderName = "cockroachdb"
	Clickhouse                 ProviderName = "clickhouse"
	Couchbase                  ProviderName = "couchbase"
	Dremio                     ProviderName = "dremio"
	DB2                        ProviderName = "db2"
	ElasticSearch              ProviderName = "elasticsearch"
	Exasol                     ProviderName = "exasol"
	Kafka                      ProviderName = "kafka"
	GoogleSheets               ProviderName = "googlesheets"
	GcpSpanner                 ProviderName = "spanner"
	Greenplum                  ProviderName = "greenplum"
	MySQL                      ProviderName = "mysql"
	MongoDB                    ProviderName = "mongodb"
	Oracle                     ProviderName = "oracle"
	PostgreSQL                 ProviderName = "postgresql"
	Presto                     ProviderName = "presto"
	SAPHana                    ProviderName = "hana"
	Snowflake                  ProviderName = "snowflake"
	Singlestore                ProviderName = "singlestore"
	Sybase                     ProviderName = "sybase"
	MSSqlServer                ProviderName = "mssqlserver"
	Sqlite                     ProviderName = "sqlite"
	RabbitMQ                   ProviderName = "rabbitmq"
	Teradata                   ProviderName = "teradata"
	Vertica                    ProviderName = "vertica"
	ODBC                       ProviderName = "odbc"
	Informix                   ProviderName = "informix"

	// graph databases
	Neo4j ProviderName = "neo4j"

	// Cloud Storage
	AliCloud     ProviderName = "alicloud"
	AzureStorage ProviderName = "azurestorage"
	DigitalOcean ProviderName = "digitalocean"
	Hetzner      ProviderName = "hetzner"
	Linode       ProviderName = "linode"
	Gcs          ProviderName = "gcs"
	Minio        ProviderName = "minio"
	Ovh          ProviderName = "ovh"
	Aws          ProviderName = "aws"
	Openstack    ProviderName = "openstack"
	FTP          ProviderName = "ftp"
	SFTP         ProviderName = "sftp"
	Dropbox      ProviderName = "dropbox"
	Box          ProviderName = "box"

	// Docker Image Registry
	Dockerhub     ProviderName = "dockerhub"
	ImageRegistry ProviderName = "image-registry"

	// Git Repository
	GitHub    ProviderName = "github"
	Bitbucket ProviderName = "bitbucket"
	Gitlab    ProviderName = "gitlab"

	// Messaging
	SmtpProvider ProviderName = "smtp"
	Slack        ProviderName = "slack"
	Hipchat      ProviderName = "hipchat"
	Discord      ProviderName = "discord"
	PageDuty     ProviderName = "pagerduty"
	PushOver     ProviderName = "pushover"
	OpsGenie     ProviderName = "opsgenie"
	Webhook      ProviderName = "webook"
	VictorOps    ProviderName = "victorops"
	Flock        ProviderName = "flock"
	MSTeam       ProviderName = "msteam"
	MatterMost   ProviderName = "mattermost"

	// Social media
	Facebook ProviderName = "facebook"
	Twitter  ProviderName = "twitter"

	// time series db
	InfluxDB        ProviderName = "influxdb"
	TimescaleDB     ProviderName = "timescaledb"
	VictoriaMetrics ProviderName = "victoria-metrics"
	Saleforce       ProviderName = "saleforce"
	SapCRM          ProviderName = "sapcrm"
	AirTable        ProviderName = "airtable"
	AppWrite        ProviderName = "appwrite"

	UnknownProvider ProviderName = "unknown"
)

type PublicDataset 

type PublicDataset struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`
	Spec              PublicDatasetSpec `json:"spec" protobuf:"bytes,2,opt,name=spec"`
}

+genclient +kubebuilder:object:root=true +kubebuilder:resource:path=publicdatasets,singular=publicdataset,categories={catalog,modela,all} +kubebuilder:storageversion +kubebuilder:printcolumn:name="Task",type="string",JSONPath=".spec.task",description="ML task name" +kubebuilder:printcolumn:name="URL",type="string",JSONPath=".spec.url",description="",priority=1 +kubebuilder:printcolumn:name="Rows",type="number",JSONPath=".spec.rows",description="" +kubebuilder:printcolumn:name="Columns",type="number",JSONPath=".spec.columns",description="" +kubebuilder:printcolumn:name="Target",type="string",JSONPath=".spec.targetColumn",description="" +kubebuilder:printcolumn:name="Imbalanced",type="string",JSONPath=".spec.imbalanced",description="",priority=1 +kubebuilder:printcolumn:name="Age",type=date,JSONPath=`.metadata.creationTimestamp` PublicDataset represent the metadata about a public dataset

func (*PublicDataset) DeepCopy 

func (in *PublicDataset) DeepCopy() *PublicDataset

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

func (*PublicDataset) DeepCopyInto 

func (in *PublicDataset) DeepCopyInto(out *PublicDataset)

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

func (*PublicDataset) DeepCopyObject 

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

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

func (*PublicDataset) Descriptor 

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

func (*PublicDataset) Marshal 

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

func (*PublicDataset) MarshalTo 

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

func (*PublicDataset) MarshalToSizedBuffer 

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

func (*PublicDataset) PodName 

func (pd *PublicDataset) PodName() string

func (*PublicDataset) ProtoMessage 

func (*PublicDataset) ProtoMessage()

func (*PublicDataset) RepEntry 

func (pd *PublicDataset) RepEntry() (string, error)

func (*PublicDataset) RepPath 

func (pd *PublicDataset) RepPath(root string) (string, error)

Return the on disk rep location

func (*PublicDataset) Reset 

func (m *PublicDataset) Reset()

func (*PublicDataset) Size 

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

func (*PublicDataset) String 

func (this *PublicDataset) String() string

func (*PublicDataset) Unmarshal 

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

func (*PublicDataset) Validate 

func (pd *PublicDataset) Validate() (bool, field.ErrorList)

func (*PublicDataset) ValidateCreate 

func (pd *PublicDataset) ValidateCreate() error

ValidateCreate implements webhook.Validator so a webhook will be registered for the type

func (*PublicDataset) ValidateDelete 

func (pd *PublicDataset) ValidateDelete() error

func (*PublicDataset) ValidateUpdate 

func (pd *PublicDataset) ValidateUpdate(old runtime.Object) error

ValidateUpdate implements webhook.Validator so a webhook will be registered for the type

func (*PublicDataset) XXX_DiscardUnknown 

func (m *PublicDataset) XXX_DiscardUnknown()

func (*PublicDataset) XXX_Marshal 

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

func (*PublicDataset) XXX_Merge 

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

func (*PublicDataset) XXX_Size 

func (m *PublicDataset) XXX_Size() int

func (*PublicDataset) XXX_Unmarshal 

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

type PublicDatasetList 

type PublicDatasetList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata" protobuf:"bytes,1,opt,name=metadata"`
	Items           []PublicDataset `json:"items" protobuf:"bytes,2,rep,name=items"`
}

+kubebuilder:object:root=true PublicDatasetList contains a list of PublicDataset

func (*PublicDatasetList) DeepCopy 

func (in *PublicDatasetList) DeepCopy() *PublicDatasetList

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

func (*PublicDatasetList) DeepCopyInto 

func (in *PublicDatasetList) DeepCopyInto(out *PublicDatasetList)

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

func (*PublicDatasetList) DeepCopyObject 

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

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

func (*PublicDatasetList) Descriptor 

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

func (*PublicDatasetList) Marshal 

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

func (*PublicDatasetList) MarshalTo 

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

func (*PublicDatasetList) MarshalToSizedBuffer 

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

func (*PublicDatasetList) ProtoMessage 

func (*PublicDatasetList) ProtoMessage()

func (*PublicDatasetList) Reset 

func (m *PublicDatasetList) Reset()

func (*PublicDatasetList) Size 

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

func (*PublicDatasetList) String 

func (this *PublicDatasetList) String() string

func (*PublicDatasetList) Unmarshal 

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

func (*PublicDatasetList) XXX_DiscardUnknown 

func (m *PublicDatasetList) XXX_DiscardUnknown()

func (*PublicDatasetList) XXX_Marshal 

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

func (*PublicDatasetList) XXX_Merge 

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

func (*PublicDatasetList) XXX_Size 

func (m *PublicDatasetList) XXX_Size() int

func (*PublicDatasetList) XXX_Unmarshal 

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

type PublicDatasetSpec 

type PublicDatasetSpec struct {
	Url string `json:"url,omitempty" protobuf:"bytes,1,opt,name=url"`
	// Entity description
	// +kubebuilder:default =""
	// +kubebuilder:validation:Optional
	Description *string `json:"description,omitempty" protobuf:"bytes,2,opt,name=description"`
	// Task is the machine learning task of the public dataset
	Task *MLTask `json:"task" protobuf:"bytes,3,opt,name=task"`
	// The open ml id of the dataset
	// +kubebuilder:validation:Optional
	// +kubebuilder:default =""
	OpenMLID *string `json:"openMLID,omitempty" protobuf:"bytes,4,opt,name=openMLID"`
	// The URL to the actual data file or folder
	// +kubebuilder:validation:Optional
	// +kubebuilder:default =""
	DataUrl *string `json:"dataUrl,omitempty" protobuf:"bytes,5,opt,name=dataUrl"`
	// Entity citation
	// +kubebuilder:validation:Optional
	// +kubebuilder:default =""
	Citation *string `json:"citation,omitempty" protobuf:"bytes,6,opt,name=citation"`
	// Number of rows in the dataset
	// +kubebuilder:validation:Optional
	// +kubebuilder:default := 0
	Rows *int32 `json:"rows,omitempty" protobuf:"varint,7,opt,name=rows"`
	// Number of columns in the dataset
	// +kubebuilder:validation:Optional
	// +kubebuilder:default := 0
	Columns *int32 `json:"columns,omitempty" protobuf:"varint,8,opt,name=columns"`
	// +kubebuilder:validation:Optional
	// The size of the dataset in bytes
	// +kubebuilder:default := 0
	FileSize *int32 `json:"fileSize,omitempty" protobuf:"varint,9,opt,name=fileSize"`
	// The target column name
	// +kubebuilder:default =""
	TargetColumn *string `json:"targetColumn,omitempty" protobuf:"bytes,10,opt,name=targetColumn"`
	// The target column name
	// +kubebuilder:default =""
	Industry *string `json:"industry,omitempty" protobuf:"bytes,11,opt,name=industry"`
	// +kubebuilder:default = false
	Imbalanced *bool `json:"imbalanced,omitempty" protobuf:"varint,12,opt,name=imbalanced"`
	// URI of the datasource CR for this public dataset
	// +kubebuilder:default =""
	DatasourceCR *string `json:"datasourceCR,omitempty" protobuf:"bytes,13,opt,name=datasourceCR"`
	// URI of the dataset CR for this public dataset
	// +kubebuilder:default =""
	DatasetCR *string `json:"datasetCR,omitempty" protobuf:"bytes,14,opt,name=datasetCR"`
	// URI of the study CR for this public dataset
	// +kubebuilder:default =""
	StudyCR *string `json:"studyCR,omitempty" protobuf:"bytes,15,opt,name=studyCR"`
	// URI of the data product CR
	// +kubebuilder:default =""
	DataProductCR *string `json:"dataProductCR,omitempty" protobuf:"bytes,16,opt,name=dataProductCR"`
}

func (*PublicDatasetSpec) DeepCopy 

func (in *PublicDatasetSpec) DeepCopy() *PublicDatasetSpec

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

func (*PublicDatasetSpec) DeepCopyInto 

func (in *PublicDatasetSpec) DeepCopyInto(out *PublicDatasetSpec)

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

func (*PublicDatasetSpec) Descriptor 

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

func (*PublicDatasetSpec) Marshal 

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

func (*PublicDatasetSpec) MarshalTo 

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

func (*PublicDatasetSpec) MarshalToSizedBuffer 

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

func (*PublicDatasetSpec) ProtoMessage 

func (*PublicDatasetSpec) ProtoMessage()

func (*PublicDatasetSpec) Reset 

func (m *PublicDatasetSpec) Reset()

func (*PublicDatasetSpec) Size 

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

func (*PublicDatasetSpec) String 

func (this *PublicDatasetSpec) String() string

func (*PublicDatasetSpec) Unmarshal 

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

func (*PublicDatasetSpec) XXX_DiscardUnknown 

func (m *PublicDatasetSpec) XXX_DiscardUnknown()

func (*PublicDatasetSpec) XXX_Marshal 

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

func (*PublicDatasetSpec) XXX_Merge 

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

func (*PublicDatasetSpec) XXX_Size 

func (m *PublicDatasetSpec) XXX_Size() int

func (*PublicDatasetSpec) XXX_Unmarshal 

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

type ReferenceDataType added in v0.5.114 

type ReferenceDataType string
const (
	ReferenceDataTrainingData ReferenceDataType = "train-data"
	ReferenceDataTestingData  ReferenceDataType = "test-data"
	ReferenceDataRange        ReferenceDataType = "range"
	ReferenceDataMovingAvg    ReferenceDataType = "moving-avg"
)

type Region 

type Region struct {
	//Code is the code of the region
	Code string `json:"code" protobuf:"bytes,1,opt,name=code"`
	// The default datacenter for a region
	//+optional
	DefaultDatacenterName string `json:"defaultDatacenterName,omitempty" protobuf:"bytes,2,opt,name=defaultDatacenterName"`
	// Location is the location code The location of the region
	Location string `json:"location,omitempty" protobuf:"bytes,3,opt,name=location"`
	// BillingCode is the billing code of the region
	BillingCode string `json:"billingCode,omitempty" protobuf:"bytes,4,opt,name=billingCode"`
	//Datacenters if the list of datacenters
	Datacenters []DataCenter `json:"datacenters,omitempty" protobuf:"bytes,5,rep,name=datacenters"`
}

Region defines a region within the data provider

func (*Region) DeepCopy 

func (in *Region) DeepCopy() *Region

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

func (*Region) DeepCopyInto 

func (in *Region) DeepCopyInto(out *Region)

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

func (*Region) Descriptor 

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

func (*Region) Marshal 

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

func (*Region) MarshalTo 

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

func (*Region) MarshalToSizedBuffer 

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

func (*Region) ProtoMessage 

func (*Region) ProtoMessage()

func (*Region) Reset 

func (m *Region) Reset()

func (*Region) Size 

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

func (*Region) String 

func (this *Region) String() string

func (*Region) Unmarshal 

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

func (*Region) XXX_DiscardUnknown 

func (m *Region) XXX_DiscardUnknown()

func (*Region) XXX_Marshal 

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

func (*Region) XXX_Merge 

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

func (*Region) XXX_Size 

func (m *Region) XXX_Size() int

func (*Region) XXX_Unmarshal 

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

type RelationshipArity 

type RelationshipArity string

+kubebuilder:validation:Enum="one-to-one";"one-to-many";"many-to-many"; Relationship type between data sources 

const (
	OneToOneRelationshipArity   RelationshipArity = "one-to-one"
	OneToManyRelationshipArity  RelationshipArity = "one-to-many"
	ManyToManyRelationshipArity RelationshipArity = "many-to-many"
)

type ReportRange added in v0.5.267 

type ReportRange string

+kubebuilder:validation:Enum="last-24-hours";"last-7-days";"last-30-days";"last-90-days";"none" 

const (
	Last24HoursReportRange ReportRange = "last-24-hours"
	Last7DaysReportRange   ReportRange = "last-7-days"
	Last30DaysReportRange  ReportRange = "last-30-days"
	Last90DaysReportRange  ReportRange = "last-90-days"
	NoneReportRange        ReportRange = "none"
)

type ResourceConsumption added in v0.5.570 

type ResourceConsumption struct {
	Cpu    uint64 `json:"cpu,omitempty" protobuf:"bytes,1,opt,name=cpu"`
	Memory uint64 `json:"memory,omitempty" protobuf:"bytes,2,opt,name=memory"`
	Gpu    uint64 `json:"gpu,omitempty" protobuf:"bytes,3,opt,name=gpu"`
}

Store resource consumption for a task

func (*ResourceConsumption) DeepCopy added in v0.5.572 

func (in *ResourceConsumption) DeepCopy() *ResourceConsumption

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

func (*ResourceConsumption) DeepCopyInto added in v0.5.572 

func (in *ResourceConsumption) DeepCopyInto(out *ResourceConsumption)

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

func (*ResourceConsumption) Descriptor added in v0.5.570 

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

func (*ResourceConsumption) Marshal added in v0.5.570 

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

func (*ResourceConsumption) MarshalTo added in v0.5.570 

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

func (*ResourceConsumption) MarshalToSizedBuffer added in v0.5.570 

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

func (*ResourceConsumption) ProtoMessage added in v0.5.570 

func (*ResourceConsumption) ProtoMessage()

func (*ResourceConsumption) Reset added in v0.5.570 

func (m *ResourceConsumption) Reset()

func (*ResourceConsumption) Size added in v0.5.570 

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

func (*ResourceConsumption) String added in v0.5.570 

func (this *ResourceConsumption) String() string

func (*ResourceConsumption) Unmarshal added in v0.5.570 

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

func (*ResourceConsumption) XXX_DiscardUnknown added in v0.5.570 

func (m *ResourceConsumption) XXX_DiscardUnknown()

func (*ResourceConsumption) XXX_Marshal added in v0.5.570 

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

func (*ResourceConsumption) XXX_Merge added in v0.5.570 

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

func (*ResourceConsumption) XXX_Size added in v0.5.570 

func (m *ResourceConsumption) XXX_Size() int

func (*ResourceConsumption) XXX_Unmarshal added in v0.5.570 

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

type ResourceLocation added in v0.6.310 

type ResourceLocation struct {
	// The type of resource which can be used as a data source
	// +kubebuilder:validation:Optional
	Kind ResourceLocationKind `json:"kind,omitempty" protobuf:"bytes,1,opt,name=kind"`
	// The name of the resource
	Name string `json:"name,omitempty" protobuf:"bytes,2,opt,name=name"`
	// The namespace of the resource. When referencing a Dataset Snapshot, default to the Data Product of the specifying resource.
	// When referencing a Public Dataset, default to the built-in catalog namespace (modela-catalog)
	Namespace *string `json:"namespace,omitempty" protobuf:"bytes,3,opt,name=namespace"`
}

func (*ResourceLocation) DeepCopy added in v0.6.310 

func (in *ResourceLocation) DeepCopy() *ResourceLocation

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

func (*ResourceLocation) DeepCopyInto added in v0.6.310 

func (in *ResourceLocation) DeepCopyInto(out *ResourceLocation)

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

func (*ResourceLocation) Descriptor added in v0.6.310 

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

func (*ResourceLocation) Marshal added in v0.6.310 

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

func (*ResourceLocation) MarshalTo added in v0.6.310 

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

func (*ResourceLocation) MarshalToSizedBuffer added in v0.6.310 

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

func (*ResourceLocation) ProtoMessage added in v0.6.310 

func (*ResourceLocation) ProtoMessage()

func (*ResourceLocation) Reset added in v0.6.310 

func (m *ResourceLocation) Reset()

func (*ResourceLocation) Size added in v0.6.310 

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

func (*ResourceLocation) String added in v0.6.310 

func (this *ResourceLocation) String() string

func (*ResourceLocation) Unmarshal added in v0.6.310 

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

func (*ResourceLocation) XXX_DiscardUnknown added in v0.6.310 

func (m *ResourceLocation) XXX_DiscardUnknown()

func (*ResourceLocation) XXX_Marshal added in v0.6.310 

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

func (*ResourceLocation) XXX_Merge added in v0.6.310 

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

func (*ResourceLocation) XXX_Size added in v0.6.310 

func (m *ResourceLocation) XXX_Size() int

func (*ResourceLocation) XXX_Unmarshal added in v0.6.310 

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

type ResourceLocationKind added in v0.6.310 

type ResourceLocationKind string

type ResourceSpec 

type ResourceSpec struct {
	// WorkloadName references the name of a Workload Class resource that will be used to determine the resource
	// requirements of the workload. If specified, WorkloadName will take precedence over custom requirements
	// +kubebuilder:validation:Optional
	WorkloadName *string `json:"workloadName,omitempty" protobuf:"bytes,1,opt,name=workloadName"`
	// Custom indicates if the custom requirements specified by Requirements will be used
	// +kubebuilder:default:=false
	// +kubebuilder:validation:Optional
	Custom *bool `json:"custom,omitempty" protobuf:"varint,2,opt,name=custom"`
	// Requirements specifies the custom resource requirements for the workload
	// +kubebuilder:validation:Optional
	Requirements *v1.ResourceRequirements `json:"requirements,omitempty" protobuf:"bytes,3,opt,name=requirements"`
}

ResourceSpec specifies the resources that will be allocated to a workload

func (*ResourceSpec) DeepCopy 

func (in *ResourceSpec) DeepCopy() *ResourceSpec

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

func (*ResourceSpec) DeepCopyInto 

func (in *ResourceSpec) DeepCopyInto(out *ResourceSpec)

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

func (*ResourceSpec) Descriptor 

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

func (*ResourceSpec) Marshal 

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

func (*ResourceSpec) MarshalTo 

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

func (*ResourceSpec) MarshalToSizedBuffer 

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

func (*ResourceSpec) ProtoMessage 

func (*ResourceSpec) ProtoMessage()

func (*ResourceSpec) Reset 

func (m *ResourceSpec) Reset()

func (*ResourceSpec) Size 

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

func (*ResourceSpec) String 

func (this *ResourceSpec) String() string

func (*ResourceSpec) Unmarshal 

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

func (*ResourceSpec) XXX_DiscardUnknown 

func (m *ResourceSpec) XXX_DiscardUnknown()

func (*ResourceSpec) XXX_Marshal 

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

func (*ResourceSpec) XXX_Merge 

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

func (*ResourceSpec) XXX_Size 

func (m *ResourceSpec) XXX_Size() int

func (*ResourceSpec) XXX_Unmarshal 

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

type RocAucCurve 

type RocAucCurve struct {
	Values []CurvePoint `json:"values,omitempty" protobuf:"bytes,1,rep,name=values"`
}

func (*RocAucCurve) DeepCopy 

func (in *RocAucCurve) DeepCopy() *RocAucCurve

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

func (*RocAucCurve) DeepCopyInto 

func (in *RocAucCurve) DeepCopyInto(out *RocAucCurve)

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

func (*RocAucCurve) Descriptor 

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

func (*RocAucCurve) Marshal 

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

func (*RocAucCurve) MarshalTo 

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

func (*RocAucCurve) MarshalToSizedBuffer 

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

func (*RocAucCurve) ProtoMessage 

func (*RocAucCurve) ProtoMessage()

func (*RocAucCurve) Reset 

func (m *RocAucCurve) Reset()

func (*RocAucCurve) Size 

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

func (*RocAucCurve) String 

func (this *RocAucCurve) String() string

func (*RocAucCurve) Unmarshal 

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

func (*RocAucCurve) XXX_DiscardUnknown 

func (m *RocAucCurve) XXX_DiscardUnknown()

func (*RocAucCurve) XXX_Marshal 

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

func (*RocAucCurve) XXX_Merge 

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

func (*RocAucCurve) XXX_Size 

func (m *RocAucCurve) XXX_Size() int

func (*RocAucCurve) XXX_Unmarshal 

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

type RunReference added in v0.6.252 

type RunReference struct {
	// The name of the run
	Name string `json:"name" protobuf:"bytes,1,opt,name=name"`
	// The version of the run
	Version Version `json:"version" protobuf:"varint,2,opt,name=version"`
}

RunReference defines a generic reference to any type of run

func (*RunReference) DeepCopy added in v0.6.252 

func (in *RunReference) DeepCopy() *RunReference

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

func (*RunReference) DeepCopyInto added in v0.6.252 

func (in *RunReference) DeepCopyInto(out *RunReference)

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

func (*RunReference) Descriptor added in v0.6.252 

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

func (*RunReference) Marshal added in v0.6.252 

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

func (*RunReference) MarshalTo added in v0.6.252 

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

func (*RunReference) MarshalToSizedBuffer added in v0.6.252 

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

func (*RunReference) ProtoMessage added in v0.6.252 

func (*RunReference) ProtoMessage()

func (*RunReference) Reset added in v0.6.252 

func (m *RunReference) Reset()

func (*RunReference) Size added in v0.6.252 

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

func (*RunReference) String added in v0.6.252 

func (this *RunReference) String() string

func (*RunReference) Unmarshal added in v0.6.252 

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

func (*RunReference) XXX_DiscardUnknown added in v0.6.252 

func (m *RunReference) XXX_DiscardUnknown()

func (*RunReference) XXX_Marshal added in v0.6.252 

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

func (*RunReference) XXX_Merge added in v0.6.252 

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

func (*RunReference) XXX_Size added in v0.6.252 

func (m *RunReference) XXX_Size() int

func (*RunReference) XXX_Unmarshal added in v0.6.252 

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

type RunReferenceList added in v0.6.252 

type RunReferenceList []RunReference

func (RunReferenceList) DeepCopy added in v0.6.252 

func (in RunReferenceList) DeepCopy() RunReferenceList

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

func (RunReferenceList) DeepCopyInto added in v0.6.252 

func (in RunReferenceList) DeepCopyInto(out *RunReferenceList)

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

func (RunReferenceList) RecordReference added in v0.6.252 

func (v RunReferenceList) RecordReference(reference RunReference, shouldExist bool) RunReferenceList

type RunSchedule 

type RunSchedule struct {
	// Enabled indicates if the schedule is enabled. When enabled, a CronJob will be created which when triggered
	// will initiate the creation of a run for the resource that specifies the schedule
	// +kubebuilder:default:=false
	// +kubebuilder:validation:Optional
	Enabled *bool `json:"enabled,omitempty" protobuf:"varint,1,opt,name=enabled"`
	// The cron string for the schedule, applicable if the trigger type is Cron.
	// See https://docs.oracle.com/cd/E12058_01/doc/doc.1014/e12030/cron_expressions.htm for more information
	// +kubebuilder:validation:Optional
	Cron *string `json:"cron,omitempty" protobuf:"bytes,2,opt,name=cron"`
	// The type of schedule, which can be a frequency interval or a cron expression
	// +kubebuilder:validation:Optional
	Type TriggerScheduleEventType `json:"type,omitempty" protobuf:"bytes,3,opt,name=type"`
}

RunSchedule specifies the schedule for a run to be executed

func (*RunSchedule) DeepCopy 

func (in *RunSchedule) DeepCopy() *RunSchedule

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

func (*RunSchedule) DeepCopyInto 

func (in *RunSchedule) DeepCopyInto(out *RunSchedule)

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

func (*RunSchedule) Descriptor 

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

func (*RunSchedule) GetEnabled added in v0.6.310 

func (schedule *RunSchedule) GetEnabled() bool

func (*RunSchedule) Marshal 

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

func (*RunSchedule) MarshalTo 

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

func (*RunSchedule) MarshalToSizedBuffer 

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

func (*RunSchedule) NextRun added in v0.5.316 

func (schedule *RunSchedule) NextRun() *string

func (*RunSchedule) ProtoMessage 

func (*RunSchedule) ProtoMessage()

func (*RunSchedule) Reset 

func (m *RunSchedule) Reset()

func (*RunSchedule) Size 

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

func (*RunSchedule) String 

func (this *RunSchedule) String() string

func (*RunSchedule) Unmarshal 

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

func (*RunSchedule) XXX_DiscardUnknown 

func (m *RunSchedule) XXX_DiscardUnknown()

func (*RunSchedule) XXX_Marshal 

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

func (*RunSchedule) XXX_Merge 

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

func (*RunSchedule) XXX_Size 

func (m *RunSchedule) XXX_Size() int

func (*RunSchedule) XXX_Unmarshal 

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

type RunScheduleStatus added in v0.5.304 

type RunScheduleStatus struct {
	// Active contains a collection of references to currently active runs
	// +optional
	Active RunReferenceList `json:"active,omitempty" protobuf:"bytes,1,rep,name=active"`
	// LastScheduleTime specifies when was the last time a run was successfully scheduled
	// +optional
	LastScheduleTime *metav1.Time `json:"lastScheduleTime,omitempty" protobuf:"bytes,2,opt,name=lastScheduleTime"`
	// LastSuccessfulTime specifies when was the last time a run successfully completed
	// +optional
	LastSuccessfulTime *metav1.Time `json:"lastSuccessfulTime,omitempty" protobuf:"bytes,3,opt,name=lastSuccessfulTime"`
}

func (*RunScheduleStatus) DeepCopy added in v0.5.304 

func (in *RunScheduleStatus) DeepCopy() *RunScheduleStatus

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

func (*RunScheduleStatus) DeepCopyInto added in v0.5.304 

func (in *RunScheduleStatus) DeepCopyInto(out *RunScheduleStatus)

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

func (*RunScheduleStatus) Descriptor added in v0.5.304 

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

func (*RunScheduleStatus) Marshal added in v0.5.304 

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

func (*RunScheduleStatus) MarshalTo added in v0.5.304 

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

func (*RunScheduleStatus) MarshalToSizedBuffer added in v0.5.304 

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

func (*RunScheduleStatus) ProtoMessage added in v0.5.304 

func (*RunScheduleStatus) ProtoMessage()

func (*RunScheduleStatus) Reset added in v0.5.304 

func (m *RunScheduleStatus) Reset()

func (*RunScheduleStatus) Size added in v0.5.304 

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

func (*RunScheduleStatus) Start added in v0.5.372 

func (runs *RunScheduleStatus) Start()

func (*RunScheduleStatus) String added in v0.5.304 

func (this *RunScheduleStatus) String() string

func (*RunScheduleStatus) Unmarshal added in v0.5.304 

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

func (*RunScheduleStatus) XXX_DiscardUnknown added in v0.5.304 

func (m *RunScheduleStatus) XXX_DiscardUnknown()

func (*RunScheduleStatus) XXX_Marshal added in v0.5.304 

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

func (*RunScheduleStatus) XXX_Merge added in v0.5.304 

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

func (*RunScheduleStatus) XXX_Size added in v0.5.304 

func (m *RunScheduleStatus) XXX_Size() int

func (*RunScheduleStatus) XXX_Unmarshal added in v0.5.304 

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

type RunSpec added in v0.6.252 

type RunSpec struct {
	// Timeout specifies the deadline in seconds for a run to complete, after which it will be aborted.
	// If empty, runs will not have a deadline
	// +kubebuilder:validation:Optional
	Timeout *int32 `json:"timeout,omitempty" protobuf:"varint,1,opt,name=timeout"`
	// MaxPreviousRuns specifies the amount of previous runs to maintain, sorted by their run version.
	// When a new run is created, the amount of completed runs will be garbage collected to the amount
	// +kubebuilder:default:=1
	// +kubebuilder:validation:Optional
	MaxPreviousRuns *int32 `json:"maxPreviousRuns,omitempty" protobuf:"varint,2,opt,name=maxPreviousRuns"`
	// Schedule specifies the schedule for the resource to create new runs
	// +kubebuilder:validation:Optional
	Schedule *RunSchedule `json:"schedule,omitempty" protobuf:"bytes,3,opt,name=schedule"`
}

RunSpec specifies the configuration for a run-producing resource

func (*RunSpec) DeepCopy added in v0.6.252 

func (in *RunSpec) DeepCopy() *RunSpec

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

func (*RunSpec) DeepCopyInto added in v0.6.252 

func (in *RunSpec) DeepCopyInto(out *RunSpec)

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

func (*RunSpec) Descriptor added in v0.6.252 

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

func (*RunSpec) Get added in v0.6.310 

func (spec *RunSpec) Get() RunSpec

func (*RunSpec) Marshal added in v0.6.252 

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

func (*RunSpec) MarshalTo added in v0.6.252 

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

func (*RunSpec) MarshalToSizedBuffer added in v0.6.252 

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

func (*RunSpec) ProtoMessage added in v0.6.252 

func (*RunSpec) ProtoMessage()

func (*RunSpec) Reset added in v0.6.252 

func (m *RunSpec) Reset()

func (*RunSpec) Size added in v0.6.252 

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

func (*RunSpec) String added in v0.6.252 

func (this *RunSpec) String() string

func (*RunSpec) Unmarshal added in v0.6.252 

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

func (*RunSpec) XXX_DiscardUnknown added in v0.6.252 

func (m *RunSpec) XXX_DiscardUnknown()

func (*RunSpec) XXX_Marshal added in v0.6.252 

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

func (*RunSpec) XXX_Merge added in v0.6.252 

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

func (*RunSpec) XXX_Size added in v0.6.252 

func (m *RunSpec) XXX_Size() int

func (*RunSpec) XXX_Unmarshal added in v0.6.252 

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

type SamplingType 

type SamplingType string

SamplingType defines how a dataset is sampled +kubebuilder:validation:Enum="header";"random";"stratified" 

const (
	Header     SamplingType = "header"
	Random     SamplingType = "random"
	Stratified SamplingType = "stratified"
)

type Scaling 

type Scaling string

+kubebuilder:validation:Enum="standard-scaling";"max-abs-scaling";"min-max-scaling";"normalization-scaling";"robust-scaling";"scale-to-unit-norm";"none";"auto"; 

const (
	StandardScaling        Scaling = "standard-scaling"
	MaxAbsScaling          Scaling = "max-abs-scaling"
	MinMaxScaling          Scaling = "min-max-scaling"
	Normalization          Scaling = "normalization-scaling"
	RobustScaling          Scaling = "robust-scaling"
	ScaleToUnitNormScaling Scaling = "scale-to-unit-norm"
	NoneScaling            Scaling = "none"
	AutoScaling            Scaling = "auto"
)

type SeasonalityMode 

type SeasonalityMode string

+kubebuilder:validation:Enum="multipicative";"additive";"auto";"none" 

const (
	MultiplicativeSeasonalityMode SeasonalityMode = "multiplicative"
	AdditiveSeasonalityMode       SeasonalityMode = "additive"
	AutoSeasonalityMode           SeasonalityMode = "auto"
	NoneSeasonalityMode           SeasonalityMode = "none"
)

type SecretKeyName added in v0.6.252 

type SecretKeyName string

SecretKeyName is the secret or in env variable +kubebuilder:validation:Enum="provider";"keyfile";"accessKey";"secretKey";"host";"token";"username";"password";"port";"ssh";"openstack-authurl" 

const (
	SecretKeyNameProvider         SecretKeyName = "provider"
	SecretKeyNameKeyFile          SecretKeyName = "keyfile"
	SecretKeyNameAccessKey        SecretKeyName = "accessKey"
	SecretKeyNameSecretKey        SecretKeyName = "secretKey"
	SecretKeyNameHost             SecretKeyName = "host"
	SecretKeyNameToken            SecretKeyName = "token"
	SecretKeyNameApiKey           SecretKeyName = "apikey"
	SecretKeyNameUsername         SecretKeyName = "username"
	SecretKeyNamePassword         SecretKeyName = "password"
	SecretKeyNameURL              SecretKeyName = "url"
	SecretKeyNamePort             SecretKeyName = "port"
	SecretKeyNameDatabase         SecretKeyName = "database"
	SecretKeyNameSsh              SecretKeyName = "ssh"
	SecretKeyNameOpenstackAuthUrl SecretKeyName = "openstack-authurl"
)

func (SecretKeyName) AsCliOption added in v0.6.252 

func (ak SecretKeyName) AsCliOption() string

type ServingSiteStage added in v0.5.553 

type ServingSiteStage string
const (
	DevServingSiteType   ServingSiteStage = "dev"
	ProdServingSiteType  ServingSiteStage = "prod"
	StageServingSiteType ServingSiteStage = "stage"
)

type ShapType added in v0.4.400 

type ShapType string

============================================================================== Shap methods ============================================================================== +kubebuilder:validation:Enum="permutation";"partition";"tree";"kernel";"sampling";"linear";"deep";"gradient";"auto";"none" 

const (
	ShapTypePermutation ShapType = "permutation"
	ShapTypePaartition  ShapType = "partition"
	ShapTypeTree        ShapType = "tree"
	ShapTypeKernel      ShapType = "kernel"
	ShapTypeSampling    ShapType = "sampling"
	ShapTypeLinear      ShapType = "linear"
	ShapTypeDeep        ShapType = "deep"
	ShapTypeGradient    ShapType = "gradient"
	ShapTypeAuto        ShapType = "auto"
	ShapTypeNone        ShapType = "none"
)

type SnapshotReference added in v0.6.252 

type SnapshotReference struct {
	// The name of the Dataset which the snapshot belongs to
	Dataset string `json:"dataset,omitempty" protobuf:"bytes,1,opt,name=dataset"`
	// The version of the snapshot to use. If empty, the latest available snapshot will be used
	Version *Version `json:"version,omitempty" protobuf:"varint,2,opt,name=version"`
	// The name of a Dataset Snapshot resource. When specified, takes precedence over Dataset
	Name *string `json:"name,omitempty" protobuf:"varint,3,opt,name=name"`
}

SnapshotReference defines a reference to a specific snapshot for a Dataset

func (*SnapshotReference) DeepCopy added in v0.6.252 

func (in *SnapshotReference) DeepCopy() *SnapshotReference

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

func (*SnapshotReference) DeepCopyInto added in v0.6.252 

func (in *SnapshotReference) DeepCopyInto(out *SnapshotReference)

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

func (*SnapshotReference) Descriptor added in v0.6.252 

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

func (*SnapshotReference) Marshal added in v0.6.252 

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

func (*SnapshotReference) MarshalTo added in v0.6.252 

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

func (*SnapshotReference) MarshalToSizedBuffer added in v0.6.252 

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

func (*SnapshotReference) ProtoMessage added in v0.6.252 

func (*SnapshotReference) ProtoMessage()

func (*SnapshotReference) Reset added in v0.6.252 

func (m *SnapshotReference) Reset()

func (*SnapshotReference) Size added in v0.6.252 

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

func (*SnapshotReference) String added in v0.6.252 

func (this *SnapshotReference) String() string

func (*SnapshotReference) Unmarshal added in v0.6.252 

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

func (*SnapshotReference) XXX_DiscardUnknown added in v0.6.252 

func (m *SnapshotReference) XXX_DiscardUnknown()

func (*SnapshotReference) XXX_Marshal added in v0.6.252 

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

func (*SnapshotReference) XXX_Merge added in v0.6.252 

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

func (*SnapshotReference) XXX_Size added in v0.6.252 

func (m *SnapshotReference) XXX_Size() int

func (*SnapshotReference) XXX_Unmarshal added in v0.6.252 

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

type StatusError added in v0.4.451 

type StatusError string
const (
	InvalidConfigurationError  StatusError = "InvalidConfiguration"
	InsufficientResourcesError StatusError = "InsufficientResources"
	CreateError                StatusError = "CreateError"
	UpdateError                StatusError = "UpdateError"
	DeleteError                StatusError = "DeleteError"
)

type StudyRunReference added in v0.6.252 

type StudyRunReference struct {
	// The name of the Study which the run belongs to
	Study string `json:"study,omitempty" protobuf:"bytes,1,opt,name=study"`
	// The version of the run to use. If empty, the latest available run will be used
	Version *Version `json:"version,omitempty" protobuf:"varint,2,opt,name=version"`
	// The name of a Study Run resource. When specified, takes precedence over Study
	Name *string `json:"name,omitempty" protobuf:"varint,3,opt,name=name"`
}

StudyRunReference defines a reference to a specific run for a Study

func (*StudyRunReference) DeepCopy added in v0.6.252 

func (in *StudyRunReference) DeepCopy() *StudyRunReference

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

func (*StudyRunReference) DeepCopyInto added in v0.6.252 

func (in *StudyRunReference) DeepCopyInto(out *StudyRunReference)

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

func (*StudyRunReference) Descriptor added in v0.6.252 

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

func (*StudyRunReference) Marshal added in v0.6.252 

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

func (*StudyRunReference) MarshalTo added in v0.6.252 

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

func (*StudyRunReference) MarshalToSizedBuffer added in v0.6.252 

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

func (*StudyRunReference) ProtoMessage added in v0.6.252 

func (*StudyRunReference) ProtoMessage()

func (*StudyRunReference) Reset added in v0.6.252 

func (m *StudyRunReference) Reset()

func (*StudyRunReference) Size added in v0.6.252 

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

func (*StudyRunReference) String added in v0.6.252 

func (this *StudyRunReference) String() string

func (*StudyRunReference) Unmarshal added in v0.6.252 

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

func (*StudyRunReference) XXX_DiscardUnknown added in v0.6.252 

func (m *StudyRunReference) XXX_DiscardUnknown()

func (*StudyRunReference) XXX_Marshal added in v0.6.252 

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

func (*StudyRunReference) XXX_Merge added in v0.6.252 

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

func (*StudyRunReference) XXX_Size added in v0.6.252 

func (m *StudyRunReference) XXX_Size() int

func (*StudyRunReference) XXX_Unmarshal added in v0.6.252 

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

type TaskName 

type TaskName string
const (
	BatchPredictTask             TaskName = "batch-predict"
	BatchPredictMCTask           TaskName = "batch-predict-multi-class"
	ForecastTask                 TaskName = "forecast"
	ProfileDatasetTask           TaskName = "profile-dataset"
	SnapshotDatasetTask          TaskName = "snapshot-dataset"
	ProfileStudyTask             TaskName = "profile-study"
	ProfileModelTask             TaskName = "profile-model"
	PublishModelTask             TaskName = "publish-model"
	BakeModelTask                TaskName = "bake-model"
	RunRecipeTask                TaskName = "run-recipe"
	ReportDatasetTask            TaskName = "report-dataset"
	ReportModelTask              TaskName = "report-model"
	ReportStudyTask              TaskName = "report-study"
	ReportPeriodTask             TaskName = "report-period"
	ReportSummaryTask            TaskName = "report-summary"
	SplitDatasetTask             TaskName = "split-dataset"
	TestEnsembleTask             TaskName = "test-ensemble"
	TestModelTask                TaskName = "test-model"
	TrainEnsembleTask            TaskName = "train-ensemble"
	TrainModelTask               TaskName = "train-model"
	MergeForecastTask            TaskName = "merge-forecast"
	PartitionForecastTask        TaskName = "partition-forecast"
	SplitDatasetToRungsTask      TaskName = "split-dataset-to-rungs"
	TransformDatasetTask         TaskName = "transform-dataset"
	CompileTask                  TaskName = "compile-model"
	PackageModelTask             TaskName = "package-model"
	ExplainModelTask             TaskName = "explain-model"
	FeatureGenTask               TaskName = "feature-gen"
	FeatureSelectTask            TaskName = "feature-select"
	RunSqlQueryTask              TaskName = "run-sql-query"
	RunWebRequestTask            TaskName = "run-web-request"
	GenerateDatasetTask          TaskName = "generate-dataset"
	UnitTestDatasetTask          TaskName = "unittest-dataset"
	UnitTestModelTask            TaskName = "unittest-model"
	UnitTestFeedbackTask         TaskName = "unittest-feedback"
	UnitTestFeatureHistogramTask TaskName = "unittest-feature-histogram"
	UnitTestPredictorTask        TaskName = "unittest-predictor"
	TrainDriftDetectorTask       TaskName = "train-drift-detector"
	PartitionDatasetTask         TaskName = "partition-dataset"
	ProfilePartitionDatasetTask  TaskName = "profile-partition-dataset"
	ProfilePartitionModelTask    TaskName = "profile-partition-model"
	ReportPartitionDatasetTask   TaskName = "report-partition-dataset"
	ReportPartitionModelTask     TaskName = "report-partition-model"
	TrainPartitionModelTask      TaskName = "train-partition-model"
	UnitTestPartitionDatasetTask TaskName = "unittest-partition-dataset"
	SplitPartitionTask           TaskName = "split-partition"
	GenerateOnlineTableTask      TaskName = "gen-online-table"  //
	SyncOnlineTableTask          TaskName = "sync-online-table" // sync the online dataset into the store.
	IngestFeatureGroupTask       TaskName = "ingest-feature-group"
	GenTrainingDatasetTask       TaskName = "gen-training-dataset"

	RefreshKnowledgeBaseTask  TaskName = "refresh-knowledgebase"
	TeardownKnowledgeBaseTask TaskName = "teardown-knowledgebase"
)

type TestSuite added in v0.4.933 

type TestSuite struct {
	// If false, this test case is disabled
	// +kubebuilder:validation:Optional
	Enabled *bool `json:"enabled,omitempty" protobuf:"varint,1,opt,name=enabled"`
	// +kubebuilder:validation:Optional
	Tests []DataTestCase `json:"tests,omitempty" protobuf:"bytes,2,rep,name=tests"`
}

func (*TestSuite) DeepCopy added in v0.4.933 

func (in *TestSuite) DeepCopy() *TestSuite

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

func (*TestSuite) DeepCopyInto added in v0.4.933 

func (in *TestSuite) DeepCopyInto(out *TestSuite)

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

func (*TestSuite) Descriptor added in v0.4.933 

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

func (*TestSuite) Marshal added in v0.4.933 

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

func (*TestSuite) MarshalTo added in v0.4.933 

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

func (*TestSuite) MarshalToSizedBuffer added in v0.4.933 

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

func (*TestSuite) ProtoMessage added in v0.4.933 

func (*TestSuite) ProtoMessage()

func (*TestSuite) Reset added in v0.4.933 

func (m *TestSuite) Reset()

func (*TestSuite) Size added in v0.4.933 

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

func (*TestSuite) String added in v0.4.933 

func (this *TestSuite) String() string

func (*TestSuite) Unmarshal added in v0.4.933 

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

func (*TestSuite) XXX_DiscardUnknown added in v0.4.933 

func (m *TestSuite) XXX_DiscardUnknown()

func (*TestSuite) XXX_Marshal added in v0.4.933 

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

func (*TestSuite) XXX_Merge added in v0.4.933 

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

func (*TestSuite) XXX_Size added in v0.4.933 

func (m *TestSuite) XXX_Size() int

func (*TestSuite) XXX_Unmarshal added in v0.4.933 

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

type TestSuiteResult added in v0.4.933 

type TestSuiteResult struct {
	// A reference to the object under test. Best practice is to have one suite for an object
	// +kubebuilder:validation:Optional
	EntityRef v1.ObjectReference `json:"entityRef,omitempty" protobuf:"bytes,1,opt,name=entityRef"`
	// Total number of failures. A failure is an unplanned error, e.g. cannot connect to a dataset
	// +kubebuilder:validation:Optional
	Failures int32 `json:"failures,omitempty" protobuf:"varint,2,opt,name=failures"`
	// Total number of assertion errors.
	// +kubebuilder:validation:Optional
	Errors int32 `json:"errors,omitempty" protobuf:"varint,3,opt,name=errors"`
	// Start time of running the suite
	// +kubebuilder:validation:Optional
	StartedAt *metav1.Time `json:"startedAt,omitempty" protobuf:"bytes,4,opt,name=startedAt"`
	// Stop time of running the suite.
	// +kubebuilder:validation:Optional
	CompletedAt *metav1.Time `json:"completedAt,omitempty" protobuf:"bytes,5,opt,name=completedAt"`
	// The result of executing the test suite. The result contain one result object per test case.
	// +kubebuilder:validation:Optional
	Tests []DataTestCaseResult `json:"tests,omitempty" protobuf:"bytes,6,rep,name=tests"`
}

func (*TestSuiteResult) DeepCopy added in v0.4.933 

func (in *TestSuiteResult) DeepCopy() *TestSuiteResult

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

func (*TestSuiteResult) DeepCopyInto added in v0.4.933 

func (in *TestSuiteResult) DeepCopyInto(out *TestSuiteResult)

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

func (*TestSuiteResult) Descriptor added in v0.4.933 

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

func (*TestSuiteResult) Marshal added in v0.4.933 

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

func (*TestSuiteResult) MarshalTo added in v0.4.933 

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

func (*TestSuiteResult) MarshalToSizedBuffer added in v0.4.933 

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

func (*TestSuiteResult) ProtoMessage added in v0.4.933 

func (*TestSuiteResult) ProtoMessage()

func (*TestSuiteResult) Reset added in v0.4.933 

func (m *TestSuiteResult) Reset()

func (*TestSuiteResult) Size added in v0.4.933 

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

func (*TestSuiteResult) String added in v0.4.933 

func (this *TestSuiteResult) String() string

func (*TestSuiteResult) Unmarshal added in v0.4.933 

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

func (*TestSuiteResult) XXX_DiscardUnknown added in v0.4.933 

func (m *TestSuiteResult) XXX_DiscardUnknown()

func (*TestSuiteResult) XXX_Marshal added in v0.4.933 

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

func (*TestSuiteResult) XXX_Merge added in v0.4.933 

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

func (*TestSuiteResult) XXX_Size added in v0.4.933 

func (m *TestSuiteResult) XXX_Size() int

func (*TestSuiteResult) XXX_Unmarshal added in v0.4.933 

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

type TextEncoding 

type TextEncoding string

+kubebuilder:validation:Enum="tfidf";"count-vec";"hasing-vec";"none";"auto" 

const (
	TfIdfTextEncding              TextEncoding = "tfidf"
	CountVectorizerTextEncoding   TextEncoding = "count-vec"
	HashingVectorizerTextEncoding TextEncoding = "hashing-vec"
	NoneTextEncoding              TextEncoding = "none"
	AutoTextEncoding              TextEncoding = "auto"
)

type TimeSeriesType added in v0.5.124 

type TimeSeriesType string

+kubebuilder:validation:Enum="series";"panel";"hierarchical" 

const (
	TimeSeriesTypeSeries       TimeSeriesType = "series"
	TimeSeriesTypePanel        TimeSeriesType = "panel"
	TimeSeriesTypeHierarchical TimeSeriesType = "hierarchical"
)

type TriggerScheduleEventType 

type TriggerScheduleEventType string

+kubebuilder:validation:Enum="hourly";"daily";"weekly";"monthly";"cron" 

const (
	HourlyTriggerScheduleEventType  TriggerScheduleEventType = "hourly"
	DailyTriggerScheduleEventType   TriggerScheduleEventType = "daily"
	WeeklyTriggerScheduleEventType  TriggerScheduleEventType = "weekly"
	MonthlyTriggerScheduleEventType TriggerScheduleEventType = "monthly"
	CronTriggerScheduleEventType    TriggerScheduleEventType = "cron"
)

type TriggerType 

type TriggerType string

+kubebuilder:validation:Enum="on-demand";"on-schedule";"on-new-data";"on-github-event";"on-concept-drift";"on-perf-degradation" 

const (
	OnDemandTriggerType        TriggerType = "on-demand"
	ScheduleTriggerType        TriggerType = "on-schedule"
	NewDataTriggerType         TriggerType = "on-new-data"
	GithubEventTriggerType     TriggerType = "on-github-event"
	ConceptDriftTriggerType    TriggerType = "on-concept-drift"
	PerfDegragationTriggerType TriggerType = "on-perf-degradation"
)

type UpdateStrategy 

type UpdateStrategy string

UpdateUpdateStrategy strategy is a dataset update strategy +kubebuilder:validation:Enum="upsert";"insert";"update" 

const (
	UpsertUpdateStrategy UpdateStrategy = "upsert"
	InsertUpdateStrategy UpdateStrategy = "insert"
	UpdateUpdateStrategy UpdateStrategy = "update"
)

type VariableTransformation 

type VariableTransformation string

+kubebuilder:validation:Enum="log-transformation";"reciprocal-transformation";"sqrt-transformation";"power-transformation";"box-cox-transformation";"yj-transformation";"none";"auto" 

const (
	LogVariableTransformation VariableTransformation = "log-transformation"
	ReciprocalTransformation  VariableTransformation = "reciprocal-transformation"
	SqrtTransformation        VariableTransformation = "sqrt-transformation"
	PowerTransformation       VariableTransformation = "power-transformation"
	BoxCoxTransformation      VariableTransformation = "box-cox-transformation"
	YeoJohnsonTransformation  VariableTransformation = "yj-transformation"
	NoneTransform             VariableTransformation = "none"
	AutoTransform             VariableTransformation = "auto"
)

type Version added in v0.6.252 

type Version uint32

Version specifies the numerical version of a resource

func (*Version) Value added in v0.6.252 

func (v *Version) Value() Version

type VersionList added in v0.6.252 

type VersionList []Version

func (VersionList) DeepCopy added in v0.6.252 

func (in VersionList) DeepCopy() VersionList

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

func (VersionList) DeepCopyInto added in v0.6.252 

func (in VersionList) DeepCopyInto(out *VersionList)

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

func (VersionList) RecordVersion added in v0.6.252 

func (v VersionList) RecordVersion(version Version, shouldExist bool) VersionList

type VideoFeaturizer 

type VideoFeaturizer string

type WebHookNameAndAction 

type WebHookNameAndAction string

WebHookNameAndAction Contain the event and the action +kubebuilder:validation:Enum="commit";"pull_request_assigned";"pull_request_unsassigned";"pull_request_labeled";"pull_request_unlabeled";"pull_request_opened";"pull_request_edited";"pull_request_closed";"pull_request_reopened";"pull_request_synchronized";"pull_request_all";"notsupported" 

const (
	CommitEvent             WebHookNameAndAction = "commit"
	PullRequestassigned     WebHookNameAndAction = "pull_request_assigned"
	PullRequestUnassigned   WebHookNameAndAction = "pull_request_unassigned"
	PullRequestLabeled      WebHookNameAndAction = "pull_request_labeled"
	PullRequestUnlabeled    WebHookNameAndAction = "pull_request_unlabeled"
	PullRequestOpened       WebHookNameAndAction = "pull_request_opened"
	PullRequestEdited       WebHookNameAndAction = "pull_request_edited"
	PullRequestClosed       WebHookNameAndAction = "pull_request_closed"
	PullRequestReopened     WebHookNameAndAction = "pull_request_reopened"
	PullRequestSynchronized WebHookNameAndAction = "pull_request_synchronized"
	AnyPullRequest          WebHookNameAndAction = "pull_request_all"
	NotSupported            WebHookNameAndAction = "notsupported"
)

type WebLocation added in v0.6.310 

type WebLocation struct {
	// The internet-accessible URL of a file to download
	// +kubebuilder:default:=""
	// +kubebuilder:validation:Optional
	URL string `json:"url,omitempty" protobuf:"bytes,1,opt,name=url"`
}

func (*WebLocation) DeepCopy added in v0.6.310 

func (in *WebLocation) DeepCopy() *WebLocation

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

func (*WebLocation) DeepCopyInto added in v0.6.310 

func (in *WebLocation) DeepCopyInto(out *WebLocation)

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

func (*WebLocation) Descriptor added in v0.6.310 

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

func (*WebLocation) Marshal added in v0.6.310 

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

func (*WebLocation) MarshalTo added in v0.6.310 

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

func (*WebLocation) MarshalToSizedBuffer added in v0.6.310 

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

func (*WebLocation) ProtoMessage added in v0.6.310 

func (*WebLocation) ProtoMessage()

func (*WebLocation) Reset added in v0.6.310 

func (m *WebLocation) Reset()

func (*WebLocation) Size added in v0.6.310 

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

func (*WebLocation) String added in v0.6.310 

func (this *WebLocation) String() string

func (*WebLocation) Unmarshal added in v0.6.310 

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

func (*WebLocation) XXX_DiscardUnknown added in v0.6.310 

func (m *WebLocation) XXX_DiscardUnknown()

func (*WebLocation) XXX_Marshal added in v0.6.310 

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

func (*WebLocation) XXX_Merge added in v0.6.310 

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

func (*WebLocation) XXX_Size added in v0.6.310 

func (m *WebLocation) XXX_Size() int

func (*WebLocation) XXX_Unmarshal added in v0.6.310 

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

type WorkerRunResult added in v0.5.182 

type WorkerRunResult struct {
	// Worker ID
	// +kubebuilder:validation:Optional
	ID int32 `json:"id,omitempty" protobuf:"bytes,1,opt,name=id"`
	// URI
	// +kubebuilder:validation:Optional
	URI string `json:"uri,omitempty" protobuf:"bytes,2,opt,name=uri"`

	// +kubebuilder:validation:Optional
	Task TaskName `json:"task,omitempty" protobuf:"bytes,3,opt,name=task"`

	// +kubebuilder:validation:Optional
	Error string `json:"error,omitempty" protobuf:"bytes,4,opt,name=error"`
}

func AddOrUpdateWorkerResult added in v0.5.187 

func AddOrUpdateWorkerResult(results []WorkerRunResult, task TaskName, workerID int32, URI string, error string) []WorkerRunResult

add or update the worker result

func FilterWorkerResult added in v0.5.189 

func FilterWorkerResult(runs []WorkerRunResult, task TaskName) []WorkerRunResult

return only the worker result for the task.

func (*WorkerRunResult) DeepCopy added in v0.5.183 

func (in *WorkerRunResult) DeepCopy() *WorkerRunResult

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

func (*WorkerRunResult) DeepCopyInto added in v0.5.183 

func (in *WorkerRunResult) DeepCopyInto(out *WorkerRunResult)

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

func (*WorkerRunResult) Descriptor added in v0.5.182 

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

func (*WorkerRunResult) Marshal added in v0.5.182 

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

func (*WorkerRunResult) MarshalTo added in v0.5.182 

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

func (*WorkerRunResult) MarshalToSizedBuffer added in v0.5.182 

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

func (*WorkerRunResult) ProtoMessage added in v0.5.182 

func (*WorkerRunResult) ProtoMessage()

func (*WorkerRunResult) Reset added in v0.5.182 

func (m *WorkerRunResult) Reset()

func (*WorkerRunResult) Size added in v0.5.182 

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

func (*WorkerRunResult) String added in v0.5.182 

func (this *WorkerRunResult) String() string

func (*WorkerRunResult) Unmarshal added in v0.5.182 

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

func (*WorkerRunResult) XXX_DiscardUnknown added in v0.5.182 

func (m *WorkerRunResult) XXX_DiscardUnknown()

func (*WorkerRunResult) XXX_Marshal added in v0.5.182 

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

func (*WorkerRunResult) XXX_Merge added in v0.5.182 

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

func (*WorkerRunResult) XXX_Size added in v0.5.182 

func (m *WorkerRunResult) XXX_Size() int

func (*WorkerRunResult) XXX_Unmarshal added in v0.5.182 

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

type WorkloadClass 

type WorkloadClass struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`
	Spec              WorkloadClassSpec `json:"spec" protobuf:"bytes,2,opt,name=spec"`
}

+genclient +kubebuilder:object:root=true +kubebuilder:resource:path=workloadclasses,singular=workloadclass,categories={catalog,modela,all} +kubebuilder:storageversion +kubebuilder:printcolumn:name="Age",type=date,JSONPath=`.metadata.creationTimestamp` WorkloadClass define a template for a job.

func ParseWorkloadClassYaml 

func ParseWorkloadClassYaml(content []byte) (*WorkloadClass, error)

func (*WorkloadClass) DeepCopy 

func (in *WorkloadClass) DeepCopy() *WorkloadClass

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

func (*WorkloadClass) DeepCopyInto 

func (in *WorkloadClass) DeepCopyInto(out *WorkloadClass)

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

func (*WorkloadClass) DeepCopyObject 

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

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

func (*WorkloadClass) Descriptor 

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

func (*WorkloadClass) Marshal 

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

func (*WorkloadClass) MarshalTo 

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

func (*WorkloadClass) MarshalToSizedBuffer 

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

func (*WorkloadClass) PodName 

func (tclass *WorkloadClass) PodName() string

func (*WorkloadClass) ProtoMessage 

func (*WorkloadClass) ProtoMessage()

func (*WorkloadClass) RepEntry 

func (tclass *WorkloadClass) RepEntry() (string, error)

func (*WorkloadClass) RepPath 

func (tclass *WorkloadClass) RepPath(root string) (string, error)

Return the on disk rep location

func (*WorkloadClass) Reset 

func (m *WorkloadClass) Reset()

func (*WorkloadClass) Size 

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

func (*WorkloadClass) String 

func (this *WorkloadClass) String() string

func (*WorkloadClass) Unmarshal 

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

func (*WorkloadClass) Validate 

func (tclass *WorkloadClass) Validate() (bool, field.ErrorList)

func (*WorkloadClass) ValidateCreate 

func (tclass *WorkloadClass) ValidateCreate() error

ValidateCreate implements webhook.Validator so a webhook will be registered for the type

func (*WorkloadClass) ValidateDelete 

func (tclass *WorkloadClass) ValidateDelete() error

func (*WorkloadClass) ValidateUpdate 

func (tclass *WorkloadClass) ValidateUpdate(old runtime.Object) error

ValidateUpdate implements webhook.Validator so a webhook will be registered for the type

func (*WorkloadClass) XXX_DiscardUnknown 

func (m *WorkloadClass) XXX_DiscardUnknown()

func (*WorkloadClass) XXX_Marshal 

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

func (*WorkloadClass) XXX_Merge 

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

func (*WorkloadClass) XXX_Size 

func (m *WorkloadClass) XXX_Size() int

func (*WorkloadClass) XXX_Unmarshal 

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

type WorkloadClassList 

type WorkloadClassList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata" protobuf:"bytes,1,opt,name=metadata"`
	Items           []WorkloadClass `json:"items" protobuf:"bytes,2,rep,name=items"`
}

+kubebuilder:object:root=true TrainerList contains a list of Trainer

func (*WorkloadClassList) DeepCopy 

func (in *WorkloadClassList) DeepCopy() *WorkloadClassList

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

func (*WorkloadClassList) DeepCopyInto 

func (in *WorkloadClassList) DeepCopyInto(out *WorkloadClassList)

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

func (*WorkloadClassList) DeepCopyObject 

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

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

func (*WorkloadClassList) Descriptor 

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

func (*WorkloadClassList) Marshal 

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

func (*WorkloadClassList) MarshalTo 

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

func (*WorkloadClassList) MarshalToSizedBuffer 

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

func (*WorkloadClassList) ProtoMessage 

func (*WorkloadClassList) ProtoMessage()

func (*WorkloadClassList) Reset 

func (m *WorkloadClassList) Reset()

func (*WorkloadClassList) Size 

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

func (*WorkloadClassList) String 

func (this *WorkloadClassList) String() string

func (*WorkloadClassList) Unmarshal 

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

func (*WorkloadClassList) XXX_DiscardUnknown 

func (m *WorkloadClassList) XXX_DiscardUnknown()

func (*WorkloadClassList) XXX_Marshal 

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

func (*WorkloadClassList) XXX_Merge 

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

func (*WorkloadClassList) XXX_Size 

func (m *WorkloadClassList) XXX_Size() int

func (*WorkloadClassList) XXX_Unmarshal 

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

type WorkloadClassSpec 

type WorkloadClassSpec struct {
	ResourcesTemplate *ResourceSpec `json:"resourcesTemplate,omitempty" protobuf:"bytes,1,opt,name=resourcesTemplate"`
}

WorkloadClassSpec defines the specification of a workload class.

func (*WorkloadClassSpec) DeepCopy 

func (in *WorkloadClassSpec) DeepCopy() *WorkloadClassSpec

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

func (*WorkloadClassSpec) DeepCopyInto 

func (in *WorkloadClassSpec) DeepCopyInto(out *WorkloadClassSpec)

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

func (*WorkloadClassSpec) Descriptor 

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

func (*WorkloadClassSpec) Marshal 

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

func (*WorkloadClassSpec) MarshalTo 

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

func (*WorkloadClassSpec) MarshalToSizedBuffer 

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

func (*WorkloadClassSpec) ProtoMessage 

func (*WorkloadClassSpec) ProtoMessage()

func (*WorkloadClassSpec) Reset 

func (m *WorkloadClassSpec) Reset()

func (*WorkloadClassSpec) Size 

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

func (*WorkloadClassSpec) String 

func (this *WorkloadClassSpec) String() string

func (*WorkloadClassSpec) Unmarshal 

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

func (*WorkloadClassSpec) XXX_DiscardUnknown 

func (m *WorkloadClassSpec) XXX_DiscardUnknown()

func (*WorkloadClassSpec) XXX_Marshal 

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

func (*WorkloadClassSpec) XXX_Merge 

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

func (*WorkloadClassSpec) XXX_Size 

func (m *WorkloadClassSpec) XXX_Size() int

func (*WorkloadClassSpec) XXX_Unmarshal 

func (m *WorkloadClassSpec) 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.