v1alpha1

package
v4.2.711+incompatible Latest Latest
Warning

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

 Go to latest Published: Feb 20, 2020 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Overview

Package v1alpha1 is the v1alpha1 version of the API. +groupName=autoscaling.containers.ai

Package v1alpha1 contains API Schema definitions for the autoscaling v1alpha1 API group +kubebuilder:object:generate=true +groupName=autoscaling.containers.ai

Index

Constants

View Source 
const (
	RecommendationPolicySTABLE  alamedaPolicy = "stable"
	RecommendationPolicyCOMPACT alamedaPolicy = "compact"
)
View Source 
const (
	DefaultTriggerThresholdCPUPercentage    = "10%"
	DefaultTriggerThresholdMemoryPercentage = "10%"
)
View Source 
const (
	DefaultMaxUnavailablePercentage = "25%"
)

Variables

View Source 
var (
	AlamedaControllerTypeName = map[AlamedaControllerType]string{
		DeploymentController:       "deployment",
		DeploymentConfigController: "deploymentconfig",
		StatefulSetController:      "statefulset",
	}

	K8SKindToAlamedaControllerType = map[string]AlamedaControllerType{
		"Deployment":       DeploymentController,
		"DeploymentConfig": DeploymentConfigController,
		"StatefulSet":      StatefulSetController,
	}
)
View Source 
var (

	// GroupVersion is group version used to register these objects
	GroupVersion = schema.GroupVersion{Group: "autoscaling.containers.ai", Version: "v1alpha1"}

	// 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 AlamedaContainer 

type AlamedaContainer struct {
	Name      string                      `json:"name" protobuf:"bytes,1,opt,name=name"`
	Resources corev1.ResourceRequirements `json:"resources,omitempty" protobuf:"bytes,2,opt,name=resources"`
}

func (*AlamedaContainer) DeepCopy 

func (in *AlamedaContainer) DeepCopy() *AlamedaContainer

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

func (*AlamedaContainer) DeepCopyInto 

func (in *AlamedaContainer) DeepCopyInto(out *AlamedaContainer)

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

type AlamedaController 

type AlamedaController struct {
	Deployments       map[NamespacedName]AlamedaResource `json:"deployments,omitempty" protobuf:"bytes,1,opt,name=deployments"`
	DeploymentConfigs map[NamespacedName]AlamedaResource `json:"deploymentConfigs,omitempty" protobuf:"bytes,2,opt,name=deployment_configs"`
	StatefulSets      map[NamespacedName]AlamedaResource `json:"statefulSets,omitempty" protobuf:"bytes,3,opt,name=stateful_sets"`
}

func NewAlamedaController 

func NewAlamedaController() AlamedaController

func (*AlamedaController) DeepCopy 

func (in *AlamedaController) DeepCopy() *AlamedaController

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

func (*AlamedaController) DeepCopyInto 

func (in *AlamedaController) DeepCopyInto(out *AlamedaController)

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

type AlamedaControllerType 

type AlamedaControllerType int
const (
	DeploymentController       AlamedaControllerType = 1
	DeploymentConfigController AlamedaControllerType = 2
	StatefulSetController      AlamedaControllerType = 3
)

type AlamedaPod 

type AlamedaPod struct {
	Namespace  string             `json:"namespace" protobuf:"bytes,1,opt,name=namespace"`
	Name       string             `json:"name" protobuf:"bytes,2,opt,name=name"`
	UID        string             `json:"uid" protobuf:"bytes,3,opt,name=uid"`
	Containers []AlamedaContainer `json:"containers" protobuf:"bytes,4,opt,name=containers"`
}

func (*AlamedaPod) DeepCopy 

func (in *AlamedaPod) DeepCopy() *AlamedaPod

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

func (*AlamedaPod) DeepCopyInto 

func (in *AlamedaPod) DeepCopyInto(out *AlamedaPod)

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

func (*AlamedaPod) GetNamespacedName 

func (p *AlamedaPod) GetNamespacedName() NamespacedName

type AlamedaRecommendation 

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

	Spec   AlamedaRecommendationSpec   `json:"spec,omitempty"`
	Status AlamedaRecommendationStatus `json:"status,omitempty"`
}

+kubebuilder:resource:scope=Namespaced

func (*AlamedaRecommendation) DeepCopy 

func (in *AlamedaRecommendation) DeepCopy() *AlamedaRecommendation

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

func (*AlamedaRecommendation) DeepCopyInto 

func (in *AlamedaRecommendation) DeepCopyInto(out *AlamedaRecommendation)

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

func (*AlamedaRecommendation) DeepCopyObject 

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

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

func (*AlamedaRecommendation) GetNamespacedName 

func (ar *AlamedaRecommendation) GetNamespacedName() NamespacedName

type AlamedaRecommendationList 

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

AlamedaRecommendationList contains a list of AlamedaRecommendation

func (*AlamedaRecommendationList) DeepCopy 

func (in *AlamedaRecommendationList) DeepCopy() *AlamedaRecommendationList

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

func (*AlamedaRecommendationList) DeepCopyInto 

func (in *AlamedaRecommendationList) DeepCopyInto(out *AlamedaRecommendationList)

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

func (*AlamedaRecommendationList) DeepCopyObject 

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

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

type AlamedaRecommendationSpec 

type AlamedaRecommendationSpec struct {
	Containers []AlamedaContainer `json:"containers" protobuf:"bytes,1,opt,name=containers"`
}

AlamedaRecommendationSpec defines the desired state of AlamedaRecommendation

func (*AlamedaRecommendationSpec) DeepCopy 

func (in *AlamedaRecommendationSpec) DeepCopy() *AlamedaRecommendationSpec

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

func (*AlamedaRecommendationSpec) DeepCopyInto 

func (in *AlamedaRecommendationSpec) DeepCopyInto(out *AlamedaRecommendationSpec)

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

type AlamedaRecommendationStatus 

type AlamedaRecommendationStatus struct {
}

AlamedaRecommendationStatus defines the observed state of AlamedaRecommendation

func (*AlamedaRecommendationStatus) DeepCopy 

func (in *AlamedaRecommendationStatus) DeepCopy() *AlamedaRecommendationStatus

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

func (*AlamedaRecommendationStatus) DeepCopyInto 

func (in *AlamedaRecommendationStatus) DeepCopyInto(out *AlamedaRecommendationStatus)

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

type AlamedaResource 

type AlamedaResource struct {
	Namespace    string                        `json:"namespace" protobuf:"bytes,1,opt,name=namespace"`
	Name         string                        `json:"name" protobuf:"bytes,2,opt,name=name"`
	UID          string                        `json:"uid" protobuf:"bytes,3,opt,name=uid"`
	Pods         map[NamespacedName]AlamedaPod `json:"pods,omitempty" protobuf:"bytes,4,opt,name=pods"`
	SpecReplicas *int32                        `json:"specReplicas" protobuf:"varint,5,opt,name=spec_replicas"`
	Effective    bool                          `json:"effective" protobuf:"varint,6,opt,name=effective"`
	Message      string                        `json:"message" protobuf:"varint,5,opt,name=message"`
}

func (*AlamedaResource) DeepCopy 

func (in *AlamedaResource) DeepCopy() *AlamedaResource

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

func (*AlamedaResource) DeepCopyInto 

func (in *AlamedaResource) DeepCopyInto(out *AlamedaResource)

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

func (AlamedaResource) GetNamespacedName 

func (a AlamedaResource) GetNamespacedName() NamespacedName

type AlamedaScaler 

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

	Spec   AlamedaScalerSpec   `json:"spec,omitempty"`
	Status AlamedaScalerStatus `json:"status,omitempty"`
}

AlamedaScaler is the Schema for the alamedascalers API

func (*AlamedaScaler) AddAlamedaResourceIntoStatus 

func (as *AlamedaScaler) AddAlamedaResourceIntoStatus(arType AlamedaControllerType, ar AlamedaResource)

func (*AlamedaScaler) DeepCopy 

func (in *AlamedaScaler) DeepCopy() *AlamedaScaler

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

func (*AlamedaScaler) DeepCopyInto 

func (in *AlamedaScaler) DeepCopyInto(out *AlamedaScaler)

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

func (*AlamedaScaler) DeepCopyObject 

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

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

func (*AlamedaScaler) GenCustomResourceVersion 

func (as *AlamedaScaler) GenCustomResourceVersion() string

func (*AlamedaScaler) GetKafkaNamespace 

func (as *AlamedaScaler) GetKafkaNamespace() string

func (*AlamedaScaler) GetLabelMapToSetToAlamedaRecommendationLabel 

func (as *AlamedaScaler) GetLabelMapToSetToAlamedaRecommendationLabel() map[string]string

func (*AlamedaScaler) GetLimitCPUMilliCores 

func (as *AlamedaScaler) GetLimitCPUMilliCores() string

func (*AlamedaScaler) GetLimitMemoryBytes 

func (as *AlamedaScaler) GetLimitMemoryBytes() string

func (*AlamedaScaler) GetMonitoredPods 

func (as *AlamedaScaler) GetMonitoredPods() []*AlamedaPod

GetMonitoredPods returns pods restoring in AlamedaScaler.Status

func (*AlamedaScaler) GetRequestCPUMilliCores 

func (as *AlamedaScaler) GetRequestCPUMilliCores() string

func (*AlamedaScaler) GetRequestMemoryBytes 

func (as *AlamedaScaler) GetRequestMemoryBytes() string

func (*AlamedaScaler) GetType 

func (as *AlamedaScaler) GetType() AlamedaScalerType

func (*AlamedaScaler) HasAlamedaPod 

func (as *AlamedaScaler) HasAlamedaPod(namespace, name string) bool

HasAlamedaPod returns true if the pod is reocording in AlamedaScaler.Status

func (*AlamedaScaler) IsEnableExecution 

func (as *AlamedaScaler) IsEnableExecution() bool

func (*AlamedaScaler) IsScalingToolTypeHPA 

func (as *AlamedaScaler) IsScalingToolTypeHPA() bool

func (*AlamedaScaler) IsScalingToolTypeVPA 

func (as *AlamedaScaler) IsScalingToolTypeVPA() bool

func (*AlamedaScaler) ListKafkaConsumerGroupSpecs 

func (as *AlamedaScaler) ListKafkaConsumerGroupSpecs() []KafkaConsumerGroupSpec

func (*AlamedaScaler) ListKafkaTopics 

func (as *AlamedaScaler) ListKafkaTopics() []string

func (*AlamedaScaler) SetCustomResourceVersion 

func (as *AlamedaScaler) SetCustomResourceVersion(v string)

func (*AlamedaScaler) SetDefaultValue 

func (as *AlamedaScaler) SetDefaultValue()

func (*AlamedaScaler) SetStatusAlamedaController 

func (as *AlamedaScaler) SetStatusAlamedaController(ac AlamedaController)

func (*AlamedaScaler) SetStatusKafka 

func (as *AlamedaScaler) SetStatusKafka(k *KafkaStatus)

func (*AlamedaScaler) SetType 

func (as *AlamedaScaler) SetType(t AlamedaScalerType)

type AlamedaScalerList 

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

AlamedaScalerList contains a list of AlamedaScaler

func (*AlamedaScalerList) DeepCopy 

func (in *AlamedaScalerList) DeepCopy() *AlamedaScalerList

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

func (*AlamedaScalerList) DeepCopyInto 

func (in *AlamedaScalerList) DeepCopyInto(out *AlamedaScalerList)

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

func (*AlamedaScalerList) DeepCopyObject 

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

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

type AlamedaScalerSpec 

type AlamedaScalerSpec struct {
	Selector        *metav1.LabelSelector `json:"selector,omitempty" protobuf:"bytes,1,name=selector"`
	EnableExecution *enableExecution      `json:"enableExecution,omitempty" protobuf:"bytes,2,name=enable_execution"`
	// +kubebuilder:validation:Enum=stable;compact
	Policy                alamedaPolicy     `json:"policy,omitempty" protobuf:"bytes,3,opt,name=policy"`
	CustomResourceVersion string            `json:"customResourceVersion,omitempty" protobuf:"bytes,4,opt,name=custom_resource_version"`
	ScalingTool           ScalingToolSpec   `json:"scalingTool,omitempty" protobuf:"bytes,5,opt,name=scaling_tool"`
	Type                  AlamedaScalerType `json:"type,omitempty" protobuf:"bytes,6,opt,name=type"`
	Kafka                 *KafkaSpec        `json:"kafka,omitempty" protobuf:"bytes,7,opt,name=kafka"`
}

AlamedaScalerSpec defines the desired state of AlamedaScaler INSERT ADDITIONAL SPEC FIELDS - desired state of cluster

func (*AlamedaScalerSpec) DeepCopy 

func (in *AlamedaScalerSpec) DeepCopy() *AlamedaScalerSpec

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

func (*AlamedaScalerSpec) DeepCopyInto 

func (in *AlamedaScalerSpec) DeepCopyInto(out *AlamedaScalerSpec)

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

type AlamedaScalerStatus 

type AlamedaScalerStatus struct {
	AlamedaController AlamedaController `json:"alamedaController,omitempty" protobuf:"bytes,4,opt,name=alameda_controller"`
	Kafka             *KafkaStatus      `json:"kafka,omitempty" protobuf:"bytes,5,opt,name=kafka"`
}

AlamedaScalerStatus defines the observed state of AlamedaScaler

func (*AlamedaScalerStatus) DeepCopy 

func (in *AlamedaScalerStatus) DeepCopy() *AlamedaScalerStatus

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

func (*AlamedaScalerStatus) DeepCopyInto 

func (in *AlamedaScalerStatus) DeepCopyInto(out *AlamedaScalerStatus)

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

type AlamedaScalerType 

type AlamedaScalerType = string
const (
	AlamedaScalerTypeNotDefine AlamedaScalerType = ""
	AlamedaScalerTypeDefault   AlamedaScalerType = "default"
	AlamedaScalerTypeKafka     AlamedaScalerType = "kafka"
)

type ExecutionStrategy 

type ExecutionStrategy struct {
	// +kubebuilder:validation:Pattern=^\d*[1-9]+\d*(%?$)$|^\d*[1-9]+\d*\.\d*(%?$)$|^\d*\.\d*[1-9]+\d*(%?$)$
	MaxUnavailable   string                       `json:"maxUnavailable,omitempty" protobuf:"bytes,1,name=max_unavailable"`
	TriggerThreshold *TriggerThreshold            `json:"triggerThreshold,omitempty" protobuf:"bytes,2,name=trigger_threshold"`
	Resources        *corev1.ResourceRequirements `json:"resources,omitempty" protobuf:"bytes,3,name=resources"`
}

func NewDefaultExecutionStrategy 

func NewDefaultExecutionStrategy() ExecutionStrategy

func (*ExecutionStrategy) DeepCopy 

func (in *ExecutionStrategy) DeepCopy() *ExecutionStrategy

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

func (*ExecutionStrategy) DeepCopyInto 

func (in *ExecutionStrategy) DeepCopyInto(out *ExecutionStrategy)

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

type KafkaConsumerGroupResourceMetadata 

type KafkaConsumerGroupResourceMetadata struct {
	CustomName string                    `json:"customName,omitempty" protobuf:"bytes,1,opt,name=custom_name"`
	Kubernetes *KubernetesObjectMetadata `json:"kubernetes,omitempty" protobuf:"bytes,2,opt,name=kubernetes"`
}

func (*KafkaConsumerGroupResourceMetadata) DeepCopy 

func (in *KafkaConsumerGroupResourceMetadata) DeepCopy() *KafkaConsumerGroupResourceMetadata

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

func (*KafkaConsumerGroupResourceMetadata) DeepCopyInto 

func (in *KafkaConsumerGroupResourceMetadata) DeepCopyInto(out *KafkaConsumerGroupResourceMetadata)

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

type KafkaConsumerGroupResourceSpec 

type KafkaConsumerGroupResourceSpec struct {
	Kubernetes *KubernetesResourceSpec `json:"kubernetes,omitempty" protobuf:"bytes,1,opt,name=kubernetes"`
	Custom     string                  `json:"custom,omitempty" protobuf:"bytes,2,opt,name=custom"`
}

func (*KafkaConsumerGroupResourceSpec) DeepCopy 

func (in *KafkaConsumerGroupResourceSpec) DeepCopy() *KafkaConsumerGroupResourceSpec

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

func (*KafkaConsumerGroupResourceSpec) DeepCopyInto 

func (in *KafkaConsumerGroupResourceSpec) DeepCopyInto(out *KafkaConsumerGroupResourceSpec)

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

type KafkaConsumerGroupSpec 

type KafkaConsumerGroupSpec struct {
	// +kubebuilder:validation:MinLength=1
	Name        string                         `json:"name,omitempty" protobuf:"bytes,1,opt,name=name"`
	Resource    KafkaConsumerGroupResourceSpec `json:"resource,omitempty" protobuf:"bytes,2,opt,name=resource"`
	MajorTopic  string                         `json:"majorTopic,omitempty" protobuf:"bytes,3,opt,name=major_topic"`
	MinReplicas *int32                         `json:"minReplicas,omitempty" protobuf:"bytes,2,opt,name=min_replicas"`
	MaxReplicas *int32                         `json:"maxReplicas,omitempty" protobuf:"bytes,3,opt,name=max_replicas"`
}

func (*KafkaConsumerGroupSpec) DeepCopy 

func (in *KafkaConsumerGroupSpec) DeepCopy() *KafkaConsumerGroupSpec

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

func (*KafkaConsumerGroupSpec) DeepCopyInto 

func (in *KafkaConsumerGroupSpec) DeepCopyInto(out *KafkaConsumerGroupSpec)

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

type KafkaConsumerGroupStatus 

type KafkaConsumerGroupStatus struct {
	Name        string                             `json:"name,omitempty" protobuf:"bytes,1,opt,name=name"`
	Topic       string                             `json:"topic,omitempty" protobuf:"bytes,2,opt,name=topic"`
	Resource    KafkaConsumerGroupResourceMetadata `json:"resource,omitempty" protobuf:"bytes,3,opt,name=resource"`
	MinReplicas int32                              `json:"minReplicas,omitempty" protobuf:"bytes,4,opt,name=min_replicas"`
	MaxReplicas int32                              `json:"maxReplicas,omitempty" protobuf:"bytes,5,opt,name=max_replicas"`
}

func (*KafkaConsumerGroupStatus) DeepCopy 

func (in *KafkaConsumerGroupStatus) DeepCopy() *KafkaConsumerGroupStatus

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

func (*KafkaConsumerGroupStatus) DeepCopyInto 

func (in *KafkaConsumerGroupStatus) DeepCopyInto(out *KafkaConsumerGroupStatus)

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

type KafkaSpec 

type KafkaSpec struct {
	// +kubebuilder:validation:MinLength=1
	ExporterNamespace string `json:"exporterNamespace,omitempty" protobuf:"bytes,1,opt,name=exporter_namespace"`
	// +kubebuilder:validation:MinItems=1
	Topics []string `json:"topics,omitempty" protobuf:"bytes,2,opt,name=topics"`
	// +kubebuilder:validation:MinItems=1
	ConsumerGroups []KafkaConsumerGroupSpec `json:"consumerGroups,omitempty" protobuf:"bytes,3,opt,name=consumer_groups"`
}

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 KafkaStatus 

type KafkaStatus struct {
	Effective         bool                       `json:"effective" protobuf:"bytes,1,opt,name=effective"`
	Message           string                     `json:"message" protobuf:"bytes,2,opt,name=message"`
	ExporterNamespace string                     `json:"namespace,omitempty" protobuf:"bytes,3,opt,name=namespace"`
	Topics            []string                   `json:"topics,omitempty" protobuf:"bytes,4,opt,name=topics"`
	ConsumerGroups    []KafkaConsumerGroupStatus `json:"consumerGroups,omitempty" protobuf:"bytes,5,opt,name=consumer_groups"`
}

func (*KafkaStatus) DeepCopy 

func (in *KafkaStatus) DeepCopy() *KafkaStatus

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

func (*KafkaStatus) DeepCopyInto 

func (in *KafkaStatus) DeepCopyInto(out *KafkaStatus)

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

type KubernetesObjectMetadata 

type KubernetesObjectMetadata struct {
	Namespace string `json:"namespace,omitempty" protobuf:"bytes,1,opt,name=namespace"`
	Name      string `json:"name,omitempty" protobuf:"bytes,2,opt,name=name"`
	Kind      string `json:"kind,omitempty" protobuf:"bytes,3,opt,name=kind"`
}

func (*KubernetesObjectMetadata) DeepCopy 

func (in *KubernetesObjectMetadata) DeepCopy() *KubernetesObjectMetadata

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

func (*KubernetesObjectMetadata) DeepCopyInto 

func (in *KubernetesObjectMetadata) DeepCopyInto(out *KubernetesObjectMetadata)

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

type KubernetesResourceSpec 

type KubernetesResourceSpec struct {
	Selector *metav1.LabelSelector `json:"selector,omitempty" protobuf:"bytes,1,opt,name=selector"`
}

func (*KubernetesResourceSpec) DeepCopy 

func (in *KubernetesResourceSpec) DeepCopy() *KubernetesResourceSpec

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

func (*KubernetesResourceSpec) DeepCopyInto 

func (in *KubernetesResourceSpec) DeepCopyInto(out *KubernetesResourceSpec)

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

type NamespacedName 

type NamespacedName = string

type ScalingToolSpec 

type ScalingToolSpec struct {
	// +kubebuilder:validation:Enum="";vpa;hpa;N/A
	Type              string             `json:"type,omitempty" protobuf:"bytes,1,name=type"`
	ExecutionStrategy *ExecutionStrategy `json:"executionStrategy,omitempty" protobuf:"bytes,2,name=execution_strategy"`
}

func (*ScalingToolSpec) DeepCopy 

func (in *ScalingToolSpec) DeepCopy() *ScalingToolSpec

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

func (*ScalingToolSpec) DeepCopyInto 

func (in *ScalingToolSpec) DeepCopyInto(out *ScalingToolSpec)

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

type ScalingToolType 

type ScalingToolType = string
const (
	ScalingToolTypeVPA     ScalingToolType = "vpa"
	ScalingToolTypeHPA     ScalingToolType = "hpa"
	ScalingToolTypeDefault ScalingToolType = "N/A"
)

type TriggerThreshold 

type TriggerThreshold struct {
	// +kubebuilder:validation:Pattern=^\d*[1-9]+\d*%$|^\d*[1-9]+\d*\.\d*%$|^\d*\.\d*[1-9]+\d*%$
	CPU string `json:"cpu,omitempty" protobuf:"bytes,1,name=cpu"`
	// +kubebuilder:validation:Pattern=^\d*[1-9]+\d*%$|^\d*[1-9]+\d*\.\d*%$|^\d*\.\d*[1-9]+\d*%$
	Memory string `json:"memory,omitempty" protobuf:"bytes,2,name=memory"`
}

func NewDefaultTriggerThreshold 

func NewDefaultTriggerThreshold() TriggerThreshold

func (*TriggerThreshold) DeepCopy 

func (in *TriggerThreshold) DeepCopy() *TriggerThreshold

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

func (*TriggerThreshold) DeepCopyInto 

func (in *TriggerThreshold) DeepCopyInto(out *TriggerThreshold)

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.