v1alpha1

package
v0.4.951 Latest Latest
Warning

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

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

Documentation

Overview

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

Index

Constants

View Source 
const PipelineLabelKey = "pipeline"

Variables

View Source 
var (
	ErrInvalidLengthGenerated        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowGenerated          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupGenerated = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	// SchemeBuilder registers our types
	SchemeBuilder = k8sruntime.NewSchemeBuilder(AddKnownTypes)
	// AddToScheme local alias for SchemeBuilder.AddToScheme
	AddToScheme = SchemeBuilder.AddToScheme
)
View Source 
var SchemeGroupVersion = schema.GroupVersion{Group: inference.GroupName, Version: "v1alpha1"}

SchemeGroupVersion is group version used to register these objects

Functions

func AddKnownTypes 

func AddKnownTypes(scheme *k8sruntime.Scheme) error

Adds the list of known types to api.Scheme.

func Kind 

func Kind(kind string) schema.GroupKind

Kind takes an unqualified kind and returns back a Group qualified GroupKind

func Resource 

func Resource(resource string) schema.GroupResource

Resource takes an unqualified resource and returns a Group qualified GroupResource

Types

type AccessSpec added in v0.4.878 

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

AccessSpec specifies the configuration to expose a Predictor service externally

func (*AccessSpec) DeepCopy added in v0.4.878 

func (in *AccessSpec) DeepCopy() *AccessSpec

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

func (*AccessSpec) DeepCopyInto added in v0.4.878 

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

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

func (*AccessSpec) Descriptor added in v0.4.878 

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

func (*AccessSpec) Marshal added in v0.4.878 

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

func (*AccessSpec) MarshalTo added in v0.4.878 

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

func (*AccessSpec) MarshalToSizedBuffer added in v0.4.878 

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

func (*AccessSpec) ProtoMessage added in v0.4.878 

func (*AccessSpec) ProtoMessage()

func (*AccessSpec) Reset added in v0.4.878 

func (m *AccessSpec) Reset()

func (*AccessSpec) Size added in v0.4.878 

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

func (*AccessSpec) String added in v0.4.878 

func (this *AccessSpec) String() string

func (*AccessSpec) Unmarshal added in v0.4.878 

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

func (*AccessSpec) XXX_DiscardUnknown added in v0.4.878 

func (m *AccessSpec) XXX_DiscardUnknown()

func (*AccessSpec) XXX_Marshal added in v0.4.878 

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

func (*AccessSpec) XXX_Merge added in v0.4.878 

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

func (*AccessSpec) XXX_Size added in v0.4.878 

func (m *AccessSpec) XXX_Size() int

func (*AccessSpec) XXX_Unmarshal added in v0.4.878 

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

type AuthMethod added in v0.4.897 

type AuthMethod string
const (
	ApiToken AuthMethod = "api-token"
	JwtToken AuthMethod = "jwt-token"
	None     AuthMethod = "none"
)

type AutoScalingSpec added in v0.4.878 

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

AutoScaling defines the configuration for the automatic scaling of a service

func (*AutoScalingSpec) DeepCopy added in v0.4.878 

func (in *AutoScalingSpec) DeepCopy() *AutoScalingSpec

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

func (*AutoScalingSpec) DeepCopyInto added in v0.4.878 

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

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

func (*AutoScalingSpec) Descriptor added in v0.4.878 

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

func (*AutoScalingSpec) Marshal added in v0.4.878 

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

func (*AutoScalingSpec) MarshalTo added in v0.4.878 

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

func (*AutoScalingSpec) MarshalToSizedBuffer added in v0.4.878 

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

func (*AutoScalingSpec) ProtoMessage added in v0.4.878 

func (*AutoScalingSpec) ProtoMessage()

func (*AutoScalingSpec) Reset added in v0.4.878 

func (m *AutoScalingSpec) Reset()

func (*AutoScalingSpec) Size added in v0.4.878 

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

func (*AutoScalingSpec) String added in v0.4.878 

func (this *AutoScalingSpec) String() string

func (*AutoScalingSpec) Unmarshal added in v0.4.878 

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

func (*AutoScalingSpec) XXX_DiscardUnknown added in v0.4.878 

func (m *AutoScalingSpec) XXX_DiscardUnknown()

func (*AutoScalingSpec) XXX_Marshal added in v0.4.878 

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

func (*AutoScalingSpec) XXX_Merge added in v0.4.878 

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

func (*AutoScalingSpec) XXX_Size added in v0.4.878 

func (m *AutoScalingSpec) XXX_Size() int

func (*AutoScalingSpec) XXX_Unmarshal added in v0.4.878 

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

type BackwardCurtainSpec added in v0.4.914 

type BackwardCurtainSpec struct {
	// +kubebuilder:default:=false
	// +kubebuilder:validation:Optional
	Enabled *bool `json:"enabled,omitempty" protobuf:"varint,1,opt,name=enabled"`
	// The forward curtain receives prediction requests before the prediction (currently unimplemented)
	// +kubebuilder:validation:Optional
	CurtainRef *v1.ObjectReference `json:"curtainRef,omitempty" protobuf:"bytes,2,opt,name=curtainRef"`
	// 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 CronPrediction 

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

CronPrediction represents a Prediction which runs on a predefined schedule +kubebuilder:object:root=true +kubebuilder:subresource:status +kubebuilder:printcolumn:name="Ready",type="string",JSONPath=".status.conditions[?(@.type==\"Ready\")].status" +kubebuilder:printcolumn:name="Owner",type="string",JSONPath=".spec.owner",priority=1 +kubebuilder:printcolumn:name="Predictor",type="string",JSONPath=".spec.template.spec.predictorName" +kubebuilder:printcolumn:name="Schedule",type="string",JSONPath=".spec.schedule" +kubebuilder:printcolumn:name="Last Run",type="date",JSONPath=".status.lastRun",description="" +kubebuilder:printcolumn:name="Age",type="date",JSONPath=".metadata.creationTimestamp" +kubebuilder:resource:path=cronpredictions,shortName=cpred,singular=cronprediction,categories={inference,modela}

func (*CronPrediction) AddFinalizer 

func (run *CronPrediction) AddFinalizer()

func (*CronPrediction) CreateOrUpdateCond 

func (run *CronPrediction) CreateOrUpdateCond(cond CronPredictionCondition)

Merge or update condition Merge or update condition

func (*CronPrediction) DeepCopy 

func (in *CronPrediction) DeepCopy() *CronPrediction

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

func (*CronPrediction) DeepCopyInto 

func (in *CronPrediction) DeepCopyInto(out *CronPrediction)

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

func (*CronPrediction) DeepCopyObject 

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

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

func (*CronPrediction) Default 

func (pre *CronPrediction) Default()

func (*CronPrediction) Descriptor 

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

func (*CronPrediction) GetCond 

func (run *CronPrediction) GetCond(t CronPredictionConditionType) CronPredictionCondition

func (*CronPrediction) GetCondIdx 

func (run *CronPrediction) GetCondIdx(t CronPredictionConditionType) int

func (*CronPrediction) HasFinalizer 

func (run *CronPrediction) HasFinalizer() bool

func (*CronPrediction) IsCompleted 

func (run *CronPrediction) IsCompleted() bool

func (*CronPrediction) IsFailed 

func (run *CronPrediction) IsFailed() bool

func (*CronPrediction) IsReady 

func (run *CronPrediction) IsReady() bool

func (*CronPrediction) IsRunning 

func (run *CronPrediction) IsRunning() bool

func (*CronPrediction) IsSaved 

func (run *CronPrediction) IsSaved() bool

func (*CronPrediction) Key 

func (run *CronPrediction) Key() string

func (*CronPrediction) ManifestUri 

func (run *CronPrediction) ManifestUri() string

func (*CronPrediction) MarkReady 

func (run *CronPrediction) MarkReady()

func (*CronPrediction) MarkSaved 

func (run *CronPrediction) MarkSaved()

func (*CronPrediction) Marshal 

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

func (*CronPrediction) MarshalTo 

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

func (*CronPrediction) MarshalToSizedBuffer 

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

func (*CronPrediction) OpName 

func (run *CronPrediction) OpName() string

func (*CronPrediction) PipelineName 

func (run *CronPrediction) PipelineName() string

func (*CronPrediction) ProtoMessage 

func (*CronPrediction) ProtoMessage()

func (*CronPrediction) RemoveFinalizer 

func (run *CronPrediction) RemoveFinalizer()

func (*CronPrediction) RepPath 

func (run *CronPrediction) RepPath(root string) (string, error)

Return the on disk rep location

func (*CronPrediction) Reset 

func (m *CronPrediction) Reset()

func (*CronPrediction) RootUri 

func (run *CronPrediction) RootUri() string

func (*CronPrediction) SetupWebhookWithManager 

func (run *CronPrediction) SetupWebhookWithManager(mgr ctrl.Manager) error

func (*CronPrediction) Size 

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

func (*CronPrediction) String 

func (this *CronPrediction) String() string

func (*CronPrediction) ToYamlFile 

func (run *CronPrediction) ToYamlFile() ([]byte, error)

func (*CronPrediction) Unmarshal 

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

func (*CronPrediction) UpdateRunStatus added in v0.4.612 

func (prediction *CronPrediction) UpdateRunStatus(run Prediction)

func (*CronPrediction) ValidateCreate 

func (prediction *CronPrediction) ValidateCreate() error

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

func (*CronPrediction) ValidateDelete 

func (prediction *CronPrediction) ValidateDelete() error

func (*CronPrediction) ValidateUpdate 

func (prediction *CronPrediction) ValidateUpdate(old runtime.Object) error

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

func (*CronPrediction) XXX_DiscardUnknown 

func (m *CronPrediction) XXX_DiscardUnknown()

func (*CronPrediction) XXX_Marshal 

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

func (*CronPrediction) XXX_Merge 

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

func (*CronPrediction) XXX_Size 

func (m *CronPrediction) XXX_Size() int

func (*CronPrediction) XXX_Unmarshal 

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

type CronPredictionCondition 

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

CronPredictionCondition describes the state of a CronPrediction at a certain point

func (*CronPredictionCondition) DeepCopy 

func (in *CronPredictionCondition) DeepCopy() *CronPredictionCondition

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

func (*CronPredictionCondition) DeepCopyInto 

func (in *CronPredictionCondition) DeepCopyInto(out *CronPredictionCondition)

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

func (*CronPredictionCondition) Descriptor 

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

func (*CronPredictionCondition) Marshal 

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

func (*CronPredictionCondition) MarshalTo 

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

func (*CronPredictionCondition) MarshalToSizedBuffer 

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

func (*CronPredictionCondition) ProtoMessage 

func (*CronPredictionCondition) ProtoMessage()

func (*CronPredictionCondition) Reset 

func (m *CronPredictionCondition) Reset()

func (*CronPredictionCondition) Size 

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

func (*CronPredictionCondition) String 

func (this *CronPredictionCondition) String() string

func (*CronPredictionCondition) Unmarshal 

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

func (*CronPredictionCondition) XXX_DiscardUnknown 

func (m *CronPredictionCondition) XXX_DiscardUnknown()

func (*CronPredictionCondition) XXX_Marshal 

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

func (*CronPredictionCondition) XXX_Merge 

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

func (*CronPredictionCondition) XXX_Size 

func (m *CronPredictionCondition) XXX_Size() int

func (*CronPredictionCondition) XXX_Unmarshal 

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

type CronPredictionConditionType 

type CronPredictionConditionType string

CronPrediction Condition 

const (
	CronPredictionReady CronPredictionConditionType = "Ready"
	CronPredictionSaved CronPredictionConditionType = "Saved"
)

type CronPredictionList 

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

CronPredictionList is a list of CronPredictions +kubebuilder:object:root=true

func (*CronPredictionList) DeepCopy 

func (in *CronPredictionList) DeepCopy() *CronPredictionList

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

func (*CronPredictionList) DeepCopyInto 

func (in *CronPredictionList) DeepCopyInto(out *CronPredictionList)

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

func (*CronPredictionList) DeepCopyObject 

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

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

func (*CronPredictionList) Descriptor 

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

func (*CronPredictionList) Marshal 

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

func (*CronPredictionList) MarshalTo 

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

func (*CronPredictionList) MarshalToSizedBuffer 

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

func (*CronPredictionList) ProtoMessage 

func (*CronPredictionList) ProtoMessage()

func (*CronPredictionList) Reset 

func (m *CronPredictionList) Reset()

func (*CronPredictionList) Size 

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

func (*CronPredictionList) String 

func (this *CronPredictionList) String() string

func (*CronPredictionList) Unmarshal 

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

func (*CronPredictionList) XXX_DiscardUnknown 

func (m *CronPredictionList) XXX_DiscardUnknown()

func (*CronPredictionList) XXX_Marshal 

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

func (*CronPredictionList) XXX_Merge 

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

func (*CronPredictionList) XXX_Size 

func (m *CronPredictionList) XXX_Size() int

func (*CronPredictionList) XXX_Unmarshal 

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

type CronPredictionSpec 

type CronPredictionSpec struct {
	// The name of the DataProductVersion which describes the version of the resource
	// that exists in the same DataProduct namespace as the resource
	// +kubebuilder:default:=""
	// +kubebuilder:validation:Optional
	VersionName *string `json:"versionName,omitempty" protobuf:"bytes,1,opt,name=versionName"`
	// The 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,2,opt,name=owner"`
	// The schedule at which new Prediction resources will be created
	// +kubebuilder:validation:Optional
	Schedule catalog.RunSchedule `json:"schedule,omitempty" protobuf:"bytes,3,opt,name=schedule"`
	// Template specifies the template to create new Prediction resources
	Template PredictionTemplate `json:"template" protobuf:"bytes,4,opt,name=template"`
	// The priority of the CronPrediction to be executed (medium, by default)
	// +kubebuilder:default:=medium
	// +kubebuilder:validation:Optional
	Priority *catalog.PriorityLevel `json:"priority,omitempty" protobuf:"bytes,5,opt,name=priority"`
	// Indicates if the CronPrediction is paused and will not create new Predictions
	// +kubebuilder:default:=false
	// +kubebuilder:validation:Optional
	Paused *bool `json:"paused,omitempty" protobuf:"varint,6,opt,name=paused"`
	// 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,7,opt,name=notification"`
}

CronPredictionSpec represent the desired state of a CronPrediction

func (*CronPredictionSpec) DeepCopy 

func (in *CronPredictionSpec) DeepCopy() *CronPredictionSpec

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

func (*CronPredictionSpec) DeepCopyInto 

func (in *CronPredictionSpec) DeepCopyInto(out *CronPredictionSpec)

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

func (*CronPredictionSpec) Descriptor 

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

func (*CronPredictionSpec) Marshal 

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

func (*CronPredictionSpec) MarshalTo 

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

func (*CronPredictionSpec) MarshalToSizedBuffer 

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

func (*CronPredictionSpec) ProtoMessage 

func (*CronPredictionSpec) ProtoMessage()

func (*CronPredictionSpec) Reset 

func (m *CronPredictionSpec) Reset()

func (*CronPredictionSpec) Size 

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

func (*CronPredictionSpec) String 

func (this *CronPredictionSpec) String() string

func (*CronPredictionSpec) Unmarshal 

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

func (*CronPredictionSpec) XXX_DiscardUnknown 

func (m *CronPredictionSpec) XXX_DiscardUnknown()

func (*CronPredictionSpec) XXX_Marshal 

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

func (*CronPredictionSpec) XXX_Merge 

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

func (*CronPredictionSpec) XXX_Size 

func (m *CronPredictionSpec) XXX_Size() int

func (*CronPredictionSpec) XXX_Unmarshal 

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

type CronPredictionStatus 

type CronPredictionStatus struct {
	// The time at which a run of the CronPrediction was last started
	//+kubebuilder:validation:Optional
	LastRun catalog.LastRunStatus `json:"lastRun,omitempty" protobuf:"bytes,1,opt,name=lastRun"`
	// The time at which the CronPrediction is next scheduled to be executed
	//+kubebuilder:validation:Optional
	NextRun *metav1.Time `json:"nextRun,omitempty" protobuf:"bytes,2,opt,name=nextRun"`
	// The last time the object was updated
	//+kubebuilder:validation:Optional
	LastUpdated *metav1.Time `json:"lastUpdated,omitempty" protobuf:"bytes,3,opt,name=lastUpdated"`
	// ObservedGeneration is the last generation that was acted on
	//+kubebuilder:validation:Optional
	ObservedGeneration int64 `json:"observedGeneration,omitempty" protobuf:"varint,4,opt,name=observedGeneration"`
	// In the case of failure, the CronPrediction 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 CronPrediction 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 []CronPredictionCondition `json:"conditions,omitempty" patchStrategy:"merge" patchMergeKey:"type" protobuf:"bytes,7,rep,name=conditions"`
}

CronPredictionStatus is the observed state of a CronPrediction

func (*CronPredictionStatus) DeepCopy 

func (in *CronPredictionStatus) DeepCopy() *CronPredictionStatus

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

func (*CronPredictionStatus) DeepCopyInto 

func (in *CronPredictionStatus) DeepCopyInto(out *CronPredictionStatus)

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

func (*CronPredictionStatus) Descriptor 

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

func (*CronPredictionStatus) Marshal 

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

func (*CronPredictionStatus) MarshalTo 

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

func (*CronPredictionStatus) MarshalToSizedBuffer 

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

func (*CronPredictionStatus) ProtoMessage 

func (*CronPredictionStatus) ProtoMessage()

func (*CronPredictionStatus) Reset 

func (m *CronPredictionStatus) Reset()

func (*CronPredictionStatus) Size 

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

func (*CronPredictionStatus) String 

func (this *CronPredictionStatus) String() string

func (*CronPredictionStatus) Unmarshal 

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

func (*CronPredictionStatus) XXX_DiscardUnknown 

func (m *CronPredictionStatus) XXX_DiscardUnknown()

func (*CronPredictionStatus) XXX_Marshal 

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

func (*CronPredictionStatus) XXX_Merge 

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

func (*CronPredictionStatus) XXX_Size 

func (m *CronPredictionStatus) XXX_Size() int

func (*CronPredictionStatus) XXX_Unmarshal 

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

type Curtain 

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

Curtain represent an object which can be placed before or after predictor +kubebuilder:printcolumn:name="Ready",type="string",JSONPath=".status.conditions[?(@.type==\"Ready\")].status",description="" +kubebuilder:printcolumn:name="Serving Site",type="string",JSONPath=".spec.servingsiteRef.name" +kubebuilder:printcolumn:name="Dataset",type="string",JSONPath=".spec.datasetRef.name" +kubebuilder:printcolumn:name="Age",type="date",JSONPath=".metadata.creationTimestamp" +kubebuilder:object:root=true +kubebuilder:subresource:status +kubebuilder:resource:path=curtains,singular=curtain,categories={inference,modela,all}

func NewCurtain 

func NewCurtain(ns string, name string, image string, replicas int32, port int32) *Curtain

func ParseCurtainYaml 

func ParseCurtainYaml(content []byte) (*Curtain, error)

func TestCurtain 

func TestCurtain() *Curtain

func (*Curtain) AddFinalizer 

func (cur *Curtain) AddFinalizer()

func (*Curtain) CreateOrUpdateCond 

func (cur *Curtain) CreateOrUpdateCond(cond CurtainCondition)

Merge or update condition Merge or update condition

func (*Curtain) DeepCopy 

func (in *Curtain) DeepCopy() *Curtain

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

func (*Curtain) DeepCopyInto 

func (in *Curtain) DeepCopyInto(out *Curtain)

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

func (*Curtain) DeepCopyObject 

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

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

func (*Curtain) Default 

func (cur *Curtain) Default()

func (*Curtain) DeploymentName 

func (cur *Curtain) DeploymentName() string

func (*Curtain) Descriptor 

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

func (*Curtain) GetCond 

func (cur *Curtain) GetCond(t CurtainConditionType) CurtainCondition

func (*Curtain) GetCondIdx 

func (cur *Curtain) GetCondIdx(t CurtainConditionType) int

func (*Curtain) HasFinalizer 

func (cur *Curtain) HasFinalizer() bool

func (*Curtain) ManifestUri 

func (cur *Curtain) ManifestUri() string

func (*Curtain) MarkSaved 

func (cur *Curtain) MarkSaved()

func (*Curtain) Marshal 

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

func (*Curtain) MarshalTo 

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

func (*Curtain) MarshalToSizedBuffer 

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

func (*Curtain) ProtoMessage 

func (*Curtain) ProtoMessage()

func (*Curtain) RemoveFinalizer 

func (cur *Curtain) RemoveFinalizer()

func (*Curtain) Reset 

func (m *Curtain) Reset()

func (*Curtain) RootUri 

func (cur *Curtain) RootUri() string

func (*Curtain) Selector 

func (cur *Curtain) Selector() *metav1.LabelSelector

func (*Curtain) Size 

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

func (*Curtain) String 

func (this *Curtain) String() string

func (*Curtain) ToYamlFile 

func (cur *Curtain) ToYamlFile() ([]byte, error)

func (*Curtain) Unmarshal 

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

func (*Curtain) Validate 

func (cur *Curtain) Validate() (bool, []metav1.StatusCause)

func (*Curtain) ValidateCreate 

func (cur *Curtain) ValidateCreate() error

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

func (*Curtain) ValidateDelete 

func (cur *Curtain) ValidateDelete() error

func (*Curtain) ValidateUpdate 

func (cur *Curtain) ValidateUpdate(old runtime.Object) error

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

func (*Curtain) XXX_DiscardUnknown 

func (m *Curtain) XXX_DiscardUnknown()

func (*Curtain) XXX_Marshal 

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

func (*Curtain) XXX_Merge 

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

func (*Curtain) XXX_Size 

func (m *Curtain) XXX_Size() int

func (*Curtain) XXX_Unmarshal 

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

type CurtainCondition 

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

CurtainCondition describes the state of a wizard of oz at a certain point.

func (*CurtainCondition) DeepCopy 

func (in *CurtainCondition) DeepCopy() *CurtainCondition

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

func (*CurtainCondition) DeepCopyInto 

func (in *CurtainCondition) DeepCopyInto(out *CurtainCondition)

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

func (*CurtainCondition) Descriptor 

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

func (*CurtainCondition) Marshal 

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

func (*CurtainCondition) MarshalTo 

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

func (*CurtainCondition) MarshalToSizedBuffer 

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

func (*CurtainCondition) ProtoMessage 

func (*CurtainCondition) ProtoMessage()

func (*CurtainCondition) Reset 

func (m *CurtainCondition) Reset()

func (*CurtainCondition) Size 

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

func (*CurtainCondition) String 

func (this *CurtainCondition) String() string

func (*CurtainCondition) Unmarshal 

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

func (*CurtainCondition) XXX_DiscardUnknown 

func (m *CurtainCondition) XXX_DiscardUnknown()

func (*CurtainCondition) XXX_Marshal 

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

func (*CurtainCondition) XXX_Merge 

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

func (*CurtainCondition) XXX_Size 

func (m *CurtainCondition) XXX_Size() int

func (*CurtainCondition) XXX_Unmarshal 

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

type CurtainConditionType 

type CurtainConditionType string

Curtain condition 

const (
	CurtainReady CurtainConditionType = "Ready"
	CurtainSaved CurtainConditionType = "Saved"
)

/ Curtain Condition

type CurtainList 

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

+kubebuilder:object:root=true CurtainList represent a list of Curtain resources

func (*CurtainList) DeepCopy 

func (in *CurtainList) DeepCopy() *CurtainList

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

func (*CurtainList) DeepCopyInto 

func (in *CurtainList) DeepCopyInto(out *CurtainList)

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

func (*CurtainList) DeepCopyObject 

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

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

func (*CurtainList) Descriptor 

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

func (*CurtainList) Marshal 

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

func (*CurtainList) MarshalTo 

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

func (*CurtainList) MarshalToSizedBuffer 

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

func (*CurtainList) ProtoMessage 

func (*CurtainList) ProtoMessage()

func (*CurtainList) Reset 

func (m *CurtainList) Reset()

func (*CurtainList) Size 

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

func (*CurtainList) String 

func (this *CurtainList) String() string

func (*CurtainList) Unmarshal 

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

func (*CurtainList) XXX_DiscardUnknown 

func (m *CurtainList) XXX_DiscardUnknown()

func (*CurtainList) XXX_Marshal 

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

func (*CurtainList) XXX_Merge 

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

func (*CurtainList) XXX_Size 

func (m *CurtainList) XXX_Size() int

func (*CurtainList) XXX_Unmarshal 

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

type CurtainSpec 

type CurtainSpec struct {
	// User provided description
	// +kubebuilder:default:=""
	// +kubebuilder:validation:Optional
	Description *string `json:"description,omitempty" protobuf:"bytes,1,opt,name=description"`
	// User provided description
	// +kubebuilder:default:=""
	// +kubebuilder:validation:Optional
	VersionName *string `json:"versionName,omitempty" protobuf:"bytes,2,opt,name=versionName"`
	// The product of the resource
	// +kubebuilder:default:=""
	// +kubebuilder:validation:Optional
	ServingSiteName *string `json:"servingsiteName,omitempty" protobuf:"bytes,3,opt,name=servingsiteName"`
	// The dataset that store the human answers
	// +kubebuilder:default:=""
	// +kubebuilder:validation:Optional
	DatasetName *string `json:"datasetName,omitempty" protobuf:"bytes,4,opt,name=datasetName"`
	// The accounts of the human which can answer the prediction.
	Wizards []string `json:"wizards,omitempty" protobuf:"bytes,5,rep,name=wizards"`
	// Question to ask the human.
	// +kubebuilder:default:=""
	// +kubebuilder:validation:MaxLength=256
	Question *string `json:"question,omitempty" protobuf:"bytes,6,opt,name=question"`
	// NotifierName is used to converse with the human.
	// +kubebuilder:default:=""
	// +kubebuilder:validation:MaxLength=256
	NotifierName *string `json:"notifierName,omitempty" protobuf:"bytes,7,opt,name=notifierName"`
	// The owner account name
	// +kubebuilder:default:='no-one'
	// +kubebuilder:validation:Optional
	Owner *string `json:"owner,omitempty" protobuf:"bytes,8,opt,name=owner"`
}

CurtainSpec define the desired state of a Curtain

func (*CurtainSpec) DeepCopy 

func (in *CurtainSpec) DeepCopy() *CurtainSpec

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

func (*CurtainSpec) DeepCopyInto 

func (in *CurtainSpec) DeepCopyInto(out *CurtainSpec)

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

func (*CurtainSpec) Descriptor 

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

func (*CurtainSpec) Marshal 

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

func (*CurtainSpec) MarshalTo 

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

func (*CurtainSpec) MarshalToSizedBuffer 

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

func (*CurtainSpec) ProtoMessage 

func (*CurtainSpec) ProtoMessage()

func (*CurtainSpec) Reset 

func (m *CurtainSpec) Reset()

func (*CurtainSpec) Size 

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

func (*CurtainSpec) String 

func (this *CurtainSpec) String() string

func (*CurtainSpec) Unmarshal 

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

func (*CurtainSpec) XXX_DiscardUnknown 

func (m *CurtainSpec) XXX_DiscardUnknown()

func (*CurtainSpec) XXX_Marshal 

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

func (*CurtainSpec) XXX_Merge 

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

func (*CurtainSpec) XXX_Size 

func (m *CurtainSpec) XXX_Size() int

func (*CurtainSpec) XXX_Unmarshal 

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

type CurtainStatus 

type CurtainStatus struct {
	// ObservedGeneration is the Last generation that was acted on
	//+kubebuilder:validation:Optional
	ObservedGeneration int64 `json:"observedGeneration,omitempty" protobuf:"varint,1,opt,name=observedGeneration"`

	// Last time the object was updated
	//+kubebuilder:validation:Optional
	LastUpdated *metav1.Time `json:"lastUpdated,omitempty" protobuf:"bytes,2,opt,name=lastUpdated"`

	// +patchMergeKey=type
	// +patchStrategy=merge
	// +kubebuilder:validation:Optional
	Conditions []CurtainCondition `json:"conditions,omitempty" patchStrategy:"merge" patchMergeKey:"type" protobuf:"bytes,3,rep,name=conditions"`
}

CurtainStatus contain the observed state of the Curtain object.

func (*CurtainStatus) DeepCopy 

func (in *CurtainStatus) DeepCopy() *CurtainStatus

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

func (*CurtainStatus) DeepCopyInto 

func (in *CurtainStatus) DeepCopyInto(out *CurtainStatus)

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

func (*CurtainStatus) Descriptor 

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

func (*CurtainStatus) Marshal 

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

func (*CurtainStatus) MarshalTo 

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

func (*CurtainStatus) MarshalToSizedBuffer 

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

func (*CurtainStatus) ProtoMessage 

func (*CurtainStatus) ProtoMessage()

func (*CurtainStatus) Reset 

func (m *CurtainStatus) Reset()

func (*CurtainStatus) Size 

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

func (*CurtainStatus) String 

func (this *CurtainStatus) String() string

func (*CurtainStatus) Unmarshal 

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

func (*CurtainStatus) XXX_DiscardUnknown 

func (m *CurtainStatus) XXX_DiscardUnknown()

func (*CurtainStatus) XXX_Marshal 

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

func (*CurtainStatus) XXX_Merge 

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

func (*CurtainStatus) XXX_Size 

func (m *CurtainStatus) XXX_Size() int

func (*CurtainStatus) XXX_Unmarshal 

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

type CurtainTemplateSpec 

type CurtainTemplateSpec struct {
	// Standard object's metadata.
	// More info: https://git.k8s.io/community/contributors/devel/sig-architecture/api-conventions.md#metadata
	// +kubebuilder:validation:Optional
	metav1.ObjectMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`
	Spec              CurtainSpec `json:"spec" protobuf:"bytes,2,opt,name=spec"`
}

func (*CurtainTemplateSpec) DeepCopy 

func (in *CurtainTemplateSpec) DeepCopy() *CurtainTemplateSpec

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

func (*CurtainTemplateSpec) DeepCopyInto 

func (in *CurtainTemplateSpec) DeepCopyInto(out *CurtainTemplateSpec)

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

func (*CurtainTemplateSpec) Descriptor 

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

func (*CurtainTemplateSpec) Marshal 

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

func (*CurtainTemplateSpec) MarshalTo 

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

func (*CurtainTemplateSpec) MarshalToSizedBuffer 

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

func (*CurtainTemplateSpec) ProtoMessage 

func (*CurtainTemplateSpec) ProtoMessage()

func (*CurtainTemplateSpec) Reset 

func (m *CurtainTemplateSpec) Reset()

func (*CurtainTemplateSpec) Size 

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

func (*CurtainTemplateSpec) String 

func (this *CurtainTemplateSpec) String() string

func (*CurtainTemplateSpec) Unmarshal 

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

func (*CurtainTemplateSpec) XXX_DiscardUnknown 

func (m *CurtainTemplateSpec) XXX_DiscardUnknown()

func (*CurtainTemplateSpec) XXX_Marshal 

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

func (*CurtainTemplateSpec) XXX_Merge 

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

func (*CurtainTemplateSpec) XXX_Size 

func (m *CurtainTemplateSpec) XXX_Size() int

func (*CurtainTemplateSpec) XXX_Unmarshal 

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

type CustomAppSpec 

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

CustomAppSpec defines the custom pages for a DataApp

func (*CustomAppSpec) DeepCopy 

func (in *CustomAppSpec) DeepCopy() *CustomAppSpec

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

func (*CustomAppSpec) DeepCopyInto 

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

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

func (*CustomAppSpec) Descriptor 

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

func (*CustomAppSpec) Marshal 

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

func (*CustomAppSpec) MarshalTo 

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

func (*CustomAppSpec) MarshalToSizedBuffer 

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

func (*CustomAppSpec) ProtoMessage 

func (*CustomAppSpec) ProtoMessage()

func (*CustomAppSpec) Reset 

func (m *CustomAppSpec) Reset()

func (*CustomAppSpec) Size 

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

func (*CustomAppSpec) String 

func (this *CustomAppSpec) String() string

func (*CustomAppSpec) Unmarshal 

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

func (*CustomAppSpec) XXX_DiscardUnknown 

func (m *CustomAppSpec) XXX_DiscardUnknown()

func (*CustomAppSpec) XXX_Marshal 

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

func (*CustomAppSpec) XXX_Merge 

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

func (*CustomAppSpec) XXX_Size 

func (m *CustomAppSpec) XXX_Size() int

func (*CustomAppSpec) XXX_Unmarshal 

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

type DataApp 

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

DataApp represents a live dashboard for a single model +kubebuilder:object:root=true +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="" +kubebuilder:resource:path=dataapps,singular=dataapp,categories={data,modela} +kubebuilder:subresource:status

func (*DataApp) AddFinalizer 

func (r *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 (r *DataApp) CreateOrUpdateCond(cond DataAppCondition)

Merge or update condition

func (*DataApp) DeepCopy 

func (in *DataApp) DeepCopy() *DataApp

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

func (*DataApp) DeepCopyInto 

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

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

func (*DataApp) DeepCopyObject 

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

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

func (*DataApp) Default 

func (dataapp *DataApp) Default()

func (*DataApp) Deleted 

func (r *DataApp) Deleted() bool

func (*DataApp) Descriptor 

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

func (*DataApp) GetCond 

func (r *DataApp) GetCond(t DataAppConditionType) DataAppCondition

func (*DataApp) GetCondIdx 

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

func (*DataApp) HasFinalizer 

func (r *DataApp) HasFinalizer() bool

func (*DataApp) IsFailed added in v0.4.675 

func (dataapp *DataApp) IsFailed() bool

func (*DataApp) IsInCond 

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

func (*DataApp) IsReady 

func (r *DataApp) IsReady() bool

func (*DataApp) IsSaved 

func (r *DataApp) IsSaved() bool

func (*DataApp) MarkReady 

func (r *DataApp) MarkReady()

func (*DataApp) MarkSaved 

func (r *DataApp) MarkSaved()

func (*DataApp) Marshal 

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

func (*DataApp) MarshalTo 

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

func (*DataApp) MarshalToSizedBuffer 

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

func (*DataApp) Populate 

func (r *DataApp) Populate(name string)

func (*DataApp) PrintConditions 

func (r *DataApp) PrintConditions()

func (*DataApp) ProtoMessage 

func (*DataApp) ProtoMessage()

func (*DataApp) RemoveFinalizer 

func (r *DataApp) RemoveFinalizer()

func (*DataApp) Reset 

func (m *DataApp) Reset()

func (*DataApp) SetupWebhookWithManager 

func (r *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) ToYamlFile 

func (r *DataApp) ToYamlFile() ([]byte, error)

func (*DataApp) Unmarshal 

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

func (*DataApp) ValidateCreate 

func (recipe *DataApp) ValidateCreate() error

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

func (*DataApp) ValidateDelete 

func (recipe *DataApp) ValidateDelete() error

func (*DataApp) ValidateUpdate 

func (recipe *DataApp) ValidateUpdate(old runtime.Object) error

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

func (*DataApp) XXX_DiscardUnknown 

func (m *DataApp) XXX_DiscardUnknown()

func (*DataApp) XXX_Marshal 

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

func (*DataApp) XXX_Merge 

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

func (*DataApp) XXX_Size 

func (m *DataApp) XXX_Size() int

func (*DataApp) XXX_Unmarshal 

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

type DataAppCondition 

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

DataAppCondition describes the state of a DataApp at a certain point

func (*DataAppCondition) DeepCopy 

func (in *DataAppCondition) DeepCopy() *DataAppCondition

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

func (*DataAppCondition) DeepCopyInto 

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

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

func (*DataAppCondition) Descriptor 

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

func (*DataAppCondition) Marshal 

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

func (*DataAppCondition) MarshalTo 

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

func (*DataAppCondition) MarshalToSizedBuffer 

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

func (*DataAppCondition) ProtoMessage 

func (*DataAppCondition) ProtoMessage()

func (*DataAppCondition) Reset 

func (m *DataAppCondition) Reset()

func (*DataAppCondition) Size 

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

func (*DataAppCondition) String 

func (this *DataAppCondition) String() string

func (*DataAppCondition) Unmarshal 

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

func (*DataAppCondition) XXX_DiscardUnknown 

func (m *DataAppCondition) XXX_DiscardUnknown()

func (*DataAppCondition) XXX_Marshal 

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

func (*DataAppCondition) XXX_Merge 

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

func (*DataAppCondition) XXX_Size 

func (m *DataAppCondition) XXX_Size() int

func (*DataAppCondition) XXX_Unmarshal 

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

type DataAppConditionType 

type DataAppConditionType string

DataAppConditionType is the condition of a DataApp 

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

/ DataApp Condition

type DataAppList 

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

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

func (*DataAppList) DeepCopy 

func (in *DataAppList) DeepCopy() *DataAppList

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

func (*DataAppList) DeepCopyInto 

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

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

func (*DataAppList) DeepCopyObject 

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

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

func (*DataAppList) Descriptor 

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

func (*DataAppList) Marshal 

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

func (*DataAppList) MarshalTo 

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

func (*DataAppList) MarshalToSizedBuffer 

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

func (*DataAppList) ProtoMessage 

func (*DataAppList) ProtoMessage()

func (*DataAppList) Reset 

func (m *DataAppList) Reset()

func (*DataAppList) Size 

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

func (*DataAppList) String 

func (this *DataAppList) String() string

func (*DataAppList) Unmarshal 

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

func (*DataAppList) XXX_DiscardUnknown 

func (m *DataAppList) XXX_DiscardUnknown()

func (*DataAppList) XXX_Marshal 

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

func (*DataAppList) XXX_Merge 

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

func (*DataAppList) XXX_Size 

func (m *DataAppList) XXX_Size() int

func (*DataAppList) XXX_Unmarshal 

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

type DataAppSpec 

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

DataAppSpec defines the desired state of a DataApp

func (*DataAppSpec) DeepCopy 

func (in *DataAppSpec) DeepCopy() *DataAppSpec

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

func (*DataAppSpec) DeepCopyInto 

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

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

func (*DataAppSpec) Descriptor 

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

func (*DataAppSpec) Marshal 

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

func (*DataAppSpec) MarshalTo 

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

func (*DataAppSpec) MarshalToSizedBuffer 

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

func (*DataAppSpec) ProtoMessage 

func (*DataAppSpec) ProtoMessage()

func (*DataAppSpec) Reset 

func (m *DataAppSpec) Reset()

func (*DataAppSpec) Size 

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

func (*DataAppSpec) String 

func (this *DataAppSpec) String() string

func (*DataAppSpec) Unmarshal 

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

func (*DataAppSpec) XXX_DiscardUnknown 

func (m *DataAppSpec) XXX_DiscardUnknown()

func (*DataAppSpec) XXX_Marshal 

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

func (*DataAppSpec) XXX_Merge 

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

func (*DataAppSpec) XXX_Size 

func (m *DataAppSpec) XXX_Size() int

func (*DataAppSpec) XXX_Unmarshal 

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

type DataAppStatus 

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

DataAppStatus defines the observed state of DataApp

func (*DataAppStatus) DeepCopy 

func (in *DataAppStatus) DeepCopy() *DataAppStatus

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

func (*DataAppStatus) DeepCopyInto 

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

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

func (*DataAppStatus) Descriptor 

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

func (*DataAppStatus) Marshal 

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

func (*DataAppStatus) MarshalTo 

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

func (*DataAppStatus) MarshalToSizedBuffer 

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

func (*DataAppStatus) ProtoMessage 

func (*DataAppStatus) ProtoMessage()

func (*DataAppStatus) Reset 

func (m *DataAppStatus) Reset()

func (*DataAppStatus) Size 

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

func (*DataAppStatus) String 

func (this *DataAppStatus) String() string

func (*DataAppStatus) Unmarshal 

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

func (*DataAppStatus) XXX_DiscardUnknown 

func (m *DataAppStatus) XXX_DiscardUnknown()

func (*DataAppStatus) XXX_Marshal 

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

func (*DataAppStatus) XXX_Merge 

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

func (*DataAppStatus) XXX_Size 

func (m *DataAppStatus) XXX_Size() int

func (*DataAppStatus) XXX_Unmarshal 

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

type DriftDetectionSpec added in v0.4.949 

type DriftDetectionSpec struct {
	// Indicates if model monitoring is enabled for the model
	// +kubebuilder:default:=false
	// +kubebuilder:validation:Optional
	Enabled *bool `json:"enabled,omitempty" protobuf:"varint,1,opt,name=enabled"`
	// Reference to the live FeatureHistogram, the live FeatureHistogram is updated by the predictor for each prediction.
	LiveHistogramRef v1.ObjectReference `json:"LiveHistogramRef,omitempty" protobuf:"bytes,2,opt,name=liveHistogramRef"`
	// Reference to the training histogram ref. The training FeatureHistogram is created
	TrainingHistogramRef v1.ObjectReference `json:"TrainingHistogramRef,omitempty" protobuf:"bytes,3,opt,name=trainingHistogramRef"`
	// Define the tests to run against the predictor.
	Tests catalog.TestSuite `json:"driftTests,omitempty" protobuf:"bytes,6,opt,name=driftTests"`
	// The schedule on which model monitoring computations will be performed
	// +kubebuilder:validation:Optional
	Schedule catalog.RunSchedule `json:"schedule,omitempty" protobuf:"bytes,8,opt,name=schedule"`
	// Reference to a model that will be used for outlier detection. If empty, an outlier detection model.
	// +kubebuilder:validation:Optional
	OutlierDetectionModelRef v1.ObjectReference `json:"outlierDetectionModelRef,omitempty" protobuf:"bytes,10,opt,name=outlierDetectionModelRef"`
}

func (*DriftDetectionSpec) DeepCopy added in v0.4.949 

func (in *DriftDetectionSpec) DeepCopy() *DriftDetectionSpec

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

func (*DriftDetectionSpec) DeepCopyInto added in v0.4.949 

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

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

func (*DriftDetectionSpec) Descriptor added in v0.4.949 

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

func (*DriftDetectionSpec) Marshal added in v0.4.949 

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

func (*DriftDetectionSpec) MarshalTo added in v0.4.949 

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

func (*DriftDetectionSpec) MarshalToSizedBuffer added in v0.4.949 

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

func (*DriftDetectionSpec) ProtoMessage added in v0.4.949 

func (*DriftDetectionSpec) ProtoMessage()

func (*DriftDetectionSpec) Reset added in v0.4.949 

func (m *DriftDetectionSpec) Reset()

func (*DriftDetectionSpec) Size added in v0.4.949 

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

func (*DriftDetectionSpec) String added in v0.4.949 

func (this *DriftDetectionSpec) String() string

func (*DriftDetectionSpec) Unmarshal added in v0.4.949 

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

func (*DriftDetectionSpec) XXX_DiscardUnknown added in v0.4.949 

func (m *DriftDetectionSpec) XXX_DiscardUnknown()

func (*DriftDetectionSpec) XXX_Marshal added in v0.4.949 

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

func (*DriftDetectionSpec) XXX_Merge added in v0.4.949 

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

func (*DriftDetectionSpec) XXX_Size added in v0.4.949 

func (m *DriftDetectionSpec) XXX_Size() int

func (*DriftDetectionSpec) XXX_Unmarshal added in v0.4.949 

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

type DriftDetectionStatus added in v0.4.949 

type DriftDetectionStatus struct {
	// +kubebuilder:validation:Optional
	Results catalog.TestSuiteResult `json:"results,omitempty" protobuf:"bytes,1,opt,name=results"`
	// +kubebuilder:validation:Optional
	LastRun *metav1.Time `json:"lastRun,omitempty" protobuf:"bytes,2,opt,name=lastRun"`
}

func (*DriftDetectionStatus) DeepCopy added in v0.4.949 

func (in *DriftDetectionStatus) DeepCopy() *DriftDetectionStatus

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

func (*DriftDetectionStatus) DeepCopyInto added in v0.4.949 

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

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

func (*DriftDetectionStatus) Descriptor added in v0.4.949 

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

func (*DriftDetectionStatus) Marshal added in v0.4.949 

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

func (*DriftDetectionStatus) MarshalTo added in v0.4.949 

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

func (*DriftDetectionStatus) MarshalToSizedBuffer added in v0.4.949 

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

func (*DriftDetectionStatus) ProtoMessage added in v0.4.949 

func (*DriftDetectionStatus) ProtoMessage()

func (*DriftDetectionStatus) Reset added in v0.4.949 

func (m *DriftDetectionStatus) Reset()

func (*DriftDetectionStatus) Size added in v0.4.949 

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

func (*DriftDetectionStatus) String added in v0.4.949 

func (this *DriftDetectionStatus) String() string

func (*DriftDetectionStatus) Unmarshal added in v0.4.949 

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

func (*DriftDetectionStatus) XXX_DiscardUnknown added in v0.4.949 

func (m *DriftDetectionStatus) XXX_DiscardUnknown()

func (*DriftDetectionStatus) XXX_Marshal added in v0.4.949 

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

func (*DriftDetectionStatus) XXX_Merge added in v0.4.949 

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

func (*DriftDetectionStatus) XXX_Size added in v0.4.949 

func (m *DriftDetectionStatus) XXX_Size() int

func (*DriftDetectionStatus) XXX_Unmarshal added in v0.4.949 

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

type FastSlowModelSpec added in v0.4.914 

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

Fast slow model mode, use two models as the champion. 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 ForecastSpec 

type ForecastSpec 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.PeriodSpec `json:"horizon,omitempty" protobuf:"bytes,2,opt,name=horizon"`
}

ForecastSpec specifies the details of a forecasting model

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 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 forward curtain receives prediction requests before the prediction (currently unimplemented)
	// +kubebuilder:validation:Optional
	CurtainRef *v1.ObjectReference `json:"curtainRef,omitempty" protobuf:"bytes,2,opt,name=curtainRef"`
	// Percent of request that are sent to the foreward curtain.
	// +kubebuilder:default:=0
	// +kubebuilder:validation:Optional
	Percent *int32 `json:"percent,omitempty" protobuf:"bytes,3,opt,name=percent"`
}

func (*ForwardCurtainSpec) DeepCopy added in v0.4.915 

func (in *ForwardCurtainSpec) DeepCopy() *ForwardCurtainSpec

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

func (*ForwardCurtainSpec) DeepCopyInto added in v0.4.915 

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

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

func (*ForwardCurtainSpec) Descriptor added in v0.4.914 

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

func (*ForwardCurtainSpec) Marshal added in v0.4.914 

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

func (*ForwardCurtainSpec) MarshalTo added in v0.4.914 

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

func (*ForwardCurtainSpec) MarshalToSizedBuffer added in v0.4.914 

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

func (*ForwardCurtainSpec) ProtoMessage added in v0.4.914 

func (*ForwardCurtainSpec) ProtoMessage()

func (*ForwardCurtainSpec) Reset added in v0.4.914 

func (m *ForwardCurtainSpec) Reset()

func (*ForwardCurtainSpec) Size added in v0.4.914 

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

func (*ForwardCurtainSpec) String added in v0.4.914 

func (this *ForwardCurtainSpec) String() string

func (*ForwardCurtainSpec) Unmarshal added in v0.4.914 

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

func (*ForwardCurtainSpec) XXX_DiscardUnknown added in v0.4.914 

func (m *ForwardCurtainSpec) XXX_DiscardUnknown()

func (*ForwardCurtainSpec) XXX_Marshal added in v0.4.914 

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

func (*ForwardCurtainSpec) XXX_Merge added in v0.4.914 

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

func (*ForwardCurtainSpec) XXX_Size added in v0.4.914 

func (m *ForwardCurtainSpec) XXX_Size() int

func (*ForwardCurtainSpec) XXX_Unmarshal added in v0.4.914 

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

type GroundTruthTestSpec added in v0.4.948 

type GroundTruthTestSpec 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 labeled ground true dataset
	GroundTrueDatasetRef v1.ObjectReference `json:"GroundTrueDatasetRef,omitempty" protobuf:"bytes,2,opt,name=groundTruthDatasetRef"`
	// Reference to the training dataset for the champion model.
	TrainingDatasetRef v1.ObjectReference `json:"TrainingDatasetRef,omitempty" protobuf:"bytes,3,opt,name=trainingDatasetRef"`
	// Define the tests to run against the predictor.
	Tests catalog.TestSuite `json:"driftTests,omitempty" protobuf:"bytes,6,opt,name=driftTests"`
	// The schedule on which model monitoring computations will be performed
	// +kubebuilder:validation:Optional
	Schedule catalog.RunSchedule `json:"schedule,omitempty" protobuf:"bytes,8,opt,name=schedule"`
}

func (*GroundTruthTestSpec) DeepCopy added in v0.4.949 

func (in *GroundTruthTestSpec) DeepCopy() *GroundTruthTestSpec

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

func (*GroundTruthTestSpec) DeepCopyInto added in v0.4.949 

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

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

func (*GroundTruthTestSpec) Descriptor added in v0.4.948 

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

func (*GroundTruthTestSpec) Marshal added in v0.4.948 

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

func (*GroundTruthTestSpec) MarshalTo added in v0.4.948 

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

func (*GroundTruthTestSpec) MarshalToSizedBuffer added in v0.4.948 

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

func (*GroundTruthTestSpec) ProtoMessage added in v0.4.948 

func (*GroundTruthTestSpec) ProtoMessage()

func (*GroundTruthTestSpec) Reset added in v0.4.948 

func (m *GroundTruthTestSpec) Reset()

func (*GroundTruthTestSpec) Size added in v0.4.948 

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

func (*GroundTruthTestSpec) String added in v0.4.948 

func (this *GroundTruthTestSpec) String() string

func (*GroundTruthTestSpec) Unmarshal added in v0.4.948 

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

func (*GroundTruthTestSpec) XXX_DiscardUnknown added in v0.4.948 

func (m *GroundTruthTestSpec) XXX_DiscardUnknown()

func (*GroundTruthTestSpec) XXX_Marshal added in v0.4.948 

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

func (*GroundTruthTestSpec) XXX_Merge added in v0.4.948 

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

func (*GroundTruthTestSpec) XXX_Size added in v0.4.948 

func (m *GroundTruthTestSpec) XXX_Size() int

func (*GroundTruthTestSpec) XXX_Unmarshal added in v0.4.948 

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

type GroundTruthTestStatus added in v0.4.948 

type GroundTruthTestStatus struct {
	// +kubebuilder:validation:Optional
	Results catalog.TestSuiteResult `json:"results,omitempty" protobuf:"bytes,1,opt,name=results"`
	// +kubebuilder:validation:Optional
	LastRun *metav1.Time `json:"lastRun,omitempty" protobuf:"bytes,2,opt,name=lastRun"`
}

func (*GroundTruthTestStatus) DeepCopy added in v0.4.949 

func (in *GroundTruthTestStatus) DeepCopy() *GroundTruthTestStatus

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

func (*GroundTruthTestStatus) DeepCopyInto added in v0.4.949 

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

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

func (*GroundTruthTestStatus) Descriptor added in v0.4.948 

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

func (*GroundTruthTestStatus) Marshal added in v0.4.948 

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

func (*GroundTruthTestStatus) MarshalTo added in v0.4.948 

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

func (*GroundTruthTestStatus) MarshalToSizedBuffer added in v0.4.948 

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

func (*GroundTruthTestStatus) ProtoMessage added in v0.4.948 

func (*GroundTruthTestStatus) ProtoMessage()

func (*GroundTruthTestStatus) Reset added in v0.4.948 

func (m *GroundTruthTestStatus) Reset()

func (*GroundTruthTestStatus) Size added in v0.4.948 

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

func (*GroundTruthTestStatus) String added in v0.4.948 

func (this *GroundTruthTestStatus) String() string

func (*GroundTruthTestStatus) Unmarshal added in v0.4.948 

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

func (*GroundTruthTestStatus) XXX_DiscardUnknown added in v0.4.948 

func (m *GroundTruthTestStatus) XXX_DiscardUnknown()

func (*GroundTruthTestStatus) XXX_Marshal added in v0.4.948 

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

func (*GroundTruthTestStatus) XXX_Merge added in v0.4.948 

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

func (*GroundTruthTestStatus) XXX_Size added in v0.4.948 

func (m *GroundTruthTestStatus) XXX_Size() int

func (*GroundTruthTestStatus) XXX_Unmarshal added in v0.4.948 

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

type K8sObjectStatusState added in v0.4.833 

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

type KubernetesObjectStatus added in v0.4.844 

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

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

func AddOrUpdateK8sStatuses added in v0.4.833 

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

func (*KubernetesObjectStatus) DeepCopy added in v0.4.844 

func (in *KubernetesObjectStatus) DeepCopy() *KubernetesObjectStatus

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

func (*KubernetesObjectStatus) DeepCopyInto added in v0.4.844 

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

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

func (*KubernetesObjectStatus) Descriptor added in v0.4.844 

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

func (*KubernetesObjectStatus) Marshal added in v0.4.844 

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

func (*KubernetesObjectStatus) MarshalTo added in v0.4.844 

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

func (*KubernetesObjectStatus) MarshalToSizedBuffer added in v0.4.844 

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

func (*KubernetesObjectStatus) ProtoMessage added in v0.4.844 

func (*KubernetesObjectStatus) ProtoMessage()

func (*KubernetesObjectStatus) Reset added in v0.4.844 

func (m *KubernetesObjectStatus) Reset()

func (*KubernetesObjectStatus) Size added in v0.4.844 

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

func (*KubernetesObjectStatus) String added in v0.4.844 

func (this *KubernetesObjectStatus) String() string

func (*KubernetesObjectStatus) Unmarshal added in v0.4.844 

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

func (*KubernetesObjectStatus) XXX_DiscardUnknown added in v0.4.844 

func (m *KubernetesObjectStatus) XXX_DiscardUnknown()

func (*KubernetesObjectStatus) XXX_Marshal added in v0.4.844 

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

func (*KubernetesObjectStatus) XXX_Merge added in v0.4.844 

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

func (*KubernetesObjectStatus) XXX_Size added in v0.4.844 

func (m *KubernetesObjectStatus) XXX_Size() int

func (*KubernetesObjectStatus) XXX_Unmarshal added in v0.4.844 

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

type ModelDeploymentPhase added in v0.4.784 

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

type ModelDeploymentStatus added in v0.4.784 

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

func (*ModelDeploymentStatus) DeepCopy added in v0.4.784 

func (in *ModelDeploymentStatus) DeepCopy() *ModelDeploymentStatus

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

func (*ModelDeploymentStatus) DeepCopyInto added in v0.4.784 

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

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

func (*ModelDeploymentStatus) Descriptor added in v0.4.784 

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

func (*ModelDeploymentStatus) Marshal added in v0.4.784 

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

func (*ModelDeploymentStatus) MarshalTo added in v0.4.784 

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

func (*ModelDeploymentStatus) MarshalToSizedBuffer added in v0.4.784 

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

func (*ModelDeploymentStatus) ProtoMessage added in v0.4.784 

func (*ModelDeploymentStatus) ProtoMessage()

func (*ModelDeploymentStatus) Reset added in v0.4.784 

func (m *ModelDeploymentStatus) Reset()

func (*ModelDeploymentStatus) Size added in v0.4.784 

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

func (*ModelDeploymentStatus) String added in v0.4.784 

func (this *ModelDeploymentStatus) String() string

func (*ModelDeploymentStatus) Unmarshal added in v0.4.784 

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

func (*ModelDeploymentStatus) XXX_DiscardUnknown added in v0.4.784 

func (m *ModelDeploymentStatus) XXX_DiscardUnknown()

func (*ModelDeploymentStatus) XXX_Marshal added in v0.4.784 

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

func (*ModelDeploymentStatus) XXX_Merge added in v0.4.784 

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

func (*ModelDeploymentStatus) XXX_Size added in v0.4.784 

func (m *ModelDeploymentStatus) XXX_Size() int

func (*ModelDeploymentStatus) XXX_Unmarshal added in v0.4.784 

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

type ModelRecord 

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

ModelRecord hold the state of a model that was in production

func (*ModelRecord) DeepCopy 

func (in *ModelRecord) DeepCopy() *ModelRecord

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

func (*ModelRecord) DeepCopyInto 

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

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

func (*ModelRecord) Descriptor 

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

func (*ModelRecord) Marshal 

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

func (*ModelRecord) MarshalTo 

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

func (*ModelRecord) MarshalToSizedBuffer 

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

func (*ModelRecord) ProtoMessage 

func (*ModelRecord) ProtoMessage()

func (*ModelRecord) Reset 

func (m *ModelRecord) Reset()

func (*ModelRecord) Size 

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

func (*ModelRecord) String 

func (this *ModelRecord) String() string

func (*ModelRecord) Unmarshal 

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

func (*ModelRecord) XXX_DiscardUnknown 

func (m *ModelRecord) XXX_DiscardUnknown()

func (*ModelRecord) XXX_Marshal 

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

func (*ModelRecord) XXX_Merge 

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

func (*ModelRecord) XXX_Size 

func (m *ModelRecord) XXX_Size() int

func (*ModelRecord) XXX_Unmarshal 

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

type ModelServingSpec added in v0.4.878 

type ModelServingSpec struct {
	// The type of predictor (online, batch, or streaming). Online is the only supported type as of the current release
	// +kubebuilder:default:="online"
	// +kubebuilder:validation:Optional
	Type *PredictorType `json:"type,omitempty" protobuf:"bytes,1,opt,name=type"`
	// If Serverless is true, the Kubernetes Deployment 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"`
}

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

func (*ModelServingSpec) DeepCopy added in v0.4.878 

func (in *ModelServingSpec) DeepCopy() *ModelServingSpec

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

func (*ModelServingSpec) DeepCopyInto added in v0.4.878 

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

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

func (*ModelServingSpec) Descriptor added in v0.4.878 

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

func (*ModelServingSpec) Marshal added in v0.4.878 

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

func (*ModelServingSpec) MarshalTo added in v0.4.878 

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

func (*ModelServingSpec) MarshalToSizedBuffer added in v0.4.878 

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

func (*ModelServingSpec) ProtoMessage added in v0.4.878 

func (*ModelServingSpec) ProtoMessage()

func (*ModelServingSpec) Reset added in v0.4.878 

func (m *ModelServingSpec) Reset()

func (*ModelServingSpec) Size added in v0.4.878 

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

func (*ModelServingSpec) String added in v0.4.878 

func (this *ModelServingSpec) String() string

func (*ModelServingSpec) Unmarshal added in v0.4.878 

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

func (*ModelServingSpec) XXX_DiscardUnknown added in v0.4.878 

func (m *ModelServingSpec) XXX_DiscardUnknown()

func (*ModelServingSpec) XXX_Marshal added in v0.4.878 

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

func (*ModelServingSpec) XXX_Merge added in v0.4.878 

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

func (*ModelServingSpec) XXX_Size added in v0.4.878 

func (m *ModelServingSpec) XXX_Size() int

func (*ModelServingSpec) XXX_Unmarshal added in v0.4.878 

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

type OnlineFeatureStoreSpec added in v0.4.784 

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

OnlineFeaturestoreSpec specifies the connection information for an online feature store

func (*OnlineFeatureStoreSpec) DeepCopy added in v0.4.784 

func (in *OnlineFeatureStoreSpec) DeepCopy() *OnlineFeatureStoreSpec

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

func (*OnlineFeatureStoreSpec) DeepCopyInto added in v0.4.784 

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

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

func (*OnlineFeatureStoreSpec) Descriptor added in v0.4.784 

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

func (*OnlineFeatureStoreSpec) Marshal added in v0.4.784 

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

func (*OnlineFeatureStoreSpec) MarshalTo added in v0.4.784 

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

func (*OnlineFeatureStoreSpec) MarshalToSizedBuffer added in v0.4.784 

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

func (*OnlineFeatureStoreSpec) ProtoMessage added in v0.4.784 

func (*OnlineFeatureStoreSpec) ProtoMessage()

func (*OnlineFeatureStoreSpec) Reset added in v0.4.784 

func (m *OnlineFeatureStoreSpec) Reset()

func (*OnlineFeatureStoreSpec) Size added in v0.4.784 

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

func (*OnlineFeatureStoreSpec) String added in v0.4.784 

func (this *OnlineFeatureStoreSpec) String() string

func (*OnlineFeatureStoreSpec) Unmarshal added in v0.4.784 

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

func (*OnlineFeatureStoreSpec) XXX_DiscardUnknown added in v0.4.784 

func (m *OnlineFeatureStoreSpec) XXX_DiscardUnknown()

func (*OnlineFeatureStoreSpec) XXX_Marshal added in v0.4.784 

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

func (*OnlineFeatureStoreSpec) XXX_Merge added in v0.4.784 

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

func (*OnlineFeatureStoreSpec) XXX_Size added in v0.4.784 

func (m *OnlineFeatureStoreSpec) XXX_Size() int

func (*OnlineFeatureStoreSpec) XXX_Unmarshal added in v0.4.784 

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

type OnlineStoreStatus added in v0.4.784 

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

func (*OnlineStoreStatus) DeepCopy added in v0.4.784 

func (in *OnlineStoreStatus) DeepCopy() *OnlineStoreStatus

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

func (*OnlineStoreStatus) DeepCopyInto added in v0.4.784 

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

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

func (*OnlineStoreStatus) Descriptor added in v0.4.784 

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

func (*OnlineStoreStatus) Marshal added in v0.4.784 

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

func (*OnlineStoreStatus) MarshalTo added in v0.4.784 

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

func (*OnlineStoreStatus) MarshalToSizedBuffer added in v0.4.784 

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

func (*OnlineStoreStatus) ProtoMessage added in v0.4.784 

func (*OnlineStoreStatus) ProtoMessage()

func (*OnlineStoreStatus) Reset added in v0.4.784 

func (m *OnlineStoreStatus) Reset()

func (*OnlineStoreStatus) Size added in v0.4.784 

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

func (*OnlineStoreStatus) String added in v0.4.784 

func (this *OnlineStoreStatus) String() string

func (*OnlineStoreStatus) Unmarshal added in v0.4.784 

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

func (*OnlineStoreStatus) XXX_DiscardUnknown added in v0.4.784 

func (m *OnlineStoreStatus) XXX_DiscardUnknown()

func (*OnlineStoreStatus) XXX_Marshal added in v0.4.784 

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

func (*OnlineStoreStatus) XXX_Merge added in v0.4.784 

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

func (*OnlineStoreStatus) XXX_Size added in v0.4.784 

func (m *OnlineStoreStatus) XXX_Size() int

func (*OnlineStoreStatus) XXX_Unmarshal added in v0.4.784 

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

type 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"`
	Status            PredictionStatus `json:"status,omitempty" protobuf:"bytes,3,opt,name=status"`
}

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

func ParsePredictionYaml 

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

func (*Prediction) AddFinalizer 

func (prediction *Prediction) AddFinalizer()

func (*Prediction) ArchiveKey added in v0.4.515 

func (prediction *Prediction) ArchiveKey() string

func (*Prediction) CompletionAlert added in v0.4.601 

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

func (*Prediction) CreateOrUpdateCond 

func (prediction *Prediction) CreateOrUpdateCond(cond PredictionCondition)

Merge or update condition Merge or update condition

func (*Prediction) DeepCopy 

func (in *Prediction) DeepCopy() *Prediction

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

func (*Prediction) DeepCopyInto 

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

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

func (*Prediction) DeepCopyObject 

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

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

func (*Prediction) Default 

func (prediction *Prediction) Default()

func (*Prediction) Descriptor 

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

func (*Prediction) ErrorAlert added in v0.4.601 

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

func (*Prediction) GetCond 

func (prediction *Prediction) GetCond(t PredictionConditionType) PredictionCondition

func (*Prediction) GetCondIdx 

func (prediction *Prediction) GetCondIdx(t PredictionConditionType) int

func (*Prediction) HasFinalizer 

func (prediction *Prediction) HasFinalizer() bool

func (*Prediction) IsCompleted 

func (prediction *Prediction) IsCompleted() bool

func (*Prediction) IsFailed added in v0.4.614 

func (in *Prediction) IsFailed() bool

func (*Prediction) IsSaved 

func (version *Prediction) IsSaved() bool

func (*Prediction) Key 

func (prediction *Prediction) Key() string

func (*Prediction) LiveKey added in v0.4.515 

func (prediction *Prediction) LiveKey() string

func (*Prediction) ManifestUri 

func (prediction *Prediction) ManifestUri() string

func (*Prediction) MarkArchived added in v0.4.517 

func (prediction *Prediction) MarkArchived()

func (*Prediction) MarkCompleted 

func (prediction *Prediction) MarkCompleted()

func (*Prediction) MarkFailed 

func (prediction *Prediction) MarkFailed(msg string)

func (*Prediction) MarkRunning 

func (run *Prediction) MarkRunning()

func (*Prediction) MarkSaved 

func (version *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) OpName 

func (prediction *Prediction) OpName() string

func (*Prediction) PipelineName 

func (prediction *Prediction) PipelineName() string

func (*Prediction) ProtoMessage 

func (*Prediction) ProtoMessage()

func (*Prediction) RemoveFinalizer 

func (prediction *Prediction) RemoveFinalizer()

func (*Prediction) RepPath 

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

Return the on disk rep location

func (*Prediction) Reset 

func (m *Prediction) Reset()

func (*Prediction) RootUri 

func (prediction *Prediction) RootUri() string

func (*Prediction) RunStatus added in v0.4.614 

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

Return the state of the run as RunStatus

func (*Prediction) SetupWebhookWithManager 

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

func (*Prediction) Size 

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

func (*Prediction) String 

func (this *Prediction) String() string

func (*Prediction) ToYamlFile 

func (prediction *Prediction) ToYamlFile() ([]byte, error)

func (*Prediction) Unmarshal 

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

func (*Prediction) ValidateCreate 

func (prediction *Prediction) ValidateCreate() error

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

func (*Prediction) ValidateDelete 

func (prediction *Prediction) ValidateDelete() error

func (*Prediction) ValidateUpdate 

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

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

func (*Prediction) XXX_DiscardUnknown 

func (m *Prediction) XXX_DiscardUnknown()

func (*Prediction) XXX_Marshal 

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

func (*Prediction) XXX_Merge 

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

func (*Prediction) XXX_Size 

func (m *Prediction) XXX_Size() int

func (*Prediction) XXX_Unmarshal 

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

type PredictionCacheSpec 

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

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

func (*PredictionCacheSpec) DeepCopy 

func (in *PredictionCacheSpec) DeepCopy() *PredictionCacheSpec

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

func (*PredictionCacheSpec) DeepCopyInto 

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

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

func (*PredictionCacheSpec) Descriptor 

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

func (*PredictionCacheSpec) Marshal 

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

func (*PredictionCacheSpec) MarshalTo 

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

func (*PredictionCacheSpec) MarshalToSizedBuffer 

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

func (*PredictionCacheSpec) ProtoMessage 

func (*PredictionCacheSpec) ProtoMessage()

func (*PredictionCacheSpec) Reset 

func (m *PredictionCacheSpec) Reset()

func (*PredictionCacheSpec) Size 

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

func (*PredictionCacheSpec) String 

func (this *PredictionCacheSpec) String() string

func (*PredictionCacheSpec) Unmarshal 

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

func (*PredictionCacheSpec) XXX_DiscardUnknown 

func (m *PredictionCacheSpec) XXX_DiscardUnknown()

func (*PredictionCacheSpec) XXX_Marshal 

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

func (*PredictionCacheSpec) XXX_Merge 

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

func (*PredictionCacheSpec) XXX_Size 

func (m *PredictionCacheSpec) XXX_Size() int

func (*PredictionCacheSpec) XXX_Unmarshal 

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

type PredictionCacheStatus added in v0.4.784 

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

func (*PredictionCacheStatus) DeepCopy added in v0.4.784 

func (in *PredictionCacheStatus) DeepCopy() *PredictionCacheStatus

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

func (*PredictionCacheStatus) DeepCopyInto added in v0.4.784 

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

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

func (*PredictionCacheStatus) Descriptor added in v0.4.784 

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

func (*PredictionCacheStatus) Marshal added in v0.4.784 

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

func (*PredictionCacheStatus) MarshalTo added in v0.4.784 

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

func (*PredictionCacheStatus) MarshalToSizedBuffer added in v0.4.784 

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

func (*PredictionCacheStatus) ProtoMessage added in v0.4.784 

func (*PredictionCacheStatus) ProtoMessage()

func (*PredictionCacheStatus) Reset added in v0.4.784 

func (m *PredictionCacheStatus) Reset()

func (*PredictionCacheStatus) Size added in v0.4.784 

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

func (*PredictionCacheStatus) String added in v0.4.784 

func (this *PredictionCacheStatus) String() string

func (*PredictionCacheStatus) Unmarshal added in v0.4.784 

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

func (*PredictionCacheStatus) XXX_DiscardUnknown added in v0.4.784 

func (m *PredictionCacheStatus) XXX_DiscardUnknown()

func (*PredictionCacheStatus) XXX_Marshal added in v0.4.784 

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

func (*PredictionCacheStatus) XXX_Merge added in v0.4.784 

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

func (*PredictionCacheStatus) XXX_Size added in v0.4.784 

func (m *PredictionCacheStatus) XXX_Size() int

func (*PredictionCacheStatus) XXX_Unmarshal added in v0.4.784 

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

type PredictionCondition 

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

PredictionCondition describes the state of a Prediction at a certain point

func (*PredictionCondition) DeepCopy 

func (in *PredictionCondition) DeepCopy() *PredictionCondition

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

func (*PredictionCondition) DeepCopyInto 

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

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

func (*PredictionCondition) Descriptor 

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

func (*PredictionCondition) Marshal 

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

func (*PredictionCondition) MarshalTo 

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

func (*PredictionCondition) MarshalToSizedBuffer 

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

func (*PredictionCondition) ProtoMessage 

func (*PredictionCondition) ProtoMessage()

func (*PredictionCondition) Reset 

func (m *PredictionCondition) Reset()

func (*PredictionCondition) Size 

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

func (*PredictionCondition) String 

func (this *PredictionCondition) String() string

func (*PredictionCondition) Unmarshal 

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

func (*PredictionCondition) XXX_DiscardUnknown 

func (m *PredictionCondition) XXX_DiscardUnknown()

func (*PredictionCondition) XXX_Marshal 

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

func (*PredictionCondition) XXX_Merge 

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

func (*PredictionCondition) XXX_Size 

func (m *PredictionCondition) XXX_Size() int

func (*PredictionCondition) XXX_Unmarshal 

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

type PredictionConditionType 

type PredictionConditionType string

PredictionConditionType is the condition type of the prediction pipeline 

const (
	PredictionCompleted PredictionConditionType = "Completed"
	PredictionSaved     PredictionConditionType = "Saved"
	PredictionArchived  PredictionConditionType = "Archived"
)

/ PredictionTemplate Condition

type PredictionList 

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

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

func (*PredictionList) DeepCopy 

func (in *PredictionList) DeepCopy() *PredictionList

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

func (*PredictionList) DeepCopyInto 

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

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

func (*PredictionList) DeepCopyObject 

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

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

func (*PredictionList) Descriptor 

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

func (*PredictionList) Marshal 

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

func (*PredictionList) MarshalTo 

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

func (*PredictionList) MarshalToSizedBuffer 

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

func (*PredictionList) ProtoMessage 

func (*PredictionList) ProtoMessage()

func (*PredictionList) Reset 

func (m *PredictionList) Reset()

func (*PredictionList) Size 

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

func (*PredictionList) String 

func (this *PredictionList) String() string

func (*PredictionList) Unmarshal 

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

func (*PredictionList) XXX_DiscardUnknown 

func (m *PredictionList) XXX_DiscardUnknown()

func (*PredictionList) XXX_Marshal 

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

func (*PredictionList) XXX_Merge 

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

func (*PredictionList) XXX_Size 

func (m *PredictionList) XXX_Size() int

func (*PredictionList) XXX_Unmarshal 

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

type PredictionLoggingSpec added in v0.4.878 

type PredictionLoggingSpec struct {
	// Indicates if prediction logging is enabled
	// +kubebuilder:default:=false
	// +kubebuilder:validation:Optional
	Enabled *bool `json:"enabled,omitempty" protobuf:"varint,1,opt,name=enabled"`
	// The number percentage (0 through 100) of prediction requests to log
	// +kubebuilder:default:=0
	// +kubebuilder:validation:Optional
	SamplePercent *int32 `json:"samplePercent,omitempty" protobuf:"varint,2,opt,name=samplePercent"`
	// Indicates if incoming requests will be logged
	// +kubebuilder:default:=true
	// +kubebuilder:validation:Optional
	LogRequests *bool `json:"logRequests,omitempty" protobuf:"varint,3,opt,name=logRequests"`
	// Indicates if outgoing predictions will be logged
	// +kubebuilder:default:=true
	// +kubebuilder:validation:Optional
	LogResponses *bool `json:"logResponses,omitempty" protobuf:"varint,4,opt,name=logResponses"`
	// Number of rows in the prediction dataset
	// +kubebuilder:default:=0
	// +kubebuilder:validation:Optional
	Rows *int32 `json:"rows,omitempty" protobuf:"varint,5,opt,name=rows"`
	//Target location of the prediction log
	// +kubebuilder:validation:Optional
	Location data.DataLocation `json:"location,omitempty" protobuf:"bytes,6,opt,name=location"`
}

PredictionLoggingSpec specifies the configuration to log incoming and outgoing prediction requests

func (*PredictionLoggingSpec) DeepCopy added in v0.4.878 

func (in *PredictionLoggingSpec) DeepCopy() *PredictionLoggingSpec

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

func (*PredictionLoggingSpec) DeepCopyInto added in v0.4.878 

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

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

func (*PredictionLoggingSpec) Descriptor added in v0.4.878 

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

func (*PredictionLoggingSpec) Marshal added in v0.4.878 

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

func (*PredictionLoggingSpec) MarshalTo added in v0.4.878 

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

func (*PredictionLoggingSpec) MarshalToSizedBuffer added in v0.4.878 

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

func (*PredictionLoggingSpec) ProtoMessage added in v0.4.878 

func (*PredictionLoggingSpec) ProtoMessage()

func (*PredictionLoggingSpec) Reset added in v0.4.878 

func (m *PredictionLoggingSpec) Reset()

func (*PredictionLoggingSpec) Size added in v0.4.878 

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

func (*PredictionLoggingSpec) String added in v0.4.878 

func (this *PredictionLoggingSpec) String() string

func (*PredictionLoggingSpec) Unmarshal added in v0.4.878 

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

func (*PredictionLoggingSpec) XXX_DiscardUnknown added in v0.4.878 

func (m *PredictionLoggingSpec) XXX_DiscardUnknown()

func (*PredictionLoggingSpec) XXX_Marshal added in v0.4.878 

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

func (*PredictionLoggingSpec) XXX_Merge added in v0.4.878 

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

func (*PredictionLoggingSpec) XXX_Size added in v0.4.878 

func (m *PredictionLoggingSpec) XXX_Size() int

func (*PredictionLoggingSpec) XXX_Unmarshal added in v0.4.878 

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

type PredictionPhase 

type PredictionPhase string

ModelPhase is the current phase of a model 

const (
	PredictionPhasePending   PredictionPhase = "Pending"
	PredictionPhaseRunning   PredictionPhase = "Running"
	PredictionPhaseFailed    PredictionPhase = "Failed"
	PredictionPhaseAborted   PredictionPhase = "Aborted"
	PredictionPhaseCompleted PredictionPhase = "Completed"
)

type PredictionSpec 

type PredictionSpec struct {
	// The name of the DataProductVersion which describes the version of the resource
	// that exists in the same DataProduct namespace as the resource
	// +kubebuilder:default:=""
	// +kubebuilder:validation:Optional
	VersionName *string `json:"versionName,omitempty" protobuf:"bytes,1,opt,name=versionName"`
	// PredictorName is the name of the Predictor resource that will be used to evaluate predictions for the
	// unlabeled input dataset. The Predictor must exist in the same DataProduct namespace as the resource
	// +kubebuilder:validation:MaxLength=63
	// +kubebuilder:validation:Required
	// +required
	PredictorName *string `json:"predictorName,omitempty" protobuf:"bytes,2,opt,name=predictorName"`
	// If true, measurements for the metrics specified by the `Tests` field will be computed for each prediction and
	// stored in the Prediction's status with the average result of all predictions
	// +kubebuilder:default:=false
	// Used usually for unit testing
	Labeled *bool `json:"labeled,omitempty" protobuf:"varint,3,opt,name=labeled"`
	// Indicates if the prediction is a forecast
	// +kubebuilder:default:=false
	// +kubebuilder:validation:Optional
	Forecast *bool `json:"forecast,omitempty" protobuf:"varint,4,opt,name=forecast"`
	// Input specifies the location of the input data, if not using a Dataset resource
	Input data.DataInputSpec `json:"input,omitempty" protobuf:"bytes,6,opt,name=input"`
	// Output specifies the location where the predicted dataset will be stored
	// +kubebuilder:validation:Optional
	Output data.DataOutputSpec `json:"output,omitempty" protobuf:"bytes,7,opt,name=output"`
	// Tests specifies a collection of metrics that will be computed for each prediction
	// if the Labeled field of the Prediction is enabled
	Test training.ModelTestSuite `json:"test,omitempty" protobuf:"bytes,8,rep,name=test"`
	// 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,9,opt,name=owner"`
	// Resources specifies the resource requirements that will be allocated to the batch prediction Job
	// +kubebuilder:validation:Optional
	Resources catalog.ResourceSpec `json:"resources,omitempty" protobuf:"bytes,10,opt,name=resources"`
	// The deadline for the batch prediction Job to be completed in seconds
	// +kubebuilder:default:=600
	// +kubebuilder:validation:Minimum=0
	// +kubebuilder:validation:Optional
	ActiveDeadlineSeconds *int64 `json:"activeDeadlineSeconds,omitempty" protobuf:"varint,11,opt,name=activeDeadlineSeconds"`
	// The priority of the Kubernetes Job created by the Prediction (medium, by default)
	// +kubebuilder:default:=medium
	// +kubebuilder:validation:Optional
	Priority *catalog.PriorityLevel `json:"priority,omitempty" protobuf:"bytes,12,opt,name=priority"`
	// Indicates if the Prediction was aborted and should stop execution
	// +kubebuilder:default:=false
	// +kubebuilder:validation:Optional
	Aborted *bool `json:"aborted,omitempty" protobuf:"varint,13,opt,name=aborted"`
	// The time-to-live of the Prediction, after which the Prediction will be archived
	// +kubebuilder:default:=0
	// +kubebuilder:validation:Optional
	TTL *int32 `json:"ttl,omitempty" protobuf:"varint,14,opt,name=ttl"`
	// The forecasting specification in the case that the predicted model is a hierarchical forecast
	// +kubebuilder:validation:Optional
	ForecastInfo ForecastSpec `json:"forecastInfo,omitempty" protobuf:"bytes,15,opt,name=forecastInfo"`
	// CronPredictionName specifies the name of the CronPrediction that created the Prediction, if applicable
	// +kubebuilder:validation:MaxLength=63
	// +kubebuilder:default:=""
	// +kubebuilder:validation:Optional
	CronPredictionName *string `json:"cronPredictorName,omitempty" protobuf:"bytes,16,opt,name=cronPredictorName"`
	// The reference to the ServingSite resource that hosts the Prediction
	// +kubebuilder:validation:Optional
	ServingSiteRef v1.ObjectReference `json:"servingsiteRef" protobuf:"bytes,17,opt,name=servingsiteRef"`
}

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 {
	// StartTime denotes the time when the batch prediction Job started
	StartTime *metav1.Time `json:"startTime,omitempty" protobuf:"bytes,1,opt,name=startTime"`
	// EndTime denotes the time when the batch prediction Job completed or failed
	EndTime *metav1.Time `json:"endTime,omitempty" protobuf:"bytes,2,opt,name=endTime"`
	// The current phase of the prediction
	// +kubebuilder:default:="Pending"
	// +kubebuilder:validation:Optional
	Phase PredictionPhase `json:"phase,omitempty" protobuf:"bytes,3,opt,name=phase"`
	// The collection of metrics that represent the average measurement across all predictions for each
	// metric specified by the Tests field of the Predictor
	// +kubebuilder:validation:Optional
	TestResult catalog.TestSuiteResult `json:"testResult,omitempty" protobuf:"bytes,4,opt,name=testResult"`
	// ObservedGeneration is the last generation that was acted on
	//+kubebuilder:validation:Optional
	ObservedGeneration int64 `json:"observedGeneration,omitempty" protobuf:"varint,5,opt,name=observedGeneration"`
	// The number of rows predicted
	//+kubebuilder:validation:Optional
	Rows int32 `json:"rows,omitempty" protobuf:"varint,6,opt,name=rows"`
	// The trigger that started the batch prediction
	//+kubebuilder:validation:Optional
	TriggeredBy catalog.TriggerType `json:"triggeredBy,omitempty" protobuf:"bytes,7,opt,name=triggeredBy"`
	// The location of logs produced by the batch prediction Job
	//+kubebuilder:validation:Optional
	Logs catalog.Logs `json:"logs,,omitempty" protobuf:"bytes,8,opt,name=logs"`
	// The last time the object was updated
	//+kubebuilder:validation:Optional
	LastUpdated *metav1.Time `json:"lastUpdated,omitempty" protobuf:"bytes,9,opt,name=lastUpdated"`
	// In the case of failure, the Prediction resource controller will set this field with a failure reason
	//+kubebuilder:validation:Optional
	FailureReason *catalog.StatusError `json:"failureReason,omitempty" protobuf:"bytes,10,opt,name=failureReason"`
	// In the case of failure, the Prediction resource controller will set this field with a failure message
	//+kubebuilder:validation:Optional
	FailureMessage *string `json:"failureMessage,omitempty" protobuf:"bytes,11,opt,name=failureMessage"`
	// +patchMergeKey=type
	// +patchStrategy=merge
	// +kubebuilder:validation:Optional
	Conditions []PredictionCondition `json:"conditions,omitempty" patchStrategy:"merge" patchMergeKey:"type" protobuf:"bytes,12,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 PredictionTemplate 

type PredictionTemplate struct {
	Spec PredictionSpec `json:"spec" protobuf:"bytes,1,opt,name=spec"`
}

PredictionTemplate defines the specification for a Prediction resource to be created

func (*PredictionTemplate) DeepCopy 

func (in *PredictionTemplate) DeepCopy() *PredictionTemplate

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

func (*PredictionTemplate) DeepCopyInto 

func (in *PredictionTemplate) DeepCopyInto(out *PredictionTemplate)

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

func (*PredictionTemplate) Descriptor 

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

func (*PredictionTemplate) Marshal 

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

func (*PredictionTemplate) MarshalTo 

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

func (*PredictionTemplate) MarshalToSizedBuffer 

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

func (*PredictionTemplate) ProtoMessage 

func (*PredictionTemplate) ProtoMessage()

func (*PredictionTemplate) Reset 

func (m *PredictionTemplate) Reset()

func (*PredictionTemplate) Size 

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

func (*PredictionTemplate) String 

func (this *PredictionTemplate) String() string

func (*PredictionTemplate) Unmarshal 

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

func (*PredictionTemplate) XXX_DiscardUnknown 

func (m *PredictionTemplate) XXX_DiscardUnknown()

func (*PredictionTemplate) XXX_Marshal 

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

func (*PredictionTemplate) XXX_Merge 

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

func (*PredictionTemplate) XXX_Size 

func (m *PredictionTemplate) XXX_Size() int

func (*PredictionTemplate) XXX_Unmarshal 

func (m *PredictionTemplate) 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"`
	Status            PredictorStatus `json:"status,omitempty" protobuf:"bytes,3,opt,name=status"`
}

Predictor specifies the deployment of a service to serve predictions for a Model +kubebuilder:object:root=true +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",priority=1 +kubebuilder:printcolumn:name="Serving Site",type="string",JSONPath=".spec.servingsiteRef.name",description="" +kubebuilder:printcolumn:name="Port",type="integer",JSONPath=".spec.port",description="" +kubebuilder:printcolumn:name="Access",type="string",JSONPath=".spec.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="" +kubebuilder:resource:path=predictors,singular=predictor,shortName=pdr,categories={inference,modela}

func ParsePredictorYaml 

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

func (*Predictor) AddFinalizer 

func (predictor *Predictor) AddFinalizer()

func (*Predictor) ConstructGrpcRule added in v0.4.693 

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

func (*Predictor) ConstructRESTRule added in v0.4.693 

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

func (*Predictor) CreateOrUpdateCond 

func (predictor *Predictor) CreateOrUpdateCond(cond PredictorCondition)

Merge or update condition Merge or update condition

func (*Predictor) DeepCopy 

func (in *Predictor) DeepCopy() *Predictor

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

func (*Predictor) DeepCopyInto 

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

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

func (*Predictor) DeepCopyObject 

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

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

func (*Predictor) Default 

func (predictor *Predictor) Default()

func (*Predictor) DeploymentName 

func (r *Predictor) DeploymentName() string

func (*Predictor) DeploymentUri 

func (predictor *Predictor) DeploymentUri() string

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

func (*Predictor) Descriptor 

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

func (*Predictor) FullServiceName 

func (r *Predictor) FullServiceName() string

func (*Predictor) GetCond 

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

func (*Predictor) GetCondIdx 

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

func (*Predictor) GreenName 

func (r *Predictor) GreenName() string

func (*Predictor) HasFinalizer 

func (predictor *Predictor) HasFinalizer() bool

func (*Predictor) IsFailed added in v0.4.675 

func (predictor *Predictor) IsFailed() bool

func (*Predictor) IsReady 

func (predictor *Predictor) IsReady() bool

func (*Predictor) IsSaved 

func (predictor *Predictor) IsSaved() bool

func (*Predictor) ManifestUri 

func (predictor *Predictor) ManifestUri() string

func (*Predictor) MarkFailed added in v0.4.448 

func (predictor *Predictor) MarkFailed(err string)

func (*Predictor) MarkReady 

func (predictor *Predictor) MarkReady()

func (*Predictor) MarkSaved 

func (predictor *Predictor) MarkSaved()

func (*Predictor) Marshal 

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

func (*Predictor) MarshalTo 

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

func (*Predictor) MarshalToSizedBuffer 

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

func (*Predictor) MirrorName 

func (r *Predictor) MirrorName() string

func (*Predictor) ProtoMessage 

func (*Predictor) ProtoMessage()

func (*Predictor) RemoveFinalizer 

func (predictor *Predictor) RemoveFinalizer()

func (*Predictor) Reset 

func (m *Predictor) Reset()

func (*Predictor) RootUri 

func (predictor *Predictor) RootUri() string

func (*Predictor) Selector 

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

func (*Predictor) ServiceName 

func (r *Predictor) ServiceName() string

func (*Predictor) ServiceUri 

func (predictor *Predictor) ServiceUri() string

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

func (*Predictor) SetupWebhookWithManager 

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

func (*Predictor) Size 

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

func (*Predictor) String 

func (this *Predictor) String() string

func (*Predictor) Unmarshal 

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

func (*Predictor) ValidateCreate 

func (predictor *Predictor) ValidateCreate() error

func (*Predictor) ValidateDelete 

func (predictor *Predictor) ValidateDelete() error

func (*Predictor) ValidateUpdate 

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

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

func (*Predictor) XXX_DiscardUnknown 

func (m *Predictor) XXX_DiscardUnknown()

func (*Predictor) XXX_Marshal 

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

func (*Predictor) XXX_Merge 

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

func (*Predictor) XXX_Size 

func (m *Predictor) XXX_Size() int

func (*Predictor) XXX_Unmarshal 

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

type PredictorCondition 

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

PredictorCondition describes the state of a Predictor at a certain point

func (*PredictorCondition) DeepCopy 

func (in *PredictorCondition) DeepCopy() *PredictorCondition

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

func (*PredictorCondition) DeepCopyInto 

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

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

func (*PredictorCondition) Descriptor 

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

func (*PredictorCondition) Marshal 

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

func (*PredictorCondition) MarshalTo 

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

func (*PredictorCondition) MarshalToSizedBuffer 

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

func (*PredictorCondition) ProtoMessage 

func (*PredictorCondition) ProtoMessage()

func (*PredictorCondition) Reset 

func (m *PredictorCondition) Reset()

func (*PredictorCondition) Size 

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

func (*PredictorCondition) String 

func (this *PredictorCondition) String() string

func (*PredictorCondition) Unmarshal 

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

func (*PredictorCondition) XXX_DiscardUnknown 

func (m *PredictorCondition) XXX_DiscardUnknown()

func (*PredictorCondition) XXX_Marshal 

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

func (*PredictorCondition) XXX_Merge 

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

func (*PredictorCondition) XXX_Size 

func (m *PredictorCondition) XXX_Size() int

func (*PredictorCondition) XXX_Unmarshal 

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

type PredictorConditionType 

type PredictorConditionType string

Predictor condition 

const (
	PredictorReady PredictorConditionType = "Ready"
	PredictorSaved PredictorConditionType = "Saved"
)

/ Predictor Condition

type PredictorList 

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

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

func (*PredictorList) DeepCopy 

func (in *PredictorList) DeepCopy() *PredictorList

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

func (*PredictorList) DeepCopyInto 

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

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

func (*PredictorList) DeepCopyObject 

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

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

func (*PredictorList) Descriptor 

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

func (*PredictorList) Marshal 

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

func (*PredictorList) MarshalTo 

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

func (*PredictorList) MarshalToSizedBuffer 

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

func (*PredictorList) ProtoMessage 

func (*PredictorList) ProtoMessage()

func (*PredictorList) Reset 

func (m *PredictorList) Reset()

func (*PredictorList) Size 

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

func (*PredictorList) String 

func (this *PredictorList) String() string

func (*PredictorList) Unmarshal 

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

func (*PredictorList) XXX_DiscardUnknown 

func (m *PredictorList) XXX_DiscardUnknown()

func (*PredictorList) XXX_Marshal 

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

func (*PredictorList) XXX_Merge 

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

func (*PredictorList) XXX_Size 

func (m *PredictorList) XXX_Size() int

func (*PredictorList) XXX_Unmarshal 

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

type PredictorSpec 

type PredictorSpec struct {
	// 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 user-provided description of the Predictor
	// +kubebuilder:validation:MaxLength=256
	// +kubebuilder:default:=""
	Description *string `json:"description,omitempty" protobuf:"bytes,2,opt,name=description"`
	// The reference to the DataProduct that the resource exists under
	ProductRef *v1.ObjectReference `json:"productRef" protobuf:"bytes,3,opt,name=productRef"`
	// The reference to the ServingSite resource that hosts the Predictor
	// +kubebuilder:validation:Optional
	ServingSiteRef *v1.ObjectReference `json:"servingsiteRef" protobuf:"bytes,4,opt,name=servingsiteRef"`
	// The collection of model deployment specifications that define which Model resources will be deployed to the
	// Predictor service and how they will be deployed. Each model should be trained with the same type of
	// dataset and possess a unique version
	// +kubebuilder:validation:Optional
	Models []catalog.ModelDeploymentSpec `json:"models,omitempty" protobuf:"bytes,6,rep,name=models"`
	// The specification to progressively deploy models. 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,7,opt,name=progressive"`
	// The data location where artifacts generated by the Predictor will be stored
	// +kubebuilder:validation:Optional
	ArtifactsFolder data.DataLocation `json:"artifactsFolder,omitempty" protobuf:"bytes,8,opt,name=artifactsFolder"`
	// Access specifies the configuration for the Predictor service to be exposed externally
	// +kubebuilder:validation:Optional
	Access AccessSpec `json:"access,omitempty" protobuf:"bytes,9,opt,name=access"`
	// The number of replicas for the Kubernetes Deployment 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,10,opt,name=replicas"`
	// AutoScaling specifies the auto-scaling policy
	// +kubebuilder:validation:Optional
	AutoScaling AutoScalingSpec `json:"autoScaling,omitempty" protobuf:"bytes,11,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,12,opt,name=owner"`
	// Resources specifies the resource requirements allocated to the prediction service
	// +kubebuilder:validation:Optional
	Resources catalog.ResourceSpec `json:"resources,omitempty" protobuf:"bytes,13,opt,name=resources"`
	// Cache specifies the configuration of the prediction cache
	// +kubebuilder:validation:Optional
	Cache PredictionCacheSpec `json:"cache,omitempty" protobuf:"bytes,14,opt,name=cache"`
	// Store specifies the configuration of the online data store
	// +kubebuilder:validation:Optional
	Store OnlineFeatureStoreSpec `json:"store,omitempty" protobuf:"bytes,15,opt,name=store"`
	// Serving specifies the configuration for individual models to handle prediction traffic
	Serving ModelServingSpec `json:"serving,omitempty" protobuf:"bytes,16,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,17,opt,name=task"`
	// The prediction threshold
	// +kubebuilder:validation:Optional
	PredictionThreshold *float64 `json:"predictionThreshold,omitempty" protobuf:"bytes,18,opt,name=predictionThreshold"`
	// Spec for the drift detection process
	// +kubebuilder:validation:Optional
	Drift DriftDetectionSpec `json:"drift,omitempty" protobuf:"bytes,19,opt,name=drift"`
	// Spec for the ground truth process.
	// +kubebuilder:validation:Optional
	GroundTruth GroundTruthTestSpec `json:"groundTruth,omitempty" protobuf:"bytes,20,opt,name=groundTruth"`
	// NotifierRef references a Notifier resource that will be triggered in the case that a concept or data drift is detected
	// +kubebuilder:validation:Optional
	NotifierRef *v1.ObjectReference `json:"notifierRef,omitempty" protobuf:"bytes,21,opt,name=notifierRef"`
	// Monitor spec specify the monitor for this predictor.
	// +kubebuilder:validation:Optional
	PredictionLogging PredictionLoggingSpec `json:"predictionLogging,omitempty" protobuf:"bytes,22,opt,name=predictionLogging"`
	// Forward curtain
	// +kubebuilder:validation:Optional
	ForwardCurtain ForwardCurtainSpec `json:"forwardCurtain,omitempty" protobuf:"bytes,23,opt,name=forwardCurtain"`
	// Backward curtain
	// +kubebuilder:validation:Optional
	BackwardCurtain BackwardCurtainSpec `json:"backwardCurtain,omitempty" protobuf:"bytes,24,opt,name=backwardCurtain"`
	// Backward curtain
	// +kubebuilder:validation:Optional
	FastSlow FastSlowModelSpec `json:"fastSlow,omitempty" protobuf:"bytes,25,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
	//+kubebuilder:validation:Optional
	History []ModelRecord `json:"history,omitempty" protobuf:"bytes,2,opt,name=history"`
	// The collection of statuses for each model deployed with the Predictor
	// +kubebuilder:validation:Optional
	ModelStatuses []ModelDeploymentStatus `json:"models,omitempty" protobuf:"bytes,3,rep,name=models"`
	// 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:"predictorlet,omitempty" protobuf:"bytes,4,rep,name=predictorlet"`
	// The status of the prediction cache managed by the Predictor
	// +kubebuilder:validation:Optional
	CacheStatus PredictionCacheStatus `json:"cache,omitempty" protobuf:"bytes,5,rep,name=cache"`
	// The status of the online store managed by the Predictor
	// +kubebuilder:validation:Optional
	OnlineStore OnlineStoreStatus `json:"onlineStore,omitempty" protobuf:"bytes,6,rep,name=onlineStore"`
	// The last time the object was updated
	//+kubebuilder:validation:Optional
	LastUpdated *metav1.Time `json:"lastUpdated,omitempty" protobuf:"bytes,7,opt,name=lastUpdated"`
	// The end-point URL of the Predictor
	//+kubebuilder:validation:Optional
	EndPoint string `json:"endPoint,omitempty" protobuf:"bytes,8,opt,name=endPoint"`
	// In the case of failure, the Predictor resource controller will set this field with a failure reason
	//+kubebuilder:validation:Optional
	FailureReason *catalog.StatusError `json:"failureReason,omitempty" protobuf:"bytes,9,opt,name=failureReason"`
	// In the case of failure, the Predictor resource controller will set this field with a failure reason
	//+kubebuilder:validation:Optional
	FailureMessage *string `json:"failureMessage,omitempty" protobuf:"bytes,10,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,11,opt,name=loadBalancerStatus"`
	// The last time that a prediction dataset was created
	//+kubebuilder:validation:Optional
	LastPredictionDataset *metav1.Time `json:"lastPredictionDataset,omitempty" protobuf:"bytes,12,opt,name=lastPredictionDataset"`
	// The result of running the last monitor.
	//+kubebuilder:validation:Optional
	GroundTruth GroundTruthTestStatus `json:"groundTruth,omitempty" protobuf:"bytes,13,rep,name=groundTruth"`
	// The result of running the last monitor.
	//+kubebuilder:validation:Optional
	Drift DriftDetectionStatus `json:"drift,omitempty" protobuf:"bytes,14,rep,name=drift"`
	// +patchMergeKey=type
	// +patchStrategy=merge
	// +kubebuilder:validation:Optional
	Conditions []PredictorCondition `json:"conditions,omitempty" patchStrategy:"merge" patchMergeKey:"type" protobuf:"bytes,15,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 PredictorType 

type PredictorType string

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

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

type PredictorletStatus added in v0.4.784 

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

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

func (*PredictorletStatus) DeepCopy added in v0.4.784 

func (in *PredictorletStatus) DeepCopy() *PredictorletStatus

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

func (*PredictorletStatus) DeepCopyInto added in v0.4.784 

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

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

func (*PredictorletStatus) Descriptor added in v0.4.784 

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

func (*PredictorletStatus) Marshal added in v0.4.784 

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

func (*PredictorletStatus) MarshalTo added in v0.4.784 

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

func (*PredictorletStatus) MarshalToSizedBuffer added in v0.4.784 

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

func (*PredictorletStatus) ProtoMessage added in v0.4.784 

func (*PredictorletStatus) ProtoMessage()

func (*PredictorletStatus) Reset added in v0.4.784 

func (m *PredictorletStatus) Reset()

func (*PredictorletStatus) Size added in v0.4.784 

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

func (*PredictorletStatus) String added in v0.4.784 

func (this *PredictorletStatus) String() string

func (*PredictorletStatus) Unmarshal added in v0.4.784 

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

func (*PredictorletStatus) XXX_DiscardUnknown added in v0.4.784 

func (m *PredictorletStatus) XXX_DiscardUnknown()

func (*PredictorletStatus) XXX_Marshal added in v0.4.784 

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

func (*PredictorletStatus) XXX_Merge added in v0.4.784 

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

func (*PredictorletStatus) XXX_Size added in v0.4.784 

func (m *PredictorletStatus) XXX_Size() int

func (*PredictorletStatus) XXX_Unmarshal added in v0.4.784 

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

type ProgressiveSpec 

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

ProgressiveSpec defines the specification to progressively deploy a model to production

func (*ProgressiveSpec) DeepCopy 

func (in *ProgressiveSpec) DeepCopy() *ProgressiveSpec

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

func (*ProgressiveSpec) DeepCopyInto 

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

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

func (*ProgressiveSpec) Descriptor 

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

func (*ProgressiveSpec) Marshal 

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

func (*ProgressiveSpec) MarshalTo 

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

func (*ProgressiveSpec) MarshalToSizedBuffer 

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

func (*ProgressiveSpec) ProtoMessage 

func (*ProgressiveSpec) ProtoMessage()

func (*ProgressiveSpec) Reset 

func (m *ProgressiveSpec) Reset()

func (*ProgressiveSpec) Size 

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

func (*ProgressiveSpec) String 

func (this *ProgressiveSpec) String() string

func (*ProgressiveSpec) Unmarshal 

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

func (*ProgressiveSpec) XXX_DiscardUnknown 

func (m *ProgressiveSpec) XXX_DiscardUnknown()

func (*ProgressiveSpec) XXX_Marshal 

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

func (*ProgressiveSpec) XXX_Merge 

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

func (*ProgressiveSpec) XXX_Size 

func (m *ProgressiveSpec) XXX_Size() int

func (*ProgressiveSpec) XXX_Unmarshal 

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

type ValidationError added in v0.4.907 

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

func (*ValidationError) DeepCopy added in v0.4.908 

func (in *ValidationError) DeepCopy() *ValidationError

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

func (*ValidationError) DeepCopyInto added in v0.4.908 

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

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

func (*ValidationError) Descriptor added in v0.4.907 

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

func (*ValidationError) Marshal added in v0.4.907 

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

func (*ValidationError) MarshalTo added in v0.4.907 

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

func (*ValidationError) MarshalToSizedBuffer added in v0.4.907 

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

func (*ValidationError) ProtoMessage added in v0.4.907 

func (*ValidationError) ProtoMessage()

func (*ValidationError) Reset added in v0.4.907 

func (m *ValidationError) Reset()

func (*ValidationError) Size added in v0.4.907 

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

func (*ValidationError) String added in v0.4.907 

func (this *ValidationError) String() string

func (*ValidationError) Unmarshal added in v0.4.907 

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

func (*ValidationError) XXX_DiscardUnknown added in v0.4.907 

func (m *ValidationError) XXX_DiscardUnknown()

func (*ValidationError) XXX_Marshal added in v0.4.907 

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

func (*ValidationError) XXX_Merge added in v0.4.907 

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

func (*ValidationError) XXX_Size added in v0.4.907 

func (m *ValidationError) XXX_Size() int

func (*ValidationError) XXX_Unmarshal added in v0.4.907 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.