v1alpha1

package
v0.7.11 Latest Latest
Warning

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

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

Documentation

Overview

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

Index

Constants

View Source 
const (
	PredictorReady = "Ready"
	PredictorSaved = "Saved"
)

Predictor Condition

View Source 
const (
	DataAppReady = "Ready"
)

/ DataApp Condition

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"`
}

AutoScalingSpec 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 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,rep,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 metav1.Condition)

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 string) metav1.Condition

func (*DataApp) GetCondIdx 

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

func (DataApp) GetObservedGeneration added in v0.6.252 

func (dataapp DataApp) GetObservedGeneration() int64

func (DataApp) GetStatus added in v0.6.252 

func (dataapp DataApp) GetStatus() proto.Message

func (DataApp) HasFinalizer 

func (dataapp DataApp) HasFinalizer() bool

func (DataApp) IsFailed added in v0.4.675 

func (dataapp DataApp) IsFailed() bool

func (DataApp) IsReady 

func (dataapp DataApp) IsReady() bool

func (*DataApp) MarkFailed added in v0.6.252 

func (dataapp *DataApp) MarkFailed(err string)

func (*DataApp) MarkReady 

func (dataapp *DataApp) MarkReady()

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) ProtoMessage 

func (*DataApp) ProtoMessage()

func (*DataApp) RemoveFinalizer 

func (dataapp *DataApp) RemoveFinalizer()

func (*DataApp) Reset 

func (m *DataApp) Reset()

func (*DataApp) SetObservedGeneration added in v0.6.252 

func (dataapp *DataApp) SetObservedGeneration(generation int64)

func (*DataApp) SetStatus added in v0.6.252 

func (dataapp *DataApp) SetStatus(status interface{})

func (*DataApp) SetUpdatedAt added in v0.6.252 

func (dataapp *DataApp) SetUpdatedAt(time *metav1.Time)

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 DataAppConditionType 

type DataAppConditionType string

DataAppConditionType is the condition of a DataApp

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"`
	// +kubebuilder:default:=""
	// +kubebuilder:validation:Optional
	VersionName *string `json:"versionName,omitempty" protobuf:"bytes,2,opt,name=versionName"`
	// ModelClassName specifies the name of the Model Class which created the Data App, if applicable
	// +kubebuilder:validation:Optional
	ModelClassName *string `json:"modelClassName,omitempty" protobuf:"bytes,3,opt,name=modelClassName"`
	// The user-provided description of the Data App
	// +kubebuilder:validation:Optional
	// +kubebuilder:default:=""
	Description *string `json:"description,omitempty" protobuf:"bytes,4,opt,name=description"`
	// Model specifies the name of the Model resource which the Data App will create a dashboard for
	// +kubebuilder:default:=""
	// +kubebuilder:validation:Optional
	ModelName *string `json:"modelName,omitempty" protobuf:"bytes,5,opt,name=modelName"`
	// Access specifies the configuration for the Data App service to be exposed externally
	Access catalog.PredictorAccessSpec `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 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 []metav1.Condition `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"`
	// +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"`
	// 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
	// +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 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"`
}

ForecastPredictionSpec 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 {
	// +kubebuilder:validation:Optional
	Key string `json:"key,omitempty" protobuf:"bytes,1,opt,name=key"`
	// +kubebuilder:validation:Optional
	ModelLocation string `json:"modelLocation,omitempty" protobuf:"bytes,2,rep,name=modelLocation"`
	// 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 {
	// A pointer to the file containing metadata about forecast profiles
	// +kubebuilder:validation:Optional
	ProfileLocation string `json:"profileURI,omitempty" protobuf:"bytes,1,opt,name=profileURI"`
	// A pointer to the file containing metadata about forecast reports
	// +kubebuilder:validation:Optional
	ReportLocation string `json:"reportURI,omitempty" protobuf:"bytes,2,rep,name=reportURI"`
	// A pointer to the file containing the metadata about the forecasts
	// +kubebuilder:validation:Optional
	ForecastLocation catalog.FileLocation `json:"forecastLocation,omitempty" protobuf:"bytes,3,rep,name=forecastLocation"`
	// WorkerResults contains the collection of statuses for ongoing and completed forecast workers
	// +kubebuilder:validation:Optional
	WorkerResults []catalog.WorkerRunResult `json:"workerResults,omitempty" protobuf:"bytes,6,opt,name=workerResults"`
}

ForecastStatus specifies the status and metadata for a forecast

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:"varint,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 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 ModelDeploymentRecord added in v0.6.252 

type ModelDeploymentRecord struct {
	// +kubebuilder:validation:Optional
	ModelName string `json:"modelName,omitempty" protobuf:"bytes,1,opt,name=modelName"`
	// +kubebuilder:validation:Optional
	ModelVersion string `json:"modelVersion,omitempty" protobuf:"bytes,2,opt,name=modelVersion"`
	// The role of the previously deployed model
	ModelRole catalog.ModelRole `json:"modelRole,omitempty" protobuf:"bytes,3,opt,name=modelRole"`
	// The image name that the deployment is currently running
	// +kubebuilder:validation:Optional
	ImageName string `json:"imageName,omitempty" protobuf:"bytes,4,opt,name=imageName"`
	// +kubebuilder:validation:Optional
	DeployedAt *metav1.Time `json:"deployedAt,omitempty" protobuf:"bytes,5,opt,name=deployedAt"`
	// +kubebuilder:validation:Optional
	RetiredAt *metav1.Time `json:"retiredAt,omitempty" protobuf:"bytes,6,opt,name=retiredAt"`
	// +kubebuilder:validation:Optional
	FailureMessage *string `json:"failureMessage,omitempty" protobuf:"bytes,7,opt,name=failureMessage"`
	// +kubebuilder:validation:Optional
	AvgDailyPrediction int32 `json:"avgDailyPrediction,omitempty" protobuf:"varint,8,opt,name=avgDailyPrediction"`
	// +kubebuilder:validation:Optional
	AvgLatency float64 `json:"avgLatency,omitempty" protobuf:"bytes,9,opt,name=avgLatency"`
}

ModelDeploymentRecord holds the state of a model that was previously live or shadowed

func (*ModelDeploymentRecord) DeepCopy added in v0.6.252 

func (in *ModelDeploymentRecord) DeepCopy() *ModelDeploymentRecord

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

func (*ModelDeploymentRecord) DeepCopyInto added in v0.6.252 

func (in *ModelDeploymentRecord) DeepCopyInto(out *ModelDeploymentRecord)

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

func (*ModelDeploymentRecord) Descriptor added in v0.6.252 

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

func (*ModelDeploymentRecord) Marshal added in v0.6.252 

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

func (*ModelDeploymentRecord) MarshalTo added in v0.6.252 

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

func (*ModelDeploymentRecord) MarshalToSizedBuffer added in v0.6.252 

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

func (*ModelDeploymentRecord) ProtoMessage added in v0.6.252 

func (*ModelDeploymentRecord) ProtoMessage()

func (*ModelDeploymentRecord) Reset added in v0.6.252 

func (m *ModelDeploymentRecord) Reset()

func (*ModelDeploymentRecord) Size added in v0.6.252 

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

func (*ModelDeploymentRecord) String added in v0.6.252 

func (this *ModelDeploymentRecord) String() string

func (*ModelDeploymentRecord) Unmarshal added in v0.6.252 

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

func (*ModelDeploymentRecord) XXX_DiscardUnknown added in v0.6.252 

func (m *ModelDeploymentRecord) XXX_DiscardUnknown()

func (*ModelDeploymentRecord) XXX_Marshal added in v0.6.252 

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

func (*ModelDeploymentRecord) XXX_Merge added in v0.6.252 

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

func (*ModelDeploymentRecord) XXX_Size added in v0.6.252 

func (m *ModelDeploymentRecord) XXX_Size() int

func (*ModelDeploymentRecord) XXX_Unmarshal added in v0.6.252 

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

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 role of the model (live or shadow)
	ModelRole catalog.ModelRole `json:"modelRole,omitempty" protobuf:"bytes,3,opt,name=modelRole"`
	// The image name that the deployment is currently running
	// +kubebuilder:validation:Optional
	ImageName string `json:"imageName,omitempty" protobuf:"bytes,4,opt,name=imageName"`
	// The reference to the Kubernetes Deployment that manages the pods for the Model
	// +kubebuilder:validation:Optional
	DeploymentRef *v1.ObjectReference `json:"deploymentRef,omitempty" protobuf:"bytes,5,opt,name=deploymentRef"`
	// The reference to the Kubernetes Service which exposes the Model externally
	// +kubebuilder:validation:Optional
	ServiceRef *v1.ObjectReference `json:"serviceRef,omitempty" protobuf:"bytes,6,opt,name=serviceRef"`
	// The reference to the Horizontal Pod Autoscaler, if enabled
	// +kubebuilder:validation:Optional
	HPARef *v1.ObjectReference `json:"hpaRef,omitempty" protobuf:"bytes,7,opt,name=hpaRef"`
	// FailureMessage contains the details of the last failure that occurred while deploying the Model
	// +kubebuilder:validation:Optional
	FailureMessage *string `json:"failureMessage,omitempty" protobuf:"bytes,8,opt,name=failureMessage"`
	// DeployedAt specifies the time that the Model deployment was created
	// +kubebuilder:validation:Optional
	DeployedAt *metav1.Time `json:"deployedAt,omitempty" protobuf:"bytes,9,opt,name=deployedAt"`
	// Reference to the last ground truth dataset that the model was tested against
	// +kubebuilder:validation:Optional
	LastFeedbackDatasetRef v1.ObjectReference `json:"lastFeedbackDatasetRef,omitempty" protobuf:"bytes,10,opt,name=lastFeedbackDatasetRef"`
	// The time at which the last ground truth test was performed
	// +kubebuilder:validation:Optional
	LastFeedbackTestAt *metav1.Time `json:"lastFeedbackTestAt,omitempty" protobuf:"bytes,11,opt,name=lastFeedbackTestAt"`
	// The results of the last ground truth test performed
	// +kubebuilder:validation:Optional
	LastFeedbackTestResults []catalog.Measurement `json:"lastFeedbackTestResults,omitempty" protobuf:"bytes,12,rep,name=lastFeedbackTestResults"`
	// MetricHistory contains the historical measurements of all previously performed ground truth tests
	// +kubebuilder:validation:Optional
	MetricHistory map[catalog.Metric]MetricHistory `json:"metricHistory,omitempty" protobuf:"bytes,13,opt,name=metricsHistory"`
	// +kubebuilder:validation:Optional
	AvgDailyPrediction int32 `json:"avgDailyPrediction,omitempty" protobuf:"varint,14,opt,name=avgDailyPrediction"`
	// +kubebuilder:validation:Optional
	AvgLatency float64 `json:"avgLatency,omitempty" protobuf:"bytes,15,opt,name=avgLatency"`
	// The end-point URL of the Model, in the case that the Predictor is exposed via an HTTP Ingress
	//+kubebuilder:validation:Optional
	Endpoint *string `json:"endpoint,omitempty" protobuf:"bytes,16,opt,name=endpoint"`
}

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 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"`
	// +kubebuilder:validation:Optional
	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 ModelSpec added in v0.6.310 

type ModelSpec struct {
	// The name of a packaged Model
	Name *string `json:"name,omitempty" protobuf:"bytes,1,opt,name=name"`
	// A reference to a Study Run, of which the best model will be used
	StudyRun *catalog.StudyRunReference `json:"studyRun,omitempty" protobuf:"bytes,2,opt,name=studyRun"`
	// The location of a Model package
	Location *catalog.FileLocation `json:"location,omitempty" protobuf:"bytes,3,opt,name=location"`
}

ModelSpec specifies the model that will be used for a Prediction

func (*ModelSpec) DeepCopy added in v0.6.310 

func (in *ModelSpec) DeepCopy() *ModelSpec

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

func (*ModelSpec) DeepCopyInto added in v0.6.310 

func (in *ModelSpec) DeepCopyInto(out *ModelSpec)

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

func (*ModelSpec) Descriptor added in v0.6.310 

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

func (*ModelSpec) Marshal added in v0.6.310 

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

func (*ModelSpec) MarshalTo added in v0.6.310 

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

func (*ModelSpec) MarshalToSizedBuffer added in v0.6.310 

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

func (*ModelSpec) ProtoMessage added in v0.6.310 

func (*ModelSpec) ProtoMessage()

func (*ModelSpec) Reset added in v0.6.310 

func (m *ModelSpec) Reset()

func (*ModelSpec) Size added in v0.6.310 

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

func (*ModelSpec) String added in v0.6.310 

func (this *ModelSpec) String() string

func (*ModelSpec) Unmarshal added in v0.6.310 

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

func (*ModelSpec) XXX_DiscardUnknown added in v0.6.310 

func (m *ModelSpec) XXX_DiscardUnknown()

func (*ModelSpec) XXX_Marshal added in v0.6.310 

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

func (*ModelSpec) XXX_Merge added in v0.6.310 

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

func (*ModelSpec) XXX_Size added in v0.6.310 

func (m *ModelSpec) XXX_Size() int

func (*ModelSpec) XXX_Unmarshal added in v0.6.310 

func (m *ModelSpec) 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 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="Owner",type="string",JSONPath=".spec.owner" +kubebuilder:printcolumn:name="Version",type="string",JSONPath=".status.version" +kubebuilder:printcolumn:name="Age",type="date",JSONPath=".metadata.creationTimestamp" +kubebuilder:printcolumn:name="Last Prediction",type="date",JSONPath=".status.lastRunAt",description="" Prediction represents a single batch prediction on a dataset

func (*Prediction) AddFinalizer 

func (prediction *Prediction) AddFinalizer()

func (*Prediction) CreateOrUpdateCondition added in v0.6.252 

func (prediction *Prediction) CreateOrUpdateCondition(condition metav1.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) Deleted added in v0.6.310 

func (prediction *Prediction) Deleted() bool

func (*Prediction) Descriptor 

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

func (*Prediction) GetCondition added in v0.6.252 

func (prediction *Prediction) GetCondition(conditionType PredictionConditionType) metav1.Condition

func (*Prediction) GetConditionIndex added in v0.6.252 

func (prediction *Prediction) GetConditionIndex(conditionType PredictionConditionType) int

func (*Prediction) GetObservedGeneration added in v0.6.252 

func (prediction *Prediction) GetObservedGeneration() int64

func (*Prediction) GetStatus added in v0.6.252 

func (prediction *Prediction) GetStatus() proto.Message

func (*Prediction) HasFinalizer 

func (prediction *Prediction) HasFinalizer() bool

func (*Prediction) ManifestURI added in v0.5.472 

func (prediction *Prediction) ManifestURI() string

func (*Prediction) MarkNotSaved added in v0.6.252 

func (prediction *Prediction) MarkNotSaved()

func (*Prediction) MarkSaved 

func (prediction *Prediction) MarkSaved()

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) ProtoMessage 

func (*Prediction) ProtoMessage()

func (*Prediction) RemoveFinalizer 

func (prediction *Prediction) RemoveFinalizer()

func (*Prediction) Reset 

func (m *Prediction) Reset()

func (*Prediction) RootURI added in v0.5.472 

func (prediction *Prediction) RootURI() string

func (Prediction) Saved added in v0.6.252 

func (prediction Prediction) Saved() bool

func (*Prediction) SetObservedGeneration added in v0.6.252 

func (prediction *Prediction) SetObservedGeneration(generation int64)

func (*Prediction) SetStatus added in v0.6.252 

func (prediction *Prediction) SetStatus(status interface{})

func (*Prediction) SetUpdatedAt added in v0.6.252 

func (prediction *Prediction) SetUpdatedAt(time *metav1.Time)

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 ConnectionName 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 PredictionConditionType 

type PredictionConditionType string

PredictionConditionType is the condition type of the prediction pipeline 

const (
	PredictionSaved PredictionConditionType = "Saved"
)

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 catalog.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 PredictionRun added in v0.6.252 

type PredictionRun struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`
	Spec              PredictionRunSpec   `json:"spec" protobuf:"bytes,2,opt,name=spec"`
	Status            PredictionRunStatus `json:"status,omitempty" protobuf:"bytes,3,opt,name=status"`
}

+kubebuilder:object:root=true +kubebuilder:subresource:status +kubebuilder:storageversion +kubebuilder:resource:path=predictionruns,shortName=prs,singular=predictionrun,categories={inference,modela} +kubebuilder:printcolumn:name="Ready",type="string",JSONPath=".status.conditions[?(@.type==\"Ready\")].status" +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" PredictionRun represents a single batch prediction on a dataset

func (*PredictionRun) Aborted added in v0.6.252 

func (predictionrun *PredictionRun) Aborted() bool

func (*PredictionRun) AddFinalizer added in v0.6.252 

func (predictionrun *PredictionRun) AddFinalizer()

func (*PredictionRun) Completed added in v0.6.252 

func (predictionrun *PredictionRun) Completed() bool

func (*PredictionRun) CompletionAlert added in v0.6.252 

func (predictionrun *PredictionRun) CompletionAlert(notification catalog.NotificationSpec) *infra.Alert

func (*PredictionRun) CreateOrUpdateCondition added in v0.6.252 

func (predictionrun *PredictionRun) CreateOrUpdateCondition(condition metav1.Condition)

func (*PredictionRun) DeepCopy added in v0.6.252 

func (in *PredictionRun) DeepCopy() *PredictionRun

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

func (*PredictionRun) DeepCopyInto added in v0.6.252 

func (in *PredictionRun) DeepCopyInto(out *PredictionRun)

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

func (*PredictionRun) DeepCopyObject added in v0.6.252 

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

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

func (*PredictionRun) Default added in v0.6.252 

func (predictionrun *PredictionRun) Default()

func (*PredictionRun) Deleted added in v0.6.310 

func (predictionrun *PredictionRun) Deleted() bool

func (*PredictionRun) Descriptor added in v0.6.252 

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

func (*PredictionRun) DriftAlert added in v0.6.252 

func (predictionrun *PredictionRun) DriftAlert(notification catalog.NotificationSpec, err error, columns []string) *infra.Alert

func (*PredictionRun) ErrorAlert added in v0.6.252 

func (predictionrun *PredictionRun) ErrorAlert(notification catalog.NotificationSpec, err error) *infra.Alert

func (*PredictionRun) ExternalStatusUpdated added in v0.6.310 

func (predictionrun *PredictionRun) ExternalStatusUpdated() bool

func (*PredictionRun) Failed added in v0.6.310 

func (predictionrun *PredictionRun) Failed() bool

func (*PredictionRun) GetCondition added in v0.6.252 

func (predictionrun *PredictionRun) GetCondition(condType PredictionRunConditionType) metav1.Condition

func (*PredictionRun) GetConditionIndex added in v0.6.252 

func (predictionrun *PredictionRun) GetConditionIndex(condType PredictionRunConditionType) int

func (*PredictionRun) GetObservedGeneration added in v0.6.252 

func (predictionrun *PredictionRun) GetObservedGeneration() int64

func (*PredictionRun) GetStatus added in v0.6.252 

func (predictionrun *PredictionRun) GetStatus() proto.Message

func (*PredictionRun) HasFinalizer added in v0.6.252 

func (predictionrun *PredictionRun) HasFinalizer() bool

func (*PredictionRun) HasScheduleTrigger added in v0.6.310 

func (predictionrun *PredictionRun) HasScheduleTrigger() bool

func (*PredictionRun) ManifestURI added in v0.6.252 

func (predictionrun *PredictionRun) ManifestURI() string

func (*PredictionRun) MarkAborted added in v0.6.252 

func (predictionrun *PredictionRun) MarkAborted()

func (*PredictionRun) MarkCompleted added in v0.6.252 

func (predictionrun *PredictionRun) MarkCompleted()

func (*PredictionRun) MarkExternalStatusNotUpdated added in v0.6.310 

func (predictionrun *PredictionRun) MarkExternalStatusNotUpdated()

func (*PredictionRun) MarkExternalStatusUpdated added in v0.6.310 

func (predictionrun *PredictionRun) MarkExternalStatusUpdated()

func (*PredictionRun) MarkFailed added in v0.6.252 

func (predictionrun *PredictionRun) MarkFailed(reason string, err string)

func (*PredictionRun) MarkPending added in v0.6.252 

func (predictionrun *PredictionRun) MarkPending()

func (*PredictionRun) MarkPrepareFailed added in v0.6.310 

func (predictionrun *PredictionRun) MarkPrepareFailed(reason string, msg string)

func (*PredictionRun) MarkPrepareSuccess added in v0.6.310 

func (predictionrun *PredictionRun) MarkPrepareSuccess()

func (*PredictionRun) MarkPreparing added in v0.6.310 

func (predictionrun *PredictionRun) MarkPreparing()

func (*PredictionRun) MarkRunning added in v0.6.252 

func (predictionrun *PredictionRun) MarkRunning()

func (*PredictionRun) MarkUnitTestFailed added in v0.6.252 

func (predictionrun *PredictionRun) MarkUnitTestFailed(reason string, err string)

func (*PredictionRun) MarkUnitTested added in v0.6.252 

func (predictionrun *PredictionRun) MarkUnitTested()

func (*PredictionRun) MarkUnitTesting added in v0.6.252 

func (predictionrun *PredictionRun) MarkUnitTesting()

func (*PredictionRun) Marshal added in v0.6.252 

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

func (*PredictionRun) MarshalTo added in v0.6.252 

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

func (*PredictionRun) MarshalToSizedBuffer added in v0.6.252 

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

func (*PredictionRun) Paused added in v0.6.310 

func (predictionrun *PredictionRun) Paused() bool

func (*PredictionRun) Prepared added in v0.6.310 

func (predictionrun *PredictionRun) Prepared() bool

func (*PredictionRun) ProtoMessage added in v0.6.252 

func (*PredictionRun) ProtoMessage()

func (*PredictionRun) ReachedMaxTime added in v0.6.310 

func (predictionrun *PredictionRun) ReachedMaxTime(prediction *Prediction) bool

func (*PredictionRun) Ready added in v0.6.310 

func (predictionrun *PredictionRun) Ready() bool

func (*PredictionRun) RemoveFinalizer added in v0.6.252 

func (predictionrun *PredictionRun) RemoveFinalizer()

func (*PredictionRun) Reset added in v0.6.252 

func (m *PredictionRun) Reset()

func (*PredictionRun) RootURI added in v0.6.252 

func (predictionrun *PredictionRun) RootURI() string

func (*PredictionRun) SetObservedGeneration added in v0.6.252 

func (predictionrun *PredictionRun) SetObservedGeneration(generation int64)

func (*PredictionRun) SetStatus added in v0.6.252 

func (predictionrun *PredictionRun) SetStatus(status interface{})

func (*PredictionRun) SetUpdatedAt added in v0.6.252 

func (predictionrun *PredictionRun) SetUpdatedAt(time *metav1.Time)

func (*PredictionRun) SetupWebhookWithManager added in v0.6.252 

func (predictionrun *PredictionRun) SetupWebhookWithManager(mgr ctrl.Manager) error

func (*PredictionRun) Size added in v0.6.252 

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

func (*PredictionRun) String added in v0.6.252 

func (this *PredictionRun) String() string

func (*PredictionRun) ToRunReference added in v0.6.310 

func (predictionrun *PredictionRun) ToRunReference() catalog.RunReference

func (*PredictionRun) UnitTested added in v0.6.252 

func (predictionrun *PredictionRun) UnitTested() bool

func (*PredictionRun) Unmarshal added in v0.6.252 

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

func (*PredictionRun) ValidateCreate added in v0.6.252 

func (predictionrun *PredictionRun) ValidateCreate() error

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

func (*PredictionRun) ValidateDelete added in v0.6.252 

func (predictionrun *PredictionRun) ValidateDelete() error

func (*PredictionRun) ValidateUpdate added in v0.6.252 

func (predictionrun *PredictionRun) ValidateUpdate(old runtime.Object) error

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

func (*PredictionRun) XXX_DiscardUnknown added in v0.6.252 

func (m *PredictionRun) XXX_DiscardUnknown()

func (*PredictionRun) XXX_Marshal added in v0.6.252 

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

func (*PredictionRun) XXX_Merge added in v0.6.252 

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

func (*PredictionRun) XXX_Size added in v0.6.252 

func (m *PredictionRun) XXX_Size() int

func (*PredictionRun) XXX_Unmarshal added in v0.6.252 

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

type PredictionRunConditionType added in v0.6.252 

type PredictionRunConditionType string

PredictionRunConditionType specifies the current condition of a PredictionRun 

const (
	PredictionRunPrepared              PredictionRunConditionType = "Prepared"
	PredictionRunCompleted             PredictionRunConditionType = "Completed"
	PredictionRunUnitTested            PredictionRunConditionType = "UnitTested"
	PredictionRunAborted               PredictionRunConditionType = "Aborted"
	PredictionRunReady                 PredictionRunConditionType = "Ready"
	PredictionRunPaused                PredictionRunConditionType = "Paused"
	PredictionRunExternalStatusUpdated PredictionRunConditionType = "ExternalStatusUpdated"
)

type PredictionRunList added in v0.6.252 

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

+kubebuilder:object:root=true PredictionRunList is a list of PredictionRuns

func (*PredictionRunList) DeepCopy added in v0.6.252 

func (in *PredictionRunList) DeepCopy() *PredictionRunList

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

func (*PredictionRunList) DeepCopyInto added in v0.6.252 

func (in *PredictionRunList) DeepCopyInto(out *PredictionRunList)

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

func (*PredictionRunList) DeepCopyObject added in v0.6.252 

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

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

func (*PredictionRunList) Descriptor added in v0.6.252 

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

func (*PredictionRunList) Marshal added in v0.6.252 

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

func (*PredictionRunList) MarshalTo added in v0.6.252 

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

func (*PredictionRunList) MarshalToSizedBuffer added in v0.6.252 

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

func (*PredictionRunList) ProtoMessage added in v0.6.252 

func (*PredictionRunList) ProtoMessage()

func (*PredictionRunList) Reset added in v0.6.252 

func (m *PredictionRunList) Reset()

func (*PredictionRunList) Size added in v0.6.252 

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

func (*PredictionRunList) String added in v0.6.252 

func (this *PredictionRunList) String() string

func (*PredictionRunList) Unmarshal added in v0.6.252 

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

func (*PredictionRunList) XXX_DiscardUnknown added in v0.6.252 

func (m *PredictionRunList) XXX_DiscardUnknown()

func (*PredictionRunList) XXX_Marshal added in v0.6.252 

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

func (*PredictionRunList) XXX_Merge added in v0.6.252 

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

func (*PredictionRunList) XXX_Size added in v0.6.252 

func (m *PredictionRunList) XXX_Size() int

func (*PredictionRunList) XXX_Unmarshal added in v0.6.252 

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

type PredictionRunPhase added in v0.6.252 

type PredictionRunPhase string

ModelPhase is the current phase of a model 

const (
	PredictionRunPhasePending     PredictionRunPhase = "Pending"
	PredictionRunPhasePreparing   PredictionRunPhase = "Preparing"
	PredictionRunPhasePrepared    PredictionRunPhase = "Prepared"
	PredictionRunPhaseRunning     PredictionRunPhase = "Running"
	PredictionRunPhaseFailed      PredictionRunPhase = "Failed"
	PredictionRunPhaseAborted     PredictionRunPhase = "Aborted"
	PredictionRunPhaseCompleted   PredictionRunPhase = "Completed"
	PredictionRunPhaseUnitTesting PredictionRunPhase = "UnitTesting"
	PredictionRunPhaseUnitTested  PredictionRunPhase = "UnitTested"
)

type PredictionRunSpec added in v0.6.252 

type PredictionRunSpec struct {
	// Owner specifies the name of the Account which the object belongs to
	// +kubebuilder:default:="no-one"
	// +kubebuilder:validation:Optional
	Owner *string `json:"owner,omitempty" protobuf:"bytes,1,opt,name=owner"`
	// PredictionName specifies the name of the Prediction resource which the snapshot will use to
	// determine the model, observation location, and post-processing options of the batch prediction
	// +kubebuilder:validation:Required
	// +required
	PredictionName string `json:"datasetName,omitempty" protobuf:"varint,2,opt,name=datasetName"`
	// Model specifies an optional model override to use for the run
	// +kubebuilder:validation:Optional
	Model *ModelSpec `json:"model,omitempty" protobuf:"bytes,3,opt,name=model"`
	// Timout specifies the time in seconds for the run to be completed. If unspecified, default to the deadline of the Prediction
	// +kubebuilder:validation:Optional
	Timeout *int32 `json:"timeout,omitempty" protobuf:"varint,4,opt,name=timeout"`
	// If true, the execution of new workloads associated with the run will be paused
	// +kubebuilder:default:=false
	// +kubebuilder:validation:Optional
	Pause *bool `json:"pause,omitempty" protobuf:"varint,5,opt,name=pause"`
	// If true, the run will be permanently aborted and all workloads created by the run will be removed
	// +kubebuilder:default:=false
	// +kubebuilder:validation:Optional
	Abort *bool `json:"abort,omitempty" protobuf:"varint,6,opt,name=abort"`
}

PredictionRunSpec defines the run configuration for a Prediction

func (*PredictionRunSpec) DeepCopy added in v0.6.252 

func (in *PredictionRunSpec) DeepCopy() *PredictionRunSpec

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

func (*PredictionRunSpec) DeepCopyInto added in v0.6.252 

func (in *PredictionRunSpec) DeepCopyInto(out *PredictionRunSpec)

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

func (*PredictionRunSpec) Descriptor added in v0.6.252 

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

func (*PredictionRunSpec) Marshal added in v0.6.252 

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

func (*PredictionRunSpec) MarshalTo added in v0.6.252 

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

func (*PredictionRunSpec) MarshalToSizedBuffer added in v0.6.252 

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

func (*PredictionRunSpec) ProtoMessage added in v0.6.252 

func (*PredictionRunSpec) ProtoMessage()

func (*PredictionRunSpec) Reset added in v0.6.252 

func (m *PredictionRunSpec) Reset()

func (*PredictionRunSpec) Size added in v0.6.252 

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

func (*PredictionRunSpec) String added in v0.6.252 

func (this *PredictionRunSpec) String() string

func (*PredictionRunSpec) Unmarshal added in v0.6.252 

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

func (*PredictionRunSpec) XXX_DiscardUnknown added in v0.6.252 

func (m *PredictionRunSpec) XXX_DiscardUnknown()

func (*PredictionRunSpec) XXX_Marshal added in v0.6.252 

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

func (*PredictionRunSpec) XXX_Merge added in v0.6.252 

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

func (*PredictionRunSpec) XXX_Size added in v0.6.252 

func (m *PredictionRunSpec) XXX_Size() int

func (*PredictionRunSpec) XXX_Unmarshal added in v0.6.252 

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

type PredictionRunStatus added in v0.6.252 

type PredictionRunStatus struct {
	// ObservedGeneration is the last generation that was acted on
	//+kubebuilder:validation:Optional
	ObservedGeneration int64 `json:"observedGeneration,omitempty" protobuf:"varint,1,opt,name=observedGeneration"`
	// PredictionManifestLocation specifies the location of the Prediction manifest used during the course of the run
	PredictionManifestLocation catalog.ManifestLocation `json:"predictionManifestLocation,omitempty" protobuf:"bytes,2,opt,name=predictionManifestLocation"`
	// RunVersion specifies the version of the run, which is determined when the Prediction manifest is saved
	RunVersion catalog.Version `json:"runVersion,omitempty" protobuf:"varint,4,opt,name=runVersion"`
	// Rows specifies the number of rows predicted
	//+kubebuilder:validation:Optional
	Rows int32 `json:"rows,omitempty" protobuf:"varint,5,opt,name=rows"`
	// The current phase of the prediction
	// +kubebuilder:default:="Pending"
	// +kubebuilder:validation:Optional
	Phase PredictionRunPhase `json:"phase,omitempty" protobuf:"bytes,6,opt,name=phase"`
	// UnitTestResults contains the results of the unit test phase
	// +kubebuilder:validation:Optional
	UnitTestResults catalog.TestSuiteResult `json:"unitTestResults,omitempty" protobuf:"bytes,7,opt,name=unitTestResults"`
	// FailureMessage is set to a failure message in the case that an error occurred during the run
	//+kubebuilder:validation:Optional
	FailureMessage *string `json:"failureMessage,omitempty" protobuf:"bytes,8,opt,name=failureMessage"`
	// Logs contains the location of all logs produced by run workloads
	//+kubebuilder:validation:Optional
	Logs catalog.Logs `json:"logs,,omitempty" protobuf:"bytes,9,opt,name=logs"`
	// Forecast specifies the forecast status for the run
	//+kubebuilder:validation:Optional
	Forecast ForecastStatus `json:"forecast,omitempty" protobuf:"bytes,10,opt,name=forecast"`
	// +kubebuilder:validation:Optional
	Usage catalog.ResourceConsumption `json:"usage,omitempty" protobuf:"bytes,11,rep,name=usage"`
	// +kubebuilder:validation:Optional
	UpdatedAt *metav1.Time `json:"updatedAt,omitempty" protobuf:"bytes,12,opt,name=updatedAt"`
	// CompletedAt specifies the time at which the run completed or failed
	// +kubebuilder:validation:Optional
	CompletedAt *metav1.Time `json:"completedAt,omitempty" protobuf:"bytes,13,opt,name=completedAt"`
	// +patchMergeKey=type
	// +patchStrategy=merge
	// +kubebuilder:validation:Optional
	Conditions []metav1.Condition `json:"conditions,omitempty" patchStrategy:"merge" patchMergeKey:"type" protobuf:"bytes,14,rep,name=conditions"`
}

PredictionRunStatus is the observed state of a PredictionRun

func (*PredictionRunStatus) DeepCopy added in v0.6.252 

func (in *PredictionRunStatus) DeepCopy() *PredictionRunStatus

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

func (*PredictionRunStatus) DeepCopyInto added in v0.6.252 

func (in *PredictionRunStatus) DeepCopyInto(out *PredictionRunStatus)

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

func (*PredictionRunStatus) Descriptor added in v0.6.252 

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

func (*PredictionRunStatus) Marshal added in v0.6.252 

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

func (*PredictionRunStatus) MarshalTo added in v0.6.252 

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

func (*PredictionRunStatus) MarshalToSizedBuffer added in v0.6.252 

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

func (*PredictionRunStatus) ProtoMessage added in v0.6.252 

func (*PredictionRunStatus) ProtoMessage()

func (*PredictionRunStatus) Reset added in v0.6.252 

func (m *PredictionRunStatus) Reset()

func (*PredictionRunStatus) Size added in v0.6.252 

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

func (*PredictionRunStatus) String added in v0.6.252 

func (this *PredictionRunStatus) String() string

func (*PredictionRunStatus) Unmarshal added in v0.6.252 

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

func (*PredictionRunStatus) XXX_DiscardUnknown added in v0.6.252 

func (m *PredictionRunStatus) XXX_DiscardUnknown()

func (*PredictionRunStatus) XXX_Marshal added in v0.6.252 

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

func (*PredictionRunStatus) XXX_Merge added in v0.6.252 

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

func (*PredictionRunStatus) XXX_Size added in v0.6.252 

func (m *PredictionRunStatus) XXX_Size() int

func (*PredictionRunStatus) XXX_Unmarshal added in v0.6.252 

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

type PredictionSpec 

type PredictionSpec struct {
	// 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,1,opt,name=owner"`
	// Description contains the user-provided description of the object
	// +kubebuilder:validation:MaxLength=512
	// +kubebuilder:default:=""
	// +kubebuilder:validation:Optional
	Description *string `json:"description,omitempty" protobuf:"bytes,2,opt,name=description"`
	// RunSpec specifies the configuration for runs created by the Prediction
	// +kubebuilder:validation:Required
	Run catalog.RunSpec `json:"run,omitempty" protobuf:"bytes,3,opt,name=run"`
	// The name of the Virtual Bucket where artifacts generated by the Prediction will be stored.
	// If empty, default to the Data Product's default artifact bucket
	// +kubebuilder:validation:Optional
	ArtifactBucketName *string `json:"artifactBucketName,omitempty" protobuf:"bytes,4,opt,name=artifactBucketName"`
	// The name of the Serving Site under which Jobs created by the Prediction will be executed.
	// If empty, default to the Data Product's default Lab
	// +kubebuilder:validation:Optional
	ServingSiteName *string `json:"servingSiteName,omitempty" protobuf:"bytes,5,opt,name=servingSiteName"`
	// The specification for the model that will be used for the Prediction
	// +kubebuilder:validation:Optional
	Model ModelSpec `json:"model,omitempty" protobuf:"bytes,6,opt,name=model"`
	// Input specifies the location of the prediction dataset
	// +kubebuilder:validation:Optional
	Input data.DataInputSpec `json:"input,omitempty" protobuf:"bytes,8,opt,name=input"`
	// Output specifies the location where the prediction results will be stored
	// +kubebuilder:validation:Optional
	Output data.DataOutputSpec `json:"output,omitempty" protobuf:"bytes,9,opt,name=output"`
	// Labeled indicates if the input dataset is labeled, in which case a batch prediction workload will not be created.
	// If enabled, a workload will be created to compute the metrics of the model based
	// on the labeled dataset and run the tests specified by UnitTests
	// +kubebuilder:default:=false
	Labeled *bool `json:"labeled,omitempty" protobuf:"varint,10,opt,name=labeled"`
	// +kubebuilder:validation:Optional
	UnitTests training.ModelTestSuite `json:"unitTests,omitempty" protobuf:"bytes,11,opt,name=unitTests"`
	// Resources specifies the resource requirements allocated to the batch prediction workload
	// +kubebuilder:validation:Optional
	Resources catalog.ResourceSpec `json:"resources,omitempty" protobuf:"bytes,12,opt,name=resources"`
	// Forecast specifies the configuration to perform a forecast
	// +kubebuilder:validation:Optional
	Forecast ForecastPredictionSpec `json:"forecast,omitempty" protobuf:"bytes,13,opt,name=forecast"`
	// ModelClassName references the name of the Model Class that created the resource, if applicable
	// +kubebuilder:validation:Optional
	ModelClassName *string `json:"modelClassName,omitempty" protobuf:"bytes,15,opt,name=modelClassName"`
}

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 {
	// ObservedGeneration specifies the last generation that was reconciled
	//+kubebuilder:validation:Optional
	ObservedGeneration int64 `json:"observedGeneration,omitempty" protobuf:"varint,1,opt,name=observedGeneration"`
	// Active contains a collection of references to currently active runs
	// +optional
	Active catalog.RunReferenceList `json:"active,omitempty" protobuf:"bytes,2,rep,name=active"`
	// LastRunVersion contains the integer version last used to create a run
	// +kubebuilder:default:=0
	LastRunVersion catalog.Version `json:"lastRunVersion,omitempty" protobuf:"varint,4,opt,name=lastRunVersion"`
	// AvailableRunVersions contains the collection of run versions which are ready for use.
	// Each version corresponds with an existing PredictionRun resource
	//+kubebuilder:validation:Optional
	AvailableRuns catalog.RunReferenceList `json:"availableRuns,omitempty" protobuf:"bytes,5,opt,name=availableRuns"`
	// LastRunAt specifies the time at which a run was last created for the Study
	//+kubebuilder:validation:Optional
	LastRunAt *metav1.Time `json:"lastRunAt,omitempty" protobuf:"bytes,6,opt,name=lastRunAt"`
	// LastFailureMessage specifies the failure message of the last run. If the last run succeeded, the field will be cleared
	//+kubebuilder:validation:Optional
	LastFailureMessage *string `json:"failureMessage,omitempty" protobuf:"bytes,7,opt,name=failureMessage"`
	// Schedule specifies the status of the run schedule
	//+kubebuilder:validation:Optional
	Schedule catalog.RunScheduleStatus `json:"schedule,omitempty" protobuf:"bytes,8,opt,name=schedule"`
	// UpdatedAt specifies the last time the Study was updated
	//+kubebuilder:validation:Optional
	UpdatedAt *metav1.Time `json:"updatedAt,omitempty" protobuf:"bytes,9,opt,name=updatedAt"`
	// +optional
	// +patchMergeKey=type
	// +patchStrategy=merge
	Conditions []metav1.Condition `json:"conditions,omitempty" patchStrategy:"merge" patchMergeKey:"type" protobuf:"bytes,10,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) ActiveModels added in v0.6.252 

func (predictor Predictor) ActiveModels() map[string]string

func (*Predictor) AddFinalizer 

func (predictor *Predictor) AddFinalizer()

func (Predictor) ClusterRole added in v0.5.498 

func (predictor Predictor) ClusterRole() *rbacv1.ClusterRole

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 metav1.Condition)

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 string) metav1.Condition

func (*Predictor) GetCondIdx 

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

func (Predictor) GetDeploymentStatus added in v0.6.252 

func (predictor Predictor) GetDeploymentStatus(name, image string, role catalog.ModelRole) *ModelDeploymentStatus

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) GetObservedGeneration added in v0.6.252 

func (predictor Predictor) GetObservedGeneration() int64

func (Predictor) GetShadowModels added in v0.4.1001 

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

func (Predictor) GetStatus added in v0.6.252 

func (predictor Predictor) GetStatus() proto.Message

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) ManifestURI added in v0.5.472 

func (predictor Predictor) ManifestURI() string

func (*Predictor) MarkFailed added in v0.4.448 

func (predictor *Predictor) MarkFailed(reason string, err string)

func (*Predictor) MarkReady 

func (predictor *Predictor) MarkReady()

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) RoleBinding added in v0.5.498 

func (predictor Predictor) RoleBinding(ns string) *rbacv1.RoleBinding

Create a role binding for a job

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) SetLiveModel added in v0.5.582 

func (predictor *Predictor) SetLiveModel(model *training.Model) error

Set the live model to the new model, if the new model is already a shadow model, return an error

func (*Predictor) SetObservedGeneration added in v0.6.252 

func (predictor *Predictor) SetObservedGeneration(generation int64)

func (*Predictor) SetStatus added in v0.6.252 

func (predictor *Predictor) SetStatus(status interface{})

func (*Predictor) SetUpdatedAt added in v0.6.252 

func (predictor *Predictor) SetUpdatedAt(time *metav1.Time)

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) 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 PredictorConditionType 

type PredictorConditionType string

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. if was created to serve model class models.
	// +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"`
	// ServingSiteRef specifies the reference to the Serving Site that the Predictor will be hosted under
	// +kubebuilder:validation:Optional
	ServingSiteRef v1.ObjectReference `json:"servingSiteRef" protobuf:"bytes,7,opt,name=servingSiteRef"`
	// If specified, the collection of models. There must be a least on live model
	// +kubebuilder:validation:MinItems=1
	// +kubebuilder:validation:MaxItems=16
	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"`
	// Access specifies the configuration for the Predictor service to be exposed externally
	// +kubebuilder:validation:Optional
	Access catalog.PredictorAccessSpec `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"`
	// Spec for the drift detection process
	// +kubebuilder:validation:Optional
	Drift DriftDetectionSpec `json:"drift,omitempty" protobuf:"bytes,21,opt,name=drift"`
	// Feedback specifies the configuration to generate feedback datasets
	// +kubebuilder:validation:Optional
	Feedback FeedbackTestSpec `json:"feedback,omitempty" protobuf:"bytes,22,opt,name=feedback"`
	// The notification specification that determines which notifiers will receive Alerts generated by the object
	// +kubebuilder:validation:Optional
	Notification *catalog.NotificationSpec `json:"notification,omitempty" protobuf:"bytes,23,opt,name=notification"`
	// 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"`
}

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.
	// When the name, role, or image of a previously deployed model is changed, it will be removed from ModelStatus
	// and appended as a record to History
	//+kubebuilder:validation:Optional
	History []ModelDeploymentRecord `json:"history,omitempty" protobuf:"bytes,2,rep,name=history"`
	// ModelStatus contains the collection of statuses for all live models
	// +kubebuilder:validation:Optional
	ModelStatus []ModelDeploymentStatus `json:"modelStatus,omitempty" protobuf:"bytes,4,rep,name=modelStatus"`
	// 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 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"`
	// 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"`
	// +patchMergeKey=type
	// +patchStrategy=merge
	// +kubebuilder:validation:Optional
	Conditions []metav1.Condition `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 reference to the Kubernetes Deployment that manages the pods for the prediction proxy
	// +kubebuilder:validation:Optional
	DeploymentRef *v1.ObjectReference `json:"deploymentRef,omitempty" protobuf:"bytes,1,opt,name=deploymentRef"`
	// The reference to the Kubernetes Service which exposes the Predictor externally
	// +kubebuilder:validation:Optional
	ServiceRef *v1.ObjectReference `json:"serviceRef,omitempty" protobuf:"bytes,2,opt,name=serviceRef"`
	// DeployedAt specifies the time that the Predictorlet deployment was created
	//+kubebuilder:validation:Optional
	DeployedAt *metav1.Time `json:"deployedAt,omitempty" protobuf:"bytes,3,opt,name=deployedAt"`
	// +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
	AvgDailyPrediction int32 `json:"avgDailyPrediction,omitempty" protobuf:"varint,7,opt,name=avgDailyPrediction"`
	// The total number of predictions served by the Predictorlet
	TotalPredictions int32 `json:"totalPredictions,omitempty" protobuf:"varint,8,opt,name=totalPredictions"`
	// The last time a prediction was served by the Predictorlet
	// +kubebuilder:validation:Optional
	LastPredictionTime *metav1.Time `json:"lastPredictionTime,omitempty" protobuf:"bytes,9,opt,name=lastPredictionTime"`
	// FailureMessage contains the details of the last failure that occurred while deploying the Predictorlet
	// +kubebuilder:validation:Optional
	FailureMessage *string `json:"failureMessage,omitempty" protobuf:"bytes,10,opt,name=failureMessage"`
}

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.