v1alpha1

package
v0.5.479 Latest Latest
Warning

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

 Go to latest Published: Dec 5, 2022 License: Apache-2.0 Imports: 28 Imported by: 0

Documentation

Overview

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

Index

Constants

View Source 
const PipelineLabelKey = "pipeline"

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 registers our types
	SchemeBuilder = k8sruntime.NewSchemeBuilder(AddKnownTypes)
	// AddToScheme local alias for SchemeBuilder.AddToScheme
	AddToScheme = SchemeBuilder.AddToScheme
)
View Source 
var SchemeGroupVersion = schema.GroupVersion{Group: inference.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 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 AutoScalingSpec added in v0.4.878 

type AutoScalingSpec struct {
	// Indicates if automatic scaling is enabled
	// +kubebuilder:default:=false
	// +kubebuilder:validation:Optional
	Enabled *bool `json:"enabled,omitempty" protobuf:"varint,1,opt,name=enabled"`
	// The minimum number of replicas running the service
	// +kubebuilder:validation:Optional
	// +kubebuilder:validation:Minimum=1
	// +kubebuilder:default:=1
	MinReplicas *int32 `json:"minReplicas,omitempty" protobuf:"varint,2,opt,name=minReplicas"`
	// The maximum number of replicas running the service
	// +kubebuilder:validation:Optional
	// +kubebuilder:validation:Minimum=1
	// +kubebuilder:validation:Maximum=10
	// +kubebuilder:default:=1
	MaxReplicas *int32 `json:"maxReplicas,omitempty" protobuf:"varint,3,opt,name=maxReplicas"`
	// The target average CPU utilization across all replicas. The HorizontalPodAutoscaler associated with the
	// service will change the number of replicas to maintain this metric
	// +kubebuilder:validation:Optional
	// +kubebuilder:validation:Minimum=1
	// +kubebuilder:validation:Maximum=100
	// +kubebuilder:default:=80
	CpuAvgUtilization *int32 `json:"cpuAvgUtilization,omitempty" protobuf:"varint,4,opt,name=cpuAvgUtilization"`
	// The target average memory utilization across all replicas. The HorizontalPodAutoscaler associated with the
	// service will change the number of replicas to maintain this metric
	// +kubebuilder:validation:Optional
	// +kubebuilder:validation:Minimum=1
	// +kubebuilder:validation:Maximum=100
	// +kubebuilder:default:=80
	MemAvgUtilization *int32 `json:"memAvgUtilization,omitempty" protobuf:"varint,5,opt,name=memAvgUtilization"`
}

AutoScaling defines the configuration for the automatic scaling of a service

func (*AutoScalingSpec) DeepCopy added in v0.4.878 

func (in *AutoScalingSpec) DeepCopy() *AutoScalingSpec

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

func (*AutoScalingSpec) DeepCopyInto added in v0.4.878 

func (in *AutoScalingSpec) DeepCopyInto(out *AutoScalingSpec)

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

func (*AutoScalingSpec) Descriptor added in v0.4.878 

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

func (*AutoScalingSpec) Marshal added in v0.4.878 

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

func (*AutoScalingSpec) MarshalTo added in v0.4.878 

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

func (*AutoScalingSpec) MarshalToSizedBuffer added in v0.4.878 

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

func (*AutoScalingSpec) ProtoMessage added in v0.4.878 

func (*AutoScalingSpec) ProtoMessage()

func (*AutoScalingSpec) Reset added in v0.4.878 

func (m *AutoScalingSpec) Reset()

func (*AutoScalingSpec) Size added in v0.4.878 

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

func (*AutoScalingSpec) String added in v0.4.878 

func (this *AutoScalingSpec) String() string

func (*AutoScalingSpec) Unmarshal added in v0.4.878 

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

func (*AutoScalingSpec) XXX_DiscardUnknown added in v0.4.878 

func (m *AutoScalingSpec) XXX_DiscardUnknown()

func (*AutoScalingSpec) XXX_Marshal added in v0.4.878 

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

func (*AutoScalingSpec) XXX_Merge added in v0.4.878 

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

func (*AutoScalingSpec) XXX_Size added in v0.4.878 

func (m *AutoScalingSpec) XXX_Size() int

func (*AutoScalingSpec) XXX_Unmarshal added in v0.4.878 

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

type BackwardCurtainSpec added in v0.4.914 

type BackwardCurtainSpec struct {
	// +kubebuilder:default:=false
	// +kubebuilder:validation:Optional
	Enabled *bool `json:"enabled,omitempty" protobuf:"varint,1,opt,name=enabled"`
	// The forward curtain receives prediction requests before the prediction (currently unimplemented)
	// +kubebuilder:validation:Optional
	AccountRef *v1.ObjectReference `json:"accountRef,omitempty" protobuf:"bytes,2,opt,name=accountRef"`
	// For backward curtain is the confidence low
	// +kubebuilder:validation:Optional
	ConfidenceLow *float64 `json:"confidenceLow,omitempty" protobuf:"bytes,4,opt,name=confidenceLow"`
	// For backward curtain is the confidence high
	// +kubebuilder:validation:Optional
	ConfidenceHigh *float64 `json:"confidenceHigh,omitempty" protobuf:"bytes,5,opt,name=confidenceHigh"`
}

func (*BackwardCurtainSpec) DeepCopy added in v0.4.915 

func (in *BackwardCurtainSpec) DeepCopy() *BackwardCurtainSpec

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

func (*BackwardCurtainSpec) DeepCopyInto added in v0.4.915 

func (in *BackwardCurtainSpec) DeepCopyInto(out *BackwardCurtainSpec)

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

func (*BackwardCurtainSpec) Descriptor added in v0.4.914 

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

func (*BackwardCurtainSpec) Marshal added in v0.4.914 

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

func (*BackwardCurtainSpec) MarshalTo added in v0.4.914 

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

func (*BackwardCurtainSpec) MarshalToSizedBuffer added in v0.4.914 

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

func (*BackwardCurtainSpec) ProtoMessage added in v0.4.914 

func (*BackwardCurtainSpec) ProtoMessage()

func (*BackwardCurtainSpec) Reset added in v0.4.914 

func (m *BackwardCurtainSpec) Reset()

func (*BackwardCurtainSpec) Size added in v0.4.914 

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

func (*BackwardCurtainSpec) String added in v0.4.914 

func (this *BackwardCurtainSpec) String() string

func (*BackwardCurtainSpec) Unmarshal added in v0.4.914 

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

func (*BackwardCurtainSpec) XXX_DiscardUnknown added in v0.4.914 

func (m *BackwardCurtainSpec) XXX_DiscardUnknown()

func (*BackwardCurtainSpec) XXX_Marshal added in v0.4.914 

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

func (*BackwardCurtainSpec) XXX_Merge added in v0.4.914 

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

func (*BackwardCurtainSpec) XXX_Size added in v0.4.914 

func (m *BackwardCurtainSpec) XXX_Size() int

func (*BackwardCurtainSpec) XXX_Unmarshal added in v0.4.914 

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

type BatchPredictionSpec added in v0.5.282 

type BatchPredictionSpec struct {
	// The schedule at which new Prediction resources will be created
	// +kubebuilder:validation:Optional
	Schedule catalog.RunSchedule `json:"schedule,omitempty" protobuf:"bytes,1,opt,name=schedule"`
	// Template specifies the template to create new Prediction resources
	Template PredictionSpec `json:"template" protobuf:"bytes,2,opt,name=template"`
}

func (*BatchPredictionSpec) DeepCopy added in v0.5.283 

func (in *BatchPredictionSpec) DeepCopy() *BatchPredictionSpec

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

func (*BatchPredictionSpec) DeepCopyInto added in v0.5.283 

func (in *BatchPredictionSpec) DeepCopyInto(out *BatchPredictionSpec)

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

func (*BatchPredictionSpec) Descriptor added in v0.5.282 

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

func (*BatchPredictionSpec) Marshal added in v0.5.282 

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

func (*BatchPredictionSpec) MarshalTo added in v0.5.282 

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

func (*BatchPredictionSpec) MarshalToSizedBuffer added in v0.5.282 

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

func (*BatchPredictionSpec) ProtoMessage added in v0.5.282 

func (*BatchPredictionSpec) ProtoMessage()

func (*BatchPredictionSpec) Reset added in v0.5.282 

func (m *BatchPredictionSpec) Reset()

func (*BatchPredictionSpec) Size added in v0.5.282 

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

func (*BatchPredictionSpec) String added in v0.5.282 

func (this *BatchPredictionSpec) String() string

func (*BatchPredictionSpec) Unmarshal added in v0.5.282 

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

func (*BatchPredictionSpec) XXX_DiscardUnknown added in v0.5.282 

func (m *BatchPredictionSpec) XXX_DiscardUnknown()

func (*BatchPredictionSpec) XXX_Marshal added in v0.5.282 

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

func (*BatchPredictionSpec) XXX_Merge added in v0.5.282 

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

func (*BatchPredictionSpec) XXX_Size added in v0.5.282 

func (m *BatchPredictionSpec) XXX_Size() int

func (*BatchPredictionSpec) XXX_Unmarshal added in v0.5.282 

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

type CustomAppSpec 

type CustomAppSpec struct {
	// Indicates if custom pages are enabled
	// +kubebuilder:default:=false
	// +kubebuilder:validation:Optional
	Enabled *bool `json:"owner,omitempty" protobuf:"varint,1,opt,name=owner"`
	// The app title
	// +kubebuilder:default:=""
	// +kubebuilder:validation:Optional
	Title *string `json:"title,omitempty" protobuf:"bytes,2,opt,name=title"`
	// The app pages
	// +kubebuilder:validation:Optional
	Pages []data.PageSpec `json:"pages,omitempty" protobuf:"bytes,3,opt,name=pages"`
}

CustomAppSpec defines the custom pages for a DataApp

func (*CustomAppSpec) DeepCopy 

func (in *CustomAppSpec) DeepCopy() *CustomAppSpec

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

func (*CustomAppSpec) DeepCopyInto 

func (in *CustomAppSpec) DeepCopyInto(out *CustomAppSpec)

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

func (*CustomAppSpec) Descriptor 

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

func (*CustomAppSpec) Marshal 

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

func (*CustomAppSpec) MarshalTo 

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

func (*CustomAppSpec) MarshalToSizedBuffer 

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

func (*CustomAppSpec) ProtoMessage 

func (*CustomAppSpec) ProtoMessage()

func (*CustomAppSpec) Reset 

func (m *CustomAppSpec) Reset()

func (*CustomAppSpec) Size 

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

func (*CustomAppSpec) String 

func (this *CustomAppSpec) String() string

func (*CustomAppSpec) Unmarshal 

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

func (*CustomAppSpec) XXX_DiscardUnknown 

func (m *CustomAppSpec) XXX_DiscardUnknown()

func (*CustomAppSpec) XXX_Marshal 

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

func (*CustomAppSpec) XXX_Merge 

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

func (*CustomAppSpec) XXX_Size 

func (m *CustomAppSpec) XXX_Size() int

func (*CustomAppSpec) XXX_Unmarshal 

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

type DataApp 

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

+kubebuilder:object:root=true +kubebuilder:storageversion +kubebuilder:resource:path=dataapps,singular=dataapp,categories={data,modela} +kubebuilder:subresource:status +kubebuilder:printcolumn:name="Ready",type="string",JSONPath=".status.conditions[?(@.type==\"Ready\")].status",description="" +kubebuilder:printcolumn:name="Owner",type="string",JSONPath=".spec.owner" +kubebuilder:printcolumn:name="Version",type="string",JSONPath=".spec.versionName" +kubebuilder:printcolumn:name="Path",type="string",JSONPath=".spec.path" +kubebuilder:printcolumn:name="Model",type="string",JSONPath=".spec.modelName" +kubebuilder:printcolumn:name="Replicas",type="string",JSONPath=".spec.replicas" +kubebuilder:printcolumn:name="Port",type="string",JSONPath=".spec.port" +kubebuilder:printcolumn:name="Age",type="date",JSONPath=".metadata.creationTimestamp",description="" DataApp represents a live dashboard for a single model

func (*DataApp) AddFinalizer 

func (dataapp *DataApp) AddFinalizer()

func (DataApp) ConstructGrpcRule added in v0.4.693 

func (dataapp DataApp) ConstructGrpcRule(fqdn string, serviceName string) *nwv1.IngressRule

func (DataApp) ConstructRESTRule added in v0.4.693 

func (dataapp DataApp) ConstructRESTRule(fqdn string, serviceName string) *nwv1.IngressRule

func (*DataApp) CreateOrUpdateCond 

func (dataapp *DataApp) CreateOrUpdateCond(cond DataAppCondition)

Merge or update condition

func (*DataApp) DeepCopy 

func (in *DataApp) DeepCopy() *DataApp

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

func (*DataApp) DeepCopyInto 

func (in *DataApp) DeepCopyInto(out *DataApp)

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

func (*DataApp) DeepCopyObject 

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

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

func (DataApp) Default 

func (dataapp DataApp) Default()

func (DataApp) Deleted 

func (dataapp DataApp) Deleted() bool

func (*DataApp) Descriptor 

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

func (DataApp) GetCond 

func (dataapp DataApp) GetCond(t DataAppConditionType) DataAppCondition

func (*DataApp) GetCondIdx 

func (dataapp *DataApp) GetCondIdx(t DataAppConditionType) int

func (DataApp) HasFinalizer 

func (dataapp DataApp) HasFinalizer() bool

func (DataApp) IsFailed added in v0.4.675 

func (dataapp DataApp) IsFailed() bool

func (*DataApp) IsInCond 

func (dataapp *DataApp) IsInCond(ct DataAppConditionType) bool

func (DataApp) IsReady 

func (dataapp DataApp) IsReady() bool

func (DataApp) IsSaved 

func (dataapp DataApp) IsSaved() bool

func (*DataApp) MarkReady 

func (dataapp *DataApp) MarkReady()

func (*DataApp) MarkSaved 

func (dataapp *DataApp) MarkSaved()

func (*DataApp) Marshal 

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

func (*DataApp) MarshalTo 

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

func (*DataApp) MarshalToSizedBuffer 

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

func (*DataApp) Populate 

func (dataapp *DataApp) Populate(name string)

func (*DataApp) PrintConditions 

func (dataapp *DataApp) PrintConditions()

func (*DataApp) ProtoMessage 

func (*DataApp) ProtoMessage()

func (*DataApp) RemoveFinalizer 

func (dataapp *DataApp) RemoveFinalizer()

func (*DataApp) Reset 

func (m *DataApp) Reset()

func (*DataApp) SetupWebhookWithManager 

func (dataapp *DataApp) SetupWebhookWithManager(mgr ctrl.Manager) error

func (*DataApp) Size 

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

func (*DataApp) String 

func (this *DataApp) String() string

func (*DataApp) Unmarshal 

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

func (DataApp) ValidateCreate 

func (dataapp DataApp) ValidateCreate() error

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

func (DataApp) ValidateDelete 

func (dataapp DataApp) ValidateDelete() error

func (DataApp) ValidateUpdate 

func (dataapp DataApp) ValidateUpdate(old runtime.Object) error

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

func (*DataApp) XXX_DiscardUnknown 

func (m *DataApp) XXX_DiscardUnknown()

func (*DataApp) XXX_Marshal 

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

func (*DataApp) XXX_Merge 

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

func (*DataApp) XXX_Size 

func (m *DataApp) XXX_Size() int

func (*DataApp) XXX_Unmarshal 

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

type DataAppCondition 

type DataAppCondition struct {
	// Type of DataApp condition
	Type DataAppConditionType `json:"type" protobuf:"bytes,1,opt,name=type,casttype=DataAppConditionType"`
	// Status of the condition, one of True, False, Unknown
	Status v1.ConditionStatus `json:"status" protobuf:"bytes,2,opt,name=status,casttype=k8s.io/api/core/v1.ConditionStatus"`
	// Last time the condition transitioned from one status to another
	LastTransitionTime *metav1.Time `json:"lastTransitionTime,omitempty" protobuf:"bytes,7,opt,name=lastTransitionTime"`
	// The reason for the condition's last transition
	Reason string `json:"reason,omitempty" protobuf:"bytes,4,opt,name=reason"`
	// A human readable message indicating details about the transition
	Message string `json:"message,omitempty" protobuf:"bytes,5,opt,name=message"`
}

DataAppCondition describes the state of a DataApp at a certain point

func (*DataAppCondition) DeepCopy 

func (in *DataAppCondition) DeepCopy() *DataAppCondition

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

func (*DataAppCondition) DeepCopyInto 

func (in *DataAppCondition) DeepCopyInto(out *DataAppCondition)

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

func (*DataAppCondition) Descriptor 

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

func (*DataAppCondition) Marshal 

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

func (*DataAppCondition) MarshalTo 

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

func (*DataAppCondition) MarshalToSizedBuffer 

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

func (*DataAppCondition) ProtoMessage 

func (*DataAppCondition) ProtoMessage()

func (*DataAppCondition) Reset 

func (m *DataAppCondition) Reset()

func (*DataAppCondition) Size 

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

func (*DataAppCondition) String 

func (this *DataAppCondition) String() string

func (*DataAppCondition) Unmarshal 

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

func (*DataAppCondition) XXX_DiscardUnknown 

func (m *DataAppCondition) XXX_DiscardUnknown()

func (*DataAppCondition) XXX_Marshal 

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

func (*DataAppCondition) XXX_Merge 

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

func (*DataAppCondition) XXX_Size 

func (m *DataAppCondition) XXX_Size() int

func (*DataAppCondition) XXX_Unmarshal 

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

type DataAppConditionType 

type DataAppConditionType string

DataAppConditionType is the condition of a DataApp 

const (
	DataAppReady DataAppConditionType = "Ready"
	DataAppSaved DataAppConditionType = "Saved"
)

/ DataApp Condition

type DataAppList 

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

DataAppList contains a list of DataApps +kubebuilder:object:root=true

func (*DataAppList) DeepCopy 

func (in *DataAppList) DeepCopy() *DataAppList

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

func (*DataAppList) DeepCopyInto 

func (in *DataAppList) DeepCopyInto(out *DataAppList)

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

func (*DataAppList) DeepCopyObject 

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

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

func (*DataAppList) Descriptor 

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

func (*DataAppList) Marshal 

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

func (*DataAppList) MarshalTo 

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

func (*DataAppList) MarshalToSizedBuffer 

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

func (*DataAppList) ProtoMessage 

func (*DataAppList) ProtoMessage()

func (*DataAppList) Reset 

func (m *DataAppList) Reset()

func (*DataAppList) Size 

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

func (*DataAppList) String 

func (this *DataAppList) String() string

func (*DataAppList) Unmarshal 

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

func (*DataAppList) XXX_DiscardUnknown 

func (m *DataAppList) XXX_DiscardUnknown()

func (*DataAppList) XXX_Marshal 

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

func (*DataAppList) XXX_Merge 

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

func (*DataAppList) XXX_Size 

func (m *DataAppList) XXX_Size() int

func (*DataAppList) XXX_Unmarshal 

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

type DataAppSpec 

type DataAppSpec struct {
	// The name of the Account which created the object, which exists in the same tenant as the object
	// +kubebuilder:validation:Optional
	// +kubebuilder:default:="no-one"
	Owner *string `json:"owner,omitempty" protobuf:"bytes,1,opt,name=owner"`
	// The name of the DataProductVersion which describes the version of the resource
	// that exists in the same DataProduct namespace as the resource
	// +kubebuilder:default:=""
	// +kubebuilder:validation:Optional
	VersionName *string `json:"versionName,omitempty" protobuf:"bytes,2,opt,name=versionName"`
	// The model class for this pipeline
	// +kubebuilder:validation:Optional
	ModelClassName *string `json:"modelClassName,omitempty" protobuf:"bytes,3,opt,name=modelClassName"`
	// The user-provided description of the DataApp
	// +kubebuilder:validation:Optional
	// +kubebuilder:default:=""
	Description *string `json:"description,omitempty" protobuf:"bytes,4,opt,name=description"`
	// The name of the predictive app model. The model will be used
	// +kubebuilder:default:=""
	// +kubebuilder:validation:Optional
	ModelName *string `json:"modelName,omitempty" protobuf:"bytes,5,opt,name=modelName"`
	// Define how to access the app.
	Access catalog.AccessSpec `json:"access,omitempty" protobuf:"bytes,6,opt,name=access"`
	// The number of replicas for the Kubernetes Serving associated with the DataApp, which will instantiate multiple
	// copies of the service in the case that automatic scaling is disabled
	// +kubebuilder:default:=1
	// +kubebuilder:validation:Optional
	Replicas *int32 `json:"replicas,omitempty" protobuf:"varint,7,opt,name=replicas"`
	// Resources specifies the resource requirements allocated to the DataApp's web server
	// +kubebuilder:validation:Optional
	Resources catalog.ResourceSpec `json:"resources,omitempty" protobuf:"bytes,10,opt,name=resources"`
	// The reference to the DataProduct that the resource exists under
	// +kubebuilder:validation:Optional
	ProductRef *v1.ObjectReference `json:"productRef,omitempty" protobuf:"bytes,12,opt,name=productRef"`
	// The reference to the ServingSite resource that hosts the Predictor
	// +kubebuilder:validation:Optional
	ServingSiteRef *v1.ObjectReference `json:"servingsiteRef" protobuf:"bytes,13,opt,name=servingsiteRef"`
	// The specification to create a custom data application (currently unimplemented)
	// +kubebuilder:validation:Optional
	Custom CustomAppSpec `json:"custom" protobuf:"bytes,14,opt,name=custom"`
}

DataAppSpec defines the desired state of a DataApp

func (*DataAppSpec) DeepCopy 

func (in *DataAppSpec) DeepCopy() *DataAppSpec

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

func (*DataAppSpec) DeepCopyInto 

func (in *DataAppSpec) DeepCopyInto(out *DataAppSpec)

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

func (*DataAppSpec) Descriptor 

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

func (*DataAppSpec) Marshal 

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

func (*DataAppSpec) MarshalTo 

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

func (*DataAppSpec) MarshalToSizedBuffer 

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

func (*DataAppSpec) ProtoMessage 

func (*DataAppSpec) ProtoMessage()

func (*DataAppSpec) Reset 

func (m *DataAppSpec) Reset()

func (*DataAppSpec) Size 

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

func (*DataAppSpec) String 

func (this *DataAppSpec) String() string

func (*DataAppSpec) Unmarshal 

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

func (*DataAppSpec) XXX_DiscardUnknown 

func (m *DataAppSpec) XXX_DiscardUnknown()

func (*DataAppSpec) XXX_Marshal 

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

func (*DataAppSpec) XXX_Merge 

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

func (*DataAppSpec) XXX_Size 

func (m *DataAppSpec) XXX_Size() int

func (*DataAppSpec) XXX_Unmarshal 

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

type DataAppStatus 

type DataAppStatus struct {
	// ObservedGeneration is the last generation that was acted on
	//+kubebuilder:validation:Optional
	ObservedGeneration int64 `json:"observedGeneration,omitempty" protobuf:"varint,1,opt,name=observedGeneration"`
	// The last time the object was updated
	//+kubebuilder:validation:Optional
	UpdatedAt *metav1.Time `json:"updatedAt,omitempty" protobuf:"bytes,2,opt,name=updatedAt"`
	// The reference to the Kubernetes Serving associated with the DataApp
	//+kubebuilder:validation:Optional
	DeploymentRef v1.ObjectReference `json:"deploymentStatus,omitempty" protobuf:"bytes,3,opt,name=deploymentStatus"`
	// The status of the Kubernetes Service associated with the DataApp
	//+kubebuilder:validation:Optional
	ServiceStatus v1.ServiceStatus `json:"serviceStatus,omitempty" protobuf:"bytes,4,opt,name=servicetStatus"`
	// In the case of failure, the DataApp resource controller will set this field with a failure reason
	//+kubebuilder:validation:Optional
	FailureReason *catalog.StatusError `json:"failureReason,omitempty" protobuf:"bytes,5,opt,name=failureReason"`
	// In the case of failure, the DataApp resource controller will set this field with a failure message
	//+kubebuilder:validation:Optional
	FailureMessage *string `json:"failureMessage,omitempty" protobuf:"bytes,6,opt,name=failureMessage"`
	// +patchMergeKey=type
	// +patchStrategy=merge
	// +kubebuilder:validation:Optional
	Conditions []DataAppCondition `json:"conditions,omitempty" patchStrategy:"merge" patchMergeKey:"type" protobuf:"bytes,7,rep,name=conditions"`
}

DataAppStatus defines the observed state of DataApp

func (*DataAppStatus) DeepCopy 

func (in *DataAppStatus) DeepCopy() *DataAppStatus

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

func (*DataAppStatus) DeepCopyInto 

func (in *DataAppStatus) DeepCopyInto(out *DataAppStatus)

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

func (*DataAppStatus) Descriptor 

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

func (*DataAppStatus) Marshal 

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

func (*DataAppStatus) MarshalTo 

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

func (*DataAppStatus) MarshalToSizedBuffer 

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

func (*DataAppStatus) ProtoMessage 

func (*DataAppStatus) ProtoMessage()

func (*DataAppStatus) Reset 

func (m *DataAppStatus) Reset()

func (*DataAppStatus) Size 

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

func (*DataAppStatus) String 

func (this *DataAppStatus) String() string

func (*DataAppStatus) Unmarshal 

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

func (*DataAppStatus) XXX_DiscardUnknown 

func (m *DataAppStatus) XXX_DiscardUnknown()

func (*DataAppStatus) XXX_Marshal 

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

func (*DataAppStatus) XXX_Merge 

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

func (*DataAppStatus) XXX_Size 

func (m *DataAppStatus) XXX_Size() int

func (*DataAppStatus) XXX_Unmarshal 

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

type DriftDetectionSpec added in v0.4.949 

type DriftDetectionSpec struct {
	// Indicates if model monitoring is enabled for the model
	// +kubebuilder:default:=false
	// +kubebuilder:validation:Optional
	Enabled *bool `json:"enabled,omitempty" protobuf:"varint,1,opt,name=enabled"`
	// If true, automatically generate drift test to all the columns based on the column type
	// +kubebuilder:default:=true
	// +kubebuilder:validation:Optional
	GenDriftTests *bool `json:"genDriftTests,omitempty" protobuf:"varint,2,opt,name=genDriftTests"`
	// If true, automatically generate drift test to all the columns based on the column type
	// +kubebuilder:default:=1000
	// +kubebuilder:validation:Optional
	MinPredictions *int32 `json:"minPredictions,omitempty" protobuf:"varint,3,opt,name=minPredictions"`
	// Set the list of columns for drift detection, if empty, watch all the columns.
	// +kubebuilder:validation:Optional
	Columns []string `json:"columns,omitempty" protobuf:"bytes,4,rep,name=columns"`
	// The drift threshold for drift metrics.
	// If empty will be set the modela
	DriftThresholds []data.DriftThreshold `json:"driftThresholds,omitempty" protobuf:"bytes,5,rep,name=driftThresholds"`
	// Define the tests to run against the predictor.
	UnitTestsTemplate catalog.TestSuite `json:"unitTestsTemplate,omitempty" protobuf:"bytes,6,opt,name=unitTestsTemplate"`
	// The schedule on which model monitoring computations will be performed
	// +kubebuilder:validation:Optional
	Schedule catalog.RunSchedule `json:"schedule,omitempty" protobuf:"bytes,7,opt,name=schedule"`
	// Reference to a model that will be used for outlier detection. If empty, an outlier detection model.
	// Currently not in use.
	// +kubebuilder:validation:Optional
	OutlierDetectionModelRef v1.ObjectReference `json:"outlierDetectionModelRef,omitempty" protobuf:"bytes,8,opt,name=outlierDetectionModelRef"`
	// how many feature histograms to keep in memory (as kubernetes objects). Histograms are garbage collected.
	// +kubebuilder:default:=5
	// +kubebuilder:validation:Optional
	MaxHistograms *int32 `json:"maxHistograms,omitempty" protobuf:"varint,9,opt,name=maxHistograms"`
	// The duration in seconds that an histogram is updated before computing drift
	// the default is one hour
	// +kubebuilder:default:=3600
	// +kubebuilder:validation:Optional
	PeriodSeconds *int32 `json:"periodSeconds,omitempty" protobuf:"varint,10,opt,name=periodSeconds"`
}

func (*DriftDetectionSpec) DeepCopy added in v0.4.949 

func (in *DriftDetectionSpec) DeepCopy() *DriftDetectionSpec

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

func (*DriftDetectionSpec) DeepCopyInto added in v0.4.949 

func (in *DriftDetectionSpec) DeepCopyInto(out *DriftDetectionSpec)

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

func (*DriftDetectionSpec) Descriptor added in v0.4.949 

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

func (*DriftDetectionSpec) Marshal added in v0.4.949 

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

func (*DriftDetectionSpec) MarshalTo added in v0.4.949 

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

func (*DriftDetectionSpec) MarshalToSizedBuffer added in v0.4.949 

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

func (*DriftDetectionSpec) ProtoMessage added in v0.4.949 

func (*DriftDetectionSpec) ProtoMessage()

func (*DriftDetectionSpec) Reset added in v0.4.949 

func (m *DriftDetectionSpec) Reset()

func (*DriftDetectionSpec) Size added in v0.4.949 

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

func (*DriftDetectionSpec) String added in v0.4.949 

func (this *DriftDetectionSpec) String() string

func (*DriftDetectionSpec) Unmarshal added in v0.4.949 

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

func (*DriftDetectionSpec) XXX_DiscardUnknown added in v0.4.949 

func (m *DriftDetectionSpec) XXX_DiscardUnknown()

func (*DriftDetectionSpec) XXX_Marshal added in v0.4.949 

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

func (*DriftDetectionSpec) XXX_Merge added in v0.4.949 

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

func (*DriftDetectionSpec) XXX_Size added in v0.4.949 

func (m *DriftDetectionSpec) XXX_Size() int

func (*DriftDetectionSpec) XXX_Unmarshal added in v0.4.949 

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

type DriftDetectionStatus added in v0.4.949 

type DriftDetectionStatus struct {
}

func (*DriftDetectionStatus) DeepCopy added in v0.4.949 

func (in *DriftDetectionStatus) DeepCopy() *DriftDetectionStatus

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

func (*DriftDetectionStatus) DeepCopyInto added in v0.4.949 

func (in *DriftDetectionStatus) DeepCopyInto(out *DriftDetectionStatus)

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

func (*DriftDetectionStatus) Descriptor added in v0.4.949 

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

func (*DriftDetectionStatus) Marshal added in v0.4.949 

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

func (*DriftDetectionStatus) MarshalTo added in v0.4.949 

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

func (*DriftDetectionStatus) MarshalToSizedBuffer added in v0.4.949 

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

func (*DriftDetectionStatus) ProtoMessage added in v0.4.949 

func (*DriftDetectionStatus) ProtoMessage()

func (*DriftDetectionStatus) Reset added in v0.4.949 

func (m *DriftDetectionStatus) Reset()

func (*DriftDetectionStatus) Size added in v0.4.949 

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

func (*DriftDetectionStatus) String added in v0.4.949 

func (this *DriftDetectionStatus) String() string

func (*DriftDetectionStatus) Unmarshal added in v0.4.949 

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

func (*DriftDetectionStatus) XXX_DiscardUnknown added in v0.4.949 

func (m *DriftDetectionStatus) XXX_DiscardUnknown()

func (*DriftDetectionStatus) XXX_Marshal added in v0.4.949 

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

func (*DriftDetectionStatus) XXX_Merge added in v0.4.949 

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

func (*DriftDetectionStatus) XXX_Size added in v0.4.949 

func (m *DriftDetectionStatus) XXX_Size() int

func (*DriftDetectionStatus) XXX_Unmarshal added in v0.4.949 

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

type FastSlowModelSpec added in v0.4.914 

type FastSlowModelSpec struct {
	// Indicates if model monitoring is enabled for the model
	// +kubebuilder:default:=false
	// +kubebuilder:validation:Optional
	Enabled *bool `json:"enabled,omitempty" protobuf:"varint,1,opt,name=enabled"`
	// Reference to the fast model
	FastModelRef v1.ObjectReference `json:"fastModelRef,omitempty" protobuf:"bytes,2,opt,name=fastModelRef"`
	// Reference to the slow model
	SlowModelRef v1.ObjectReference `json:"slowModelRef,omitempty" protobuf:"bytes,3,opt,name=slowModelRef"`
	// The low range of confidence.
	// +kubebuilder:default:=40
	// +kubebuilder:validation:Optional
	ProbaLowPct *int32 `json:"probaLowPct,omitempty" protobuf:"varint,4,opt,name=probaLowPct"`
	// The high range of confidence , Must be higher than probalow
	// +kubebuilder:default:=60
	// +kubebuilder:validation:Optional
	ProbaHighPct *int32 `json:"probaHighPct,omitempty" protobuf:"varint,5,opt,name=probaHighPct"`
}

Fast slow model mode, use two models as the live. All request are send first to the fast model.

func (*FastSlowModelSpec) DeepCopy added in v0.4.915 

func (in *FastSlowModelSpec) DeepCopy() *FastSlowModelSpec

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

func (*FastSlowModelSpec) DeepCopyInto added in v0.4.915 

func (in *FastSlowModelSpec) DeepCopyInto(out *FastSlowModelSpec)

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

func (*FastSlowModelSpec) Descriptor added in v0.4.914 

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

func (*FastSlowModelSpec) Marshal added in v0.4.914 

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

func (*FastSlowModelSpec) MarshalTo added in v0.4.914 

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

func (*FastSlowModelSpec) MarshalToSizedBuffer added in v0.4.914 

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

func (*FastSlowModelSpec) ProtoMessage added in v0.4.914 

func (*FastSlowModelSpec) ProtoMessage()

func (*FastSlowModelSpec) Reset added in v0.4.914 

func (m *FastSlowModelSpec) Reset()

func (*FastSlowModelSpec) Size added in v0.4.914 

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

func (*FastSlowModelSpec) String added in v0.4.914 

func (this *FastSlowModelSpec) String() string

func (*FastSlowModelSpec) Unmarshal added in v0.4.914 

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

func (*FastSlowModelSpec) XXX_DiscardUnknown added in v0.4.914 

func (m *FastSlowModelSpec) XXX_DiscardUnknown()

func (*FastSlowModelSpec) XXX_Marshal added in v0.4.914 

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

func (*FastSlowModelSpec) XXX_Merge added in v0.4.914 

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

func (*FastSlowModelSpec) XXX_Size added in v0.4.914 

func (m *FastSlowModelSpec) XXX_Size() int

func (*FastSlowModelSpec) XXX_Unmarshal added in v0.4.914 

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

type FeedbackTestSpec added in v0.4.984 

type FeedbackTestSpec struct {
	// Indicates if model monitoring is enabled for the model
	// +kubebuilder:default:=false
	// +kubebuilder:validation:Optional
	Enabled *bool `json:"enabled,omitempty" protobuf:"varint,1,opt,name=enabled"`
	// Define the tests to run against the predictor.
	// +kubebuilder:validation:Optional
	Tests catalog.TestSuite `json:"tests,omitempty" protobuf:"bytes,2,opt,name=tests"`
	// The schedule on which model monitoring computations will be performed
	// +kubebuilder:validation:Optional
	Schedule catalog.RunSchedule `json:"schedule,omitempty" protobuf:"bytes,3,opt,name=schedule"`
}

func (*FeedbackTestSpec) DeepCopy added in v0.4.984 

func (in *FeedbackTestSpec) DeepCopy() *FeedbackTestSpec

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

func (*FeedbackTestSpec) DeepCopyInto added in v0.4.984 

func (in *FeedbackTestSpec) DeepCopyInto(out *FeedbackTestSpec)

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

func (*FeedbackTestSpec) Descriptor added in v0.4.984 

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

func (*FeedbackTestSpec) Marshal added in v0.4.984 

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

func (*FeedbackTestSpec) MarshalTo added in v0.4.984 

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

func (*FeedbackTestSpec) MarshalToSizedBuffer added in v0.4.984 

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

func (*FeedbackTestSpec) ProtoMessage added in v0.4.984 

func (*FeedbackTestSpec) ProtoMessage()

func (*FeedbackTestSpec) Reset added in v0.4.984 

func (m *FeedbackTestSpec) Reset()

func (*FeedbackTestSpec) Size added in v0.4.984 

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

func (*FeedbackTestSpec) String added in v0.4.984 

func (this *FeedbackTestSpec) String() string

func (*FeedbackTestSpec) Unmarshal added in v0.4.984 

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

func (*FeedbackTestSpec) XXX_DiscardUnknown added in v0.4.984 

func (m *FeedbackTestSpec) XXX_DiscardUnknown()

func (*FeedbackTestSpec) XXX_Marshal added in v0.4.984 

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

func (*FeedbackTestSpec) XXX_Merge added in v0.4.984 

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

func (*FeedbackTestSpec) XXX_Size added in v0.4.984 

func (m *FeedbackTestSpec) XXX_Size() int

func (*FeedbackTestSpec) XXX_Unmarshal added in v0.4.984 

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

type ForecastPredictionSpec added in v0.5.94 

type ForecastPredictionSpec struct {
	// The hierarchy specification, which maps columns to values
	// +kubebuilder:validation:Optional
	HierarchyValues map[string]string `json:"hierarchyValues,omitempty" protobuf:"bytes,1,opt,name=hierarchyValues"`
	// The interval of the forecast
	Horizon training.WindowSpec `json:"horizon,omitempty" protobuf:"bytes,2,opt,name=horizon"`
}

ForecastSpec specifies the details of a forecasting model

func (*ForecastPredictionSpec) DeepCopy added in v0.5.96 

func (in *ForecastPredictionSpec) DeepCopy() *ForecastPredictionSpec

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

func (*ForecastPredictionSpec) DeepCopyInto added in v0.5.96 

func (in *ForecastPredictionSpec) DeepCopyInto(out *ForecastPredictionSpec)

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

func (*ForecastPredictionSpec) Descriptor added in v0.5.94 

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

func (*ForecastPredictionSpec) Marshal added in v0.5.94 

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

func (*ForecastPredictionSpec) MarshalTo added in v0.5.94 

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

func (*ForecastPredictionSpec) MarshalToSizedBuffer added in v0.5.94 

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

func (*ForecastPredictionSpec) ProtoMessage added in v0.5.94 

func (*ForecastPredictionSpec) ProtoMessage()

func (*ForecastPredictionSpec) Reset added in v0.5.94 

func (m *ForecastPredictionSpec) Reset()

func (*ForecastPredictionSpec) Size added in v0.5.94 

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

func (*ForecastPredictionSpec) String added in v0.5.94 

func (this *ForecastPredictionSpec) String() string

func (*ForecastPredictionSpec) Unmarshal added in v0.5.94 

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

func (*ForecastPredictionSpec) XXX_DiscardUnknown added in v0.5.94 

func (m *ForecastPredictionSpec) XXX_DiscardUnknown()

func (*ForecastPredictionSpec) XXX_Marshal added in v0.5.94 

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

func (*ForecastPredictionSpec) XXX_Merge added in v0.5.94 

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

func (*ForecastPredictionSpec) XXX_Size added in v0.5.94 

func (m *ForecastPredictionSpec) XXX_Size() int

func (*ForecastPredictionSpec) XXX_Unmarshal added in v0.5.94 

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

type ForecastRun added in v0.5.105 

type ForecastRun struct {
	// The reference to the ServingSite resource that
	// +kubebuilder:validation:Optional
	Key string `json:"key,omitempty" protobuf:"bytes,1,opt,name=key"`
	// The reference to the ServingSite resource that
	// +kubebuilder:validation:Optional
	ModelURI string `json:"modelURI,omitempty" protobuf:"bytes,2,rep,name=modelURI"`
	// the prediction horizon
	// +kubebuilder:validation:Optional
	Horizon training.WindowSpec `json:"horizon,omitempty" protobuf:"bytes,3,opt,name=horizon"`
}

func (*ForecastRun) DeepCopy added in v0.5.106 

func (in *ForecastRun) DeepCopy() *ForecastRun

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

func (*ForecastRun) DeepCopyInto added in v0.5.106 

func (in *ForecastRun) DeepCopyInto(out *ForecastRun)

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

func (*ForecastRun) Descriptor added in v0.5.105 

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

func (*ForecastRun) Marshal added in v0.5.105 

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

func (*ForecastRun) MarshalTo added in v0.5.105 

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

func (*ForecastRun) MarshalToSizedBuffer added in v0.5.105 

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

func (*ForecastRun) ProtoMessage added in v0.5.105 

func (*ForecastRun) ProtoMessage()

func (*ForecastRun) Reset added in v0.5.105 

func (m *ForecastRun) Reset()

func (*ForecastRun) Size added in v0.5.105 

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

func (*ForecastRun) String added in v0.5.105 

func (this *ForecastRun) String() string

func (*ForecastRun) Unmarshal added in v0.5.105 

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

func (*ForecastRun) XXX_DiscardUnknown added in v0.5.105 

func (m *ForecastRun) XXX_DiscardUnknown()

func (*ForecastRun) XXX_Marshal added in v0.5.105 

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

func (*ForecastRun) XXX_Merge added in v0.5.105 

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

func (*ForecastRun) XXX_Size added in v0.5.105 

func (m *ForecastRun) XXX_Size() int

func (*ForecastRun) XXX_Unmarshal added in v0.5.105 

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

type ForecastSpec 

type ForecastSpec struct {
	// The list of forecast runs. Runs are indexed by key
	// +kubebuilder:validation:Optional
	Runs map[string]ForecastRun `json:"runs,omitempty" protobuf:"bytes,9,rep,name=runs"`
}

func (*ForecastSpec) DeepCopy 

func (in *ForecastSpec) DeepCopy() *ForecastSpec

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

func (*ForecastSpec) DeepCopyInto 

func (in *ForecastSpec) DeepCopyInto(out *ForecastSpec)

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

func (*ForecastSpec) Descriptor 

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

func (*ForecastSpec) Marshal 

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

func (*ForecastSpec) MarshalTo 

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

func (*ForecastSpec) MarshalToSizedBuffer 

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

func (*ForecastSpec) ProtoMessage 

func (*ForecastSpec) ProtoMessage()

func (*ForecastSpec) Reset 

func (m *ForecastSpec) Reset()

func (*ForecastSpec) Size 

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

func (*ForecastSpec) String 

func (this *ForecastSpec) String() string

func (*ForecastSpec) Unmarshal 

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

func (*ForecastSpec) XXX_DiscardUnknown 

func (m *ForecastSpec) XXX_DiscardUnknown()

func (*ForecastSpec) XXX_Marshal 

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

func (*ForecastSpec) XXX_Merge 

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

func (*ForecastSpec) XXX_Size 

func (m *ForecastSpec) XXX_Size() int

func (*ForecastSpec) XXX_Unmarshal 

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

type ForecastStatus added in v0.5.100 

type ForecastStatus struct {
	// The URI of all the porfiles
	// +kubebuilder:validation:Optional
	ProfileURI string `json:"profileURI,omitempty" protobuf:"bytes,1,opt,name=profileURI"`
	// A pointer to the actual forecast
	// +kubebuilder:validation:Optional
	ReportURI string `json:"reportURI,omitempty" protobuf:"bytes,2,rep,name=reportURI"`
	// A pointer to the file containing the metadata about the forecasts
	// +kubebuilder:validation:Optional
	ForecastURI string `json:"forecastURI,omitempty" protobuf:"bytes,3,rep,name=forecastURI"`
	// Mark forecast as a failure.
	// +kubebuilder:validation:Optional
	Failed *bool `json:"failed,omitempty" protobuf:"bytes,4,opt,name=failed"`
	// In case of failure, this is the failure message
	// +kubebuilder:validation:Optional
	FailureMessage *string `json:"failureMessage,omitempty" protobuf:"bytes,5,opt,name=failureMsg"`
	// Holds the worker on going result, when a worker finish, we update the location of thier result files
	// +kubebuilder:validation:Optional
	WorkerResults []catalog.WorkerRunResult `json:"workerResults,omitempty" protobuf:"bytes,6,opt,name=workerResults"`
}

The result of forecasting one item. The forecast data itself is stored on the cloud. The dataURI is pointing to the forecast, the profile URI

func (*ForecastStatus) DeepCopy added in v0.5.102 

func (in *ForecastStatus) DeepCopy() *ForecastStatus

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

func (*ForecastStatus) DeepCopyInto added in v0.5.102 

func (in *ForecastStatus) DeepCopyInto(out *ForecastStatus)

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

func (*ForecastStatus) Descriptor added in v0.5.100 

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

func (*ForecastStatus) Marshal added in v0.5.100 

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

func (*ForecastStatus) MarshalTo added in v0.5.100 

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

func (*ForecastStatus) MarshalToSizedBuffer added in v0.5.100 

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

func (*ForecastStatus) ProtoMessage added in v0.5.100 

func (*ForecastStatus) ProtoMessage()

func (*ForecastStatus) Reset added in v0.5.100 

func (m *ForecastStatus) Reset()

func (*ForecastStatus) Size added in v0.5.100 

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

func (*ForecastStatus) String added in v0.5.100 

func (this *ForecastStatus) String() string

func (*ForecastStatus) Unmarshal added in v0.5.100 

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

func (*ForecastStatus) XXX_DiscardUnknown added in v0.5.100 

func (m *ForecastStatus) XXX_DiscardUnknown()

func (*ForecastStatus) XXX_Marshal added in v0.5.100 

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

func (*ForecastStatus) XXX_Merge added in v0.5.100 

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

func (*ForecastStatus) XXX_Size added in v0.5.100 

func (m *ForecastStatus) XXX_Size() int

func (*ForecastStatus) XXX_Unmarshal added in v0.5.100 

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

type ForwardCurtainSpec added in v0.4.914 

type ForwardCurtainSpec struct {
	// +kubebuilder:default:=false
	// +kubebuilder:validation:Optional
	Enabled *bool `json:"enabled,omitempty" protobuf:"varint,1,opt,name=enabled"`
	// The user account of the forward ref
	// +kubebuilder:validation:Optional
	AccountRef *v1.ObjectReference `json:"accountRef,omitempty" protobuf:"bytes,2,opt,name=accountRef"`
	// Percent of request that are sent to the foreward curtain.
	// +kubebuilder:default:=0
	// +kubebuilder:validation:Optional
	Percent *int32 `json:"percent,omitempty" protobuf:"bytes,3,opt,name=percent"`
}

func (*ForwardCurtainSpec) DeepCopy added in v0.4.915 

func (in *ForwardCurtainSpec) DeepCopy() *ForwardCurtainSpec

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

func (*ForwardCurtainSpec) DeepCopyInto added in v0.4.915 

func (in *ForwardCurtainSpec) DeepCopyInto(out *ForwardCurtainSpec)

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

func (*ForwardCurtainSpec) Descriptor added in v0.4.914 

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

func (*ForwardCurtainSpec) Marshal added in v0.4.914 

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

func (*ForwardCurtainSpec) MarshalTo added in v0.4.914 

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

func (*ForwardCurtainSpec) MarshalToSizedBuffer added in v0.4.914 

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

func (*ForwardCurtainSpec) ProtoMessage added in v0.4.914 

func (*ForwardCurtainSpec) ProtoMessage()

func (*ForwardCurtainSpec) Reset added in v0.4.914 

func (m *ForwardCurtainSpec) Reset()

func (*ForwardCurtainSpec) Size added in v0.4.914 

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

func (*ForwardCurtainSpec) String added in v0.4.914 

func (this *ForwardCurtainSpec) String() string

func (*ForwardCurtainSpec) Unmarshal added in v0.4.914 

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

func (*ForwardCurtainSpec) XXX_DiscardUnknown added in v0.4.914 

func (m *ForwardCurtainSpec) XXX_DiscardUnknown()

func (*ForwardCurtainSpec) XXX_Marshal added in v0.4.914 

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

func (*ForwardCurtainSpec) XXX_Merge added in v0.4.914 

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

func (*ForwardCurtainSpec) XXX_Size added in v0.4.914 

func (m *ForwardCurtainSpec) XXX_Size() int

func (*ForwardCurtainSpec) XXX_Unmarshal added in v0.4.914 

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

type K8sObjectStatusState added in v0.4.833 

type K8sObjectStatusState string
const (
	K8sObjectStatusHealthy K8sObjectStatusState = "healthy"
	K8sObjectStatusWarning K8sObjectStatusState = "warning"
	K8sObjectStatusError   K8sObjectStatusState = "error"
	K8sObjectStatusUnknown K8sObjectStatusState = "unknown"
)

type KubernetesObjectStatus added in v0.4.844 

type KubernetesObjectStatus struct {
	// The object reference
	// +kubebuilder:validation:Optional
	Ref *v1.ObjectReference `json:"ref,omitempty" protobuf:"bytes,1,opt,name=ref"`
	// The status of the object
	// +kubebuilder:validation:Optional
	Status K8sObjectStatusState `json:"status,omitempty" protobuf:"bytes,2,opt,name=status"`
}

KubernetesObjectStatus describes the location and status of a Kubernetes-native resource

func AddOrUpdateK8sStatuses added in v0.4.833 

func AddOrUpdateK8sStatuses(current []KubernetesObjectStatus, status KubernetesObjectStatus) []KubernetesObjectStatus

func (*KubernetesObjectStatus) DeepCopy added in v0.4.844 

func (in *KubernetesObjectStatus) DeepCopy() *KubernetesObjectStatus

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

func (*KubernetesObjectStatus) DeepCopyInto added in v0.4.844 

func (in *KubernetesObjectStatus) DeepCopyInto(out *KubernetesObjectStatus)

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

func (*KubernetesObjectStatus) Descriptor added in v0.4.844 

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

func (*KubernetesObjectStatus) Marshal added in v0.4.844 

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

func (*KubernetesObjectStatus) MarshalTo added in v0.4.844 

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

func (*KubernetesObjectStatus) MarshalToSizedBuffer added in v0.4.844 

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

func (*KubernetesObjectStatus) ProtoMessage added in v0.4.844 

func (*KubernetesObjectStatus) ProtoMessage()

func (*KubernetesObjectStatus) Reset added in v0.4.844 

func (m *KubernetesObjectStatus) Reset()

func (*KubernetesObjectStatus) Size added in v0.4.844 

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

func (*KubernetesObjectStatus) String added in v0.4.844 

func (this *KubernetesObjectStatus) String() string

func (*KubernetesObjectStatus) Unmarshal added in v0.4.844 

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

func (*KubernetesObjectStatus) XXX_DiscardUnknown added in v0.4.844 

func (m *KubernetesObjectStatus) XXX_DiscardUnknown()

func (*KubernetesObjectStatus) XXX_Marshal added in v0.4.844 

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

func (*KubernetesObjectStatus) XXX_Merge added in v0.4.844 

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

func (*KubernetesObjectStatus) XXX_Size added in v0.4.844 

func (m *KubernetesObjectStatus) XXX_Size() int

func (*KubernetesObjectStatus) XXX_Unmarshal added in v0.4.844 

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

type MetricHistory added in v0.5.114 

type MetricHistory struct {
	// The Metric Name
	// +kubebuilder:validation:Optional
	Metric catalog.Metric `json:"metric,omitempty" protobuf:"bytes,1,rep,name=metric"`
	// History
	// +kubebuilder:validation:Optional
	History []float64 `json:"history,omitempty" protobuf:"bytes,2,rep,name=history"`
}

Hold the Last X measurments of a metric

func (*MetricHistory) DeepCopy added in v0.5.116 

func (in *MetricHistory) DeepCopy() *MetricHistory

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

func (*MetricHistory) DeepCopyInto added in v0.5.116 

func (in *MetricHistory) DeepCopyInto(out *MetricHistory)

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

func (*MetricHistory) Descriptor added in v0.5.114 

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

func (*MetricHistory) Marshal added in v0.5.114 

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

func (*MetricHistory) MarshalTo added in v0.5.114 

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

func (*MetricHistory) MarshalToSizedBuffer added in v0.5.114 

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

func (*MetricHistory) ProtoMessage added in v0.5.114 

func (*MetricHistory) ProtoMessage()

func (*MetricHistory) Reset added in v0.5.114 

func (m *MetricHistory) Reset()

func (*MetricHistory) Size added in v0.5.114 

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

func (*MetricHistory) String added in v0.5.114 

func (this *MetricHistory) String() string

func (*MetricHistory) Unmarshal added in v0.5.114 

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

func (*MetricHistory) XXX_DiscardUnknown added in v0.5.114 

func (m *MetricHistory) XXX_DiscardUnknown()

func (*MetricHistory) XXX_Marshal added in v0.5.114 

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

func (*MetricHistory) XXX_Merge added in v0.5.114 

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

func (*MetricHistory) XXX_Size added in v0.5.114 

func (m *MetricHistory) XXX_Size() int

func (*MetricHistory) XXX_Unmarshal added in v0.5.114 

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

type ModelDeploymentPhase added in v0.4.784 

type ModelDeploymentPhase string
const (
	ModelDeploymentPhaseDeploying ModelDeploymentPhase = "Deploying"
	ModelDeploymentPhaseDeployed  ModelDeploymentPhase = "Deployed"
	ModelDeploymentPhaseShadowing ModelDeploymentPhase = "Shadowing"
	ModelDeploymentPhaseReleasing ModelDeploymentPhase = "Releasing"
	ModelDeploymentPhaseReleased  ModelDeploymentPhase = "Released"
	ModelDeploymentPhaseFailed    ModelDeploymentPhase = "FailedConditionReason"
)

type ModelDeploymentStatus added in v0.4.784 

type ModelDeploymentStatus struct {
	// The name of the Model resource associated with the deployment
	// +kubebuilder:validation:Optional
	ModelName string `json:"modelName,omitempty" protobuf:"bytes,1,opt,name=modelName"`
	// The version of the Model resource
	// +kubebuilder:validation:Optional
	ModelVersion string `json:"modelVersion,omitempty" protobuf:"bytes,2,opt,name=modelVersion"`
	// The image name that the deployment is currently running
	// +kubebuilder:validation:Optional
	ImageName string `json:"imageName,omitempty" protobuf:"bytes,3,opt,name=imageName"`
	// The name of the Kubernetes Serving that manages the pods of the Model
	// +kubebuilder:validation:Optional
	DeploymentRef v1.ObjectReference `json:"deploymentRef,omitempty" protobuf:"bytes,4,opt,name=deploymentRef"`
	// The name of the Kubernetes Service which exposes the Model externally
	// +kubebuilder:validation:Optional
	ServiceRef v1.ObjectReference `json:"serviceRef,omitempty" protobuf:"bytes,5,opt,name=serviceRef"`
	// the name of the horizonal pod autoscaler, if autoscaling is true
	// +kubebuilder:validation:Optional
	HPARef v1.ObjectReference `json:"hpaRef,omitempty" protobuf:"bytes,6,opt,name=hpaRef"`
	// 50% latency (median) for predictions served by the model
	// +kubebuilder:validation:Optional
	P50 float64 `json:"p50,omitempty" protobuf:"bytes,7,opt,name=p50"`
	// 95% latency for predictions served by the model
	// +kubebuilder:validation:Optional
	P95 float64 `json:"p95,omitempty" protobuf:"bytes,8,opt,name=p95"`
	// 99% latency for predictions served by the model
	// +kubebuilder:validation:Optional
	P99 float64 `json:"p99,omitempty" protobuf:"bytes,9,opt,name=p99"`
	// The last time a prediction was served by the Predictorlet
	// +kubebuilder:validation:Optional
	LastPredictionTime *metav1.Time `json:"lastPredictionTime,omitempty" protobuf:"bytes,10,opt,name=lastPredictionTime"`
	// +kubebuilder:validation:Optional
	DailyPredictionAvg int32 `json:"dailyPredictionAvg,omitempty" protobuf:"varint,11,opt,name=dailyPredictionAvg"`
	// LastFailure is the last failure that occured with the model
	// +kubebuilder:validation:Optional
	LastFailure string `json:"lastFailure,omitempty" protobuf:"bytes,12,opt,name=lastFailure"`
	// Phase is the current phase of the model deployment
	// +kubebuilder:validation:Optional
	Phase ModelDeploymentPhase `json:"phase,omitempty" protobuf:"bytes,13,opt,name=phase"`
	// DeployedAt is the last time that the model was deployed
	// +kubebuilder:validation:Optional
	DeployedAt *metav1.Time `json:"deployedAt,omitempty" protobuf:"bytes,14,opt,name=deployedAt"`
	// ReleasedAt is the time that the model was released
	// +kubebuilder:validation:Optional
	ReleasedAt *metav1.Time `json:"releasedAt,omitempty" protobuf:"bytes,15,opt,name=releasedAt"`
	// Indicates if a data drift has been detected based on incoming prediction data
	// +kubebuilder:validation:Optional
	DataDrift bool `json:"dataDrift,omitempty" protobuf:"varint,16,opt,name=dataDrift"`
	// Indicates if a concept drift has been detected based on incoming prediction data
	// +kubebuilder:validation:Optional
	ConceptDrift bool `json:"conceptDrift,omitempty" protobuf:"varint,17,opt,name=conceptDrift"`
	// The predictions from the last 7 days
	// +kubebuilder:validation:Optional
	LastDailyPredictions []int32 `json:"lastDailyPredictions,omitempty" protobuf:"bytes,18,rep,name=lastDailyPredictions"`
	// +kubebuilder:validation:Optional
	ObjectStatuses []KubernetesObjectStatus `json:"objectStatuses,omitempty" protobuf:"bytes,19,rep,name=objectStatuses"`
	// the set of validation errors
	// +kubebuilder:validation:Optional
	Errors []ValidationError `json:"errors,omitempty" protobuf:"bytes,20,opt,name=errors"`
	// Ref to the last ground true dataset that this model was tested against.
	// +kubebuilder:validation:Optional
	LastFeedbackDatasetRef v1.ObjectReference `json:"lastFeedbackDatasetRef,omitempty" protobuf:"bytes,21,opt,name=lastFeedbackDatasetRef"`
	// Last time that a ground true test was done.
	// +kubebuilder:validation:Optional
	LastFeedbackTest *metav1.Time `json:"lastFeedbackTest,omitempty" protobuf:"bytes,22,opt,name=lastFeedbackTest"`
	// Last results of the ground truth tests.
	// +kubebuilder:validation:Optional
	LastFeedbackTestResults []catalog.Measurement `json:"lastFeedbackTestResults,omitempty" protobuf:"bytes,23,opt,name=lastFeedbackTestResults"`
	// Holds the last N metrics for this model
	// +kubebuilder:validation:Optional
	MetricHistory map[catalog.Metric]MetricHistory `json:"metricHistory,omitempty" protobuf:"bytes,24,opt,name=metricsHistory"`
}

func (*ModelDeploymentStatus) DeepCopy added in v0.4.784 

func (in *ModelDeploymentStatus) DeepCopy() *ModelDeploymentStatus

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

func (*ModelDeploymentStatus) DeepCopyInto added in v0.4.784 

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

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

func (*ModelDeploymentStatus) Descriptor added in v0.4.784 

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

func (*ModelDeploymentStatus) Marshal added in v0.4.784 

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

func (*ModelDeploymentStatus) MarshalTo added in v0.4.784 

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

func (*ModelDeploymentStatus) MarshalToSizedBuffer added in v0.4.784 

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

func (*ModelDeploymentStatus) ProtoMessage added in v0.4.784 

func (*ModelDeploymentStatus) ProtoMessage()

func (*ModelDeploymentStatus) Reset added in v0.4.784 

func (m *ModelDeploymentStatus) Reset()

func (*ModelDeploymentStatus) Size added in v0.4.784 

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

func (*ModelDeploymentStatus) String added in v0.4.784 

func (this *ModelDeploymentStatus) String() string

func (*ModelDeploymentStatus) Unmarshal added in v0.4.784 

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

func (*ModelDeploymentStatus) XXX_DiscardUnknown added in v0.4.784 

func (m *ModelDeploymentStatus) XXX_DiscardUnknown()

func (*ModelDeploymentStatus) XXX_Marshal added in v0.4.784 

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

func (*ModelDeploymentStatus) XXX_Merge added in v0.4.784 

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

func (*ModelDeploymentStatus) XXX_Size added in v0.4.784 

func (m *ModelDeploymentStatus) XXX_Size() int

func (*ModelDeploymentStatus) XXX_Unmarshal added in v0.4.784 

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

type ModelRecord 

type ModelRecord struct {
	// Model Name is the name of the model
	// +kubebuilder:validation:Optional
	ModelName string `json:"modelName,omitempty" protobuf:"bytes,1,opt,name=modelName"`
	// Model version is the version of the model
	// +kubebuilder:validation:Optional
	ModelVersion string `json:"modelVersion,omitempty" protobuf:"bytes,2,opt,name=modelVersion"`
	// Live at is the time that the model were placed in production
	// +kubebuilder:validation:Optional
	LiveAt *metav1.Time `json:"liveAt,omitempty" protobuf:"bytes,3,opt,name=liveAt"`
	// Retried at is the time that the model was retired from production.
	// +kubebuilder:validation:Optional
	RetiredAt *metav1.Time `json:"retiredAt,omitempty" protobuf:"bytes,4,opt,name=retiredAt"`
	// Retried at is the time that the model was retired from production.
	// +kubebuilder:validation:Optional
	AvgDailyPrediction int32 `json:"avgDailyPrediction,omitempty" protobuf:"varint,5,opt,name=avgDailyPrediction"`
	// Retried at is the time that the model was retired from production.
	// +kubebuilder:validation:Optional
	AvgLatency float64 `json:"avgLatency,omitempty" protobuf:"bytes,6,opt,name=avgLatency"`
}

ModelRecord hold the state of a model that was in production

func (*ModelRecord) DeepCopy 

func (in *ModelRecord) DeepCopy() *ModelRecord

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

func (*ModelRecord) DeepCopyInto 

func (in *ModelRecord) DeepCopyInto(out *ModelRecord)

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

func (*ModelRecord) Descriptor 

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

func (*ModelRecord) Marshal 

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

func (*ModelRecord) MarshalTo 

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

func (*ModelRecord) MarshalToSizedBuffer 

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

func (*ModelRecord) ProtoMessage 

func (*ModelRecord) ProtoMessage()

func (*ModelRecord) Reset 

func (m *ModelRecord) Reset()

func (*ModelRecord) Size 

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

func (*ModelRecord) String 

func (this *ModelRecord) String() string

func (*ModelRecord) Unmarshal 

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

func (*ModelRecord) XXX_DiscardUnknown 

func (m *ModelRecord) XXX_DiscardUnknown()

func (*ModelRecord) XXX_Marshal 

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

func (*ModelRecord) XXX_Merge 

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

func (*ModelRecord) XXX_Size 

func (m *ModelRecord) XXX_Size() int

func (*ModelRecord) XXX_Unmarshal 

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

type ModelServingSpec added in v0.4.878 

type ModelServingSpec struct {
	// If Serverless is true, the Kubernetes Serving which serves the model will not be created
	// until it starts to receive prediction traffic, and will be destroyed once the model becomes dormant
	Serverless *bool `json:"serverless,omitempty" protobuf:"varint,2,opt,name=serverless"`

	UnitTestsTemplate catalog.TestSuite `json:"servingTests,omitempty" protobuf:"bytes,4,opt,name=servingTests"`
}

ModelServingSpec specifies the configuration for models to be served by a Predictor

func (*ModelServingSpec) DeepCopy added in v0.4.878 

func (in *ModelServingSpec) DeepCopy() *ModelServingSpec

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

func (*ModelServingSpec) DeepCopyInto added in v0.4.878 

func (in *ModelServingSpec) DeepCopyInto(out *ModelServingSpec)

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

func (*ModelServingSpec) Descriptor added in v0.4.878 

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

func (*ModelServingSpec) Marshal added in v0.4.878 

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

func (*ModelServingSpec) MarshalTo added in v0.4.878 

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

func (*ModelServingSpec) MarshalToSizedBuffer added in v0.4.878 

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

func (*ModelServingSpec) ProtoMessage added in v0.4.878 

func (*ModelServingSpec) ProtoMessage()

func (*ModelServingSpec) Reset added in v0.4.878 

func (m *ModelServingSpec) Reset()

func (*ModelServingSpec) Size added in v0.4.878 

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

func (*ModelServingSpec) String added in v0.4.878 

func (this *ModelServingSpec) String() string

func (*ModelServingSpec) Unmarshal added in v0.4.878 

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

func (*ModelServingSpec) XXX_DiscardUnknown added in v0.4.878 

func (m *ModelServingSpec) XXX_DiscardUnknown()

func (*ModelServingSpec) XXX_Marshal added in v0.4.878 

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

func (*ModelServingSpec) XXX_Merge added in v0.4.878 

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

func (*ModelServingSpec) XXX_Size added in v0.4.878 

func (m *ModelServingSpec) XXX_Size() int

func (*ModelServingSpec) XXX_Unmarshal added in v0.4.878 

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

type OnlineFeatureStoreSpec added in v0.4.784 

type OnlineFeatureStoreSpec struct {
	// +kubebuilder:default:=false
	// +kubebuilder:validation:Optional
	Enabled *bool `json:"enabled,omitempty" protobuf:"varint,1,opt,name=enabled"`
	// The host name of the feature store micro service.
	// +kubebuilder:default:=""
	Hostname *string `json:"hostname,omitempty" protobuf:"bytes,2,opt,name=hostname"`
}

OnlineFeaturestoreSpec specifies the connection information for an online feature store

func (*OnlineFeatureStoreSpec) DeepCopy added in v0.4.784 

func (in *OnlineFeatureStoreSpec) DeepCopy() *OnlineFeatureStoreSpec

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

func (*OnlineFeatureStoreSpec) DeepCopyInto added in v0.4.784 

func (in *OnlineFeatureStoreSpec) DeepCopyInto(out *OnlineFeatureStoreSpec)

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

func (*OnlineFeatureStoreSpec) Descriptor added in v0.4.784 

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

func (*OnlineFeatureStoreSpec) Marshal added in v0.4.784 

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

func (*OnlineFeatureStoreSpec) MarshalTo added in v0.4.784 

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

func (*OnlineFeatureStoreSpec) MarshalToSizedBuffer added in v0.4.784 

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

func (*OnlineFeatureStoreSpec) ProtoMessage added in v0.4.784 

func (*OnlineFeatureStoreSpec) ProtoMessage()

func (*OnlineFeatureStoreSpec) Reset added in v0.4.784 

func (m *OnlineFeatureStoreSpec) Reset()

func (*OnlineFeatureStoreSpec) Size added in v0.4.784 

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

func (*OnlineFeatureStoreSpec) String added in v0.4.784 

func (this *OnlineFeatureStoreSpec) String() string

func (*OnlineFeatureStoreSpec) Unmarshal added in v0.4.784 

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

func (*OnlineFeatureStoreSpec) XXX_DiscardUnknown added in v0.4.784 

func (m *OnlineFeatureStoreSpec) XXX_DiscardUnknown()

func (*OnlineFeatureStoreSpec) XXX_Marshal added in v0.4.784 

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

func (*OnlineFeatureStoreSpec) XXX_Merge added in v0.4.784 

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

func (*OnlineFeatureStoreSpec) XXX_Size added in v0.4.784 

func (m *OnlineFeatureStoreSpec) XXX_Size() int

func (*OnlineFeatureStoreSpec) XXX_Unmarshal added in v0.4.784 

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

type OnlineStoreStatus added in v0.4.784 

type OnlineStoreStatus struct {
	// LastAccessed specifies the last time the online store was accessed
	LastAccessed *metav1.Time `json:"lastAccessed,omitempty" protobuf:"bytes,1,opt,name=lastAccessed"`
}

func (*OnlineStoreStatus) DeepCopy added in v0.4.784 

func (in *OnlineStoreStatus) DeepCopy() *OnlineStoreStatus

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

func (*OnlineStoreStatus) DeepCopyInto added in v0.4.784 

func (in *OnlineStoreStatus) DeepCopyInto(out *OnlineStoreStatus)

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

func (*OnlineStoreStatus) Descriptor added in v0.4.784 

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

func (*OnlineStoreStatus) Marshal added in v0.4.784 

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

func (*OnlineStoreStatus) MarshalTo added in v0.4.784 

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

func (*OnlineStoreStatus) MarshalToSizedBuffer added in v0.4.784 

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

func (*OnlineStoreStatus) ProtoMessage added in v0.4.784 

func (*OnlineStoreStatus) ProtoMessage()

func (*OnlineStoreStatus) Reset added in v0.4.784 

func (m *OnlineStoreStatus) Reset()

func (*OnlineStoreStatus) Size added in v0.4.784 

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

func (*OnlineStoreStatus) String added in v0.4.784 

func (this *OnlineStoreStatus) String() string

func (*OnlineStoreStatus) Unmarshal added in v0.4.784 

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

func (*OnlineStoreStatus) XXX_DiscardUnknown added in v0.4.784 

func (m *OnlineStoreStatus) XXX_DiscardUnknown()

func (*OnlineStoreStatus) XXX_Marshal added in v0.4.784 

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

func (*OnlineStoreStatus) XXX_Merge added in v0.4.784 

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

func (*OnlineStoreStatus) XXX_Size added in v0.4.784 

func (m *OnlineStoreStatus) XXX_Size() int

func (*OnlineStoreStatus) XXX_Unmarshal added in v0.4.784 

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

type PartitionPredictionLocationsSpec added in v0.5.402 

type PartitionPredictionLocationsSpec struct {
	// The folder of group data
	// +kubebuilder:validation:Optional
	GroupForecastFile *string `json:"groupForecastFile,omitempty" protobuf:"bytes,2,opt,name=groupForecastFile"`
}

func (*PartitionPredictionLocationsSpec) DeepCopy added in v0.5.402 

func (in *PartitionPredictionLocationsSpec) DeepCopy() *PartitionPredictionLocationsSpec

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

func (*PartitionPredictionLocationsSpec) DeepCopyInto added in v0.5.402 

func (in *PartitionPredictionLocationsSpec) DeepCopyInto(out *PartitionPredictionLocationsSpec)

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

func (*PartitionPredictionLocationsSpec) Descriptor added in v0.5.402 

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

func (*PartitionPredictionLocationsSpec) Marshal added in v0.5.402 

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

func (*PartitionPredictionLocationsSpec) MarshalTo added in v0.5.402 

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

func (*PartitionPredictionLocationsSpec) MarshalToSizedBuffer added in v0.5.402 

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

func (*PartitionPredictionLocationsSpec) ProtoMessage added in v0.5.402 

func (*PartitionPredictionLocationsSpec) ProtoMessage()

func (*PartitionPredictionLocationsSpec) Reset added in v0.5.402 

func (m *PartitionPredictionLocationsSpec) Reset()

func (*PartitionPredictionLocationsSpec) Size added in v0.5.402 

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

func (*PartitionPredictionLocationsSpec) String added in v0.5.402 

func (this *PartitionPredictionLocationsSpec) String() string

func (*PartitionPredictionLocationsSpec) Unmarshal added in v0.5.402 

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

func (*PartitionPredictionLocationsSpec) XXX_DiscardUnknown added in v0.5.402 

func (m *PartitionPredictionLocationsSpec) XXX_DiscardUnknown()

func (*PartitionPredictionLocationsSpec) XXX_Marshal added in v0.5.402 

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

func (*PartitionPredictionLocationsSpec) XXX_Merge added in v0.5.402 

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

func (*PartitionPredictionLocationsSpec) XXX_Size added in v0.5.402 

func (m *PartitionPredictionLocationsSpec) XXX_Size() int

func (*PartitionPredictionLocationsSpec) XXX_Unmarshal added in v0.5.402 

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

type Prediction 

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

+kubebuilder:object:root=true +kubebuilder:subresource:status +kubebuilder:storageversion +kubebuilder:resource:path=predictions,shortName=pred,singular=prediction,categories={inference,modela} +kubebuilder:printcolumn:name="Ready",type="string",JSONPath=".status.conditions[?(@.type==\"Ready\")].status" +kubebuilder:printcolumn:name="Predictor",type="string",JSONPath=".spec.predictorRef.Name" +kubebuilder:printcolumn:name="Bucket",type="string",JSONPath=".spec.output.bucketName",priority=1 +kubebuilder:printcolumn:name="Key",type="string",JSONPath=".spec.output.path",priority=1 +kubebuilder:printcolumn:name="Score",type="string",JSONPath=".status.score" +kubebuilder:printcolumn:name="Status",type="string",JSONPath=".status.phase" +kubebuilder:printcolumn:name="Rows",type="string",JSONPath=".status.rows" +kubebuilder:printcolumn:name="Age",type="date",JSONPath=".metadata.creationTimestamp" Prediction represents a single batch prediction on a dataset

func ParsePredictionYaml 

func ParsePredictionYaml(content []byte) (*Prediction, error)

func (*Prediction) AddFinalizer 

func (prediction *Prediction) AddFinalizer()

func (Prediction) CompletionAlert added in v0.4.601 

func (prediction Prediction) CompletionAlert(tenantRef *v1.ObjectReference, notifierName *string) *infra.Alert

func (*Prediction) ConstructDataset added in v0.5.87 

func (prediction *Prediction) ConstructDataset() (*data.Dataset, error)

func (*Prediction) CreateOrUpdateCond 

func (prediction *Prediction) CreateOrUpdateCond(cond PredictionCondition)

Merge or update condition Merge or update condition

func (*Prediction) DeepCopy 

func (in *Prediction) DeepCopy() *Prediction

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

func (*Prediction) DeepCopyInto 

func (in *Prediction) DeepCopyInto(out *Prediction)

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

func (*Prediction) DeepCopyObject 

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

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

func (*Prediction) Default 

func (prediction *Prediction) Default()

func (*Prediction) Descriptor 

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

func (*Prediction) DriftAlert added in v0.5.92 

func (prediction *Prediction) DriftAlert(tenantRef *v1.ObjectReference, notifierName *string, columns []string) *infra.Alert

func (Prediction) ErrorAlert added in v0.4.601 

func (prediction Prediction) ErrorAlert(tenantRef *v1.ObjectReference, notifierName *string, err error) *infra.Alert

func (Prediction) GetCond 

func (prediction Prediction) GetCond(t PredictionConditionType) PredictionCondition

func (Prediction) GetCondIdx 

func (prediction Prediction) GetCondIdx(t PredictionConditionType) int

func (Prediction) HasFinalizer 

func (prediction Prediction) HasFinalizer() bool

func (Prediction) IsCompleted 

func (prediction Prediction) IsCompleted() bool

func (Prediction) IsFailed added in v0.4.614 

func (prediction Prediction) IsFailed() bool

func (Prediction) IsSaved 

func (prediction Prediction) IsSaved() bool

func (Prediction) Key 

func (prediction Prediction) Key() string

func (Prediction) ManifestURI added in v0.5.472 

func (prediction Prediction) ManifestURI() string

func (*Prediction) MarkArchived added in v0.4.517 

func (prediction *Prediction) MarkArchived()

func (*Prediction) MarkCompleted 

func (prediction *Prediction) MarkCompleted()

func (*Prediction) MarkCreatingDataset added in v0.5.86 

func (prediction *Prediction) MarkCreatingDataset()

func (*Prediction) MarkFailed 

func (prediction *Prediction) MarkFailed(msg string)

func (*Prediction) MarkPending added in v0.5.86 

func (prediction *Prediction) MarkPending()

Mark Expired

func (*Prediction) MarkRunning 

func (prediction *Prediction) MarkRunning()

func (*Prediction) MarkSaved 

func (prediction *Prediction) MarkSaved()

func (*Prediction) MarkUnitTestFailed added in v0.5.90 

func (prediction *Prediction) MarkUnitTestFailed(msg string)

func (*Prediction) MarkUnitTested added in v0.5.91 

func (prediction *Prediction) MarkUnitTested()

func (*Prediction) MarkUnitTesting added in v0.5.91 

func (prediction *Prediction) MarkUnitTesting()

func (*Prediction) MarkWaitingForDataset added in v0.5.86 

func (prediction *Prediction) MarkWaitingForDataset()

func (*Prediction) Marshal 

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

func (*Prediction) MarshalTo 

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

func (*Prediction) MarshalToSizedBuffer 

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

func (Prediction) OpName 

func (prediction Prediction) OpName() string

func (Prediction) PipelineName 

func (prediction Prediction) PipelineName() string

func (*Prediction) ProtoMessage 

func (*Prediction) ProtoMessage()

func (*Prediction) RemoveFinalizer 

func (prediction *Prediction) RemoveFinalizer()

func (Prediction) RepPath 

func (prediction Prediction) RepPath(root string) (string, error)

Return the on disk rep location

func (*Prediction) Reset 

func (m *Prediction) Reset()

func (Prediction) RootURI added in v0.5.472 

func (prediction Prediction) RootURI() string

func (*Prediction) RunStatus added in v0.4.614 

func (prediction *Prediction) RunStatus() *catalog.LastRunStatus

Return the state of the run as RunStatus

func (*Prediction) SetupWebhookWithManager 

func (prediction *Prediction) SetupWebhookWithManager(mgr ctrl.Manager) error

func (*Prediction) Size 

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

func (*Prediction) String 

func (this *Prediction) String() string

func (*Prediction) Unmarshal 

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

func (Prediction) ValidateCreate 

func (prediction Prediction) ValidateCreate() error

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

func (Prediction) ValidateDelete 

func (prediction Prediction) ValidateDelete() error

func (Prediction) ValidateUpdate 

func (prediction Prediction) ValidateUpdate(old runtime.Object) error

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

func (*Prediction) XXX_DiscardUnknown 

func (m *Prediction) XXX_DiscardUnknown()

func (*Prediction) XXX_Marshal 

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

func (*Prediction) XXX_Merge 

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

func (*Prediction) XXX_Size 

func (m *Prediction) XXX_Size() int

func (*Prediction) XXX_Unmarshal 

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

type PredictionCacheSpec 

type PredictionCacheSpec struct {
	// Enabled indicates if predictions will be cached
	// +kubebuilder:default:=false
	// +kubebuilder:validation:Optional
	Enabled *bool `json:"enabled,omitempty" protobuf:"varint,1,opt,name=enabled"`
	// InMemory indicates if predictions will be cached in the available memory of the Pod serving the model
	// +kubebuilder:default:=false
	// +kubebuilder:validation:Optional
	InMemory *bool `json:"inMemory,omitempty" protobuf:"varint,2,opt,name=inMemory"`
	// Redis indicates if predictions will be cached in an external Redis deployment
	// +kubebuilder:default:=false
	// +kubebuilder:validation:Optional
	Redis *bool `json:"redis,omitempty" protobuf:"varint,3,opt,name=redis"`
	// The reference to a Connection resource to an external Redis deployment
	ConnectionRef *v1.ObjectReference `json:"connectionRef,omitempty" protobuf:"bytes,4,opt,name=connectionRef"`
}

PredictionCacheSpec specifies the connection information of a key-value cache to store predictions

func (*PredictionCacheSpec) DeepCopy 

func (in *PredictionCacheSpec) DeepCopy() *PredictionCacheSpec

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

func (*PredictionCacheSpec) DeepCopyInto 

func (in *PredictionCacheSpec) DeepCopyInto(out *PredictionCacheSpec)

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

func (*PredictionCacheSpec) Descriptor 

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

func (*PredictionCacheSpec) Marshal 

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

func (*PredictionCacheSpec) MarshalTo 

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

func (*PredictionCacheSpec) MarshalToSizedBuffer 

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

func (*PredictionCacheSpec) ProtoMessage 

func (*PredictionCacheSpec) ProtoMessage()

func (*PredictionCacheSpec) Reset 

func (m *PredictionCacheSpec) Reset()

func (*PredictionCacheSpec) Size 

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

func (*PredictionCacheSpec) String 

func (this *PredictionCacheSpec) String() string

func (*PredictionCacheSpec) Unmarshal 

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

func (*PredictionCacheSpec) XXX_DiscardUnknown 

func (m *PredictionCacheSpec) XXX_DiscardUnknown()

func (*PredictionCacheSpec) XXX_Marshal 

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

func (*PredictionCacheSpec) XXX_Merge 

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

func (*PredictionCacheSpec) XXX_Size 

func (m *PredictionCacheSpec) XXX_Size() int

func (*PredictionCacheSpec) XXX_Unmarshal 

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

type PredictionCacheStatus added in v0.4.784 

type PredictionCacheStatus struct {
	// LastAccessed specifies the last time the prediction cache was accessed
	LastAccessed *metav1.Time `json:"lastAccessed,omitempty" protobuf:"bytes,1,opt,name=lastAccessed"`
}

func (*PredictionCacheStatus) DeepCopy added in v0.4.784 

func (in *PredictionCacheStatus) DeepCopy() *PredictionCacheStatus

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

func (*PredictionCacheStatus) DeepCopyInto added in v0.4.784 

func (in *PredictionCacheStatus) DeepCopyInto(out *PredictionCacheStatus)

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

func (*PredictionCacheStatus) Descriptor added in v0.4.784 

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

func (*PredictionCacheStatus) Marshal added in v0.4.784 

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

func (*PredictionCacheStatus) MarshalTo added in v0.4.784 

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

func (*PredictionCacheStatus) MarshalToSizedBuffer added in v0.4.784 

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

func (*PredictionCacheStatus) ProtoMessage added in v0.4.784 

func (*PredictionCacheStatus) ProtoMessage()

func (*PredictionCacheStatus) Reset added in v0.4.784 

func (m *PredictionCacheStatus) Reset()

func (*PredictionCacheStatus) Size added in v0.4.784 

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

func (*PredictionCacheStatus) String added in v0.4.784 

func (this *PredictionCacheStatus) String() string

func (*PredictionCacheStatus) Unmarshal added in v0.4.784 

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

func (*PredictionCacheStatus) XXX_DiscardUnknown added in v0.4.784 

func (m *PredictionCacheStatus) XXX_DiscardUnknown()

func (*PredictionCacheStatus) XXX_Marshal added in v0.4.784 

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

func (*PredictionCacheStatus) XXX_Merge added in v0.4.784 

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

func (*PredictionCacheStatus) XXX_Size added in v0.4.784 

func (m *PredictionCacheStatus) XXX_Size() int

func (*PredictionCacheStatus) XXX_Unmarshal added in v0.4.784 

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

type PredictionCondition 

type PredictionCondition struct {
	// Type of Prediction condition
	Type PredictionConditionType `json:"type" protobuf:"bytes,1,opt,name=type,casttype=PredictionConditionType"`
	// Status of the condition, one of True, False, Unknown
	Status v1.ConditionStatus `json:"status" protobuf:"bytes,2,opt,name=status,casttype=k8s.io/api/core/v1.ConditionStatus"`
	// Last time the condition transitioned from one status to another
	LastTransitionTime *metav1.Time `json:"lastTransitionTime,omitempty" protobuf:"bytes,3,opt,name=lastTransitionTime"`
	// The reason for the condition's last transition
	Reason string `json:"reason,omitempty" protobuf:"bytes,4,opt,name=reason"`
	// A human-readable message indicating details about the transition
	Message string `json:"message,omitempty" protobuf:"bytes,5,opt,name=message"`
}

PredictionCondition describes the state of a Prediction at a certain point

func (*PredictionCondition) DeepCopy 

func (in *PredictionCondition) DeepCopy() *PredictionCondition

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

func (*PredictionCondition) DeepCopyInto 

func (in *PredictionCondition) DeepCopyInto(out *PredictionCondition)

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

func (*PredictionCondition) Descriptor 

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

func (*PredictionCondition) Marshal 

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

func (*PredictionCondition) MarshalTo 

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

func (*PredictionCondition) MarshalToSizedBuffer 

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

func (*PredictionCondition) ProtoMessage 

func (*PredictionCondition) ProtoMessage()

func (*PredictionCondition) Reset 

func (m *PredictionCondition) Reset()

func (*PredictionCondition) Size 

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

func (*PredictionCondition) String 

func (this *PredictionCondition) String() string

func (*PredictionCondition) Unmarshal 

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

func (*PredictionCondition) XXX_DiscardUnknown 

func (m *PredictionCondition) XXX_DiscardUnknown()

func (*PredictionCondition) XXX_Marshal 

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

func (*PredictionCondition) XXX_Merge 

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

func (*PredictionCondition) XXX_Size 

func (m *PredictionCondition) XXX_Size() int

func (*PredictionCondition) XXX_Unmarshal 

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

type PredictionConditionType 

type PredictionConditionType string

PredictionConditionType is the condition type of the prediction pipeline 

const (
	PredictionCompleted  PredictionConditionType = "CompletedModelsCount"
	PredictionSaved      PredictionConditionType = "Saved"
	PredictionUnitTested PredictionConditionType = "UnitTested"
	PredictionArchived   PredictionConditionType = "Archived"
)

/ PredictionTemplate Condition

type PredictionList 

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

+kubebuilder:object:root=true PredictionList is a list of Predictions

func (*PredictionList) DeepCopy 

func (in *PredictionList) DeepCopy() *PredictionList

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

func (*PredictionList) DeepCopyInto 

func (in *PredictionList) DeepCopyInto(out *PredictionList)

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

func (*PredictionList) DeepCopyObject 

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

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

func (*PredictionList) Descriptor 

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

func (*PredictionList) Marshal 

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

func (*PredictionList) MarshalTo 

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

func (*PredictionList) MarshalToSizedBuffer 

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

func (*PredictionList) ProtoMessage 

func (*PredictionList) ProtoMessage()

func (*PredictionList) Reset 

func (m *PredictionList) Reset()

func (*PredictionList) Size 

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

func (*PredictionList) String 

func (this *PredictionList) String() string

func (*PredictionList) Unmarshal 

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

func (*PredictionList) XXX_DiscardUnknown 

func (m *PredictionList) XXX_DiscardUnknown()

func (*PredictionList) XXX_Marshal 

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

func (*PredictionList) XXX_Merge 

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

func (*PredictionList) XXX_Size 

func (m *PredictionList) XXX_Size() int

func (*PredictionList) XXX_Unmarshal 

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

type PredictionLoggingSpec added in v0.4.878 

type PredictionLoggingSpec struct {
	// Indicates if prediction logging is enabled
	// +kubebuilder:default:=false
	// +kubebuilder:validation:Optional
	Enabled *bool `json:"enabled,omitempty" protobuf:"varint,1,opt,name=enabled"`
	// The number percentage (0 through 100) of prediction requests to log
	// +kubebuilder:default:=0
	// +kubebuilder:validation:Optional
	SamplePercent *int32 `json:"samplePercent,omitempty" protobuf:"varint,2,opt,name=samplePercent"`
	// Number of rows in the serving dataset
	// +kubebuilder:default:=0
	// +kubebuilder:validation:Optional
	Rows *int32 `json:"rows,omitempty" protobuf:"varint,3,opt,name=rows"`
	// Backup Frequency seconds.
	// +kubebuilder:default:=0
	// +kubebuilder:validation:Optional
	BackupFreqSeconds *int32 `json:"backupFreqSeconds,omitempty" protobuf:"varint,4,opt,name=backupFreqSeconds"`
	// Reference to backup location.
	// +kubebuilder:validation:Optional
	BackupConnectionRef v1.ObjectReference `json:"backupConnectionRef,omitempty" protobuf:"bytes,5,opt,name=backupConnectionRef"`
	// Target location of the serving dataset
	// +kubebuilder:validation:Optional
	Location data.DataLocation `json:"location,omitempty" protobuf:"bytes,6,opt,name=location"`
}

PredictionLoggingSpec specifies the configuration to log incoming and outgoing prediction requests

func (*PredictionLoggingSpec) DeepCopy added in v0.4.878 

func (in *PredictionLoggingSpec) DeepCopy() *PredictionLoggingSpec

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

func (*PredictionLoggingSpec) DeepCopyInto added in v0.4.878 

func (in *PredictionLoggingSpec) DeepCopyInto(out *PredictionLoggingSpec)

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

func (*PredictionLoggingSpec) Descriptor added in v0.4.878 

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

func (*PredictionLoggingSpec) Marshal added in v0.4.878 

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

func (*PredictionLoggingSpec) MarshalTo added in v0.4.878 

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

func (*PredictionLoggingSpec) MarshalToSizedBuffer added in v0.4.878 

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

func (*PredictionLoggingSpec) ProtoMessage added in v0.4.878 

func (*PredictionLoggingSpec) ProtoMessage()

func (*PredictionLoggingSpec) Reset added in v0.4.878 

func (m *PredictionLoggingSpec) Reset()

func (*PredictionLoggingSpec) Size added in v0.4.878 

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

func (*PredictionLoggingSpec) String added in v0.4.878 

func (this *PredictionLoggingSpec) String() string

func (*PredictionLoggingSpec) Unmarshal added in v0.4.878 

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

func (*PredictionLoggingSpec) XXX_DiscardUnknown added in v0.4.878 

func (m *PredictionLoggingSpec) XXX_DiscardUnknown()

func (*PredictionLoggingSpec) XXX_Marshal added in v0.4.878 

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

func (*PredictionLoggingSpec) XXX_Merge added in v0.4.878 

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

func (*PredictionLoggingSpec) XXX_Size added in v0.4.878 

func (m *PredictionLoggingSpec) XXX_Size() int

func (*PredictionLoggingSpec) XXX_Unmarshal added in v0.4.878 

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

type PredictionPhase 

type PredictionPhase string

ModelPhase is the current phase of a model 

const (
	PredictionPhasePending           PredictionPhase = "Pending"
	PredictionPhaseCreatingDataset   PredictionPhase = "CreatingDataset"
	PredictionPhaseWaitingForDataset PredictionPhase = "WaitingForDataset"
	PredictionPhaseRunning           PredictionPhase = "RunningModelsCount"
	PredictionPhaseFailed            PredictionPhase = "FailedConditionReason"
	PredictionPhaseAborted           PredictionPhase = "Aborted"
	PredictionPhaseCompleted         PredictionPhase = "CompletedModelsCount"
	PredictionPhaseUnitTesting       PredictionPhase = "UnitTesting"
	PredictionPhaseUnitTested        PredictionPhase = "UnitTested"
)

type PredictionSpec 

type PredictionSpec struct {
	// The name of the DataProductVersion which describes the version of the resource
	// that exists in the same DataProduct namespace as the resource
	// +kubebuilder:default:=""
	// +kubebuilder:validation:Optional
	VersionName *string `json:"versionName,omitempty" protobuf:"bytes,1,opt,name=versionName"`
	// The model class for this pipeline
	// +kubebuilder:validation:Optional
	ModelClassName *string `json:"modelClassName,omitempty" protobuf:"bytes,2,opt,name=modelClassName"`
	// PredictorRef is the name of the Predictor resource that will be used to evaluate predictions for the
	// unlabeled input dataset. The Predictor must exist in the same DataProduct namespace as the resource
	// +kubebuilder:validation:Required
	// +required
	PredictorRef *v1.ObjectReference `json:"predictorRef,omitempty" protobuf:"bytes,3,opt,name=predictorRef"`
	// If true, measurements for the metrics specified by the `Tests` field will be computed for each prediction and
	// stored in the Prediction's status with the average result of all predictions
	// +kubebuilder:default:=false
	// Used usually for unit testing
	Labeled *bool `json:"labeled,omitempty" protobuf:"varint,4,opt,name=labeled"`
	// Indicates if the prediction is a forecast
	// +kubebuilder:default:=false
	// +kubebuilder:validation:Optional
	Forecast *bool `json:"forecast,omitempty" protobuf:"varint,5,opt,name=forecast"`
	// A reference to the input data source ref
	// +kubebuilder:validation:Optional
	DataSourceRef v1.ObjectReference `json:"dataSourceRef,omitempty" protobuf:"bytes,6,opt,name=dataSourceRef"`
	// Output specifies the location where the predicted dataset will be stored
	// +kubebuilder:validation:Optional
	Input data.DataInputSpec `json:"input,omitempty" protobuf:"bytes,7,opt,name=input"`
	// Output specifies the location where the predicted dataset will be stored
	// +kubebuilder:validation:Optional
	Output data.DataOutputSpec `json:"output,omitempty" protobuf:"bytes,8,opt,name=output"`
	// If true create output dataset
	// +kubebuilder:default:=false
	// +kubebuilder:validation:Optional
	CreateDataset *bool `json:"createDataset,omitempty" protobuf:"bytes,9,opt,name=createDataset"`
	// Tests specifies a collection of metrics that will be computed for each prediction
	// if the Labeled field of the Prediction is enabled
	// +kubebuilder:validation:Optional
	UnitTests training.ModelTestSuite `json:"unitTests,omitempty" protobuf:"bytes,10,opt,name=unitTests"`
	// The name of the Account which created the object, which exists in the same tenant as the object
	// +kubebuilder:default:="no-one"
	// +kubebuilder:validation:Optional
	Owner *string `json:"owner,omitempty" protobuf:"bytes,11,opt,name=owner"`
	// Resources specifies the resource requirements that will be allocated to the batch prediction Job
	// +kubebuilder:validation:Optional
	Resources catalog.ResourceSpec `json:"resources,omitempty" protobuf:"bytes,12,opt,name=resources"`
	// The deadline for the batch prediction Job to be completed in seconds
	// +kubebuilder:default:=600
	// +kubebuilder:validation:Minimum=0
	// +kubebuilder:validation:Optional
	ActiveDeadlineSeconds *int64 `json:"activeDeadlineSeconds,omitempty" protobuf:"varint,13,opt,name=activeDeadlineSeconds"`
	// The priority of the Kubernetes Job created by the Prediction (medium, by default)
	// +kubebuilder:default:=medium
	// +kubebuilder:validation:Optional
	Priority *catalog.PriorityLevel `json:"priority,omitempty" protobuf:"bytes,14,opt,name=priority"`
	// Indicates if the Prediction was aborted and should stop execution
	// +kubebuilder:default:=false
	// +kubebuilder:validation:Optional
	Aborted *bool `json:"aborted,omitempty" protobuf:"varint,15,opt,name=aborted"`
	// The time-to-live of the Prediction, after which the Prediction will be archived
	// +kubebuilder:default:=0
	// +kubebuilder:validation:Optional
	TTL *int32 `json:"ttl,omitempty" protobuf:"varint,16,opt,name=ttl"`
	// The forecasting specification in the case that the predicted model is a hierarchical forecast
	// +kubebuilder:validation:Optional
	ForecastSpec ForecastPredictionSpec `json:"forecastSpec,omitempty" protobuf:"bytes,17,opt,name=forecastSpec"`
	// The reference to the ServingSite resource that hosts the Prediction
	// +kubebuilder:validation:Optional
	ServingSiteRef v1.ObjectReference `json:"servingsiteRef" protobuf:"bytes,19,opt,name=servingsiteRef"`
	// Locations for group forecasts
	// +kubebuilder:validation:Optional
	PartitionLocation PartitionPredictionLocationsSpec `json:"partitionLocation" protobuf:"bytes,20,opt,name=partitionLocation"`
	// In case of batch prediction, how many workers.
	// +kubebuilder:default:=1
	// +kubebuilder:validation:Optional
	Workers *int32 `json:"workers" protobuf:"bytes,21,opt,name=workers"`
}

PredictionSpec represent the desired state of Prediction

func (*PredictionSpec) DeepCopy 

func (in *PredictionSpec) DeepCopy() *PredictionSpec

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

func (*PredictionSpec) DeepCopyInto 

func (in *PredictionSpec) DeepCopyInto(out *PredictionSpec)

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

func (*PredictionSpec) Descriptor 

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

func (*PredictionSpec) Marshal 

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

func (*PredictionSpec) MarshalTo 

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

func (*PredictionSpec) MarshalToSizedBuffer 

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

func (*PredictionSpec) ProtoMessage 

func (*PredictionSpec) ProtoMessage()

func (*PredictionSpec) Reset 

func (m *PredictionSpec) Reset()

func (*PredictionSpec) Size 

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

func (*PredictionSpec) String 

func (this *PredictionSpec) String() string

func (*PredictionSpec) Unmarshal 

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

func (*PredictionSpec) XXX_DiscardUnknown 

func (m *PredictionSpec) XXX_DiscardUnknown()

func (*PredictionSpec) XXX_Marshal 

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

func (*PredictionSpec) XXX_Merge 

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

func (*PredictionSpec) XXX_Size 

func (m *PredictionSpec) XXX_Size() int

func (*PredictionSpec) XXX_Unmarshal 

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

type PredictionStatus 

type PredictionStatus struct {
	// CompletedAt denotes the time when the batch prediction Job completed or failed
	CompletedAt *metav1.Time `json:"completedAt,omitempty" protobuf:"bytes,1,opt,name=completedAt"`
	// The current phase of the prediction
	// +kubebuilder:default:="Pending"
	// +kubebuilder:validation:Optional
	Phase PredictionPhase `json:"phase,omitempty" protobuf:"bytes,2,opt,name=phase"`
	// The collection of metrics that represent the average measurement across all predictions for each
	// metric specified by the Tests field of the Predictor
	// +kubebuilder:validation:Optional
	UnitTestsResult catalog.TestSuiteResult `json:"unitTestsResult,omitempty" protobuf:"bytes,3,opt,name=unitTestsResult"`
	// ObservedGeneration is the last generation that was acted on
	//+kubebuilder:validation:Optional
	ObservedGeneration int64 `json:"observedGeneration,omitempty" protobuf:"varint,4,opt,name=observedGeneration"`
	// The number of rows predicted
	//+kubebuilder:validation:Optional
	Rows int32 `json:"rows,omitempty" protobuf:"varint,5,opt,name=rows"`
	// The trigger that started the batch prediction
	//+kubebuilder:validation:Optional
	TriggeredBy catalog.TriggerType `json:"triggeredBy,omitempty" protobuf:"bytes,6,opt,name=triggeredBy"`
	// The location of logs produced by the batch prediction Job
	//+kubebuilder:validation:Optional
	Logs catalog.Logs `json:"logs,,omitempty" protobuf:"bytes,7,opt,name=logs"`
	// The last time the object was updated
	//+kubebuilder:validation:Optional
	UpdatedAt *metav1.Time `json:"updatedAt,omitempty" protobuf:"bytes,8,opt,name=updatedAt"`
	// In the case of failure, the Prediction resource controller will set this field with a failure reason
	//+kubebuilder:validation:Optional
	FailureReason *catalog.StatusError `json:"failureReason,omitempty" protobuf:"bytes,9,opt,name=failureReason"`
	// In the case of failure, the Prediction resource controller will set this field with a failure message
	//+kubebuilder:validation:Optional
	FailureMessage *string `json:"failureMessage,omitempty" protobuf:"bytes,10,opt,name=failureMessage"`
	// The dataset that was generated.
	//+kubebuilder:validation:Optional
	DatasetRef v1.ObjectReference `json:"datasetRef,omitempty" protobuf:"bytes,11,opt,name=datasetRef"`
	// The histogram values, map from column name to an histogram
	// +kubebuilder:validation:Optional
	Columns []data.ColumnHistogram `json:"columns,omitempty" protobuf:"bytes,12,rep,name=columns"`
	// Set to true if drifted
	// +kubebuilder:validation:Optional
	Drifted bool `json:"drifted,omitempty" protobuf:"bytes,13,rep,name=drifted"`
	// the forecast results for this forecast
	//+kubebuilder:validation:Optional
	Forecast ForecastStatus `json:"forecast,omitempty" protobuf:"bytes,14,opt,name=forecast"`
	// +patchMergeKey=type
	// +patchStrategy=merge
	// +kubebuilder:validation:Optional
	Conditions []PredictionCondition `json:"conditions,omitempty" patchStrategy:"merge" patchMergeKey:"type" protobuf:"bytes,15,rep,name=conditions"`
}

PredictionStatus is the observed state of a Prediction

func (*PredictionStatus) DeepCopy 

func (in *PredictionStatus) DeepCopy() *PredictionStatus

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

func (*PredictionStatus) DeepCopyInto 

func (in *PredictionStatus) DeepCopyInto(out *PredictionStatus)

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

func (*PredictionStatus) Descriptor 

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

func (*PredictionStatus) Marshal 

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

func (*PredictionStatus) MarshalTo 

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

func (*PredictionStatus) MarshalToSizedBuffer 

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

func (*PredictionStatus) ProtoMessage 

func (*PredictionStatus) ProtoMessage()

func (*PredictionStatus) Reset 

func (m *PredictionStatus) Reset()

func (*PredictionStatus) Size 

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

func (*PredictionStatus) String 

func (this *PredictionStatus) String() string

func (*PredictionStatus) Unmarshal 

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

func (*PredictionStatus) XXX_DiscardUnknown 

func (m *PredictionStatus) XXX_DiscardUnknown()

func (*PredictionStatus) XXX_Marshal 

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

func (*PredictionStatus) XXX_Merge 

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

func (*PredictionStatus) XXX_Size 

func (m *PredictionStatus) XXX_Size() int

func (*PredictionStatus) XXX_Unmarshal 

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

type Predictor 

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

+kubebuilder:object:root=true +kubebuilder:resource:path=predictors,singular=predictor,shortName=pdr,categories={inference,modela} +kubebuilder:subresource:status +kubebuilder:storageversion +kubebuilder:printcolumn:name="Ready",type="string",JSONPath=".status.conditions[?(@.type==\"Ready\")].status",description="" +kubebuilder:printcolumn:name="Owner",type="string",JSONPath=".spec.owner",priority=1 +kubebuilder:printcolumn:name="Serving Site",type="string",JSONPath=".spec.servingsiteRef.name",description="" +kubebuilder:printcolumn:name="Port",type="integer",JSONPath=".spec.access.port",description="" +kubebuilder:printcolumn:name="Access",type="string",JSONPath=".spec.access.accessType",description="" +kubebuilder:printcolumn:name="Replicas",type="integer",JSONPath=".spec.replicas",description="" +kubebuilder:printcolumn:name="Type",type="string",JSONPath=".spec.type",description="" +kubebuilder:printcolumn:name="Age",type="date",JSONPath=".metadata.creationTimestamp",description="" Predictor specifies the deployment of a service to serve predictions for a Model

func ParsePredictorYaml 

func ParsePredictorYaml(content []byte) (*Predictor, error)

func (*Predictor) AddFinalizer 

func (predictor *Predictor) AddFinalizer()

func (Predictor) ConstructGrpcRule added in v0.4.693 

func (predictor Predictor) ConstructGrpcRule(fqdn string, serviceName string) *nwv1.IngressRule

func (Predictor) ConstructRESTRule added in v0.4.693 

func (predictor Predictor) ConstructRESTRule(serviceName string) *nwv1.HTTPIngressPath

func (*Predictor) CreateOrUpdateCond 

func (predictor *Predictor) CreateOrUpdateCond(cond PredictorCondition)

Merge or update condition Merge or update condition

func (*Predictor) DeepCopy 

func (in *Predictor) DeepCopy() *Predictor

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

func (*Predictor) DeepCopyInto 

func (in *Predictor) DeepCopyInto(out *Predictor)

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

func (*Predictor) DeepCopyObject 

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

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

func (*Predictor) Default 

func (predictor *Predictor) Default()

func (Predictor) DeploymentName 

func (predictor Predictor) DeploymentName() string

func (Predictor) DeploymentURI added in v0.5.472 

func (predictor Predictor) DeploymentURI() string

dataproducts/*/predictor/*/manifests/deployment-<name>.yaml

func (*Predictor) Descriptor 

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

func (Predictor) FullServiceName 

func (predictor Predictor) FullServiceName() string

func (*Predictor) GetCond 

func (predictor *Predictor) GetCond(t PredictorConditionType) PredictorCondition

func (*Predictor) GetCondIdx 

func (predictor *Predictor) GetCondIdx(t PredictorConditionType) int

func (Predictor) GetLiveModel added in v0.4.1001 

func (predictor Predictor) GetLiveModel() *catalog.ModelDeploymentSpec

Get the first live model or none if none exist

func (*Predictor) GetLiveModelName added in v0.4.998 

func (predictor *Predictor) GetLiveModelName() string

Return the live model name.

func (Predictor) GetShadowModels added in v0.4.1001 

func (predictor Predictor) GetShadowModels() []catalog.ModelDeploymentSpec

func (Predictor) GreenName 

func (predictor Predictor) GreenName() string

func (Predictor) HasFinalizer 

func (predictor Predictor) HasFinalizer() bool

func (Predictor) IsFailed added in v0.4.675 

func (predictor Predictor) IsFailed() bool

func (Predictor) IsReady 

func (predictor Predictor) IsReady() bool

func (Predictor) IsSaved 

func (predictor Predictor) IsSaved() bool

func (Predictor) ManifestURI added in v0.5.472 

func (predictor Predictor) ManifestURI() string

func (*Predictor) MarkFailed added in v0.4.448 

func (predictor *Predictor) MarkFailed(err string)

func (*Predictor) MarkReady 

func (predictor *Predictor) MarkReady()

func (*Predictor) MarkSaved 

func (predictor *Predictor) MarkSaved()

func (*Predictor) Marshal 

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

func (*Predictor) MarshalTo 

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

func (*Predictor) MarshalToSizedBuffer 

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

func (Predictor) MirrorName 

func (predictor Predictor) MirrorName() string

func (*Predictor) ProtoMessage 

func (*Predictor) ProtoMessage()

func (*Predictor) RemoveFinalizer 

func (predictor *Predictor) RemoveFinalizer()

func (*Predictor) Reset 

func (m *Predictor) Reset()

func (Predictor) RootURI added in v0.5.472 

func (predictor Predictor) RootURI() string

func (Predictor) Selector 

func (predictor Predictor) Selector() *metav1.LabelSelector

func (Predictor) ServiceName 

func (predictor Predictor) ServiceName() string

func (Predictor) ServiceURI added in v0.5.472 

func (predictor Predictor) ServiceURI() string

dataproducts/*/predictor/*/manifests/service-<name>.yaml

func (*Predictor) SetupWebhookWithManager 

func (predictor *Predictor) SetupWebhookWithManager(mgr ctrl.Manager) error

func (*Predictor) Size 

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

func (*Predictor) String 

func (this *Predictor) String() string

func (*Predictor) Unmarshal 

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

func (*Predictor) UpdateK8sDeploymentStatus added in v0.4.972 

func (predictor *Predictor) UpdateK8sDeploymentStatus(model training.Model, deployment kapps.Deployment, k8sStatus KubernetesObjectStatus)

func (*Predictor) UpdateK8sServiceStatus added in v0.4.972 

func (predictor *Predictor) UpdateK8sServiceStatus(model training.Model, service v1.Service, k8sStatus KubernetesObjectStatus)

func (Predictor) ValidateCreate 

func (predictor Predictor) ValidateCreate() error

func (Predictor) ValidateDelete 

func (predictor Predictor) ValidateDelete() error

func (Predictor) ValidateUpdate 

func (predictor Predictor) ValidateUpdate(old runtime.Object) error

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

func (*Predictor) XXX_DiscardUnknown 

func (m *Predictor) XXX_DiscardUnknown()

func (*Predictor) XXX_Marshal 

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

func (*Predictor) XXX_Merge 

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

func (*Predictor) XXX_Size 

func (m *Predictor) XXX_Size() int

func (*Predictor) XXX_Unmarshal 

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

type PredictorCondition 

type PredictorCondition struct {
	// Type of Predictor condition
	Type PredictorConditionType `json:"type" protobuf:"bytes,1,opt,name=type,casttype=PredictorConditionType"`
	// Status of the condition, one of True, False, Unknown
	Status v1.ConditionStatus `json:"status" protobuf:"bytes,2,opt,name=status,casttype=k8s.io/api/core/v1.ConditionStatus"`
	// Last time the condition transitioned from one status to another
	LastTransitionTime *metav1.Time `json:"lastTransitionTime,omitempty" protobuf:"bytes,3,opt,name=lastTransitionTime"`
	// The reason for the condition's last transition
	Reason string `json:"reason,omitempty" protobuf:"bytes,4,opt,name=reason"`
	// A human-readable message indicating details about the transition
	Message string `json:"message,omitempty" protobuf:"bytes,5,opt,name=message"`
}

PredictorCondition describes the state of a Predictor at a certain point

func (*PredictorCondition) DeepCopy 

func (in *PredictorCondition) DeepCopy() *PredictorCondition

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

func (*PredictorCondition) DeepCopyInto 

func (in *PredictorCondition) DeepCopyInto(out *PredictorCondition)

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

func (*PredictorCondition) Descriptor 

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

func (*PredictorCondition) Marshal 

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

func (*PredictorCondition) MarshalTo 

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

func (*PredictorCondition) MarshalToSizedBuffer 

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

func (*PredictorCondition) ProtoMessage 

func (*PredictorCondition) ProtoMessage()

func (*PredictorCondition) Reset 

func (m *PredictorCondition) Reset()

func (*PredictorCondition) Size 

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

func (*PredictorCondition) String 

func (this *PredictorCondition) String() string

func (*PredictorCondition) Unmarshal 

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

func (*PredictorCondition) XXX_DiscardUnknown 

func (m *PredictorCondition) XXX_DiscardUnknown()

func (*PredictorCondition) XXX_Marshal 

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

func (*PredictorCondition) XXX_Merge 

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

func (*PredictorCondition) XXX_Size 

func (m *PredictorCondition) XXX_Size() int

func (*PredictorCondition) XXX_Unmarshal 

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

type PredictorConditionType 

type PredictorConditionType string

Predictor condition 

const (
	PredictorReady        PredictorConditionType = "Ready"
	PredictorSaved        PredictorConditionType = "Saved"
	PredictorBatchPredict PredictorConditionType = "BatchPredict" // Batch Predicting
)

/ Predictor Condition

type PredictorList 

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

+kubebuilder:object:root=true PredictorList contains a list of Predictors

func (*PredictorList) DeepCopy 

func (in *PredictorList) DeepCopy() *PredictorList

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

func (*PredictorList) DeepCopyInto 

func (in *PredictorList) DeepCopyInto(out *PredictorList)

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

func (*PredictorList) DeepCopyObject 

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

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

func (*PredictorList) Descriptor 

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

func (*PredictorList) Marshal 

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

func (*PredictorList) MarshalTo 

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

func (*PredictorList) MarshalToSizedBuffer 

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

func (*PredictorList) ProtoMessage 

func (*PredictorList) ProtoMessage()

func (*PredictorList) Reset 

func (m *PredictorList) Reset()

func (*PredictorList) Size 

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

func (*PredictorList) String 

func (this *PredictorList) String() string

func (*PredictorList) Unmarshal 

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

func (*PredictorList) XXX_DiscardUnknown 

func (m *PredictorList) XXX_DiscardUnknown()

func (*PredictorList) XXX_Marshal 

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

func (*PredictorList) XXX_Merge 

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

func (*PredictorList) XXX_Size 

func (m *PredictorList) XXX_Size() int

func (*PredictorList) XXX_Unmarshal 

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

type PredictorSpec 

type PredictorSpec struct {
	// If specified, the name of the DataProductVersion which describes the version of the resource
	// that exists in the same DataProduct namespace as the resource
	// +kubebuilder:default:=""
	// +kubebuilder:validation:Optional
	VersionName *string `json:"versionName,omitempty" protobuf:"bytes,1,opt,name=versionName"`
	// The model class for this pipeline
	// +kubebuilder:validation:Optional
	ModelClassName *string `json:"modelClassName,omitempty" protobuf:"bytes,2,opt,name=modelClassName"`
	// If specified, the user-provided description of the Predictor
	// +kubebuilder:validation:MaxLength=256
	// +kubebuilder:default:=""
	Description *string `json:"description,omitempty" protobuf:"bytes,3,opt,name=description"`
	// The reference to the DataProduct that the resource exists under
	ProductRef *v1.ObjectReference `json:"productRef" protobuf:"bytes,4,opt,name=productRef"`
	// If true, this predictor is a template predictor. I.e. it is used in model class
	// +kubebuilder:default:=false
	// +kubebuilder:validation:Optional
	Template *bool `json:"template" protobuf:"varint,5,opt,name=template"`
	// If true, create an online predictor. else this predictor is only for batch predictions.
	// +kubebuilder:default:=false
	// +kubebuilder:validation:Optional
	Online *bool `json:"online" protobuf:"varint,6,opt,name=online"`
	// If specified, the reference to the ServingSite resource that hosts the Predictor
	// If not specified, the predictor will be hosted on the default serving site.
	// +kubebuilder:validation:Optional
	ServingSiteRef *v1.ObjectReference `json:"servingsiteRef" protobuf:"bytes,7,opt,name=servingsiteRef"`
	// If specified, the collection of shadow models. A shadow model receives prediction request, but does
	// not serve the reply.
	// +kubebuilder:validation:Optional
	Models []catalog.ModelDeploymentSpec `json:"models,omitempty" protobuf:"bytes,8,rep,name=models"`
	// The specification to progressively deploy a new live model. ModelDeploymentSpec specifications within Models that have the
	// `Canary` field enabled will be progressively deployed according to the specification when they are applied to the Predictor
	// +kubebuilder:validation:Optional
	Progressive *ProgressiveSpec `json:"progressive,omitempty" protobuf:"bytes,9,opt,name=progressive"`
	// The data location where artifacts generated by the Predictor will be stored
	// +kubebuilder:validation:Optional
	ArtifactsFolder data.DataLocation `json:"artifactsFolder,omitempty" protobuf:"bytes,10,opt,name=artifactsFolder"`
	// Access specifies the configuration for the Predictor service to be exposed externally
	// +kubebuilder:validation:Optional
	Access catalog.AccessSpec `json:"access,omitempty" protobuf:"bytes,11,opt,name=access"`
	// The number of replicas for the Kubernetes Serving associated with the Predictor, which will instantiate multiple
	// copies of the service in the case that automatic scaling is disabled
	// +kubebuilder:validation:Optional
	Replicas *int32 `json:"replicas,omitempty" protobuf:"varint,12,opt,name=replicas"`
	// AutoScaling specifies the auto-scaling policy
	// +kubebuilder:validation:Optional
	AutoScaling AutoScalingSpec `json:"autoScaling,omitempty" protobuf:"bytes,13,opt,name=autoScaling"`
	// The name of the Account which created the object, which exists in the same tenant as the object
	// +kubebuilder:default:="no-one"
	// +kubebuilder:validation:Optional
	Owner *string `json:"owner,omitempty" protobuf:"bytes,14,opt,name=owner"`
	// Resources specifies the resource requirements allocated to the prediction service
	// +kubebuilder:validation:Optional
	Resources catalog.ResourceSpec `json:"resources,omitempty" protobuf:"bytes,15,opt,name=resources"`
	// Cache specifies the configuration of the prediction cache
	Cache PredictionCacheSpec `json:"cache,omitempty" protobuf:"bytes,16,opt,name=cache"`
	// Store specifies the configuration of the online data store
	Store OnlineFeatureStoreSpec `json:"store,omitempty" protobuf:"bytes,17,opt,name=store"`
	// Serving specifies the configuration for individual models to handle prediction traffic
	Serving ModelServingSpec `json:"serving,omitempty" protobuf:"bytes,18,opt,name=serving"`
	// The task type of the Predictor, which should match the task type of the models being served
	// +kubebuilder:default:="unknown"
	// +kubebuilder:validation:Optional
	Task *catalog.MLTask `json:"task,omitempty" protobuf:"bytes,19,opt,name=task"`
	// The prediction threshold
	// +kubebuilder:validation:Optional
	PredictionThreshold *float64 `json:"predictionThreshold,omitempty" protobuf:"bytes,20,opt,name=predictionThreshold"`
	// Spec for the drift detection process
	// +kubebuilder:validation:Optional
	Drift DriftDetectionSpec `json:"drift,omitempty" protobuf:"bytes,21,opt,name=drift"`
	// Spec for the ground truth process.
	// +kubebuilder:validation:Optional
	Feedback FeedbackTestSpec `json:"feedback,omitempty" protobuf:"bytes,22,opt,name=feedback"`
	// NotifierRef references a Notifier resource that will be triggered in the case that a concept or data drift is detected
	// +kubebuilder:validation:Optional
	NotifierRef *v1.ObjectReference `json:"notifierRef,omitempty" protobuf:"bytes,23,opt,name=notifierRef"`
	// Monitor spec specify the monitor for this predictor.
	// +kubebuilder:validation:Optional
	PredictionLogging PredictionLoggingSpec `json:"predictionLogging,omitempty" protobuf:"bytes,24,opt,name=predictionLogging"`
	// Forward curtain
	// +kubebuilder:validation:Optional
	ForwardCurtain ForwardCurtainSpec `json:"forwardCurtain,omitempty" protobuf:"bytes,25,opt,name=forwardCurtain"`
	// Backward curtain
	// +kubebuilder:validation:Optional
	BackwardCurtain BackwardCurtainSpec `json:"backwardCurtain,omitempty" protobuf:"bytes,26,opt,name=backwardCurtain"`
	// Fast slow is the specification of deployment of a fast - slow models.
	// +kubebuilder:validation:Optional
	FastSlow FastSlowModelSpec `json:"fastSlow,omitempty" protobuf:"bytes,27,opt,name=fastSlow"`
	// The batch prediction settings for this predictor
	// +kubebuilder:validation:Optional
	Batch BatchPredictionSpec `json:"batch,omitempty" protobuf:"bytes,28,opt,name=batch"`
}

PredictorSpec defines the desired state of a Predictor

func (*PredictorSpec) DeepCopy 

func (in *PredictorSpec) DeepCopy() *PredictorSpec

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

func (*PredictorSpec) DeepCopyInto 

func (in *PredictorSpec) DeepCopyInto(out *PredictorSpec)

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

func (*PredictorSpec) Descriptor 

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

func (*PredictorSpec) Marshal 

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

func (*PredictorSpec) MarshalTo 

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

func (*PredictorSpec) MarshalToSizedBuffer 

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

func (*PredictorSpec) ProtoMessage 

func (*PredictorSpec) ProtoMessage()

func (*PredictorSpec) Reset 

func (m *PredictorSpec) Reset()

func (*PredictorSpec) Size 

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

func (*PredictorSpec) String 

func (this *PredictorSpec) String() string

func (*PredictorSpec) Unmarshal 

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

func (*PredictorSpec) XXX_DiscardUnknown 

func (m *PredictorSpec) XXX_DiscardUnknown()

func (*PredictorSpec) XXX_Marshal 

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

func (*PredictorSpec) XXX_Merge 

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

func (*PredictorSpec) XXX_Size 

func (m *PredictorSpec) XXX_Size() int

func (*PredictorSpec) XXX_Unmarshal 

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

type PredictorStatus 

type PredictorStatus struct {
	// ObservedGeneration is the last generation that was acted on
	//+kubebuilder:validation:Optional
	ObservedGeneration int64 `json:"observedGeneration,omitempty" protobuf:"varint,1,opt,name=observedGeneration"`
	// The collection of historical records of models deployed to the Predictor, used internally to roll-back models
	//+kubebuilder:validation:Optional
	History []ModelRecord `json:"history,omitempty" protobuf:"bytes,2,opt,name=history"`
	// The status of the shadow models
	// +kubebuilder:validation:Optional
	ModelStatus []ModelDeploymentStatus `json:"modelsStatus,omitempty" protobuf:"bytes,4,rep,name=modelsStatus"`
	// The status of the Predictorlet associated with the Predictor. The Predictorlet is a service which handles prediction traffic
	// and routes predictions to individual models based on the specification of the Predictor
	// +kubebuilder:validation:Optional
	PredictorletStatus PredictorletStatus `json:"predictorletStatus,omitempty" protobuf:"bytes,5,opt,name=predictorletStatus"`
	// The status of the prediction cache managed by the Predictor
	// +kubebuilder:validation:Optional
	CacheStatus PredictionCacheStatus `json:"cacheStatus,omitempty" protobuf:"bytes,6,opt,name=cacheStatus"`
	// The status of the online store managed by the Predictor
	// +kubebuilder:validation:Optional
	OnlineStore OnlineStoreStatus `json:"onlineStoreStatus,omitempty" protobuf:"bytes,7,opt,name=onlineStoreStatus"`
	// The last time the object was updated
	//+kubebuilder:validation:Optional
	UpdatedAt *metav1.Time `json:"updatedAt,omitempty" protobuf:"bytes,8,opt,name=updatedAt"`
	// The end-point URL of the Predictor
	//+kubebuilder:validation:Optional
	EndPoint string `json:"endPoint,omitempty" protobuf:"bytes,9,opt,name=endPoint"`
	// In the case of failure, the Predictor resource controller will set this field with a failure reason
	//+kubebuilder:validation:Optional
	FailureReason *catalog.StatusError `json:"failureReason,omitempty" protobuf:"bytes,10,opt,name=failureReason"`
	// In the case of failure, the Predictor resource controller will set this field with a failure reason
	//+kubebuilder:validation:Optional
	FailureMessage *string `json:"failureMessage,omitempty" protobuf:"bytes,11,opt,name=failureMessage"`
	// The status of the load balancer, if the Predictor's access type is LoadBalancer
	//+kubebuilder:validation:Optional
	LoadBalancerStatus *v1.LoadBalancerStatus `json:"loadBalancerStatus,omitempty" protobuf:"bytes,12,opt,name=loadBalancerStatus"`
	// The last time that a prediction dataset was created
	//+kubebuilder:validation:Optional
	LastPredictionDataset v1.ObjectReference `json:"lastPredictionDataset,omitempty" protobuf:"bytes,13,opt,name=lastPredictionDataset"`
	// The results of running the serving tests
	//+kubebuilder:validation:Optional
	ServingTestResult catalog.TestSuiteResult `json:"servingTestResult,omitempty" protobuf:"bytes,14,opt,name=servingTestsResults"`
	// The status for the batch prediction.
	//+kubebuilder:validation:Optional
	PredictionSchedule catalog.RunScheduleStatus `json:"predictionSchedule,omitempty" protobuf:"bytes,15,opt,name=predictionSchedule"`
	// +patchMergeKey=type
	// +patchStrategy=merge
	// +kubebuilder:validation:Optional
	Conditions []PredictorCondition `json:"conditions,omitempty" patchStrategy:"merge" patchMergeKey:"type" protobuf:"bytes,17,rep,name=conditions"`
}

PredictorStatus contain the current state of the Predictor resource

func (*PredictorStatus) DeepCopy 

func (in *PredictorStatus) DeepCopy() *PredictorStatus

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

func (*PredictorStatus) DeepCopyInto 

func (in *PredictorStatus) DeepCopyInto(out *PredictorStatus)

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

func (*PredictorStatus) Descriptor 

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

func (*PredictorStatus) Marshal 

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

func (*PredictorStatus) MarshalTo 

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

func (*PredictorStatus) MarshalToSizedBuffer 

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

func (*PredictorStatus) ProtoMessage 

func (*PredictorStatus) ProtoMessage()

func (*PredictorStatus) Reset 

func (m *PredictorStatus) Reset()

func (*PredictorStatus) Size 

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

func (*PredictorStatus) String 

func (this *PredictorStatus) String() string

func (*PredictorStatus) Unmarshal 

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

func (*PredictorStatus) XXX_DiscardUnknown 

func (m *PredictorStatus) XXX_DiscardUnknown()

func (*PredictorStatus) XXX_Marshal 

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

func (*PredictorStatus) XXX_Merge 

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

func (*PredictorStatus) XXX_Size 

func (m *PredictorStatus) XXX_Size() int

func (*PredictorStatus) XXX_Unmarshal 

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

type PredictorletStatus added in v0.4.784 

type PredictorletStatus struct {
	// The image name that the Predictorlet is currently running
	// +kubebuilder:validation:Optional
	ImageName string `json:"imageName,omitempty" protobuf:"bytes,1,opt,name=imageName"`
	// The name of the Kubernetes Serving that manages the pods of the Predictorlet
	// +kubebuilder:validation:Optional
	DeploymentRef v1.ObjectReference `json:"deploymentRef,omitempty" protobuf:"bytes,2,opt,name=deploymentRef"`
	// The name of the Kubernetes Service which exposes the Predictorlet externally
	// +kubebuilder:validation:Optional
	ServiceRef v1.ObjectReference `json:"serviceRef,omitempty" protobuf:"bytes,3,opt,name=serviceRef"`
	// 50% latency (median) for predictions served by the Predictorlet
	// +kubebuilder:validation:Optional
	P50 float64 `json:"p50,omitempty" protobuf:"bytes,4,opt,name=p50"`
	// 95% latency for predictions served by the Predictorlet
	// +kubebuilder:validation:Optional
	P95 float64 `json:"p95,omitempty" protobuf:"bytes,5,opt,name=p95"`
	// 99% latency for predictions served by the Predictorlet
	// +kubebuilder:validation:Optional
	P99 float64 `json:"p99,omitempty" protobuf:"bytes,6,opt,name=p99"`
	// +kubebuilder:validation:Optional
	DailyPredictionAvg int32 `json:"dailyPredictionAvg,omitempty" protobuf:"varint,7,opt,name=dailyPredictionAvg"`
	// The total number of predictions served by the Predictorlet
	TotalPredictions int32 `json:"totalPredictions,omitempty" protobuf:"varint,8,opt,name=totalPredictions"`
	// The predictions from the last 7 days
	LastDailyPredictions []int32 `json:"lastDailyPredictions,omitempty" protobuf:"bytes,9,rep,name=lastDailyPredictions"`
	// The last time a prediction was served by the Predictorlet
	// +kubebuilder:validation:Optional
	LastPredictionTime *metav1.Time `json:"lastPredictionTime,omitempty" protobuf:"bytes,10,opt,name=lastPredictionTime"`
	// LastFailure contains the last failure that occured with a model served by the Predictorlet
	// +kubebuilder:validation:Optional
	LastFailure string `json:"lastFailure,omitempty" protobuf:"bytes,11,opt,name=lastFailure"`
	// +kubebuilder:validation:Optional
	ObjectStatuses []KubernetesObjectStatus `json:"objectStatuses,omitempty" protobuf:"bytes,12,rep,name=objectStatuses"`
}

PredictorletStatus describes the current state of a prediction proxy service associated with a Predictor

func (*PredictorletStatus) DeepCopy added in v0.4.784 

func (in *PredictorletStatus) DeepCopy() *PredictorletStatus

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

func (*PredictorletStatus) DeepCopyInto added in v0.4.784 

func (in *PredictorletStatus) DeepCopyInto(out *PredictorletStatus)

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

func (*PredictorletStatus) Descriptor added in v0.4.784 

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

func (*PredictorletStatus) Marshal added in v0.4.784 

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

func (*PredictorletStatus) MarshalTo added in v0.4.784 

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

func (*PredictorletStatus) MarshalToSizedBuffer added in v0.4.784 

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

func (*PredictorletStatus) ProtoMessage added in v0.4.784 

func (*PredictorletStatus) ProtoMessage()

func (*PredictorletStatus) Reset added in v0.4.784 

func (m *PredictorletStatus) Reset()

func (*PredictorletStatus) Size added in v0.4.784 

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

func (*PredictorletStatus) String added in v0.4.784 

func (this *PredictorletStatus) String() string

func (*PredictorletStatus) Unmarshal added in v0.4.784 

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

func (*PredictorletStatus) XXX_DiscardUnknown added in v0.4.784 

func (m *PredictorletStatus) XXX_DiscardUnknown()

func (*PredictorletStatus) XXX_Marshal added in v0.4.784 

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

func (*PredictorletStatus) XXX_Merge added in v0.4.784 

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

func (*PredictorletStatus) XXX_Size added in v0.4.784 

func (m *PredictorletStatus) XXX_Size() int

func (*PredictorletStatus) XXX_Unmarshal added in v0.4.784 

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

type ProgressiveSpec 

type ProgressiveSpec struct {
	// The time, in seconds, for the warm-up period
	// +kubebuilder:validation:Optional
	// +kubebuilder:validation:Maximum=100
	// +kubebuilder:validation:Minimum=0
	Warmup *int32 `json:"warmup,omitempty" protobuf:"varint,1,opt,name=warmup"`
	// The percentage of traffic to increment
	// +kubebuilder:validation:Maximum=10
	// +kubebuilder:validation:Minimum=1
	// +kubebuilder:validation:Optional
	TrafficIncrement *int32 `json:"trafficIncrement,omitempty" protobuf:"varint,2,opt,name=trafficIncrement"`
	// What metric to use when comparing the candidate model to the current model
	// +kubebuilder:validation:Optional
	CanaryMetrics []catalog.Metric `json:"canaryMetrics,omitempty" protobuf:"bytes,3,rep,name=canaryMetrics"`
}

ProgressiveSpec defines the specification to progressively deploy a model to production

func (*ProgressiveSpec) DeepCopy 

func (in *ProgressiveSpec) DeepCopy() *ProgressiveSpec

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

func (*ProgressiveSpec) DeepCopyInto 

func (in *ProgressiveSpec) DeepCopyInto(out *ProgressiveSpec)

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

func (*ProgressiveSpec) Descriptor 

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

func (*ProgressiveSpec) Marshal 

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

func (*ProgressiveSpec) MarshalTo 

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

func (*ProgressiveSpec) MarshalToSizedBuffer 

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

func (*ProgressiveSpec) ProtoMessage 

func (*ProgressiveSpec) ProtoMessage()

func (*ProgressiveSpec) Reset 

func (m *ProgressiveSpec) Reset()

func (*ProgressiveSpec) Size 

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

func (*ProgressiveSpec) String 

func (this *ProgressiveSpec) String() string

func (*ProgressiveSpec) Unmarshal 

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

func (*ProgressiveSpec) XXX_DiscardUnknown 

func (m *ProgressiveSpec) XXX_DiscardUnknown()

func (*ProgressiveSpec) XXX_Marshal 

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

func (*ProgressiveSpec) XXX_Merge 

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

func (*ProgressiveSpec) XXX_Size 

func (m *ProgressiveSpec) XXX_Size() int

func (*ProgressiveSpec) XXX_Unmarshal 

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

type ValidationError added in v0.4.907 

type ValidationError struct {
	// The name of the column
	Column string `json:"column,omitempty" protobuf:"bytes,1,opt,name=column"`
	// The metric from the rule
	Metric catalog.Metric `json:"metric,omitempty" protobuf:"bytes,2,opt,name=metric"`
	// Expected min
	Min float64 `json:"min,omitempty" protobuf:"bytes,3,opt,name=min"`
	// Expected max
	Max float64 `json:"max,omitempty" protobuf:"bytes,4,opt,name=max"`
	// Actual value
	Actual float64 `json:"actual,omitempty" protobuf:"bytes,5,opt,name=actual"`
}

func (*ValidationError) DeepCopy added in v0.4.908 

func (in *ValidationError) DeepCopy() *ValidationError

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

func (*ValidationError) DeepCopyInto added in v0.4.908 

func (in *ValidationError) DeepCopyInto(out *ValidationError)

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

func (*ValidationError) Descriptor added in v0.4.907 

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

func (*ValidationError) Marshal added in v0.4.907 

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

func (*ValidationError) MarshalTo added in v0.4.907 

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

func (*ValidationError) MarshalToSizedBuffer added in v0.4.907 

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

func (*ValidationError) ProtoMessage added in v0.4.907 

func (*ValidationError) ProtoMessage()

func (*ValidationError) Reset added in v0.4.907 

func (m *ValidationError) Reset()

func (*ValidationError) Size added in v0.4.907 

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

func (*ValidationError) String added in v0.4.907 

func (this *ValidationError) String() string

func (*ValidationError) Unmarshal added in v0.4.907 

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

func (*ValidationError) XXX_DiscardUnknown added in v0.4.907 

func (m *ValidationError) XXX_DiscardUnknown()

func (*ValidationError) XXX_Marshal added in v0.4.907 

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

func (*ValidationError) XXX_Merge added in v0.4.907 

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

func (*ValidationError) XXX_Size added in v0.4.907 

func (m *ValidationError) XXX_Size() int

func (*ValidationError) XXX_Unmarshal added in v0.4.907 

func (m *ValidationError) 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.