v1alpha1

Documentation

Index

• Constants
• Variables
• func Resource(resource string) schema.GroupResource
• type ThroughputAnomalyDetector
  • func (in *ThroughputAnomalyDetector) DeepCopy() *ThroughputAnomalyDetector
  • func (in *ThroughputAnomalyDetector) DeepCopyInto(out *ThroughputAnomalyDetector)
  • func (in *ThroughputAnomalyDetector) DeepCopyObject() runtime.Object
• type ThroughputAnomalyDetectorList
  • func (in *ThroughputAnomalyDetectorList) DeepCopy() *ThroughputAnomalyDetectorList
  • func (in *ThroughputAnomalyDetectorList) DeepCopyInto(out *ThroughputAnomalyDetectorList)
  • func (in *ThroughputAnomalyDetectorList) DeepCopyObject() runtime.Object
• type ThroughputAnomalyDetectorStats
  • func (in *ThroughputAnomalyDetectorStats) DeepCopy() *ThroughputAnomalyDetectorStats
  • func (in *ThroughputAnomalyDetectorStats) DeepCopyInto(out *ThroughputAnomalyDetectorStats)
• type ThroughputAnomalyDetectorStatus
  • func (in *ThroughputAnomalyDetectorStatus) DeepCopy() *ThroughputAnomalyDetectorStatus
  • func (in *ThroughputAnomalyDetectorStatus) DeepCopyInto(out *ThroughputAnomalyDetectorStatus)

Constants

const GroupName = "anomalydetector.theia.antrea.io"

Variables

var (
	SchemeGroupVersion = schema.GroupVersion{
		Group:   GroupName,
		Version: "v1alpha1"}

	StatusResource = schema.GroupVersionResource{
		Group:    SchemeGroupVersion.Group,
		Version:  SchemeGroupVersion.Version,
		Resource: "throughputanomalydetectors"}
)

var (
	SchemeBuilder runtime.SchemeBuilder

	AddToScheme = localSchemeBuilder.AddToScheme
)

Functions

func Resource

func Resource(resource string) schema.GroupResource

Types

type ThroughputAnomalyDetector

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

	Type                string                           `json:"jobType,omitempty"`
	StartInterval       metav1.Time                      `json:"startInterval,omitempty"`
	EndInterval         metav1.Time                      `json:"endInterval,omitempty"`
	ExecutorInstances   int                              `json:"executorInstances,omitempty"`
	DriverCoreRequest   string                           `json:"driverCoreRequest,omitempty"`
	DriverMemory        string                           `json:"driverMemory,omitempty"`
	ExecutorCoreRequest string                           `json:"executorCoreRequest,omitempty"`
	ExecutorMemory      string                           `json:"executorMemory,omitempty"`
	Status              ThroughputAnomalyDetectorStatus  `json:"status,omitempty"`
	Stats               []ThroughputAnomalyDetectorStats `json:"stats,omitempty"`
}

func (*ThroughputAnomalyDetector) DeepCopy

func (in *ThroughputAnomalyDetector) DeepCopy() *ThroughputAnomalyDetector

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

func (*ThroughputAnomalyDetector) DeepCopyInto

func (in *ThroughputAnomalyDetector) DeepCopyInto(out *ThroughputAnomalyDetector)

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

func (*ThroughputAnomalyDetector) DeepCopyObject

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

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

type ThroughputAnomalyDetectorList

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

func (*ThroughputAnomalyDetectorList) DeepCopy

func (in *ThroughputAnomalyDetectorList) DeepCopy() *ThroughputAnomalyDetectorList

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

func (*ThroughputAnomalyDetectorList) DeepCopyInto

func (in *ThroughputAnomalyDetectorList) DeepCopyInto(out *ThroughputAnomalyDetectorList)

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

func (*ThroughputAnomalyDetectorList) DeepCopyObject

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

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

type ThroughputAnomalyDetectorStats

type ThroughputAnomalyDetectorStats struct {
	Id                       string `json:"id,omitempty"`
	SourceIP                 string `json:"sourceIP,omitempty"`
	SourceTransportPort      string `json:"sourceTransportPort,omitempty"`
	DestinationIP            string `json:"destinationIP,omitempty"`
	DestinationTransportPort string `json:"destinationTransportPort,omitempty"`
	FlowStartSeconds         string `json:"FlowStartSeconds,omitempty"`
	FlowEndSeconds           string `json:"FlowEndSeconds,omitempty"`
	Throughput               string `json:"Throughput,omitempty"`
	AlgoCalc                 string `json:"AlgoCalc,omitempty"`
	Anomaly                  string `json:"anomaly,omitempty"`
}

func (*ThroughputAnomalyDetectorStats) DeepCopy

func (in *ThroughputAnomalyDetectorStats) DeepCopy() *ThroughputAnomalyDetectorStats

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

func (*ThroughputAnomalyDetectorStats) DeepCopyInto

func (in *ThroughputAnomalyDetectorStats) DeepCopyInto(out *ThroughputAnomalyDetectorStats)

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

type ThroughputAnomalyDetectorStatus

type ThroughputAnomalyDetectorStatus struct {
	State            string      `json:"state,omitempty"`
	SparkApplication string      `json:"sparkApplication,omitempty"`
	CompletedStages  int         `json:"completedStages,omitempty"`
	TotalStages      int         `json:"totalStages,omitempty"`
	ErrorMsg         string      `json:"errorMsg,omitempty"`
	StartTime        metav1.Time `json:"startTime,omitempty"`
	EndTime          metav1.Time `json:"endTime,omitempty"`
}

func (*ThroughputAnomalyDetectorStatus) DeepCopy

func (in *ThroughputAnomalyDetectorStatus) DeepCopy() *ThroughputAnomalyDetectorStatus

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

func (*ThroughputAnomalyDetectorStatus) DeepCopyInto

func (in *ThroughputAnomalyDetectorStatus) DeepCopyInto(out *ThroughputAnomalyDetectorStatus)

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