v1beta1

package
v0.0.0-...-34e6c99 Latest Latest
Warning

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

 Go to latest Published: Aug 2, 2020 License: GPL-3.0 Imports: 11 Imported by: 0

Documentation

Overview

Package v1beta1 contains API Schema definitions for the monitoring v1beta1 API group +kubebuilder:object:generate=true +groupName=monitoring.hops.io

Index

Constants

This section is empty.

Variables

View Source 
var (
	// GroupVersion is group version used to register these objects
	GroupVersion = schema.GroupVersion{Group: "monitoring.hops.io", Version: "v1beta1"}

	// SchemeBuilder is used to add go types to the GroupVersionKind scheme
	SchemeBuilder = &scheme.Builder{GroupVersion: GroupVersion}

	// AddToScheme adds the types in this group-version to the given scheme.
	AddToScheme = SchemeBuilder.AddToScheme
)

Functions

This section is empty.

Types

type AnalysisSpec 

type AnalysisSpec struct {
	//+required
	Stats SinkSpec `json:"stats"`
	//+optional
	Outliers *SinkSpec `json:"outliers,omitempty"`
	//+optional
	Drift *SinkSpec `json:"drift,omitempty"`
}

AnalysisSpec defines the Analysis storage

func (*AnalysisSpec) DeepCopy 

func (in *AnalysisSpec) DeepCopy() *AnalysisSpec

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

func (*AnalysisSpec) DeepCopyInto 

func (in *AnalysisSpec) DeepCopyInto(out *AnalysisSpec)

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

type Autoscaler 

type Autoscaler string

Autoscaler defines the autoscaler class +kubebuilder:validation:Enum=kpa.autoscaling.knative.dev;hpa.autoscaling.knative.dev

type AutoscalerMetric 

type AutoscalerMetric string

AutoscalerMetric defines the metric for the autoscaler +kubebuilder:validation:Enum=concurrency;rps;cpu

type AvgSpec 

type AvgSpec struct{}

AvgSpec defines an Avg

func (*AvgSpec) DeepCopy 

func (in *AvgSpec) DeepCopy() *AvgSpec

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

func (*AvgSpec) DeepCopyInto 

func (in *AvgSpec) DeepCopyInto(out *AvgSpec)

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

type BaselineSpec 

type BaselineSpec struct {
	//+optional
	Descriptive string `json:"descriptive,omitempty"`
	//+optional
	Distributions string `json:"distributions,omitempty"`
}

BaselineSpec defines Baseline stats

func (*BaselineSpec) DeepCopy 

func (in *BaselineSpec) DeepCopy() *BaselineSpec

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

func (*BaselineSpec) DeepCopyInto 

func (in *BaselineSpec) DeepCopyInto(out *BaselineSpec)

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

type Binning 

type Binning string

Binning defines the Distribution binning algorithm +kubebuilder:validation:Enum=sturge

type CorrSpec 

type CorrSpec struct {
	//+optional
	//+kubebuilder:validation:Enum=sample;population
	Type string `json:"type,omitempty"`
}

CorrSpec defines a Correlation

func (*CorrSpec) DeepCopy 

func (in *CorrSpec) DeepCopy() *CorrSpec

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

func (*CorrSpec) DeepCopyInto 

func (in *CorrSpec) DeepCopyInto(out *CorrSpec)

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

type CountSpec 

type CountSpec struct{}

CountSpec defines a Count stat

func (*CountSpec) DeepCopy 

func (in *CountSpec) DeepCopy() *CountSpec

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

func (*CountSpec) DeepCopyInto 

func (in *CountSpec) DeepCopyInto(out *CountSpec)

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

type CovSpec 

type CovSpec struct {
	//+optional
	//+kubebuilder:validation:Enum=sample;population
	Type string `json:"type,omitempty"`
}

CovSpec defines a Covariance

func (*CovSpec) DeepCopy 

func (in *CovSpec) DeepCopy() *CovSpec

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

func (*CovSpec) DeepCopyInto 

func (in *CovSpec) DeepCopyInto(out *CovSpec)

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

type DistrSpec 

type DistrSpec struct {
	//+optional
	Bounds map[string][]string `json:"bounds,omitempty"`
	//+optional
	Binning Binning `json:"binning,omitempty"`
}

DistrSpec defines a Distribution

func (*DistrSpec) DeepCopy 

func (in *DistrSpec) DeepCopy() *DistrSpec

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

func (*DistrSpec) DeepCopyInto 

func (in *DistrSpec) DeepCopyInto(out *DistrSpec)

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

type DriftSpec 

type DriftSpec struct {
	//+optional
	Wasserstein *ThresholdBasedDriftSpec `json:"wasserstein,omitempty"`
	//+optional
	KullbackLeibler *ThresholdBasedDriftSpec `json:"kullbackLeibler,omitempty"`
	//+optional
	JensenShannon *ThresholdBasedDriftSpec `json:"jensenShannon,omitempty"`
}

DriftSpec defines a Drift detector

func (*DriftSpec) DeepCopy 

func (in *DriftSpec) DeepCopy() *DriftSpec

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

func (*DriftSpec) DeepCopyInto 

func (in *DriftSpec) DeepCopyInto(out *DriftSpec)

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

type DriverSpec 

type DriverSpec struct {
	ResourcesSpec `json:",inline"`
}

DriverSpec defines the configuration for Monitoring Job drivers

func (*DriverSpec) DeepCopy 

func (in *DriverSpec) DeepCopy() *DriverSpec

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

func (*DriverSpec) DeepCopyInto 

func (in *DriverSpec) DeepCopyInto(out *DriverSpec)

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

type ExecutorSpec 

type ExecutorSpec struct {
	ResourcesSpec `json:",inline"`
	//+optional
	Instances int32 `json:"instances"`
}

ExecutorSpec defines the configuration for Monitoring Job executors

func (*ExecutorSpec) DeepCopy 

func (in *ExecutorSpec) DeepCopy() *ExecutorSpec

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

func (*ExecutorSpec) DeepCopyInto 

func (in *ExecutorSpec) DeepCopyInto(out *ExecutorSpec)

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

type InferenceLoggerConfig 

type InferenceLoggerConfig struct {
	ContainerImage string `json:"containerImage"`
}

InferenceLoggerConfig defines the configuration for the InferenceLogger service +k8s:openapi-gen=false

func (*InferenceLoggerConfig) DeepCopy 

func (in *InferenceLoggerConfig) DeepCopy() *InferenceLoggerConfig

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

func (*InferenceLoggerConfig) DeepCopyInto 

func (in *InferenceLoggerConfig) DeepCopyInto(out *InferenceLoggerConfig)

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

type InferenceLoggerSpec 

type InferenceLoggerSpec struct {
	//+optional
	Autoscaler Autoscaler `json:"autoscaler,omitempty"`
	//+optional
	Metric AutoscalerMetric `json:"metric,omitempty"`
	//+optional
	Window string `json:"window,omitempty"`
	//+optional
	PanicWindow string `json:"panicWindow,omitempty"`
	//+optional
	PanicThreshold string `json:"panicThreshold,omitempty"`
	//+optional
	MinScale int `json:"minScale,omitempty"`
	//+optional
	MaxScale int `json:"maxScale,omitempty"`
	//+optional
	Target int `json:"target,omitempty"`
	//+optional
	TargetUtilization string `json:"targetUtilization,omitempty"`
	//+optional
	Resources corev1.ResourceRequirements `json:"resources,omitempty"`
}

InferenceLoggerSpec defines the configuration for InferenceLogger Knative Service.

func (*InferenceLoggerSpec) DeepCopy 

func (in *InferenceLoggerSpec) DeepCopy() *InferenceLoggerSpec

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

func (*InferenceLoggerSpec) DeepCopyInto 

func (in *InferenceLoggerSpec) DeepCopyInto(out *InferenceLoggerSpec)

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

type JobConfig 

type JobConfig struct {
	ContainerImage      string `json:"containerImage"`
	MainClass           string `json:"mainClass"`
	MainApplicationFile string `json:"mainApplicationFile"`
}

JobConfig defines the configuration for the Monitoring job +k8s:openapi-gen=false

func (*JobConfig) DeepCopy 

func (in *JobConfig) DeepCopy() *JobConfig

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

func (*JobConfig) DeepCopyInto 

func (in *JobConfig) DeepCopyInto(out *JobConfig)

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

type JobSpec 

type JobSpec struct {
	//+optional
	Timeout int `json:"timeout,omitempty"`
	//+optional
	ExposeMetrics bool `json:"exposeMetrics,omitempty"`
	//+optional
	Driver DriverSpec `json:"driver,omitempty"`
	//+optional
	Executor ExecutorSpec `json:"executor,omitempty"`
}

JobSpec defines the configuration for Monitoring job

func (*JobSpec) DeepCopy 

func (in *JobSpec) DeepCopy() *JobSpec

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

func (*JobSpec) DeepCopyInto 

func (in *JobSpec) DeepCopyInto(out *JobSpec)

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

type KafkaSpec 

type KafkaSpec struct {
	//+required
	Brokers string `json:"brokers"`
	//+required
	Topic KafkaTopicSpec `json:"topic"`
}

KafkaSpec defines the KafkaTopic used for inference logging.

func (*KafkaSpec) DeepCopy 

func (in *KafkaSpec) DeepCopy() *KafkaSpec

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

func (*KafkaSpec) DeepCopyInto 

func (in *KafkaSpec) DeepCopyInto(out *KafkaSpec)

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

type KafkaTopicSpec 

type KafkaTopicSpec struct {
	//+required
	Name string `json:"name"`
	//+optional
	Partitions int32 `json:"partitions,omitempty"`
	//+optional
	ReplicationFactor int16 `json:"replicationFactor,omitempty"`
}

KafkaTopicSpec defines a Kafka topic

func (*KafkaTopicSpec) DeepCopy 

func (in *KafkaTopicSpec) DeepCopy() *KafkaTopicSpec

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

func (*KafkaTopicSpec) DeepCopyInto 

func (in *KafkaTopicSpec) DeepCopyInto(out *KafkaTopicSpec)

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

type MaxSpec 

type MaxSpec struct{}

MaxSpec defines a Max stat

func (*MaxSpec) DeepCopy 

func (in *MaxSpec) DeepCopy() *MaxSpec

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

func (*MaxSpec) DeepCopyInto 

func (in *MaxSpec) DeepCopyInto(out *MaxSpec)

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

type MeanSpec 

type MeanSpec struct{}

MeanSpec defines a Mean

func (*MeanSpec) DeepCopy 

func (in *MeanSpec) DeepCopy() *MeanSpec

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

func (*MeanSpec) DeepCopyInto 

func (in *MeanSpec) DeepCopyInto(out *MeanSpec)

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

type MinSpec 

type MinSpec struct{}

MinSpec defines a Min stat

func (*MinSpec) DeepCopy 

func (in *MinSpec) DeepCopy() *MinSpec

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

func (*MinSpec) DeepCopyInto 

func (in *MinSpec) DeepCopyInto(out *MinSpec)

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

type ModelMonitor 

type ModelMonitor struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   ModelMonitorSpec   `json:"spec,omitempty"`
	Status ModelMonitorStatus `json:"status,omitempty"`
}

ModelMonitor is the Schema for the modelmonitors API

func (*ModelMonitor) DeepCopy 

func (in *ModelMonitor) DeepCopy() *ModelMonitor

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

func (*ModelMonitor) DeepCopyInto 

func (in *ModelMonitor) DeepCopyInto(out *ModelMonitor)

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

func (*ModelMonitor) DeepCopyObject 

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

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

type ModelMonitorConfig 

type ModelMonitorConfig struct {
	Job             *JobConfig             `json:"job"`
	InferenceLogger *InferenceLoggerConfig `json:"inferenceLogger"`
}

ModelMonitorConfig defines the ModelMonitor configuration +k8s:openapi-gen=false

func GetModelMonitorConfig 

func GetModelMonitorConfig(client client.Client) (*ModelMonitorConfig, error)

GetModelMonitorConfig returns the ModelMonitor config

func NewModelMonitorConfig 

func NewModelMonitorConfig(configMap *corev1.ConfigMap) (*ModelMonitorConfig, error)

NewModelMonitorConfig creates a ModelMonitorConfig from a given configmap

func (*ModelMonitorConfig) DeepCopy 

func (in *ModelMonitorConfig) DeepCopy() *ModelMonitorConfig

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

func (*ModelMonitorConfig) DeepCopyInto 

func (in *ModelMonitorConfig) DeepCopyInto(out *ModelMonitorConfig)

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

type ModelMonitorList 

type ModelMonitorList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []ModelMonitor `json:"items"`
}

ModelMonitorList contains a list of ModelMonitor

func (*ModelMonitorList) DeepCopy 

func (in *ModelMonitorList) DeepCopy() *ModelMonitorList

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

func (*ModelMonitorList) DeepCopyInto 

func (in *ModelMonitorList) DeepCopyInto(out *ModelMonitorList)

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

func (*ModelMonitorList) DeepCopyObject 

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

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

type ModelMonitorSpec 

type ModelMonitorSpec struct {
	//+required
	Model ModelSpec `json:"model"`
	//+required
	Monitoring MonitoringSpec `json:"monitoring"`
	//+required
	Storage StorageSpec `json:"storage"`
	//+optional
	Job JobSpec `json:"job,omitempty"`
	//+optional
	InferenceLogger InferenceLoggerSpec `json:"inferenceLogger,omitempty"`
}

ModelMonitorSpec defines the desired state of ModelMonitor

func (*ModelMonitorSpec) DeepCopy 

func (in *ModelMonitorSpec) DeepCopy() *ModelMonitorSpec

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

func (*ModelMonitorSpec) DeepCopyInto 

func (in *ModelMonitorSpec) DeepCopyInto(out *ModelMonitorSpec)

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

type ModelMonitorStatus 

type ModelMonitorStatus struct {
}

ModelMonitorStatus defines the observed state of ModelMonitor

func (*ModelMonitorStatus) DeepCopy 

func (in *ModelMonitorStatus) DeepCopy() *ModelMonitorStatus

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

func (*ModelMonitorStatus) DeepCopyInto 

func (in *ModelMonitorStatus) DeepCopyInto(out *ModelMonitorStatus)

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

type ModelSchemasSpec 

type ModelSchemasSpec struct {
	//+required
	Request string `json:"request"`
	//+required
	Response string `json:"response"`

	//+required
	Instance string `json:"instance"`
	//+required
	Prediction string `json:"prediction"`
}

ModelSchemasSpec defines the inference schema of a model

func (*ModelSchemasSpec) DeepCopy 

func (in *ModelSchemasSpec) DeepCopy() *ModelSchemasSpec

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

func (*ModelSchemasSpec) DeepCopyInto 

func (in *ModelSchemasSpec) DeepCopyInto(out *ModelSchemasSpec)

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

type ModelSpec 

type ModelSpec struct {
	//+required
	Name string `json:"name"`
	//+optional
	ID string `json:"id,omitempty"`
	//+optional
	Version *int `json:"version,omitempty"`
	//+required
	Schemas ModelSchemasSpec `json:"schemas"`
}

ModelSpec defines the Model being monitored. It should match with KFserving inferenceservice name

func (*ModelSpec) DeepCopy 

func (in *ModelSpec) DeepCopy() *ModelSpec

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

func (*ModelSpec) DeepCopyInto 

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

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

type MonitoringSpec 

type MonitoringSpec struct {
	//+required
	Trigger TriggerSpec `json:"trigger"`
	//+required
	Stats StatSpec `json:"stats"`
	//+optional
	Baseline *BaselineSpec `json:"baseline,omitempty"`
	//+optional
	Outliers *OutlierSpec `json:"outliers,omitempty"`
	//+optional
	Drift *DriftSpec `json:"drift,omitempty"`
}

MonitoringSpec defines the Monitoring settings

func (*MonitoringSpec) DeepCopy 

func (in *MonitoringSpec) DeepCopy() *MonitoringSpec

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

func (*MonitoringSpec) DeepCopyInto 

func (in *MonitoringSpec) DeepCopyInto(out *MonitoringSpec)

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

type OutlierSpec 

type OutlierSpec struct {
	//+optional
	Descriptive []string `json:"descriptive,omitempty"`
}

OutlierSpec defines an Outlier detector

func (*OutlierSpec) DeepCopy 

func (in *OutlierSpec) DeepCopy() *OutlierSpec

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

func (*OutlierSpec) DeepCopyInto 

func (in *OutlierSpec) DeepCopyInto(out *OutlierSpec)

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

type PercSpec 

type PercSpec struct {
	//+required
	Percentiles []string `json:"percentiles"`
	//+optional
	IQR bool `json:"iqr,omitempty"`
}

PercSpec defines Percentiles

func (*PercSpec) DeepCopy 

func (in *PercSpec) DeepCopy() *PercSpec

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

func (*PercSpec) DeepCopyInto 

func (in *PercSpec) DeepCopyInto(out *PercSpec)

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

type Pow2SumSpec 

type Pow2SumSpec struct{}

Pow2SumSpec defines a Pow2Sum stat

func (*Pow2SumSpec) DeepCopy 

func (in *Pow2SumSpec) DeepCopy() *Pow2SumSpec

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

func (*Pow2SumSpec) DeepCopyInto 

func (in *Pow2SumSpec) DeepCopyInto(out *Pow2SumSpec)

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

type ResourcesSpec 

type ResourcesSpec struct {
	//+optional
	Cores int32 `json:"cores,omitempty"`
	//+optional
	CoreLimit string `json:"coreLimit,omitempty"`
	//+optional
	Memory string `json:"memory,omitempty"`
}

ResourcesSpec defines resources configuration

func (*ResourcesSpec) DeepCopy 

func (in *ResourcesSpec) DeepCopy() *ResourcesSpec

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

func (*ResourcesSpec) DeepCopyInto 

func (in *ResourcesSpec) DeepCopyInto(out *ResourcesSpec)

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

type SinkSpec 

type SinkSpec struct {
	//+required
	Kafka KafkaSpec `json:"kafka"`
}

SinkSpec defines the configuration of a Sink

func (*SinkSpec) DeepCopy 

func (in *SinkSpec) DeepCopy() *SinkSpec

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

func (*SinkSpec) DeepCopyInto 

func (in *SinkSpec) DeepCopyInto(out *SinkSpec)

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

type StatSpec 

type StatSpec struct {
	//+optional
	Max *MaxSpec `json:"max,omitempty"`
	//+optional
	Min *MinSpec `json:"min,omitempty"`
	//+optional
	Count *CountSpec `json:"count,omitempty"`
	//+optional
	Sum *SumSpec `json:"sum,omitempty"`
	//+optional
	Pow2Sum *Pow2SumSpec `json:"pow2Sum,omitempty"`
	//+optional
	Distr *DistrSpec `json:"distr,omitempty"`

	//+optional
	Avg *AvgSpec `json:"avg,omitempty"`
	//+optional
	Mean *MeanSpec `json:"mean,omitempty"`
	//+optional
	Stddev *StddevSpec `json:"stddev,omitempty"`
	//+optional
	Perc *PercSpec `json:"perc,omitempty"`

	//+optional
	Cov *CovSpec `json:"cov,omitempty"`
	//+optional
	Corr *CorrSpec `json:"corr,omitempty"`
}

StatSpec defines a Statistic

func (*StatSpec) DeepCopy 

func (in *StatSpec) DeepCopy() *StatSpec

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

func (*StatSpec) DeepCopyInto 

func (in *StatSpec) DeepCopyInto(out *StatSpec)

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

type StddevSpec 

type StddevSpec struct {
	//+optional
	//+kubebuilder:validation:Enum=sample;population
	Type string `json:"type,omitempty"`
}

StddevSpec defines a Standard deviation

func (*StddevSpec) DeepCopy 

func (in *StddevSpec) DeepCopy() *StddevSpec

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

func (*StddevSpec) DeepCopyInto 

func (in *StddevSpec) DeepCopyInto(out *StddevSpec)

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

type StorageSpec 

type StorageSpec struct {
	//+required
	Inference SinkSpec `json:"inference"`
	//+required
	Analysis AnalysisSpec `json:"analysis"`
}

StorageSpec defines the Storage settings

func (*StorageSpec) DeepCopy 

func (in *StorageSpec) DeepCopy() *StorageSpec

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

func (*StorageSpec) DeepCopyInto 

func (in *StorageSpec) DeepCopyInto(out *StorageSpec)

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

type SumSpec 

type SumSpec struct{}

SumSpec defines a Sum stat

func (*SumSpec) DeepCopy 

func (in *SumSpec) DeepCopy() *SumSpec

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

func (*SumSpec) DeepCopyInto 

func (in *SumSpec) DeepCopyInto(out *SumSpec)

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

type ThresholdBasedDriftSpec 

type ThresholdBasedDriftSpec struct {
	//+required
	Threshold string `json:"threshold"`
	//+optional
	ShowAll bool `json:"showAll,omitempty"`
}

ThresholdBasedDriftSpec defines a threshold-based Drift detector

func (*ThresholdBasedDriftSpec) DeepCopy 

func (in *ThresholdBasedDriftSpec) DeepCopy() *ThresholdBasedDriftSpec

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

func (*ThresholdBasedDriftSpec) DeepCopyInto 

func (in *ThresholdBasedDriftSpec) DeepCopyInto(out *ThresholdBasedDriftSpec)

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

type TriggerSpec 

type TriggerSpec struct {
	//+required
	Window WindowSpec `json:"window"`
}

TriggerSpec defines the Monitoring trigger setting

func (*TriggerSpec) DeepCopy 

func (in *TriggerSpec) DeepCopy() *TriggerSpec

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

func (*TriggerSpec) DeepCopyInto 

func (in *TriggerSpec) DeepCopyInto(out *TriggerSpec)

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

type WindowSpec 

type WindowSpec struct {
	//+required
	Duration int `json:"duration"`
	//+required
	Slide int `json:"slide"`
	//+required
	WatermarkDelay int `json:"watermarkDelay"`
}

WindowSpec defines a Window as Monitoring job trigger

func (*WindowSpec) DeepCopy 

func (in *WindowSpec) DeepCopy() *WindowSpec

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

func (*WindowSpec) DeepCopyInto 

func (in *WindowSpec) DeepCopyInto(out *WindowSpec)

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

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.