v1alpha1

package
v4.5.2003+incompatible Latest Latest
Warning

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

 Go to latest Published: Jun 29, 2020 License: Apache-2.0 Imports: 7 Imported by: 5

Documentation

Overview

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 (
	ScalingToolTypeVPA     = "vpa"
	ScalingToolTypeHPA     = "hpa"
	ScalingToolTypeCA      = "ca"
	ScalingToolTypeDefault = "N/A"
)
View Source 
const (
	AlamedaScalerTypeNotDefine = ""
	AlamedaScalerTypeDefault   = "default"
	AlamedaScalerTypeKafka     = "kafka"
	AlamedaScalerTypeNginx     = "nginx"
)
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[string]AlamedaResource `json:"deployments,omitempty" protobuf:"bytes,1,opt,name=deployments"`
	DeploymentConfigs map[string]AlamedaResource `json:"deploymentConfigs,omitempty" protobuf:"bytes,2,opt,name=deployment_configs"`
	StatefulSets      map[string]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 AlamedaMachineGroupScaler 

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

	Spec   AlamedaMachineGroupScalerSpec   `json:"spec,omitempty"`
	Status AlamedaMachineGroupScalerStatus `json:"status,omitempty"`
}

AlamedaMachineGroupScaler is the Schema for the alamedamachinegroupscalers API

func (*AlamedaMachineGroupScaler) DeepCopy 

func (in *AlamedaMachineGroupScaler) DeepCopy() *AlamedaMachineGroupScaler

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

func (*AlamedaMachineGroupScaler) DeepCopyInto 

func (in *AlamedaMachineGroupScaler) DeepCopyInto(out *AlamedaMachineGroupScaler)

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

func (*AlamedaMachineGroupScaler) DeepCopyObject 

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

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

type AlamedaMachineGroupScalerList 

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

AlamedaMachineGroupScalerList contains a list of AlamedaMachineGroupScaler

func (*AlamedaMachineGroupScalerList) DeepCopy 

func (in *AlamedaMachineGroupScalerList) DeepCopy() *AlamedaMachineGroupScalerList

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

func (*AlamedaMachineGroupScalerList) DeepCopyInto 

func (in *AlamedaMachineGroupScalerList) DeepCopyInto(out *AlamedaMachineGroupScalerList)

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

func (*AlamedaMachineGroupScalerList) DeepCopyObject 

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

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

type AlamedaMachineGroupScalerSpec 

type AlamedaMachineGroupScalerSpec struct {
	MachineSets []MachineSet          `json:"machineSets"`
	Metrics     map[string]MetricRule `json:"metrics"`
}

AlamedaMachineGroupScalerSpec defines the desired state of AlamedaMachineGroupScaler

func (*AlamedaMachineGroupScalerSpec) DeepCopy 

func (in *AlamedaMachineGroupScalerSpec) DeepCopy() *AlamedaMachineGroupScalerSpec

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

func (*AlamedaMachineGroupScalerSpec) DeepCopyInto 

func (in *AlamedaMachineGroupScalerSpec) DeepCopyInto(out *AlamedaMachineGroupScalerSpec)

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

type AlamedaMachineGroupScalerStatus 

type AlamedaMachineGroupScalerStatus struct {
}

AlamedaMachineGroupScalerStatus defines the observed state of AlamedaMachineGroupScaler

func (*AlamedaMachineGroupScalerStatus) DeepCopy 

func (in *AlamedaMachineGroupScalerStatus) DeepCopy() *AlamedaMachineGroupScalerStatus

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

func (*AlamedaMachineGroupScalerStatus) DeepCopyInto 

func (in *AlamedaMachineGroupScalerStatus) DeepCopyInto(out *AlamedaMachineGroupScalerStatus)

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

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() string

type AlamedaRecommendation 

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

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

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() string

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[string]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() string

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 +kubebuilder:object:root=true +kubebuilder:printcolumn:name="Scaling Type",type=string,JSONPath=`.spec.type`,description="The type of scaling" +kubebuilder:printcolumn:name="Scaling Tool",type=string,JSONPath=`.spec.scalingTool.type`,description="The type of scaling tool" +kubebuilder:printcolumn:name="Execution",type=boolean,JSONPath=`.spec.enableExecution`,description="The enable of execution" +kubebuilder:printcolumn:name="Selector",type=string,JSONPath=`.spec.selector.matchLabels`,description="The match labels of selector" +kubebuilder:printcolumn:name="Age",type=date,JSONPath=`.metadata.creationTimestamp`,description="The time of creation"

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() string

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) IsScalingToolTypeCA 

func (as *AlamedaScaler) IsScalingToolTypeCA() 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 string)

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                  string          `json:"type,omitempty" protobuf:"bytes,6,opt,name=type"`
	Kafka                 *KafkaSpec      `json:"kafka,omitempty" protobuf:"bytes,7,opt,name=kafka"`
	Nginx                 *NginxSpec      `json:"nginx,omitempty" protobuf:"bytes,8,opt,name=nginx"`
}

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"`
	Nginx             *NginxStatus      `json:"nginx,omitempty" protobuf:"bytes,6,opt,name=nginx"`
}

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 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" protobuf:"bytes,3,opt,name=major_topic"`
	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 (*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 MachineSet 

type MachineSet struct {
	Name           string `json:"name"`
	Namespace      string `json:"namespace"`
	MinReplicas    *int32 `json:"minReplicas,omitempty"`
	MaxReplicas    *int32 `json:"maxReplicas,omitempty"`
	ScaleUpDelay   *int64 `json:"scaleUpDelay,omitempty"`
	ScaleDownDelay *int64 `json:"scaleDownDelay,omitempty"`
}

func (*MachineSet) DeepCopy 

func (in *MachineSet) DeepCopy() *MachineSet

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

func (*MachineSet) DeepCopyInto 

func (in *MachineSet) DeepCopyInto(out *MachineSet)

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

type MetricRule 

type MetricRule struct {
	UtilizationTarget               *int32 `json:"utilizationTarget,omitempty"`
	ScaleUpGap                      *int32 `json:"scaleUpGap,omitempty"`
	ScaleDownGap                    *int32 `json:"scaleDownGap,omitempty"`
	DurationUpThresholdPercentage   *int32 `json:"durationUpThresholdPercentage,omitempty"`
	DurationDownThresholdPercentage *int32 `json:"durationDownThresholdPercentage,omitempty"`
}

func (*MetricRule) DeepCopy 

func (in *MetricRule) DeepCopy() *MetricRule

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

func (*MetricRule) DeepCopyInto 

func (in *MetricRule) DeepCopyInto(out *MetricRule)

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

type NginxResourceSpec 

type NginxResourceSpec struct {
	Kubernetes *KubernetesResourceSpec `json:"kubernetes,omitempty" protobuf:"bytes,1,opt,name=kubernetes"`
}

func (*NginxResourceSpec) DeepCopy 

func (in *NginxResourceSpec) DeepCopy() *NginxResourceSpec

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

func (*NginxResourceSpec) DeepCopyInto 

func (in *NginxResourceSpec) DeepCopyInto(out *NginxResourceSpec)

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

type NginxSpec 

type NginxSpec struct {
	Name                    string                `json:"name,omitempty" protobuf:"bytes,1,opt,name=name"`
	Selector                *metav1.LabelSelector `json:"selector,omitempty" protobuf:"bytes,2,opt,name=selector"`
	ExporterNamespace       string                `json:"exporterNamespace,omitempty" protobuf:"bytes,3,opt,name=exporter_namespace"`
	ReplicaMarginPercentage *int32                `json:"replicaMarginPercentage,omitempty" protobuf:"bytes,4,opt,name=replica_margin_percentage"`
	MinReplicas             *int32                `json:"minReplicas,omitempty" protobuf:"bytes,5,opt,name=min_replicas"`
	MaxReplicas             *int32                `json:"maxReplicas,omitempty" protobuf:"bytes,6,opt,name=max_replicas"`
	Service                 string                `json:"service,omitempty" protobuf:"bytes,7,opt,name=service"`
	TargetResponseTime      *int64                `json:"targetResponseTime,omitempty" protobuf:"bytes,8,opt,name=target_response_time"`
}

func (*NginxSpec) DeepCopy 

func (in *NginxSpec) DeepCopy() *NginxSpec

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

func (*NginxSpec) DeepCopyInto 

func (in *NginxSpec) DeepCopyInto(out *NginxSpec)

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

type NginxStatus 

type NginxStatus struct {
	Message           string            `json:"message" protobuf:"bytes,1,opt,name=message"`
	AlamedaController AlamedaController `json:"alamedaController,omitempty" protobuf:"bytes,2,opt,name=alameda_controller"`
}

func (*NginxStatus) DeepCopy 

func (in *NginxStatus) DeepCopy() *NginxStatus

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

func (*NginxStatus) DeepCopyInto 

func (in *NginxStatus) DeepCopyInto(out *NginxStatus)

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

type ScalingToolSpec 

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

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 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.