v1alpha1

Jan 18, 2024

Changes in this version

+ type ModelSpec struct

+ Location *catalog.FileLocation

+ Name *string

+ StudyRun *catalog.StudyRunReference

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

+ func (*ModelSpec) ProtoMessage()

+ func (in *ModelSpec) DeepCopy() *ModelSpec

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

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

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

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

+ func (m *ModelSpec) Reset()

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

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

+ func (m *ModelSpec) XXX_DiscardUnknown()

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

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

+ func (m *ModelSpec) XXX_Size() int

+ func (m *ModelSpec) XXX_Unmarshal(b []byte) error

+ func (this *ModelSpec) String() string

type Prediction

+ func (prediction *Prediction) Deleted() bool

type PredictionRun

+ func (predictionrun *PredictionRun) Deleted() bool

+ func (predictionrun *PredictionRun) ExternalStatusUpdated() bool

+ func (predictionrun *PredictionRun) Failed() bool

+ func (predictionrun *PredictionRun) HasScheduleTrigger() bool

+ func (predictionrun *PredictionRun) MarkExternalStatusNotUpdated()

+ func (predictionrun *PredictionRun) MarkExternalStatusUpdated()

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

+ func (predictionrun *PredictionRun) MarkPrepareSuccess()

+ func (predictionrun *PredictionRun) MarkPreparing()

+ func (predictionrun *PredictionRun) Paused() bool

+ func (predictionrun *PredictionRun) Prepared() bool

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

+ func (predictionrun *PredictionRun) Ready() bool

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

type PredictionRunConditionType

+ const PredictionRunExternalStatusUpdated

+ const PredictionRunPaused

+ const PredictionRunPrepared

+ const PredictionRunReady

type PredictionRunPhase

+ const PredictionRunPhasePrepared

+ const PredictionRunPhasePreparing

type PredictionRunSpec

+ Model *ModelSpec

type PredictionSpec

+ ArtifactBucketName *string

+ Model ModelSpec

+ ServingSiteName *string

type PredictionStatus

+ AvailableRuns catalog.RunReferenceList

Sep 21, 2023

Changes in this version

type DataApp

+ func (dataapp *DataApp) MarkFailed(err string)

+ func (dataapp *DataApp) SetObservedGeneration(generation int64)

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

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

+ func (dataapp DataApp) GetObservedGeneration() int64

+ func (dataapp DataApp) GetStatus() proto.Message

type ForecastRun

+ ModelLocation string

type ForecastStatus

+ ForecastLocation catalog.FileLocation

+ ProfileLocation string

+ ReportLocation string

+ type ModelDeploymentRecord struct

+ AvgDailyPrediction int32

+ AvgLatency float64

+ DeployedAt *metav1.Time

+ FailureMessage *string

+ ImageName string

+ ModelName string

+ ModelRole catalog.ModelRole

+ ModelVersion string

+ RetiredAt *metav1.Time

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

+ func (*ModelDeploymentRecord) ProtoMessage()

+ func (in *ModelDeploymentRecord) DeepCopy() *ModelDeploymentRecord

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

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

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

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

+ func (m *ModelDeploymentRecord) Reset()

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

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

+ func (m *ModelDeploymentRecord) XXX_DiscardUnknown()

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

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

+ func (m *ModelDeploymentRecord) XXX_Size() int

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

+ func (this *ModelDeploymentRecord) String() string

type ModelDeploymentStatus

+ AvgDailyPrediction int32

+ AvgLatency float64

+ Endpoint *string

+ FailureMessage *string

+ LastFeedbackTestAt *metav1.Time

+ ModelRole catalog.ModelRole

type Prediction

+ func (prediction *Prediction) CreateOrUpdateCondition(condition metav1.Condition)

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

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

+ func (prediction *Prediction) GetObservedGeneration() int64

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

+ func (prediction *Prediction) MarkNotSaved()

+ func (prediction *Prediction) SetObservedGeneration(generation int64)

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

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

+ func (prediction Prediction) Saved() bool

+ type PredictionRun struct

+ Spec PredictionRunSpec

+ Status PredictionRunStatus

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

+ func (*PredictionRun) ProtoMessage()

+ func (in *PredictionRun) DeepCopy() *PredictionRun

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

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

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

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

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

+ func (m *PredictionRun) Reset()

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

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

+ func (m *PredictionRun) XXX_DiscardUnknown()

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

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

+ func (m *PredictionRun) XXX_Size() int

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

+ func (predictionrun *PredictionRun) Aborted() bool

+ func (predictionrun *PredictionRun) AddFinalizer()

+ func (predictionrun *PredictionRun) Completed() bool

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

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

+ func (predictionrun *PredictionRun) Default()

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

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

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

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

+ func (predictionrun *PredictionRun) GetObservedGeneration() int64

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

+ func (predictionrun *PredictionRun) HasFinalizer() bool

+ func (predictionrun *PredictionRun) ManifestURI() string

+ func (predictionrun *PredictionRun) MarkAborted()

+ func (predictionrun *PredictionRun) MarkCompleted()

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

+ func (predictionrun *PredictionRun) MarkPending()

+ func (predictionrun *PredictionRun) MarkRunning()

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

+ func (predictionrun *PredictionRun) MarkUnitTested()

+ func (predictionrun *PredictionRun) MarkUnitTesting()

+ func (predictionrun *PredictionRun) RemoveFinalizer()

+ func (predictionrun *PredictionRun) RootURI() string

+ func (predictionrun *PredictionRun) SetObservedGeneration(generation int64)

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

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

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

+ func (predictionrun *PredictionRun) UnitTested() bool

+ func (predictionrun *PredictionRun) ValidateCreate() error

+ func (predictionrun *PredictionRun) ValidateDelete() error

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

+ func (this *PredictionRun) String() string

+ type PredictionRunConditionType string

+ const PredictionRunAborted

+ const PredictionRunCompleted

+ const PredictionRunUnitTested

+ type PredictionRunList struct

+ Items []PredictionRun

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

+ func (*PredictionRunList) ProtoMessage()

+ func (in *PredictionRunList) DeepCopy() *PredictionRunList

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

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

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

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

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

+ func (m *PredictionRunList) Reset()

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

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

+ func (m *PredictionRunList) XXX_DiscardUnknown()

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

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

+ func (m *PredictionRunList) XXX_Size() int

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

+ func (this *PredictionRunList) String() string

+ type PredictionRunPhase string

+ const PredictionRunPhaseAborted

+ const PredictionRunPhaseCompleted

+ const PredictionRunPhaseFailed

+ const PredictionRunPhasePending

+ const PredictionRunPhaseRunning

+ const PredictionRunPhaseUnitTested

+ const PredictionRunPhaseUnitTesting

+ type PredictionRunSpec struct

+ Abort *bool

+ ModelRef *v1.ObjectReference

+ Owner *string

+ Pause *bool

+ PredictionName string

+ Timeout *int64

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

+ func (*PredictionRunSpec) ProtoMessage()

+ func (in *PredictionRunSpec) DeepCopy() *PredictionRunSpec

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

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

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

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

+ func (m *PredictionRunSpec) Reset()

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

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

+ func (m *PredictionRunSpec) XXX_DiscardUnknown()

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

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

+ func (m *PredictionRunSpec) XXX_Size() int

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

+ func (this *PredictionRunSpec) String() string

+ type PredictionRunStatus struct

+ CompletedAt *metav1.Time

+ Conditions []metav1.Condition

+ FailureMessage *string

+ Forecast ForecastStatus

+ Logs catalog.Logs

+ ObservedGeneration int64

+ Phase PredictionRunPhase

+ PredictionManifestLocation catalog.ManifestLocation

+ Rows int32

+ RunVersion catalog.Version

+ UnitTestResults catalog.TestSuiteResult

+ UpdatedAt *metav1.Time

+ Usage catalog.ResourceConsumption

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

+ func (*PredictionRunStatus) ProtoMessage()

+ func (in *PredictionRunStatus) DeepCopy() *PredictionRunStatus

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

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

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

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

+ func (m *PredictionRunStatus) Reset()

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

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

+ func (m *PredictionRunStatus) XXX_DiscardUnknown()

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

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

+ func (m *PredictionRunStatus) XXX_Size() int

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

+ func (this *PredictionRunStatus) String() string

type PredictionSpec

+ Description *string

+ ModelRef *v1.ObjectReference

+ Run catalog.RunSpec

+ Schedule catalog.RunSchedule

+ StudyRunRef *catalog.StudyRunReference

type PredictionStatus

+ Active catalog.RunReferenceList

+ AvailableRunVersions catalog.VersionList

+ LastFailureMessage *string

+ LastRunAt *metav1.Time

+ LastRunVersion catalog.Version

+ Schedule catalog.RunScheduleStatus

+ Version catalog.Version

type Predictor

+ func (predictor *Predictor) SetObservedGeneration(generation int64)

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

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

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

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

+ func (predictor Predictor) GetObservedGeneration() int64

+ func (predictor Predictor) GetStatus() proto.Message

type PredictorSpec

+ Notification *catalog.NotificationSpec

type PredictorletStatus

+ AvgDailyPrediction int32

+ FailureMessage *string

Jan 16, 2023

Changes in this version

type Predictor

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

Jan 13, 2023

Changes in this version

type PredictionStatus

+ Usage catalog.ResourceConsumption

Dec 9, 2022

Changes in this version

type Predictor

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

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

+ func (predictor Predictor) ServiceAccount(ns string) *v1.ServiceAccount

Dec 5, 2022

Changes in this version

type PredictorStatus

+ UpdatedAt *metav1.Time

Dec 4, 2022

Changes in this version

type Prediction

+ func (prediction Prediction) ManifestURI() string

+ func (prediction Prediction) RootURI() string

type Predictor

+ func (predictor Predictor) DeploymentURI() string

+ func (predictor Predictor) ManifestURI() string

+ func (predictor Predictor) RootURI() string

+ func (predictor Predictor) ServiceURI() string

Dec 4, 2022

Changes in this version

type DataAppStatus

+ UpdatedAt *metav1.Time

type PredictionStatus

+ CompletedAt *metav1.Time

+ UpdatedAt *metav1.Time

Nov 17, 2022

Changes in this version

+ type PartitionPredictionLocationsSpec struct

+ GroupForecastFile *string

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

+ func (*PartitionPredictionLocationsSpec) ProtoMessage()

+ func (in *PartitionPredictionLocationsSpec) DeepCopy() *PartitionPredictionLocationsSpec

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

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

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

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

+ func (m *PartitionPredictionLocationsSpec) Reset()

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

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

+ func (m *PartitionPredictionLocationsSpec) XXX_DiscardUnknown()

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

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

+ func (m *PartitionPredictionLocationsSpec) XXX_Size() int

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

+ func (this *PartitionPredictionLocationsSpec) String() string

type PredictionSpec

+ PartitionLocation PartitionPredictionLocationsSpec

Nov 11, 2022

Changes in this version

type PredictionSpec

+ ModelClassRef v1.ObjectReference

Oct 27, 2022

Changes in this version

type BackwardCurtainSpec

+ AccountRef *v1.ObjectReference

type ForwardCurtainSpec

+ AccountRef *v1.ObjectReference

type PredictorConditionType

+ const PredictorBatchPredict

type PredictorSpec

+ Online *bool

Oct 26, 2022

Changes in this version

type PredictorStatus

+ LastPrediction *metav1.Time

Oct 26, 2022

Changes in this version

type PredictorStatus

+ PredictionSchedule catalog.RunScheduleStatus

Oct 21, 2022

Changes in this version

type BatchPredictionSpec

+ func (in *BatchPredictionSpec) DeepCopy() *BatchPredictionSpec

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

type PredictionSpec

+ Workers *int32

Oct 21, 2022

Changes in this version

+ type BatchPredictionSpec struct

+ Schedule catalog.RunSchedule

+ Template PredictionTemplate

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

+ func (*BatchPredictionSpec) ProtoMessage()

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

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

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

+ func (m *BatchPredictionSpec) Reset()

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

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

+ func (m *BatchPredictionSpec) XXX_DiscardUnknown()

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

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

+ func (m *BatchPredictionSpec) XXX_Size() int

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

+ func (this *BatchPredictionSpec) String() string

type PredictorSpec

+ Batch BatchPredictionSpec

Oct 17, 2022

Changes in this version

type DataAppSpec

+ ModelClassName *string

type PredictionSpec

+ ModelClassName *string

type PredictorSpec

+ ModelClassName *string

Oct 16, 2022

Changes in this version

type GroupPredictionLocationsSpec

+ func (in *GroupPredictionLocationsSpec) DeepCopy() *GroupPredictionLocationsSpec

+ func (in *GroupPredictionLocationsSpec) DeepCopyInto(out *GroupPredictionLocationsSpec)

Oct 4, 2022

Changes in this version

+ type GroupPredictionLocationsSpec struct

+ GroupForecastFile *string

+ func (*GroupPredictionLocationsSpec) Descriptor() ([]byte, []int)

+ func (*GroupPredictionLocationsSpec) ProtoMessage()

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

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

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

+ func (m *GroupPredictionLocationsSpec) Reset()

+ func (m *GroupPredictionLocationsSpec) Size() (n int)

+ func (m *GroupPredictionLocationsSpec) Unmarshal(dAtA []byte) error

+ func (m *GroupPredictionLocationsSpec) XXX_DiscardUnknown()

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

+ func (m *GroupPredictionLocationsSpec) XXX_Merge(src proto.Message)

+ func (m *GroupPredictionLocationsSpec) XXX_Size() int

+ func (m *GroupPredictionLocationsSpec) XXX_Unmarshal(b []byte) error

+ func (this *GroupPredictionLocationsSpec) String() string

type PredictionSpec

+ GroupLocation GroupPredictionLocationsSpec

Sep 26, 2022

Changes in this version

type ForecastStatus

+ ForecastURI string

+ ProfileURI string

+ ReportURI string

+ WorkerResults map[int32]string

type PredictionStatus

+ Forecast ForecastStatus

Aug 19, 2022

Changes in this version

type MetricHistory

+ func (in *MetricHistory) DeepCopy() *MetricHistory

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

Aug 19, 2022

Changes in this version

+ type MetricHistory struct

+ History []float64

+ Metric catalog.Metric

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

+ func (*MetricHistory) ProtoMessage()

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

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

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

+ func (m *MetricHistory) Reset()

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

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

+ func (m *MetricHistory) XXX_DiscardUnknown()

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

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

+ func (m *MetricHistory) XXX_Size() int

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

+ func (this *MetricHistory) String() string

type ModelDeploymentStatus

+ MetricHistory map[catalog.Metric]MetricHistory

Aug 14, 2022

Changes in this version

type PredictionStatus

+ Runs map[string]ForecastRunResult

Aug 14, 2022

Changes in this version

type ForecastRun

+ func (in *ForecastRun) DeepCopy() *ForecastRun

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

type ForecastRunResult

+ func (in *ForecastRunResult) DeepCopy() *ForecastRunResult

+ func (in *ForecastRunResult) DeepCopyInto(out *ForecastRunResult)

Aug 13, 2022

Changes in this version

+ type ForecastRun struct

+ Horizon training.PeriodSpec

+ Key string

+ ModelURI string

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

+ func (*ForecastRun) ProtoMessage()

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

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

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

+ func (m *ForecastRun) Reset()

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

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

+ func (m *ForecastRun) XXX_DiscardUnknown()

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

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

+ func (m *ForecastRun) XXX_Size() int

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

+ func (this *ForecastRun) String() string

+ type ForecastRunResult struct

+ DataURI string

+ Failed *bool

+ FailureMessage *string

+ Features map[training.TSFeature]float64

+ Key string

+ ProfileURI string

+ UnitTestsResult catalog.TestSuiteResult

+ func (*ForecastRunResult) Descriptor() ([]byte, []int)

+ func (*ForecastRunResult) ProtoMessage()

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

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

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

+ func (m *ForecastRunResult) Reset()

+ func (m *ForecastRunResult) Size() (n int)

+ func (m *ForecastRunResult) Unmarshal(dAtA []byte) error

+ func (m *ForecastRunResult) XXX_DiscardUnknown()

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

+ func (m *ForecastRunResult) XXX_Merge(src proto.Message)

+ func (m *ForecastRunResult) XXX_Size() int

+ func (m *ForecastRunResult) XXX_Unmarshal(b []byte) error

+ func (this *ForecastRunResult) String() string

type ForecastSpec

+ Runs map[string]ForecastRun

type ForecastStatus

+ Runs map[string]ForecastRunResult

Aug 13, 2022

Changes in this version

+ type ForecastItemResult struct

+ DataURI string

+ Failed *bool

+ FailureMessage *string

+ Features map[training.TSFeature]float64

+ Key []string

+ ProfileURI string

+ UnitTestsResult catalog.TestSuiteResult

+ func (*ForecastItemResult) Descriptor() ([]byte, []int)

+ func (*ForecastItemResult) ProtoMessage()

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

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

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

+ func (m *ForecastItemResult) Reset()

+ func (m *ForecastItemResult) Size() (n int)

+ func (m *ForecastItemResult) Unmarshal(dAtA []byte) error

+ func (m *ForecastItemResult) XXX_DiscardUnknown()

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

+ func (m *ForecastItemResult) XXX_Merge(src proto.Message)

+ func (m *ForecastItemResult) XXX_Size() int

+ func (m *ForecastItemResult) XXX_Unmarshal(b []byte) error

+ func (this *ForecastItemResult) String() string

type ForecastSpec

+ Keys []string

+ PredictionRef *v1.ObjectReference

type ForecastStatus

+ Failed int32

+ Items []ForecastItemResult

+ Total int32

Aug 12, 2022

Changes in this version

type Forecast

+ func (in *Forecast) DeepCopy() *Forecast

+ func (in *Forecast) DeepCopyInto(out *Forecast)

+ func (in *Forecast) DeepCopyObject() runtime.Object

type ForecastCondition

+ func (in *ForecastCondition) DeepCopy() *ForecastCondition

+ func (in *ForecastCondition) DeepCopyInto(out *ForecastCondition)

type ForecastForecastSpec

+ func (in *ForecastForecastSpec) DeepCopy() *ForecastForecastSpec

+ func (in *ForecastForecastSpec) DeepCopyInto(out *ForecastForecastSpec)

type ForecastList

+ func (in *ForecastList) DeepCopy() *ForecastList

+ func (in *ForecastList) DeepCopyInto(out *ForecastList)

+ func (in *ForecastList) DeepCopyObject() runtime.Object

type ForecastStatus

+ func (in *ForecastStatus) DeepCopy() *ForecastStatus

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

Aug 12, 2022

Changes in this version

+ type Forecast struct

+ Spec ForecastSpec

+ Status ForecastStatus

+ func ParseForecastYaml(content []byte) (*Forecast, error)

+ func (*Forecast) Descriptor() ([]byte, []int)

+ func (*Forecast) ProtoMessage()

+ func (fh *Forecast) DriftAlert(tenantRef *v1.ObjectReference, notifierName *string, columns []string) *infra.Alert

+ func (forecast *Forecast) AddFinalizer()

+ func (forecast *Forecast) CompletionAlert(tenantRef *v1.ObjectReference, notifierName *string) *infra.Alert

+ func (forecast *Forecast) ConstructDataset() (*data.Dataset, error)

+ func (forecast *Forecast) CreateOrUpdateCond(cond ForecastCondition)

+ func (forecast *Forecast) Default()

+ func (forecast *Forecast) ErrorAlert(tenantRef *v1.ObjectReference, notifierName *string, err error) *infra.Alert

+ func (forecast *Forecast) GetCond(t ForecastConditionType) ForecastCondition

+ func (forecast *Forecast) GetCondIdx(t ForecastConditionType) int

+ func (forecast *Forecast) HasFinalizer() bool

+ func (forecast *Forecast) IsCompleted() bool

+ func (forecast *Forecast) Key() string

+ func (forecast *Forecast) ManifestUri() string

+ func (forecast *Forecast) MarkArchived()

+ func (forecast *Forecast) MarkCompleted()

+ func (forecast *Forecast) MarkCreatingDataset()

+ func (forecast *Forecast) MarkFailed(msg string)

+ func (forecast *Forecast) MarkPending()

+ func (forecast *Forecast) MarkUnitTestFailed(msg string)

+ func (forecast *Forecast) MarkUnitTested()

+ func (forecast *Forecast) MarkUnitTesting()

+ func (forecast *Forecast) MarkWaitingForDataset()

+ func (forecast *Forecast) OpName() string

+ func (forecast *Forecast) PipelineName() string

+ func (forecast *Forecast) RemoveFinalizer()

+ func (forecast *Forecast) RepPath(root string) (string, error)

+ func (forecast *Forecast) RootUri() string

+ func (forecast *Forecast) SetupWebhookWithManager(mgr ctrl.Manager) error

+ func (forecast *Forecast) ValidateCreate() error

+ func (forecast *Forecast) ValidateDelete() error

+ func (forecast *Forecast) ValidateUpdate(old runtime.Object) error

+ func (in *Forecast) IsFailed() bool

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

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

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

+ func (m *Forecast) Reset()

+ func (m *Forecast) Size() (n int)

+ func (m *Forecast) Unmarshal(dAtA []byte) error

+ func (m *Forecast) XXX_DiscardUnknown()

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

+ func (m *Forecast) XXX_Merge(src proto.Message)

+ func (m *Forecast) XXX_Size() int

+ func (m *Forecast) XXX_Unmarshal(b []byte) error

+ func (run *Forecast) MarkRunning()

+ func (run *Forecast) RunStatus() *catalog.LastRunStatus

+ func (this *Forecast) String() string

+ func (version *Forecast) IsSaved() bool

+ func (version *Forecast) MarkSaved()

+ type ForecastCondition struct

+ LastTransitionTime *metav1.Time

+ Message string

+ Reason string

+ Status v1.ConditionStatus

+ Type ForecastConditionType

+ func (*ForecastCondition) Descriptor() ([]byte, []int)

+ func (*ForecastCondition) ProtoMessage()

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

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

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

+ func (m *ForecastCondition) Reset()

+ func (m *ForecastCondition) Size() (n int)

+ func (m *ForecastCondition) Unmarshal(dAtA []byte) error

+ func (m *ForecastCondition) XXX_DiscardUnknown()

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

+ func (m *ForecastCondition) XXX_Merge(src proto.Message)

+ func (m *ForecastCondition) XXX_Size() int

+ func (m *ForecastCondition) XXX_Unmarshal(b []byte) error

+ func (this *ForecastCondition) String() string

+ type ForecastConditionType string

+ const ForecastArchived

+ const ForecastCompleted

+ const ForecastSaved

+ const ForecastUnitTested

+ type ForecastForecastSpec struct

+ HierarchyValues map[string]string

+ Horizon training.PeriodSpec

+ func (*ForecastForecastSpec) Descriptor() ([]byte, []int)

+ func (*ForecastForecastSpec) ProtoMessage()

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

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

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

+ func (m *ForecastForecastSpec) Reset()

+ func (m *ForecastForecastSpec) Size() (n int)

+ func (m *ForecastForecastSpec) Unmarshal(dAtA []byte) error

+ func (m *ForecastForecastSpec) XXX_DiscardUnknown()

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

+ func (m *ForecastForecastSpec) XXX_Merge(src proto.Message)

+ func (m *ForecastForecastSpec) XXX_Size() int

+ func (m *ForecastForecastSpec) XXX_Unmarshal(b []byte) error

+ func (this *ForecastForecastSpec) String() string

+ type ForecastList struct

+ Items []Forecast

+ func (*ForecastList) Descriptor() ([]byte, []int)

+ func (*ForecastList) ProtoMessage()

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

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

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

+ func (m *ForecastList) Reset()

+ func (m *ForecastList) Size() (n int)

+ func (m *ForecastList) Unmarshal(dAtA []byte) error

+ func (m *ForecastList) XXX_DiscardUnknown()

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

+ func (m *ForecastList) XXX_Merge(src proto.Message)

+ func (m *ForecastList) XXX_Size() int

+ func (m *ForecastList) XXX_Unmarshal(b []byte) error

+ func (this *ForecastList) String() string

+ type ForecastPhase string

+ const ForecastPhaseAborted

+ const ForecastPhaseCompleted

+ const ForecastPhaseCreatingDataset

+ const ForecastPhaseFailed

+ const ForecastPhasePending

+ const ForecastPhaseRunning

+ const ForecastPhaseUnitTested

+ const ForecastPhaseUnitTesting

+ const ForecastPhaseWaitingForDataset

type ForecastSpec

+ Aborted *bool

+ ActiveDeadlineSeconds *int64

+ CreateDataset *bool

+ CronForecastName *string

+ DataSourceRef v1.ObjectReference

+ Forecast *bool

+ ForecastSpec ForecastForecastSpec

+ Input data.DataInputSpec

+ Labeled *bool

+ Output data.DataOutputSpec

+ Owner *string

+ PredictorRef *v1.ObjectReference

+ Priority *catalog.PriorityLevel

+ Resources catalog.ResourceSpec

+ ServingSiteRef v1.ObjectReference

+ TTL *int32

+ UnitTests training.ModelTestSuite

+ VersionName *string

+ type ForecastStatus struct

+ Columns []data.ColumnHistogram

+ Conditions []ForecastCondition

+ DatasetRef v1.ObjectReference

+ Drifted bool

+ EndTime *metav1.Time

+ FailureMessage *string

+ FailureReason *catalog.StatusError

+ LastUpdated *metav1.Time

+ Logs catalog.Logs

+ ObservedGeneration int64

+ Phase ForecastPhase

+ Rows int32

+ StartTime *metav1.Time

+ TriggeredBy catalog.TriggerType

+ UnitTestsResult catalog.TestSuiteResult

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

+ func (*ForecastStatus) ProtoMessage()

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

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

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

+ func (m *ForecastStatus) Reset()

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

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

+ func (m *ForecastStatus) XXX_DiscardUnknown()

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

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

+ func (m *ForecastStatus) XXX_Size() int

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

+ func (this *ForecastStatus) String() string

Aug 10, 2022

Changes in this version

type ForecastPredictionSpec

+ func (in *ForecastPredictionSpec) DeepCopy() *ForecastPredictionSpec

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

Aug 10, 2022

Changes in this version

+ type ForecastPredictionSpec struct

+ HierarchyValues map[string]string

+ Horizon training.PeriodSpec

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

+ func (*ForecastPredictionSpec) ProtoMessage()

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

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

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

+ func (m *ForecastPredictionSpec) Reset()

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

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

+ func (m *ForecastPredictionSpec) XXX_DiscardUnknown()

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

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

+ func (m *ForecastPredictionSpec) XXX_Size() int

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

+ func (this *ForecastPredictionSpec) String() string

type PredictionSpec

+ ForecastSpec ForecastPredictionSpec

Aug 9, 2022

Changes in this version

type Prediction

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

Aug 9, 2022

Changes in this version

type Prediction

+ func (prediction *Prediction) MarkUnitTested()

+ func (prediction *Prediction) MarkUnitTesting()

type PredictionConditionType

+ const PredictionUnitTested

type PredictionPhase

+ const PredictionPhaseUnitTested

+ const PredictionPhaseUnitTesting

type PredictionStatus

+ Drifted bool

Aug 9, 2022

Changes in this version

type Prediction

+ func (prediction *Prediction) MarkUnitTestFailed(msg string)

type PredictionStatus

+ Columns []data.ColumnHistogram

Aug 8, 2022

Changes in this version

type Prediction

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

+ func (run *Prediction) CreateDataset() *data.Dataset

type PredictionStatus

+ DatasetRef v1.ObjectReference

Aug 8, 2022

Changes in this version

type Prediction

+ func (prediction *Prediction) MarkCreatingDataset()

+ func (prediction *Prediction) MarkDetectingDrift()

+ func (prediction *Prediction) MarkPending()

+ func (prediction *Prediction) MarkWaitingForDataset()

type PredictionConditionType

+ const PredictionDrifted

type PredictionLoggingSpec

+ BackupConnectionRef v1.ObjectReference

+ BackupFreqSeconds *int32

type PredictionPhase

+ const PredictionPhaseCreatingDataset

+ const PredictionPhaseDetectingDrift

+ const PredictionPhaseWaitingForDataset

Aug 8, 2022

Changes in this version

type PredictionSpec

+ DataSourceRef v1.ObjectReference

Aug 4, 2022

Changes in this version

type DriftDetectionSpec

+ MinPredictions *int32

Aug 3, 2022

Changes in this version

type DriftDetectionSpec

+ GenDriftTests *bool

Aug 1, 2022

Changes in this version

type DriftDetectionSpec

+ DriftThresholds []data.DriftThreshold

Aug 1, 2022

Changes in this version

type DriftDetectionSpec

+ Columns []string

+ Generate *bool

Jul 26, 2022

Changes in this version

type ModelServingSpec

+ UnitTestsTemplate catalog.TestSuite

type PredictionSpec

+ CreateDataset *bool

+ InputRef v1.ObjectReference

+ PredictorRef *v1.ObjectReference

type PredictorStatus

+ ServingTestResult catalog.TestSuiteResult

Jul 23, 2022

Changes in this version

type DriftDetectionSpec

+ UnitTestsTemplate catalog.TestSuite

type FeedbackTestSpec

+ UnitTestsTemplate catalog.TestSuite

type PredictionSpec

+ UnitTests training.ModelTestSuite

type PredictionStatus

+ UnitTestsResult catalog.TestSuiteResult

Jul 23, 2022

Changes in this version

type PredictionStatus

+ TestsResult catalog.TestSuiteResult

Jul 22, 2022

Changes in this version

type PredictorStatus

+ DriftDetectionTestsResult catalog.TestSuiteResult

+ FeedbackTestsResult catalog.TestSuiteResult

Jul 22, 2022

Changes in this version

type PredictorStatus

+ DriftDetectionResult catalog.TestSuiteResult

Jul 18, 2022

Changes in this version

type DriftDetectionSpec

+ Thresholds []data.DriftThreshold

Jul 15, 2022

Changes in this version

type Predictor

+ func (p *Predictor) GetLiveModel() *catalog.ModelDeploymentSpec

+ func (p *Predictor) GetShadowModels() []catalog.ModelDeploymentSpec

Jul 15, 2022

Changes in this version

type Predictor

+ func (p *Predictor) GetLiveModelName() string

Jul 15, 2022

Changes in this version

type DriftDetectionSpec

+ ServingHistogramRef v1.ObjectReference

type PredictorStatus

+ ModelStatus []ModelDeploymentStatus

Jul 14, 2022

Changes in this version

type ModelDeploymentStatus

+ LastFeedbackDatasetRef v1.ObjectReference

+ LastFeedbackTest *metav1.Time

+ LastFeedbackTestResults []catalog.Measurement

type PredictorSpec

+ Feedback FeedbackTestSpec

Jul 13, 2022

Changes in this version

type DriftDetectionSpec

+ PeriodSeconds *int32

+ type FeedbackTestStatus struct

+ LastRun *metav1.Time

+ Results catalog.TestSuiteResult

+ func (*FeedbackTestStatus) Descriptor() ([]byte, []int)

+ func (*FeedbackTestStatus) ProtoMessage()

+ func (in *FeedbackTestStatus) DeepCopy() *FeedbackTestStatus

+ func (in *FeedbackTestStatus) DeepCopyInto(out *FeedbackTestStatus)

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

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

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

+ func (m *FeedbackTestStatus) Reset()

+ func (m *FeedbackTestStatus) Size() (n int)

+ func (m *FeedbackTestStatus) Unmarshal(dAtA []byte) error

+ func (m *FeedbackTestStatus) XXX_DiscardUnknown()

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

+ func (m *FeedbackTestStatus) XXX_Merge(src proto.Message)

+ func (m *FeedbackTestStatus) XXX_Size() int

+ func (m *FeedbackTestStatus) XXX_Unmarshal(b []byte) error

+ func (this *FeedbackTestStatus) String() string

type PredictorStatus

+ DriftStatus DriftDetectionStatus

+ FeedbackTests FeedbackTestStatus

Jul 13, 2022

Changes in this version

type DriftDetectionSpec

+ WindowSecs *int32

+ type FeedbackTestSpec struct

+ Enabled *bool

+ FeedbackDatasetRef v1.ObjectReference

+ Schedule catalog.RunSchedule

+ Tests catalog.TestSuite

+ TrainingDatasetRef v1.ObjectReference

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

+ func (*FeedbackTestSpec) ProtoMessage()

+ func (in *FeedbackTestSpec) DeepCopy() *FeedbackTestSpec

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

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

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

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

+ func (m *FeedbackTestSpec) Reset()

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

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

+ func (m *FeedbackTestSpec) XXX_DiscardUnknown()

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

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

+ func (m *FeedbackTestSpec) XXX_Size() int

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

+ func (this *FeedbackTestSpec) String() string

Jul 12, 2022

Changes in this version

type PredictorStatus

+ LiveStatus ModelDeploymentStatus

+ ShadowsStatus []ModelDeploymentStatus

Jul 11, 2022

Changes in this version

type DriftDetectionSpec

+ HistogramDurationMin *int32

+ MaxHistograms *int32

+ TresholdsTemplate data.DriftTresholdsSpec

type ModelDeploymentStatus

+ LastGroundTruthDatasetRef v1.ObjectReference

+ LastGroundTruthTest *metav1.Time

+ LastGroundTruthTestResults []catalog.Measurement

Jul 11, 2022

Changes in this version

type Predictor

+ func (p *Predictor) UpdateK8sDeploymentStatus(model training.Model, deployment kapps.Deployment, ...)

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

Jul 11, 2022

Changes in this version

type Predictor

+ func (p *Predictor) UpdateK8sStatus(model training.Model, deployment kapps.Deployment, ...)

Jul 11, 2022

Changes in this version

type PredictorSpec

+ Live catalog.ModelDeploymentSpec

+ Shadows []catalog.ModelDeploymentSpec

type PredictorStatus

+ Live ModelDeploymentStatus

+ Shadows []ModelDeploymentStatus

Jul 9, 2022

Changes in this version

type PredictorStatus

+ Models []ModelDeploymentStatus

Jul 7, 2022

Changes in this version

+ type DriftDetectionSpec struct

+ Enabled *bool

+ LiveHistogramRef v1.ObjectReference

+ OutlierDetectionModelRef v1.ObjectReference

+ Schedule catalog.RunSchedule

+ Tests catalog.TestSuite

+ TrainingHistogramRef v1.ObjectReference

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

+ func (*DriftDetectionSpec) ProtoMessage()

+ func (in *DriftDetectionSpec) DeepCopy() *DriftDetectionSpec

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

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

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

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

+ func (m *DriftDetectionSpec) Reset()

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

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

+ func (m *DriftDetectionSpec) XXX_DiscardUnknown()

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

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

+ func (m *DriftDetectionSpec) XXX_Size() int

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

+ func (this *DriftDetectionSpec) String() string

+ type DriftDetectionStatus struct

+ LastRun *metav1.Time

+ Results catalog.TestSuiteResult

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

+ func (*DriftDetectionStatus) ProtoMessage()

+ func (in *DriftDetectionStatus) DeepCopy() *DriftDetectionStatus

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

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

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

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

+ func (m *DriftDetectionStatus) Reset()

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

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

+ func (m *DriftDetectionStatus) XXX_DiscardUnknown()

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

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

+ func (m *DriftDetectionStatus) XXX_Size() int

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

+ func (this *DriftDetectionStatus) String() string

type GroundTruthTestSpec

+ func (in *GroundTruthTestSpec) DeepCopy() *GroundTruthTestSpec

+ func (in *GroundTruthTestSpec) DeepCopyInto(out *GroundTruthTestSpec)

type GroundTruthTestStatus

+ func (in *GroundTruthTestStatus) DeepCopy() *GroundTruthTestStatus

+ func (in *GroundTruthTestStatus) DeepCopyInto(out *GroundTruthTestStatus)

Jul 7, 2022

Changes in this version

+ type DriftDetectorSpec struct

+ Enabled *bool

+ LiveHistogramRef v1.ObjectReference

+ OutlierDetectionModelRef v1.ObjectReference

+ Schedule catalog.RunSchedule

+ Tests catalog.TestSuite

+ TrainingHistogramRef v1.ObjectReference

+ func (*DriftDetectorSpec) Descriptor() ([]byte, []int)

+ func (*DriftDetectorSpec) ProtoMessage()

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

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

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

+ func (m *DriftDetectorSpec) Reset()

+ func (m *DriftDetectorSpec) Size() (n int)

+ func (m *DriftDetectorSpec) Unmarshal(dAtA []byte) error

+ func (m *DriftDetectorSpec) XXX_DiscardUnknown()

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

+ func (m *DriftDetectorSpec) XXX_Merge(src proto.Message)

+ func (m *DriftDetectorSpec) XXX_Size() int

+ func (m *DriftDetectorSpec) XXX_Unmarshal(b []byte) error

+ func (this *DriftDetectorSpec) String() string

+ type DriftDetectorStatus struct

+ LastRun *metav1.Time

+ Results catalog.TestSuiteResult

+ func (*DriftDetectorStatus) Descriptor() ([]byte, []int)

+ func (*DriftDetectorStatus) ProtoMessage()

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

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

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

+ func (m *DriftDetectorStatus) Reset()

+ func (m *DriftDetectorStatus) Size() (n int)

+ func (m *DriftDetectorStatus) Unmarshal(dAtA []byte) error

+ func (m *DriftDetectorStatus) XXX_DiscardUnknown()

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

+ func (m *DriftDetectorStatus) XXX_Merge(src proto.Message)

+ func (m *DriftDetectorStatus) XXX_Size() int

+ func (m *DriftDetectorStatus) XXX_Unmarshal(b []byte) error

+ func (this *DriftDetectorStatus) String() string

+ type GroundTruthTestSpec struct

+ Enabled *bool

+ GroundTrueDatasetRef v1.ObjectReference

+ Schedule catalog.RunSchedule

+ Tests catalog.TestSuite

+ TrainingDatasetRef v1.ObjectReference

+ func (*GroundTruthTestSpec) Descriptor() ([]byte, []int)

+ func (*GroundTruthTestSpec) ProtoMessage()

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

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

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

+ func (m *GroundTruthTestSpec) Reset()

+ func (m *GroundTruthTestSpec) Size() (n int)

+ func (m *GroundTruthTestSpec) Unmarshal(dAtA []byte) error

+ func (m *GroundTruthTestSpec) XXX_DiscardUnknown()

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

+ func (m *GroundTruthTestSpec) XXX_Merge(src proto.Message)

+ func (m *GroundTruthTestSpec) XXX_Size() int

+ func (m *GroundTruthTestSpec) XXX_Unmarshal(b []byte) error

+ func (this *GroundTruthTestSpec) String() string

+ type GroundTruthTestStatus struct

+ LastRun *metav1.Time

+ Results catalog.TestSuiteResult

+ func (*GroundTruthTestStatus) Descriptor() ([]byte, []int)

+ func (*GroundTruthTestStatus) ProtoMessage()

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

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

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

+ func (m *GroundTruthTestStatus) Reset()

+ func (m *GroundTruthTestStatus) Size() (n int)

+ func (m *GroundTruthTestStatus) Unmarshal(dAtA []byte) error

+ func (m *GroundTruthTestStatus) XXX_DiscardUnknown()

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

+ func (m *GroundTruthTestStatus) XXX_Merge(src proto.Message)

+ func (m *GroundTruthTestStatus) XXX_Size() int

+ func (m *GroundTruthTestStatus) XXX_Unmarshal(b []byte) error

+ func (this *GroundTruthTestStatus) String() string

type PredictorSpec

+ Drift DriftDetectorSpec

+ GroundTruth GroundTruthTestSpec

+ NotifierRef *v1.ObjectReference

type PredictorStatus

+ Drift DriftDetectorStatus

+ GroundTruth GroundTruthTestStatus

Jul 6, 2022

Changes in this version

type PredictionSpec

+ Test training.ModelTest

type PredictionStatus

+ TestResult catalog.TestSuiteResult

Jul 6, 2022

Changes in this version

type PredictorMonitorSpec

+ func (in *PredictorMonitorSpec) DeepCopy() *PredictorMonitorSpec

+ func (in *PredictorMonitorSpec) DeepCopyInto(out *PredictorMonitorSpec)

Jul 6, 2022

Changes in this version

type PredictorMonitorSpec

+ Tests catalog.TestSuite

type PredictorStatus

+ LastMonitorResults catalog.TestSuiteResult

Jul 6, 2022

Changes in this version

+ type PredictorMonitorSpec struct

+ Enabled *bool

+ NotifierRef *v1.ObjectReference

+ OutlierDetectionModelRef v1.ObjectReference

+ Schedule catalog.RunSchedule

+ TestSuite catalog.TestSuite

+ func (*PredictorMonitorSpec) Descriptor() ([]byte, []int)

+ func (*PredictorMonitorSpec) ProtoMessage()

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

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

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

+ func (m *PredictorMonitorSpec) Reset()

+ func (m *PredictorMonitorSpec) Size() (n int)

+ func (m *PredictorMonitorSpec) Unmarshal(dAtA []byte) error

+ func (m *PredictorMonitorSpec) XXX_DiscardUnknown()

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

+ func (m *PredictorMonitorSpec) XXX_Merge(src proto.Message)

+ func (m *PredictorMonitorSpec) XXX_Size() int

+ func (m *PredictorMonitorSpec) XXX_Unmarshal(b []byte) error

+ func (this *PredictorMonitorSpec) String() string

Jul 6, 2022

Changes in this version

type MonitorPart

+ TestSuite catalog.TestSuite

Jul 5, 2022

Changes in this version

type MonitorPart

+ Tests catalog.TestSuite

Jul 3, 2022

Changes in this version

type PredictionLoggingSpec

+ Location data.DataLocation

+ Rows *int32

Jul 3, 2022

Changes in this version

type ForwardCurtainSpec

+ CurtainRef *v1.ObjectReference

Jul 3, 2022

Changes in this version

type BackwardCurtainSpec

+ func (in *BackwardCurtainSpec) DeepCopy() *BackwardCurtainSpec

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

type FastSlowModelSpec

+ func (in *FastSlowModelSpec) DeepCopy() *FastSlowModelSpec

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

type ForwardCurtainSpec

+ func (in *ForwardCurtainSpec) DeepCopy() *ForwardCurtainSpec

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

Jul 3, 2022

Changes in this version

+ type BackwardCurtainSpec struct

+ ConfidenceHigh *float64

+ ConfidenceLow *float64

+ CurtainRef *v1.ObjectReference

+ Enabled *bool

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

+ func (*BackwardCurtainSpec) ProtoMessage()

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

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

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

+ func (m *BackwardCurtainSpec) Reset()

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

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

+ func (m *BackwardCurtainSpec) XXX_DiscardUnknown()

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

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

+ func (m *BackwardCurtainSpec) XXX_Size() int

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

+ func (this *BackwardCurtainSpec) String() string

+ type FastSlowModelSpec struct

+ Enabled *bool

+ FastModelRef v1.ObjectReference

+ ProbaHighPct *int32

+ ProbaLowPct *int32

+ SlowModelRef v1.ObjectReference

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

+ func (*FastSlowModelSpec) ProtoMessage()

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

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

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

+ func (m *FastSlowModelSpec) Reset()

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

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

+ func (m *FastSlowModelSpec) XXX_DiscardUnknown()

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

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

+ func (m *FastSlowModelSpec) XXX_Size() int

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

+ func (this *FastSlowModelSpec) String() string

+ type ForwardCurtainSpec struct

+ Enabled *bool

+ ForwardCurtainRef *v1.ObjectReference

+ Percent *int32

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

+ func (*ForwardCurtainSpec) ProtoMessage()

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

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

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

+ func (m *ForwardCurtainSpec) Reset()

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

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

+ func (m *ForwardCurtainSpec) XXX_DiscardUnknown()

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

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

+ func (m *ForwardCurtainSpec) XXX_Size() int

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

+ func (this *ForwardCurtainSpec) String() string

type PredictionLoggingSpec

+ UploadIntervalMinutes *int32

type PredictorSpec

+ BackwardCurtain BackwardCurtainSpec

+ FastSlow FastSlowModelSpec

+ ForwardCurtain ForwardCurtainSpec

type PredictorStatus

+ GroundTrueMetrics []catalog.Metric

+ LastPredictionDataset *metav1.Time

Jun 30, 2022

Changes in this version

type MonitorPart

+ func (in *MonitorPart) DeepCopy() *MonitorPart

+ func (in *MonitorPart) DeepCopyInto(out *MonitorPart)

type ValidationError

+ func (in *ValidationError) DeepCopy() *ValidationError

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

Jun 30, 2022

Changes in this version

type ModelDeploymentStatus

+ Errors []ValidationError

+ type MonitorPart struct

+ Enabled *bool

+ NotifierRef *v1.ObjectReference

+ OutlierDetectionModelRef v1.ObjectReference

+ RefFreq catalog.Freq

+ RefInterval *int32

+ RefTraining *bool

+ Rules []catalog.ModelValidationRule

+ Schedule catalog.RunSchedule

+ func (*MonitorPart) Descriptor() ([]byte, []int)

+ func (*MonitorPart) ProtoMessage()

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

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

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

+ func (m *MonitorPart) Reset()

+ func (m *MonitorPart) Size() (n int)

+ func (m *MonitorPart) Unmarshal(dAtA []byte) error

+ func (m *MonitorPart) XXX_DiscardUnknown()

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

+ func (m *MonitorPart) XXX_Merge(src proto.Message)

+ func (m *MonitorPart) XXX_Size() int

+ func (m *MonitorPart) XXX_Unmarshal(b []byte) error

+ func (this *MonitorPart) String() string

type MonitorSpec

+ DataDrift MonitorPart

+ ModelPerformance MonitorPart

+ Other MonitorPart

+ PredictionDrift MonitorPart

+ ServiceHealth MonitorPart

+ type ValidationError struct

+ Actual float64

+ Column string

+ Max float64

+ Metric catalog.Metric

+ Min float64

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

+ func (*ValidationError) ProtoMessage()

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

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

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

+ func (m *ValidationError) Reset()

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

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

+ func (m *ValidationError) XXX_DiscardUnknown()

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

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

+ func (m *ValidationError) XXX_Size() int

+ func (m *ValidationError) XXX_Unmarshal(b []byte) error

+ func (this *ValidationError) String() string

Jun 27, 2022

Changes in this version

+ const ApiToken

+ const JwtToken

+ const None

type AccessSpec

+ AuthMethod *AuthMethod

+ type AuthMethod string

Jun 25, 2022

Changes in this version

type PredictionCacheSpec

+ ConnectionRef *v1.ObjectReference

Jun 23, 2022

Changes in this version

type DataAppSpec

+ Access AccessSpec

type MonitorSpec

+ OutlierDetectionModelRef v1.ObjectReference

Jun 22, 2022

Changes in this version

+ type AccessSpec struct

+ AccessType *catalog.AccessType

+ ApiKeySecretRef *v1.SecretReference

+ NodePort *int32

+ Path *string

+ Port *int32

+ REST *bool

+ func (*AccessSpec) Descriptor() ([]byte, []int)

+ func (*AccessSpec) ProtoMessage()

+ func (in *AccessSpec) DeepCopy() *AccessSpec

+ func (in *AccessSpec) DeepCopyInto(out *AccessSpec)

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

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

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

+ func (m *AccessSpec) Reset()

+ func (m *AccessSpec) Size() (n int)

+ func (m *AccessSpec) Unmarshal(dAtA []byte) error

+ func (m *AccessSpec) XXX_DiscardUnknown()

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

+ func (m *AccessSpec) XXX_Merge(src proto.Message)

+ func (m *AccessSpec) XXX_Size() int

+ func (m *AccessSpec) XXX_Unmarshal(b []byte) error

+ func (this *AccessSpec) String() string

+ type AutoScalingSpec struct

+ CpuAvgUtilization *int32

+ Enabled *bool

+ MaxReplicas *int32

+ MemAvgUtilization *int32

+ MinReplicas *int32

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

+ func (*AutoScalingSpec) ProtoMessage()

+ func (in *AutoScalingSpec) DeepCopy() *AutoScalingSpec

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

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

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

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

+ func (m *AutoScalingSpec) Reset()

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

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

+ func (m *AutoScalingSpec) XXX_DiscardUnknown()

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

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

+ func (m *AutoScalingSpec) XXX_Size() int

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

+ func (this *AutoScalingSpec) String() string

+ type HumanInTheLoopSpec struct

+ BackwardCurtainRef *v1.ObjectReference

+ Enabled *bool

+ ForwardCurtainRef *v1.ObjectReference

+ func (*HumanInTheLoopSpec) Descriptor() ([]byte, []int)

+ func (*HumanInTheLoopSpec) ProtoMessage()

+ func (in *HumanInTheLoopSpec) DeepCopy() *HumanInTheLoopSpec

+ func (in *HumanInTheLoopSpec) DeepCopyInto(out *HumanInTheLoopSpec)

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

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

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

+ func (m *HumanInTheLoopSpec) Reset()

+ func (m *HumanInTheLoopSpec) Size() (n int)

+ func (m *HumanInTheLoopSpec) Unmarshal(dAtA []byte) error

+ func (m *HumanInTheLoopSpec) XXX_DiscardUnknown()

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

+ func (m *HumanInTheLoopSpec) XXX_Merge(src proto.Message)

+ func (m *HumanInTheLoopSpec) XXX_Size() int

+ func (m *HumanInTheLoopSpec) XXX_Unmarshal(b []byte) error

+ func (this *HumanInTheLoopSpec) String() string

+ type ModelServingSpec struct

+ Serverless *bool

+ Type *PredictorType

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

+ func (*ModelServingSpec) ProtoMessage()

+ func (in *ModelServingSpec) DeepCopy() *ModelServingSpec

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

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

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

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

+ func (m *ModelServingSpec) Reset()

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

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

+ func (m *ModelServingSpec) XXX_DiscardUnknown()

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

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

+ func (m *ModelServingSpec) XXX_Size() int

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

+ func (this *ModelServingSpec) String() string

type MonitorSpec

+ NotifierRef *v1.ObjectReference

+ OutlierDetectionModel v1.ObjectReference

type OnlineFeatureStoreSpec

+ Enabled *bool

+ Hostname *string

type PredictionCacheSpec

+ Enabled *bool

+ Hostname *string

+ InMemory *bool

+ Redis *bool

+ type PredictionLoggingSpec struct

+ Enabled *bool

+ LogRequests *bool

+ LogResponses *bool

+ SamplePercent *int32

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

+ func (*PredictionLoggingSpec) ProtoMessage()

+ func (in *PredictionLoggingSpec) DeepCopy() *PredictionLoggingSpec

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

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

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

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

+ func (m *PredictionLoggingSpec) Reset()

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

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

+ func (m *PredictionLoggingSpec) XXX_DiscardUnknown()

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

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

+ func (m *PredictionLoggingSpec) XXX_Size() int

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

+ func (this *PredictionLoggingSpec) String() string

type PredictorSpec

+ Access AccessSpec

+ Humans HumanInTheLoopSpec

+ PredictionLogging PredictionLoggingSpec

+ Serving ModelServingSpec

Jun 12, 2022

Changes in this version

type ModelDeploymentStatus

+ HPARef v1.ObjectReference

+ ModelName string

+ ModelVersion string

Jun 11, 2022

Changes in this version

type KubernetesObjectStatus

+ Status K8sObjectStatusState

type ModelDeploymentStatus

+ ObjectStatuses []KubernetesObjectStatus

type PredictorletStatus

+ ObjectStatuses []KubernetesObjectStatus

Jun 11, 2022

Changes in this version

+ type KubernetesObjectStatus struct

+ Health *bool

+ Ref *v1.ObjectReference

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

+ func (*KubernetesObjectStatus) ProtoMessage()

+ func (in *KubernetesObjectStatus) DeepCopy() *KubernetesObjectStatus

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

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

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

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

+ func (m *KubernetesObjectStatus) Reset()

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

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

+ func (m *KubernetesObjectStatus) XXX_DiscardUnknown()

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

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

+ func (m *KubernetesObjectStatus) XXX_Size() int

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

+ func (this *KubernetesObjectStatus) String() string

Jun 11, 2022

Changes in this version

type ModelDeploymentStatus

+ DeploymentStatus K8sObjectStatus

+ ServiceStatus K8sObjectStatus

type PredictorletStatus

+ DeploymentStatus K8sObjectStatus

+ ServiceStatus K8sObjectStatus

Jun 11, 2022

Changes in this version

type K8SObjectStatus

+ Ref v11.ObjectReference

type K8sObjectStatus

+ Ref v1.ObjectReference

Jun 11, 2022

Changes in this version

type ModelDeploymentStatus

+ ResourceStatus []K8sObjectStatus

Jun 11, 2022

Changes in this version

+ type K8SObjectStatus struct

+ Age *v1.Time

+ Kind string

+ Name string

+ Namespace string

+ Status K8sObjectStatusState

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ func (*K8SObjectStatus) Descriptor() ([]byte, []int)

+ func (*K8SObjectStatus) ProtoMessage()

+ func (in *K8SObjectStatus) DeepCopy() *K8SObjectStatus

+ func (in *K8SObjectStatus) DeepCopyInto(out *K8SObjectStatus)

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

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

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

+ func (m *K8SObjectStatus) Reset()

+ func (m *K8SObjectStatus) Size() (n int)

+ func (m *K8SObjectStatus) Unmarshal(dAtA []byte) error

+ func (m *K8SObjectStatus) XXX_DiscardUnknown()

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

+ func (m *K8SObjectStatus) XXX_Merge(src proto.Message)

+ func (m *K8SObjectStatus) XXX_Size() int

+ func (m *K8SObjectStatus) XXX_Unmarshal(b []byte) error

+ func (this *K8SObjectStatus) String() string

+ type K8sObjectStatus struct

+ Age *metav1.Time

+ Kind string

+ Name string

+ Namespace string

+ Status K8sObjectStatusState

+ func AddOrUpdateK8sStatuses(current []K8sObjectStatus, status K8sObjectStatus) []K8sObjectStatus

+ func (in *K8sObjectStatus) DeepCopy() *K8sObjectStatus

+ func (in *K8sObjectStatus) DeepCopyInto(out *K8sObjectStatus)

+ type K8sObjectStatusState string

+ const K8sObjectStatusError

+ const K8sObjectStatusHealthy

+ const K8sObjectStatusUnknown

+ const K8sObjectStatusWarning