v1alpha1

package
v0.14.0-beta.3 Latest Latest
Warning

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

 Go to latest Published: Sep 18, 2020 License: Apache-2.0 Imports: 21 Imported by: 0

Documentation

Overview

+groupName=autoscaling.kubedb.com

Index

Constants

View Source 
const (
	ResourceCodeElasticsearchAutoscaler     = "esscaler"
	ResourceKindElasticsearchAutoscaler     = "ElasticsearchAutoscaler"
	ResourceSingularElasticsearchAutoscaler = "elasticsearchautoscaler"
	ResourcePluralElasticsearchAutoscaler   = "elasticsearchautoscalers"
)
View Source 
const (
	ResourceCodeEtcdAutoscaler     = "etcdscaler"
	ResourceKindEtcdAutoscaler     = "EtcdAutoscaler"
	ResourceSingularEtcdAutoscaler = "etcdautoscaler"
	ResourcePluralEtcdAutoscaler   = "etcdautoscalers"
)
View Source 
const (
	ResourceCodeMemcachedAutoscaler     = "mcscaler"
	ResourceKindMemcachedAutoscaler     = "MemcachedAutoscaler"
	ResourceSingularMemcachedAutoscaler = "memcachedautoscaler"
	ResourcePluralMemcachedAutoscaler   = "memcachedautoscalers"
)
View Source 
const (
	ResourceCodeMongoDBAutoscaler     = "mgscaler"
	ResourceKindMongoDBAutoscaler     = "MongoDBAutoscaler"
	ResourceSingularMongoDBAutoscaler = "mongodbautoscaler"
	ResourcePluralMongoDBAutoscaler   = "mongodbautoscalers"
)
View Source 
const (
	ResourceCodeMySQLAutoscaler     = "myscaler"
	ResourceKindMySQLAutoscaler     = "MySQLAutoscaler"
	ResourceSingularMySQLAutoscaler = "mysqlautoscaler"
	ResourcePluralMySQLAutoscaler   = "mysqlautoscalers"
)
View Source 
const (
	ResourceCodePerconaXtraDBAutoscaler     = "pxcscaler"
	ResourceKindPerconaXtraDBAutoscaler     = "PerconaXtraDBAutoscaler"
	ResourceSingularPerconaXtraDBAutoscaler = "perconaxtradbautoscaler"
	ResourcePluralPerconaXtraDBAutoscaler   = "perconaxtradbautoscalers"
)
View Source 
const (
	ResourceCodePgBouncerAutoscaler     = "pbscaler"
	ResourceKindPgBouncerAutoscaler     = "PgBouncerAutoscaler"
	ResourceSingularPgBouncerAutoscaler = "pgbouncerautoscaler"
	ResourcePluralPgBouncerAutoscaler   = "pgbouncerautoscalers"
)
View Source 
const (
	ResourceCodePostgresAutoscaler     = "pgscaler"
	ResourceKindPostgresAutoscaler     = "PostgresAutoscaler"
	ResourceSingularPostgresAutoscaler = "postgresautoscaler"
	ResourcePluralPostgresAutoscaler   = "postgresautoscalers"
)
View Source 
const (
	ResourceCodeProxySQLAutoscaler     = "pxscaler"
	ResourceKindProxySQLAutoscaler     = "ProxySQLAutoscaler"
	ResourceSingularProxySQLAutoscaler = "proxysqlautoscaler"
	ResourcePluralProxySQLAutoscaler   = "proxysqlautoscalers"
)
View Source 
const (
	ResourceCodeRedisAutoscaler     = "rdscaler"
	ResourceKindRedisAutoscaler     = "RedisAutoscaler"
	ResourceSingularRedisAutoscaler = "redisautoscaler"
	ResourcePluralRedisAutoscaler   = "redisautoscalers"
)
View Source 
const (
	AccessApproved            = "Approved"
	AccessDenied              = "Denied"
	DisableSharding           = "DisableSharding"
	EnableSharding            = "EnableSharding"
	Failure                   = "Failure"
	HorizontalScalingDatabase = "HorizontalScaling"
	MigratingData             = "MigratingData"
	NodeCreated               = "NodeCreated"
	NodeDeleted               = "NodeDeleted"
	NodeRestarted             = "NodeRestarted"
	PauseDatabase             = "PauseDatabase"
	PausingDatabase           = "PausingDatabase"
	PausedDatabase            = "PausedDatabase"
	Progressing               = "Progressing"
	ResumeDatabase            = "ResumeDatabase"
	ResumingDatabase          = "ResumingDatabase"
	ResumedDatabase           = "ResumedDatabase"
	ScalingDatabase           = "Scaling"
	ScalingDown               = "ScalingDown"
	ScalingUp                 = "ScalingUp"
	Successful                = "Successful"
	Updating                  = "Updating"
	UpgradedVersion           = "UpgradedVersion"
	UpgradingVersion          = "UpgradingVersion"
	VerticalScalingDatabase   = "VerticalScaling"
	VotingExclusionAdded      = "VotingExclusionAdded"
	VotingExclusionDeleted    = "VotingExclusionDeleted"
	UpdateStatefulSets        = "UpdateStatefulSets"

	// MongoDB Constants
	StartingBalancer            = "StartingBalancer"
	StoppingBalancer            = "StoppingBalancer"
	UpdateShardImage            = "UpdateShardImage"
	UpdateStatefulSetResources  = "UpdateStatefulSetResources"
	UpdateShardResources        = "UpdateShardResources"
	ScaleDownShard              = "ScaleDownShard"
	ScaleUpShard                = "ScaleUpShard"
	UpdateReplicaSetImage       = "UpdateReplicaSetImage"
	UpdateConfigServerImage     = "UpdateConfigServerImage"
	UpdateMongosImage           = "UpdateMongosImage"
	UpdateReplicaSetResources   = "UpdateReplicaSetResources"
	UpdateConfigServerResources = "UpdateConfigServerResources"
	UpdateMongosResources       = "UpdateMongosResources"
	FlushRouterConfig           = "FlushRouterConfig"
	ScaleDownReplicaSet         = "ScaleDownReplicaSet"
	ScaleUpReplicaSet           = "ScaleUpReplicaSet"
	ScaleUpShardReplicas        = "ScaleUpShardReplicas"
	ScaleDownShardReplicas      = "ScaleDownShardReplicas"
	ScaleDownConfigServer       = "ScaleDownConfigServer "
	ScaleUpConfigServer         = "ScaleUpConfigServer "
	ScaleMongos                 = "ScaleMongos"
	VolumeExpansion             = "VolumeExpansion"
)

List of possible condition types for a ops request

View Source 
const (
	GenericKey = "autoscaling.kubedb.com"
)

Variables

View Source 
var (
	ErrInvalidLengthGenerated        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowGenerated          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupGenerated = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	// TODO: move SchemeBuilder with zz_generated.deepcopy.go to k8s.io/api.
	// localSchemeBuilder and AddToScheme will stay in k8s.io/kubernetes.
	SchemeBuilder runtime.SchemeBuilder

	AddToScheme = localSchemeBuilder.AddToScheme
)
View Source 
var SchemeGroupVersion = schema.GroupVersion{Group: autoscaling.GroupName, Version: "v1alpha1"}

Functions

func GetOpenAPIDefinitions 

func GetOpenAPIDefinitions(ref common.ReferenceCallback) map[string]common.OpenAPIDefinition

func Kind 

func Kind(kind string) schema.GroupKind

Kind takes an unqualified kind and returns a Group qualified GroupKind

func Resource 

func Resource(resource string) schema.GroupResource

Resource takes an unqualified resource and returns a Group qualified GroupResource

Types

type AutoscalerPhase 

type AutoscalerPhase string
const (
	// used for ops requests that are currently Progressing
	AutoscalerPhaseProgressing AutoscalerPhase = "Progressing"
	// used for ops requests that are executed successfully
	AutoscalerPhaseSuccessful AutoscalerPhase = "Successful"
	// used for ops requests that are waiting for approval
	AutoscalerPhaseWaitingForApproval AutoscalerPhase = "WaitingForApproval"
	// used for ops requests that are failed
	AutoscalerPhaseFailed AutoscalerPhase = "Failed"
	// used for ops requests that are approved
	AutoscalerApproved AutoscalerPhase = "Approved"
	// used for ops requests that are denied
	AutoscalerDenied AutoscalerPhase = "Denied"
)

type AutoscalerType 

type AutoscalerType string

+kubebuilder:validation:Enum=Upgrade;HorizontalScaling;VerticalScaling;VolumeExpansion;Restart;RotateCertificates 

const (
	// used for Upgrade operation
	AutoscalerTypeUpgrade AutoscalerType = "Upgrade"
	// used for HorizontalScaling operation
	AutoscalerTypeHorizontalScaling AutoscalerType = "HorizontalScaling"
	// used for VerticalScaling operation
	AutoscalerTypeVerticalScaling AutoscalerType = "VerticalScaling"
	// used for VolumeExpansion operation
	AutoscalerTypeVolumeExpansion AutoscalerType = "VolumeExpansion"
	// used for Restart operation
	AutoscalerTypeRestart AutoscalerType = "Restart"
	// used for RotateCertificates operation
	AutoscalerTypeRotateCertificates AutoscalerType = "RotateCertificates"
)

type ElasticsearchAutoscaler 

type ElasticsearchAutoscaler struct {
	metav1.TypeMeta `json:",inline"`
	// metadata is the standard object metadata.
	// More info: https://git.k8s.io/community/contributors/devel/sig-architecture/api-conventions.md#metadata
	// +optional
	metav1.ObjectMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`

	// spec is the specification for the behaviour of the autoscaler.
	// More info: https://git.k8s.io/community/contributors/devel/sig-architecture/api-conventions.md#spec-and-status.
	// +optional
	Spec ElasticsearchAutoscalerSpec `json:"spec,omitempty" protobuf:"bytes,2,opt,name=spec"`

	// status is the current information about the autoscaler.
	// +optional
	Status ElasticsearchAutoscalerStatus `json:"status,omitempty" protobuf:"bytes,3,opt,name=status"`
}

+kubebuilder:object:root=true +kubebuilder:resource:path=elasticsearchautoscalers,singular=elasticsearchautoscaler,shortName=esscaler,categories={datastore,kubedb,appscode} +kubebuilder:subresource:status

func (ElasticsearchAutoscaler) CustomResourceDefinition 

func (_ ElasticsearchAutoscaler) CustomResourceDefinition() *apiextensions.CustomResourceDefinition

func (*ElasticsearchAutoscaler) DeepCopy 

func (in *ElasticsearchAutoscaler) DeepCopy() *ElasticsearchAutoscaler

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

func (*ElasticsearchAutoscaler) DeepCopyInto 

func (in *ElasticsearchAutoscaler) DeepCopyInto(out *ElasticsearchAutoscaler)

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

func (*ElasticsearchAutoscaler) DeepCopyObject 

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

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

func (*ElasticsearchAutoscaler) Descriptor 

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

func (*ElasticsearchAutoscaler) Marshal 

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

func (*ElasticsearchAutoscaler) MarshalTo 

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

func (*ElasticsearchAutoscaler) MarshalToSizedBuffer 

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

func (*ElasticsearchAutoscaler) ProtoMessage 

func (*ElasticsearchAutoscaler) ProtoMessage()

func (*ElasticsearchAutoscaler) Reset 

func (m *ElasticsearchAutoscaler) Reset()

func (ElasticsearchAutoscaler) ResourceKind 

func (e ElasticsearchAutoscaler) ResourceKind() string

func (ElasticsearchAutoscaler) ResourcePlural 

func (e ElasticsearchAutoscaler) ResourcePlural() string

func (ElasticsearchAutoscaler) ResourceShortCode 

func (e ElasticsearchAutoscaler) ResourceShortCode() string

func (ElasticsearchAutoscaler) ResourceSingular 

func (e ElasticsearchAutoscaler) ResourceSingular() string

func (*ElasticsearchAutoscaler) Size 

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

func (*ElasticsearchAutoscaler) String 

func (this *ElasticsearchAutoscaler) String() string

func (*ElasticsearchAutoscaler) Unmarshal 

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

func (ElasticsearchAutoscaler) ValidateSpecs 

func (e ElasticsearchAutoscaler) ValidateSpecs() error

func (*ElasticsearchAutoscaler) XXX_DiscardUnknown 

func (m *ElasticsearchAutoscaler) XXX_DiscardUnknown()

func (*ElasticsearchAutoscaler) XXX_Marshal 

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

func (*ElasticsearchAutoscaler) XXX_Merge 

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

func (*ElasticsearchAutoscaler) XXX_Size 

func (m *ElasticsearchAutoscaler) XXX_Size() int

func (*ElasticsearchAutoscaler) XXX_Unmarshal 

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

type ElasticsearchAutoscalerBehavior 

type ElasticsearchAutoscalerBehavior struct {
	// scaleUp is scaling policy for scaling Up.
	// If not set, the default value is the higher of:
	//   * increase no more than 4 pods per 60 seconds
	//   * double the number of pods per 60 seconds
	// No stabilization is used.
	// +optional
	ScaleUp *ElasticsearchScalingRules `json:"scaleUp,omitempty" protobuf:"bytes,1,opt,name=scaleUp"`
	// scaleDown is scaling policy for scaling Down.
	// If not set, the default value is to allow to scale down to minReplicas pods, with a
	// 300 second stabilization window (i.e., the highest recommendation for
	// the last 300sec is used).
	// +optional
	ScaleDown *ElasticsearchScalingRules `json:"scaleDown,omitempty" protobuf:"bytes,2,opt,name=scaleDown"`
}

ElasticsearchAutoscalerBehavior configures the scaling behavior of the target in both Up and Down directions (scaleUp and scaleDown fields respectively).

func (*ElasticsearchAutoscalerBehavior) DeepCopy 

func (in *ElasticsearchAutoscalerBehavior) DeepCopy() *ElasticsearchAutoscalerBehavior

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

func (*ElasticsearchAutoscalerBehavior) DeepCopyInto 

func (in *ElasticsearchAutoscalerBehavior) DeepCopyInto(out *ElasticsearchAutoscalerBehavior)

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

func (*ElasticsearchAutoscalerBehavior) Descriptor 

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

func (*ElasticsearchAutoscalerBehavior) Marshal 

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

func (*ElasticsearchAutoscalerBehavior) MarshalTo 

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

func (*ElasticsearchAutoscalerBehavior) MarshalToSizedBuffer 

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

func (*ElasticsearchAutoscalerBehavior) ProtoMessage 

func (*ElasticsearchAutoscalerBehavior) ProtoMessage()

func (*ElasticsearchAutoscalerBehavior) Reset 

func (m *ElasticsearchAutoscalerBehavior) Reset()

func (*ElasticsearchAutoscalerBehavior) Size 

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

func (*ElasticsearchAutoscalerBehavior) String 

func (this *ElasticsearchAutoscalerBehavior) String() string

func (*ElasticsearchAutoscalerBehavior) Unmarshal 

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

func (*ElasticsearchAutoscalerBehavior) XXX_DiscardUnknown 

func (m *ElasticsearchAutoscalerBehavior) XXX_DiscardUnknown()

func (*ElasticsearchAutoscalerBehavior) XXX_Marshal 

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

func (*ElasticsearchAutoscalerBehavior) XXX_Merge 

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

func (*ElasticsearchAutoscalerBehavior) XXX_Size 

func (m *ElasticsearchAutoscalerBehavior) XXX_Size() int

func (*ElasticsearchAutoscalerBehavior) XXX_Unmarshal 

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

type ElasticsearchAutoscalerList 

type ElasticsearchAutoscalerList struct {
	metav1.TypeMeta `json:",inline"`
	// metadata is the standard list metadata.
	// +optional
	metav1.ListMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`

	// items is the list of horizontal pod autoscaler objects.
	Items []ElasticsearchAutoscaler `json:"items" protobuf:"bytes,2,rep,name=items"`
}

ElasticsearchAutoscalerList is a list of horizontal pod autoscaler objects.

func (*ElasticsearchAutoscalerList) DeepCopy 

func (in *ElasticsearchAutoscalerList) DeepCopy() *ElasticsearchAutoscalerList

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

func (*ElasticsearchAutoscalerList) DeepCopyInto 

func (in *ElasticsearchAutoscalerList) DeepCopyInto(out *ElasticsearchAutoscalerList)

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

func (*ElasticsearchAutoscalerList) DeepCopyObject 

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

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

func (*ElasticsearchAutoscalerList) Descriptor 

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

func (*ElasticsearchAutoscalerList) Marshal 

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

func (*ElasticsearchAutoscalerList) MarshalTo 

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

func (*ElasticsearchAutoscalerList) MarshalToSizedBuffer 

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

func (*ElasticsearchAutoscalerList) ProtoMessage 

func (*ElasticsearchAutoscalerList) ProtoMessage()

func (*ElasticsearchAutoscalerList) Reset 

func (m *ElasticsearchAutoscalerList) Reset()

func (*ElasticsearchAutoscalerList) Size 

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

func (*ElasticsearchAutoscalerList) String 

func (this *ElasticsearchAutoscalerList) String() string

func (*ElasticsearchAutoscalerList) Unmarshal 

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

func (*ElasticsearchAutoscalerList) XXX_DiscardUnknown 

func (m *ElasticsearchAutoscalerList) XXX_DiscardUnknown()

func (*ElasticsearchAutoscalerList) XXX_Marshal 

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

func (*ElasticsearchAutoscalerList) XXX_Merge 

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

func (*ElasticsearchAutoscalerList) XXX_Size 

func (m *ElasticsearchAutoscalerList) XXX_Size() int

func (*ElasticsearchAutoscalerList) XXX_Unmarshal 

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

type ElasticsearchAutoscalerSpec 

type ElasticsearchAutoscalerSpec struct {
	// scaleTargetRef points to the target resource to scale, and is used to the pods for which metrics
	// should be collected, as well as to actually change the replica count.
	ScaleTargetRef core.LocalObjectReference `json:"scaleTargetRef" protobuf:"bytes,1,opt,name=scaleTargetRef"`
	// minReplicas is the lower limit for the number of replicas to which the autoscaler
	// can scale down.  It defaults to 1 pod.  minReplicas is allowed to be 0 if the
	// alpha feature gate HPAScaleToZero is enabled and at least one Object or External
	// metric is configured.  Scaling is active as long as at least one metric value is
	// available.
	// +optional
	MinReplicas *int32 `json:"minReplicas,omitempty" protobuf:"varint,2,opt,name=minReplicas"`
	// maxReplicas is the upper limit for the number of replicas to which the autoscaler can scale up.
	// It cannot be less that minReplicas.
	MaxReplicas int32 `json:"maxReplicas" protobuf:"varint,3,opt,name=maxReplicas"`
	// metrics contains the specifications for which to use to calculate the
	// desired replica count (the maximum replica count across all metrics will
	// be used).  The desired replica count is calculated multiplying the
	// ratio between the target value and the current value by the current
	// number of pods.  Ergo, metrics used must decrease as the pod count is
	// increased, and vice-versa.  See the individual metric source types for
	// more information about how each type of metric must respond.
	// If not set, the default metric will be set to 80% average CPU utilization.
	// +optional
	Metrics []v2beta2.MetricSpec `json:"metrics,omitempty" protobuf:"bytes,4,rep,name=metrics"`

	// behavior configures the scaling behavior of the target
	// in both Up and Down directions (scaleUp and scaleDown fields respectively).
	// If not set, the default ElasticsearchScalingRules for scale up and scale down are used.
	// +optional
	Behavior *ElasticsearchAutoscalerBehavior `json:"behavior,omitempty" protobuf:"bytes,5,opt,name=behavior"`
}

ElasticsearchAutoscalerSpec describes the desired functionality of the ElasticsearchAutoscaler.

func (*ElasticsearchAutoscalerSpec) DeepCopy 

func (in *ElasticsearchAutoscalerSpec) DeepCopy() *ElasticsearchAutoscalerSpec

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

func (*ElasticsearchAutoscalerSpec) DeepCopyInto 

func (in *ElasticsearchAutoscalerSpec) DeepCopyInto(out *ElasticsearchAutoscalerSpec)

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

func (*ElasticsearchAutoscalerSpec) Descriptor 

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

func (*ElasticsearchAutoscalerSpec) Marshal 

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

func (*ElasticsearchAutoscalerSpec) MarshalTo 

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

func (*ElasticsearchAutoscalerSpec) MarshalToSizedBuffer 

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

func (*ElasticsearchAutoscalerSpec) ProtoMessage 

func (*ElasticsearchAutoscalerSpec) ProtoMessage()

func (*ElasticsearchAutoscalerSpec) Reset 

func (m *ElasticsearchAutoscalerSpec) Reset()

func (*ElasticsearchAutoscalerSpec) Size 

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

func (*ElasticsearchAutoscalerSpec) String 

func (this *ElasticsearchAutoscalerSpec) String() string

func (*ElasticsearchAutoscalerSpec) Unmarshal 

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

func (*ElasticsearchAutoscalerSpec) XXX_DiscardUnknown 

func (m *ElasticsearchAutoscalerSpec) XXX_DiscardUnknown()

func (*ElasticsearchAutoscalerSpec) XXX_Marshal 

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

func (*ElasticsearchAutoscalerSpec) XXX_Merge 

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

func (*ElasticsearchAutoscalerSpec) XXX_Size 

func (m *ElasticsearchAutoscalerSpec) XXX_Size() int

func (*ElasticsearchAutoscalerSpec) XXX_Unmarshal 

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

type ElasticsearchAutoscalerStatus 

type ElasticsearchAutoscalerStatus struct {
	// observedGeneration is the most recent generation observed by this autoscaler.
	// +optional
	ObservedGeneration *int64 `json:"observedGeneration,omitempty" protobuf:"varint,1,opt,name=observedGeneration"`

	// lastScaleTime is the last time the ElasticsearchAutoscaler scaled the number of pods,
	// used by the autoscaler to control how often the number of pods is changed.
	// +optional
	LastScaleTime *metav1.Time `json:"lastScaleTime,omitempty" protobuf:"bytes,2,opt,name=lastScaleTime"`

	// currentReplicas is current number of replicas of pods managed by this autoscaler,
	// as last seen by the autoscaler.
	CurrentReplicas int32 `json:"currentReplicas" protobuf:"varint,3,opt,name=currentReplicas"`

	// desiredReplicas is the desired number of replicas of pods managed by this autoscaler,
	// as last calculated by the autoscaler.
	DesiredReplicas int32 `json:"desiredReplicas" protobuf:"varint,4,opt,name=desiredReplicas"`

	// currentMetrics is the last read state of the metrics used by this autoscaler.
	// +optional
	CurrentMetrics []v2beta2.MetricStatus `json:"currentMetrics" protobuf:"bytes,5,rep,name=currentMetrics"`

	// conditions is the set of conditions required for this autoscaler to scale its target,
	// and indicates whether or not those conditions are met.
	Conditions []kmapi.Condition `json:"conditions" protobuf:"bytes,6,rep,name=conditions"`
}

ElasticsearchAutoscalerStatus describes the current status of a horizontal pod autoscaler.

func (*ElasticsearchAutoscalerStatus) DeepCopy 

func (in *ElasticsearchAutoscalerStatus) DeepCopy() *ElasticsearchAutoscalerStatus

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

func (*ElasticsearchAutoscalerStatus) DeepCopyInto 

func (in *ElasticsearchAutoscalerStatus) DeepCopyInto(out *ElasticsearchAutoscalerStatus)

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

func (*ElasticsearchAutoscalerStatus) Descriptor 

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

func (*ElasticsearchAutoscalerStatus) Marshal 

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

func (*ElasticsearchAutoscalerStatus) MarshalTo 

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

func (*ElasticsearchAutoscalerStatus) MarshalToSizedBuffer 

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

func (*ElasticsearchAutoscalerStatus) ProtoMessage 

func (*ElasticsearchAutoscalerStatus) ProtoMessage()

func (*ElasticsearchAutoscalerStatus) Reset 

func (m *ElasticsearchAutoscalerStatus) Reset()

func (*ElasticsearchAutoscalerStatus) Size 

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

func (*ElasticsearchAutoscalerStatus) String 

func (this *ElasticsearchAutoscalerStatus) String() string

func (*ElasticsearchAutoscalerStatus) Unmarshal 

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

func (*ElasticsearchAutoscalerStatus) XXX_DiscardUnknown 

func (m *ElasticsearchAutoscalerStatus) XXX_DiscardUnknown()

func (*ElasticsearchAutoscalerStatus) XXX_Marshal 

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

func (*ElasticsearchAutoscalerStatus) XXX_Merge 

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

func (*ElasticsearchAutoscalerStatus) XXX_Size 

func (m *ElasticsearchAutoscalerStatus) XXX_Size() int

func (*ElasticsearchAutoscalerStatus) XXX_Unmarshal 

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

type ElasticsearchScalingPolicy 

type ElasticsearchScalingPolicy struct {
	// Type is used to specify the scaling policy.
	Type v2beta2.HPAScalingPolicyType `json:"type" protobuf:"bytes,1,opt,name=type,casttype=HPAScalingPolicyType"`
	// Value contains the amount of change which is permitted by the policy.
	// It must be greater than zero
	Value int32 `json:"value" protobuf:"varint,2,opt,name=value"`
	// PeriodSeconds specifies the window of time for which the policy should hold true.
	// PeriodSeconds must be greater than zero and less than or equal to 1800 (30 min).
	PeriodSeconds int32 `json:"periodSeconds" protobuf:"varint,3,opt,name=periodSeconds"`
}

ElasticsearchScalingPolicy is a single policy which must hold true for a specified past interval.

func (*ElasticsearchScalingPolicy) DeepCopy 

func (in *ElasticsearchScalingPolicy) DeepCopy() *ElasticsearchScalingPolicy

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

func (*ElasticsearchScalingPolicy) DeepCopyInto 

func (in *ElasticsearchScalingPolicy) DeepCopyInto(out *ElasticsearchScalingPolicy)

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

func (*ElasticsearchScalingPolicy) Descriptor 

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

func (*ElasticsearchScalingPolicy) Marshal 

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

func (*ElasticsearchScalingPolicy) MarshalTo 

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

func (*ElasticsearchScalingPolicy) MarshalToSizedBuffer 

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

func (*ElasticsearchScalingPolicy) ProtoMessage 

func (*ElasticsearchScalingPolicy) ProtoMessage()

func (*ElasticsearchScalingPolicy) Reset 

func (m *ElasticsearchScalingPolicy) Reset()

func (*ElasticsearchScalingPolicy) Size 

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

func (*ElasticsearchScalingPolicy) String 

func (this *ElasticsearchScalingPolicy) String() string

func (*ElasticsearchScalingPolicy) Unmarshal 

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

func (*ElasticsearchScalingPolicy) XXX_DiscardUnknown 

func (m *ElasticsearchScalingPolicy) XXX_DiscardUnknown()

func (*ElasticsearchScalingPolicy) XXX_Marshal 

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

func (*ElasticsearchScalingPolicy) XXX_Merge 

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

func (*ElasticsearchScalingPolicy) XXX_Size 

func (m *ElasticsearchScalingPolicy) XXX_Size() int

func (*ElasticsearchScalingPolicy) XXX_Unmarshal 

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

type ElasticsearchScalingRules 

type ElasticsearchScalingRules struct {
	// StabilizationWindowSeconds is the number of seconds for which past recommendations should be
	// considered while scaling up or scaling down.
	// StabilizationWindowSeconds must be greater than or equal to zero and less than or equal to 3600 (one hour).
	// If not set, use the default values:
	// - For scale up: 0 (i.e. no stabilization is done).
	// - For scale down: 300 (i.e. the stabilization window is 300 seconds long).
	// +optional
	StabilizationWindowSeconds *int32 `json:"stabilizationWindowSeconds" protobuf:"varint,3,opt,name=stabilizationWindowSeconds"`
	// selectPolicy is used to specify which policy should be used.
	// If not set, the default value MaxPolicySelect is used.
	// +optional
	SelectPolicy *v2beta2.ScalingPolicySelect `json:"selectPolicy,omitempty" protobuf:"bytes,1,opt,name=selectPolicy"`
	// policies is a list of potential scaling polices which can be used during scaling.
	// At least one policy must be specified, otherwise the ElasticsearchScalingRules will be discarded as invalid
	// +optional
	Policies []ElasticsearchScalingPolicy `json:"policies,omitempty" protobuf:"bytes,2,rep,name=policies"`
}

ElasticsearchScalingRules configures the scaling behavior for one direction. These Rules are applied after calculating DesiredReplicas from metrics for the HPA. They can limit the scaling velocity by specifying scaling policies. They can prevent flapping by specifying the stabilization window, so that the number of replicas is not set instantly, instead, the safest value from the stabilization window is chosen.

func (*ElasticsearchScalingRules) DeepCopy 

func (in *ElasticsearchScalingRules) DeepCopy() *ElasticsearchScalingRules

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

func (*ElasticsearchScalingRules) DeepCopyInto 

func (in *ElasticsearchScalingRules) DeepCopyInto(out *ElasticsearchScalingRules)

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

func (*ElasticsearchScalingRules) Descriptor 

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

func (*ElasticsearchScalingRules) Marshal 

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

func (*ElasticsearchScalingRules) MarshalTo 

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

func (*ElasticsearchScalingRules) MarshalToSizedBuffer 

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

func (*ElasticsearchScalingRules) ProtoMessage 

func (*ElasticsearchScalingRules) ProtoMessage()

func (*ElasticsearchScalingRules) Reset 

func (m *ElasticsearchScalingRules) Reset()

func (*ElasticsearchScalingRules) Size 

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

func (*ElasticsearchScalingRules) String 

func (this *ElasticsearchScalingRules) String() string

func (*ElasticsearchScalingRules) Unmarshal 

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

func (*ElasticsearchScalingRules) XXX_DiscardUnknown 

func (m *ElasticsearchScalingRules) XXX_DiscardUnknown()

func (*ElasticsearchScalingRules) XXX_Marshal 

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

func (*ElasticsearchScalingRules) XXX_Merge 

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

func (*ElasticsearchScalingRules) XXX_Size 

func (m *ElasticsearchScalingRules) XXX_Size() int

func (*ElasticsearchScalingRules) XXX_Unmarshal 

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

type EtcdAutoscaler 

type EtcdAutoscaler struct {
	metav1.TypeMeta `json:",inline"`
	// metadata is the standard object metadata.
	// More info: https://git.k8s.io/community/contributors/devel/sig-architecture/api-conventions.md#metadata
	// +optional
	metav1.ObjectMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`

	// spec is the specification for the behaviour of the autoscaler.
	// More info: https://git.k8s.io/community/contributors/devel/sig-architecture/api-conventions.md#spec-and-status.
	// +optional
	Spec EtcdAutoscalerSpec `json:"spec,omitempty" protobuf:"bytes,2,opt,name=spec"`

	// status is the current information about the autoscaler.
	// +optional
	Status EtcdAutoscalerStatus `json:"status,omitempty" protobuf:"bytes,3,opt,name=status"`
}

+kubebuilder:object:root=true +kubebuilder:resource:path=etcdautoscalers,singular=etcdautoscaler,shortName=etcdscaler,categories={datastore,kubedb,appscode} +kubebuilder:subresource:status

func (EtcdAutoscaler) CustomResourceDefinition 

func (_ EtcdAutoscaler) CustomResourceDefinition() *apiextensions.CustomResourceDefinition

func (*EtcdAutoscaler) DeepCopy 

func (in *EtcdAutoscaler) DeepCopy() *EtcdAutoscaler

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

func (*EtcdAutoscaler) DeepCopyInto 

func (in *EtcdAutoscaler) DeepCopyInto(out *EtcdAutoscaler)

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

func (*EtcdAutoscaler) DeepCopyObject 

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

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

func (*EtcdAutoscaler) Descriptor 

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

func (*EtcdAutoscaler) Marshal 

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

func (*EtcdAutoscaler) MarshalTo 

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

func (*EtcdAutoscaler) MarshalToSizedBuffer 

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

func (*EtcdAutoscaler) ProtoMessage 

func (*EtcdAutoscaler) ProtoMessage()

func (*EtcdAutoscaler) Reset 

func (m *EtcdAutoscaler) Reset()

func (EtcdAutoscaler) ResourceKind 

func (e EtcdAutoscaler) ResourceKind() string

func (EtcdAutoscaler) ResourcePlural 

func (e EtcdAutoscaler) ResourcePlural() string

func (EtcdAutoscaler) ResourceShortCode 

func (e EtcdAutoscaler) ResourceShortCode() string

func (EtcdAutoscaler) ResourceSingular 

func (e EtcdAutoscaler) ResourceSingular() string

func (*EtcdAutoscaler) Size 

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

func (*EtcdAutoscaler) String 

func (this *EtcdAutoscaler) String() string

func (*EtcdAutoscaler) Unmarshal 

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

func (EtcdAutoscaler) ValidateSpecs 

func (e EtcdAutoscaler) ValidateSpecs() error

func (*EtcdAutoscaler) XXX_DiscardUnknown 

func (m *EtcdAutoscaler) XXX_DiscardUnknown()

func (*EtcdAutoscaler) XXX_Marshal 

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

func (*EtcdAutoscaler) XXX_Merge 

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

func (*EtcdAutoscaler) XXX_Size 

func (m *EtcdAutoscaler) XXX_Size() int

func (*EtcdAutoscaler) XXX_Unmarshal 

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

type EtcdAutoscalerBehavior 

type EtcdAutoscalerBehavior struct {
	// scaleUp is scaling policy for scaling Up.
	// If not set, the default value is the higher of:
	//   * increase no more than 4 pods per 60 seconds
	//   * double the number of pods per 60 seconds
	// No stabilization is used.
	// +optional
	ScaleUp *EtcdScalingRules `json:"scaleUp,omitempty" protobuf:"bytes,1,opt,name=scaleUp"`
	// scaleDown is scaling policy for scaling Down.
	// If not set, the default value is to allow to scale down to minReplicas pods, with a
	// 300 second stabilization window (i.e., the highest recommendation for
	// the last 300sec is used).
	// +optional
	ScaleDown *EtcdScalingRules `json:"scaleDown,omitempty" protobuf:"bytes,2,opt,name=scaleDown"`
}

EtcdAutoscalerBehavior configures the scaling behavior of the target in both Up and Down directions (scaleUp and scaleDown fields respectively).

func (*EtcdAutoscalerBehavior) DeepCopy 

func (in *EtcdAutoscalerBehavior) DeepCopy() *EtcdAutoscalerBehavior

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

func (*EtcdAutoscalerBehavior) DeepCopyInto 

func (in *EtcdAutoscalerBehavior) DeepCopyInto(out *EtcdAutoscalerBehavior)

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

func (*EtcdAutoscalerBehavior) Descriptor 

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

func (*EtcdAutoscalerBehavior) Marshal 

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

func (*EtcdAutoscalerBehavior) MarshalTo 

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

func (*EtcdAutoscalerBehavior) MarshalToSizedBuffer 

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

func (*EtcdAutoscalerBehavior) ProtoMessage 

func (*EtcdAutoscalerBehavior) ProtoMessage()

func (*EtcdAutoscalerBehavior) Reset 

func (m *EtcdAutoscalerBehavior) Reset()

func (*EtcdAutoscalerBehavior) Size 

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

func (*EtcdAutoscalerBehavior) String 

func (this *EtcdAutoscalerBehavior) String() string

func (*EtcdAutoscalerBehavior) Unmarshal 

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

func (*EtcdAutoscalerBehavior) XXX_DiscardUnknown 

func (m *EtcdAutoscalerBehavior) XXX_DiscardUnknown()

func (*EtcdAutoscalerBehavior) XXX_Marshal 

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

func (*EtcdAutoscalerBehavior) XXX_Merge 

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

func (*EtcdAutoscalerBehavior) XXX_Size 

func (m *EtcdAutoscalerBehavior) XXX_Size() int

func (*EtcdAutoscalerBehavior) XXX_Unmarshal 

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

type EtcdAutoscalerList 

type EtcdAutoscalerList struct {
	metav1.TypeMeta `json:",inline"`
	// metadata is the standard list metadata.
	// +optional
	metav1.ListMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`

	// items is the list of horizontal pod autoscaler objects.
	Items []EtcdAutoscaler `json:"items" protobuf:"bytes,2,rep,name=items"`
}

EtcdAutoscalerList is a list of horizontal pod autoscaler objects.

func (*EtcdAutoscalerList) DeepCopy 

func (in *EtcdAutoscalerList) DeepCopy() *EtcdAutoscalerList

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

func (*EtcdAutoscalerList) DeepCopyInto 

func (in *EtcdAutoscalerList) DeepCopyInto(out *EtcdAutoscalerList)

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

func (*EtcdAutoscalerList) DeepCopyObject 

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

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

func (*EtcdAutoscalerList) Descriptor 

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

func (*EtcdAutoscalerList) Marshal 

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

func (*EtcdAutoscalerList) MarshalTo 

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

func (*EtcdAutoscalerList) MarshalToSizedBuffer 

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

func (*EtcdAutoscalerList) ProtoMessage 

func (*EtcdAutoscalerList) ProtoMessage()

func (*EtcdAutoscalerList) Reset 

func (m *EtcdAutoscalerList) Reset()

func (*EtcdAutoscalerList) Size 

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

func (*EtcdAutoscalerList) String 

func (this *EtcdAutoscalerList) String() string

func (*EtcdAutoscalerList) Unmarshal 

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

func (*EtcdAutoscalerList) XXX_DiscardUnknown 

func (m *EtcdAutoscalerList) XXX_DiscardUnknown()

func (*EtcdAutoscalerList) XXX_Marshal 

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

func (*EtcdAutoscalerList) XXX_Merge 

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

func (*EtcdAutoscalerList) XXX_Size 

func (m *EtcdAutoscalerList) XXX_Size() int

func (*EtcdAutoscalerList) XXX_Unmarshal 

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

type EtcdAutoscalerSpec 

type EtcdAutoscalerSpec struct {
	// scaleTargetRef points to the target resource to scale, and is used to the pods for which metrics
	// should be collected, as well as to actually change the replica count.
	ScaleTargetRef core.LocalObjectReference `json:"scaleTargetRef" protobuf:"bytes,1,opt,name=scaleTargetRef"`
	// minReplicas is the lower limit for the number of replicas to which the autoscaler
	// can scale down.  It defaults to 1 pod.  minReplicas is allowed to be 0 if the
	// alpha feature gate HPAScaleToZero is enabled and at least one Object or External
	// metric is configured.  Scaling is active as long as at least one metric value is
	// available.
	// +optional
	MinReplicas *int32 `json:"minReplicas,omitempty" protobuf:"varint,2,opt,name=minReplicas"`
	// maxReplicas is the upper limit for the number of replicas to which the autoscaler can scale up.
	// It cannot be less that minReplicas.
	MaxReplicas int32 `json:"maxReplicas" protobuf:"varint,3,opt,name=maxReplicas"`
	// metrics contains the specifications for which to use to calculate the
	// desired replica count (the maximum replica count across all metrics will
	// be used).  The desired replica count is calculated multiplying the
	// ratio between the target value and the current value by the current
	// number of pods.  Ergo, metrics used must decrease as the pod count is
	// increased, and vice-versa.  See the individual metric source types for
	// more information about how each type of metric must respond.
	// If not set, the default metric will be set to 80% average CPU utilization.
	// +optional
	Metrics []v2beta2.MetricSpec `json:"metrics,omitempty" protobuf:"bytes,4,rep,name=metrics"`

	// behavior configures the scaling behavior of the target
	// in both Up and Down directions (scaleUp and scaleDown fields respectively).
	// If not set, the default EtcdScalingRules for scale up and scale down are used.
	// +optional
	Behavior *EtcdAutoscalerBehavior `json:"behavior,omitempty" protobuf:"bytes,5,opt,name=behavior"`
}

EtcdAutoscalerSpec describes the desired functionality of the EtcdAutoscaler.

func (*EtcdAutoscalerSpec) DeepCopy 

func (in *EtcdAutoscalerSpec) DeepCopy() *EtcdAutoscalerSpec

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

func (*EtcdAutoscalerSpec) DeepCopyInto 

func (in *EtcdAutoscalerSpec) DeepCopyInto(out *EtcdAutoscalerSpec)

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

func (*EtcdAutoscalerSpec) Descriptor 

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

func (*EtcdAutoscalerSpec) Marshal 

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

func (*EtcdAutoscalerSpec) MarshalTo 

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

func (*EtcdAutoscalerSpec) MarshalToSizedBuffer 

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

func (*EtcdAutoscalerSpec) ProtoMessage 

func (*EtcdAutoscalerSpec) ProtoMessage()

func (*EtcdAutoscalerSpec) Reset 

func (m *EtcdAutoscalerSpec) Reset()

func (*EtcdAutoscalerSpec) Size 

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

func (*EtcdAutoscalerSpec) String 

func (this *EtcdAutoscalerSpec) String() string

func (*EtcdAutoscalerSpec) Unmarshal 

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

func (*EtcdAutoscalerSpec) XXX_DiscardUnknown 

func (m *EtcdAutoscalerSpec) XXX_DiscardUnknown()

func (*EtcdAutoscalerSpec) XXX_Marshal 

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

func (*EtcdAutoscalerSpec) XXX_Merge 

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

func (*EtcdAutoscalerSpec) XXX_Size 

func (m *EtcdAutoscalerSpec) XXX_Size() int

func (*EtcdAutoscalerSpec) XXX_Unmarshal 

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

type EtcdAutoscalerStatus 

type EtcdAutoscalerStatus struct {
	// observedGeneration is the most recent generation observed by this autoscaler.
	// +optional
	ObservedGeneration *int64 `json:"observedGeneration,omitempty" protobuf:"varint,1,opt,name=observedGeneration"`

	// lastScaleTime is the last time the EtcdAutoscaler scaled the number of pods,
	// used by the autoscaler to control how often the number of pods is changed.
	// +optional
	LastScaleTime *metav1.Time `json:"lastScaleTime,omitempty" protobuf:"bytes,2,opt,name=lastScaleTime"`

	// currentReplicas is current number of replicas of pods managed by this autoscaler,
	// as last seen by the autoscaler.
	CurrentReplicas int32 `json:"currentReplicas" protobuf:"varint,3,opt,name=currentReplicas"`

	// desiredReplicas is the desired number of replicas of pods managed by this autoscaler,
	// as last calculated by the autoscaler.
	DesiredReplicas int32 `json:"desiredReplicas" protobuf:"varint,4,opt,name=desiredReplicas"`

	// currentMetrics is the last read state of the metrics used by this autoscaler.
	// +optional
	CurrentMetrics []v2beta2.MetricStatus `json:"currentMetrics" protobuf:"bytes,5,rep,name=currentMetrics"`

	// conditions is the set of conditions required for this autoscaler to scale its target,
	// and indicates whether or not those conditions are met.
	Conditions []kmapi.Condition `json:"conditions" protobuf:"bytes,6,rep,name=conditions"`
}

EtcdAutoscalerStatus describes the current status of a horizontal pod autoscaler.

func (*EtcdAutoscalerStatus) DeepCopy 

func (in *EtcdAutoscalerStatus) DeepCopy() *EtcdAutoscalerStatus

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

func (*EtcdAutoscalerStatus) DeepCopyInto 

func (in *EtcdAutoscalerStatus) DeepCopyInto(out *EtcdAutoscalerStatus)

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

func (*EtcdAutoscalerStatus) Descriptor 

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

func (*EtcdAutoscalerStatus) Marshal 

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

func (*EtcdAutoscalerStatus) MarshalTo 

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

func (*EtcdAutoscalerStatus) MarshalToSizedBuffer 

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

func (*EtcdAutoscalerStatus) ProtoMessage 

func (*EtcdAutoscalerStatus) ProtoMessage()

func (*EtcdAutoscalerStatus) Reset 

func (m *EtcdAutoscalerStatus) Reset()

func (*EtcdAutoscalerStatus) Size 

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

func (*EtcdAutoscalerStatus) String 

func (this *EtcdAutoscalerStatus) String() string

func (*EtcdAutoscalerStatus) Unmarshal 

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

func (*EtcdAutoscalerStatus) XXX_DiscardUnknown 

func (m *EtcdAutoscalerStatus) XXX_DiscardUnknown()

func (*EtcdAutoscalerStatus) XXX_Marshal 

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

func (*EtcdAutoscalerStatus) XXX_Merge 

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

func (*EtcdAutoscalerStatus) XXX_Size 

func (m *EtcdAutoscalerStatus) XXX_Size() int

func (*EtcdAutoscalerStatus) XXX_Unmarshal 

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

type EtcdScalingPolicy 

type EtcdScalingPolicy struct {
	// Type is used to specify the scaling policy.
	Type v2beta2.HPAScalingPolicyType `json:"type" protobuf:"bytes,1,opt,name=type,casttype=HPAScalingPolicyType"`
	// Value contains the amount of change which is permitted by the policy.
	// It must be greater than zero
	Value int32 `json:"value" protobuf:"varint,2,opt,name=value"`
	// PeriodSeconds specifies the window of time for which the policy should hold true.
	// PeriodSeconds must be greater than zero and less than or equal to 1800 (30 min).
	PeriodSeconds int32 `json:"periodSeconds" protobuf:"varint,3,opt,name=periodSeconds"`
}

EtcdScalingPolicy is a single policy which must hold true for a specified past interval.

func (*EtcdScalingPolicy) DeepCopy 

func (in *EtcdScalingPolicy) DeepCopy() *EtcdScalingPolicy

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

func (*EtcdScalingPolicy) DeepCopyInto 

func (in *EtcdScalingPolicy) DeepCopyInto(out *EtcdScalingPolicy)

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

func (*EtcdScalingPolicy) Descriptor 

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

func (*EtcdScalingPolicy) Marshal 

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

func (*EtcdScalingPolicy) MarshalTo 

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

func (*EtcdScalingPolicy) MarshalToSizedBuffer 

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

func (*EtcdScalingPolicy) ProtoMessage 

func (*EtcdScalingPolicy) ProtoMessage()

func (*EtcdScalingPolicy) Reset 

func (m *EtcdScalingPolicy) Reset()

func (*EtcdScalingPolicy) Size 

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

func (*EtcdScalingPolicy) String 

func (this *EtcdScalingPolicy) String() string

func (*EtcdScalingPolicy) Unmarshal 

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

func (*EtcdScalingPolicy) XXX_DiscardUnknown 

func (m *EtcdScalingPolicy) XXX_DiscardUnknown()

func (*EtcdScalingPolicy) XXX_Marshal 

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

func (*EtcdScalingPolicy) XXX_Merge 

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

func (*EtcdScalingPolicy) XXX_Size 

func (m *EtcdScalingPolicy) XXX_Size() int

func (*EtcdScalingPolicy) XXX_Unmarshal 

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

type EtcdScalingRules 

type EtcdScalingRules struct {
	// StabilizationWindowSeconds is the number of seconds for which past recommendations should be
	// considered while scaling up or scaling down.
	// StabilizationWindowSeconds must be greater than or equal to zero and less than or equal to 3600 (one hour).
	// If not set, use the default values:
	// - For scale up: 0 (i.e. no stabilization is done).
	// - For scale down: 300 (i.e. the stabilization window is 300 seconds long).
	// +optional
	StabilizationWindowSeconds *int32 `json:"stabilizationWindowSeconds" protobuf:"varint,3,opt,name=stabilizationWindowSeconds"`
	// selectPolicy is used to specify which policy should be used.
	// If not set, the default value MaxPolicySelect is used.
	// +optional
	SelectPolicy *v2beta2.ScalingPolicySelect `json:"selectPolicy,omitempty" protobuf:"bytes,1,opt,name=selectPolicy"`
	// policies is a list of potential scaling polices which can be used during scaling.
	// At least one policy must be specified, otherwise the EtcdScalingRules will be discarded as invalid
	// +optional
	Policies []EtcdScalingPolicy `json:"policies,omitempty" protobuf:"bytes,2,rep,name=policies"`
}

EtcdScalingRules configures the scaling behavior for one direction. These Rules are applied after calculating DesiredReplicas from metrics for the HPA. They can limit the scaling velocity by specifying scaling policies. They can prevent flapping by specifying the stabilization window, so that the number of replicas is not set instantly, instead, the safest value from the stabilization window is chosen.

func (*EtcdScalingRules) DeepCopy 

func (in *EtcdScalingRules) DeepCopy() *EtcdScalingRules

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

func (*EtcdScalingRules) DeepCopyInto 

func (in *EtcdScalingRules) DeepCopyInto(out *EtcdScalingRules)

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

func (*EtcdScalingRules) Descriptor 

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

func (*EtcdScalingRules) Marshal 

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

func (*EtcdScalingRules) MarshalTo 

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

func (*EtcdScalingRules) MarshalToSizedBuffer 

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

func (*EtcdScalingRules) ProtoMessage 

func (*EtcdScalingRules) ProtoMessage()

func (*EtcdScalingRules) Reset 

func (m *EtcdScalingRules) Reset()

func (*EtcdScalingRules) Size 

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

func (*EtcdScalingRules) String 

func (this *EtcdScalingRules) String() string

func (*EtcdScalingRules) Unmarshal 

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

func (*EtcdScalingRules) XXX_DiscardUnknown 

func (m *EtcdScalingRules) XXX_DiscardUnknown()

func (*EtcdScalingRules) XXX_Marshal 

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

func (*EtcdScalingRules) XXX_Merge 

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

func (*EtcdScalingRules) XXX_Size 

func (m *EtcdScalingRules) XXX_Size() int

func (*EtcdScalingRules) XXX_Unmarshal 

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

type MemcachedAutoscaler 

type MemcachedAutoscaler struct {
	metav1.TypeMeta `json:",inline"`
	// metadata is the standard object metadata.
	// More info: https://git.k8s.io/community/contributors/devel/sig-architecture/api-conventions.md#metadata
	// +optional
	metav1.ObjectMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`

	// spec is the specification for the behaviour of the autoscaler.
	// More info: https://git.k8s.io/community/contributors/devel/sig-architecture/api-conventions.md#spec-and-status.
	// +optional
	Spec MemcachedAutoscalerSpec `json:"spec,omitempty" protobuf:"bytes,2,opt,name=spec"`

	// status is the current information about the autoscaler.
	// +optional
	Status MemcachedAutoscalerStatus `json:"status,omitempty" protobuf:"bytes,3,opt,name=status"`
}

+kubebuilder:object:root=true +kubebuilder:resource:path=memcachedautoscalers,singular=memcachedautoscaler,shortName=mcscaler,categories={datastore,kubedb,appscode} +kubebuilder:subresource:status

func (MemcachedAutoscaler) CustomResourceDefinition 

func (_ MemcachedAutoscaler) CustomResourceDefinition() *apiextensions.CustomResourceDefinition

func (*MemcachedAutoscaler) DeepCopy 

func (in *MemcachedAutoscaler) DeepCopy() *MemcachedAutoscaler

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

func (*MemcachedAutoscaler) DeepCopyInto 

func (in *MemcachedAutoscaler) DeepCopyInto(out *MemcachedAutoscaler)

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

func (*MemcachedAutoscaler) DeepCopyObject 

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

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

func (*MemcachedAutoscaler) Descriptor 

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

func (*MemcachedAutoscaler) Marshal 

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

func (*MemcachedAutoscaler) MarshalTo 

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

func (*MemcachedAutoscaler) MarshalToSizedBuffer 

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

func (*MemcachedAutoscaler) ProtoMessage 

func (*MemcachedAutoscaler) ProtoMessage()

func (*MemcachedAutoscaler) Reset 

func (m *MemcachedAutoscaler) Reset()

func (MemcachedAutoscaler) ResourceKind 

func (m MemcachedAutoscaler) ResourceKind() string

func (MemcachedAutoscaler) ResourcePlural 

func (m MemcachedAutoscaler) ResourcePlural() string

func (MemcachedAutoscaler) ResourceShortCode 

func (m MemcachedAutoscaler) ResourceShortCode() string

func (MemcachedAutoscaler) ResourceSingular 

func (m MemcachedAutoscaler) ResourceSingular() string

func (*MemcachedAutoscaler) Size 

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

func (*MemcachedAutoscaler) String 

func (this *MemcachedAutoscaler) String() string

func (*MemcachedAutoscaler) Unmarshal 

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

func (MemcachedAutoscaler) ValidateSpecs 

func (m MemcachedAutoscaler) ValidateSpecs() error

func (*MemcachedAutoscaler) XXX_DiscardUnknown 

func (m *MemcachedAutoscaler) XXX_DiscardUnknown()

func (*MemcachedAutoscaler) XXX_Marshal 

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

func (*MemcachedAutoscaler) XXX_Merge 

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

func (*MemcachedAutoscaler) XXX_Size 

func (m *MemcachedAutoscaler) XXX_Size() int

func (*MemcachedAutoscaler) XXX_Unmarshal 

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

type MemcachedAutoscalerBehavior 

type MemcachedAutoscalerBehavior struct {
	// scaleUp is scaling policy for scaling Up.
	// If not set, the default value is the higher of:
	//   * increase no more than 4 pods per 60 seconds
	//   * double the number of pods per 60 seconds
	// No stabilization is used.
	// +optional
	ScaleUp *MemcachedScalingRules `json:"scaleUp,omitempty" protobuf:"bytes,1,opt,name=scaleUp"`
	// scaleDown is scaling policy for scaling Down.
	// If not set, the default value is to allow to scale down to minReplicas pods, with a
	// 300 second stabilization window (i.e., the highest recommendation for
	// the last 300sec is used).
	// +optional
	ScaleDown *MemcachedScalingRules `json:"scaleDown,omitempty" protobuf:"bytes,2,opt,name=scaleDown"`
}

MemcachedAutoscalerBehavior configures the scaling behavior of the target in both Up and Down directions (scaleUp and scaleDown fields respectively).

func (*MemcachedAutoscalerBehavior) DeepCopy 

func (in *MemcachedAutoscalerBehavior) DeepCopy() *MemcachedAutoscalerBehavior

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

func (*MemcachedAutoscalerBehavior) DeepCopyInto 

func (in *MemcachedAutoscalerBehavior) DeepCopyInto(out *MemcachedAutoscalerBehavior)

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

func (*MemcachedAutoscalerBehavior) Descriptor 

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

func (*MemcachedAutoscalerBehavior) Marshal 

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

func (*MemcachedAutoscalerBehavior) MarshalTo 

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

func (*MemcachedAutoscalerBehavior) MarshalToSizedBuffer 

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

func (*MemcachedAutoscalerBehavior) ProtoMessage 

func (*MemcachedAutoscalerBehavior) ProtoMessage()

func (*MemcachedAutoscalerBehavior) Reset 

func (m *MemcachedAutoscalerBehavior) Reset()

func (*MemcachedAutoscalerBehavior) Size 

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

func (*MemcachedAutoscalerBehavior) String 

func (this *MemcachedAutoscalerBehavior) String() string

func (*MemcachedAutoscalerBehavior) Unmarshal 

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

func (*MemcachedAutoscalerBehavior) XXX_DiscardUnknown 

func (m *MemcachedAutoscalerBehavior) XXX_DiscardUnknown()

func (*MemcachedAutoscalerBehavior) XXX_Marshal 

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

func (*MemcachedAutoscalerBehavior) XXX_Merge 

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

func (*MemcachedAutoscalerBehavior) XXX_Size 

func (m *MemcachedAutoscalerBehavior) XXX_Size() int

func (*MemcachedAutoscalerBehavior) XXX_Unmarshal 

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

type MemcachedAutoscalerList 

type MemcachedAutoscalerList struct {
	metav1.TypeMeta `json:",inline"`
	// metadata is the standard list metadata.
	// +optional
	metav1.ListMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`

	// items is the list of horizontal pod autoscaler objects.
	Items []MemcachedAutoscaler `json:"items" protobuf:"bytes,2,rep,name=items"`
}

MemcachedAutoscalerList is a list of horizontal pod autoscaler objects.

func (*MemcachedAutoscalerList) DeepCopy 

func (in *MemcachedAutoscalerList) DeepCopy() *MemcachedAutoscalerList

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

func (*MemcachedAutoscalerList) DeepCopyInto 

func (in *MemcachedAutoscalerList) DeepCopyInto(out *MemcachedAutoscalerList)

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

func (*MemcachedAutoscalerList) DeepCopyObject 

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

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

func (*MemcachedAutoscalerList) Descriptor 

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

func (*MemcachedAutoscalerList) Marshal 

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

func (*MemcachedAutoscalerList) MarshalTo 

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

func (*MemcachedAutoscalerList) MarshalToSizedBuffer 

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

func (*MemcachedAutoscalerList) ProtoMessage 

func (*MemcachedAutoscalerList) ProtoMessage()

func (*MemcachedAutoscalerList) Reset 

func (m *MemcachedAutoscalerList) Reset()

func (*MemcachedAutoscalerList) Size 

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

func (*MemcachedAutoscalerList) String 

func (this *MemcachedAutoscalerList) String() string

func (*MemcachedAutoscalerList) Unmarshal 

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

func (*MemcachedAutoscalerList) XXX_DiscardUnknown 

func (m *MemcachedAutoscalerList) XXX_DiscardUnknown()

func (*MemcachedAutoscalerList) XXX_Marshal 

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

func (*MemcachedAutoscalerList) XXX_Merge 

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

func (*MemcachedAutoscalerList) XXX_Size 

func (m *MemcachedAutoscalerList) XXX_Size() int

func (*MemcachedAutoscalerList) XXX_Unmarshal 

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

type MemcachedAutoscalerSpec 

type MemcachedAutoscalerSpec struct {
	// scaleTargetRef points to the target resource to scale, and is used to the pods for which metrics
	// should be collected, as well as to actually change the replica count.
	ScaleTargetRef core.LocalObjectReference `json:"scaleTargetRef" protobuf:"bytes,1,opt,name=scaleTargetRef"`
	// minReplicas is the lower limit for the number of replicas to which the autoscaler
	// can scale down.  It defaults to 1 pod.  minReplicas is allowed to be 0 if the
	// alpha feature gate HPAScaleToZero is enabled and at least one Object or External
	// metric is configured.  Scaling is active as long as at least one metric value is
	// available.
	// +optional
	MinReplicas *int32 `json:"minReplicas,omitempty" protobuf:"varint,2,opt,name=minReplicas"`
	// maxReplicas is the upper limit for the number of replicas to which the autoscaler can scale up.
	// It cannot be less that minReplicas.
	MaxReplicas int32 `json:"maxReplicas" protobuf:"varint,3,opt,name=maxReplicas"`
	// metrics contains the specifications for which to use to calculate the
	// desired replica count (the maximum replica count across all metrics will
	// be used).  The desired replica count is calculated multiplying the
	// ratio between the target value and the current value by the current
	// number of pods.  Ergo, metrics used must decrease as the pod count is
	// increased, and vice-versa.  See the individual metric source types for
	// more information about how each type of metric must respond.
	// If not set, the default metric will be set to 80% average CPU utilization.
	// +optional
	Metrics []v2beta2.MetricSpec `json:"metrics,omitempty" protobuf:"bytes,4,rep,name=metrics"`

	// behavior configures the scaling behavior of the target
	// in both Up and Down directions (scaleUp and scaleDown fields respectively).
	// If not set, the default MemcachedScalingRules for scale up and scale down are used.
	// +optional
	Behavior *MemcachedAutoscalerBehavior `json:"behavior,omitempty" protobuf:"bytes,5,opt,name=behavior"`
}

MemcachedAutoscalerSpec describes the desired functionality of the MemcachedAutoscaler.

func (*MemcachedAutoscalerSpec) DeepCopy 

func (in *MemcachedAutoscalerSpec) DeepCopy() *MemcachedAutoscalerSpec

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

func (*MemcachedAutoscalerSpec) DeepCopyInto 

func (in *MemcachedAutoscalerSpec) DeepCopyInto(out *MemcachedAutoscalerSpec)

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

func (*MemcachedAutoscalerSpec) Descriptor 

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

func (*MemcachedAutoscalerSpec) Marshal 

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

func (*MemcachedAutoscalerSpec) MarshalTo 

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

func (*MemcachedAutoscalerSpec) MarshalToSizedBuffer 

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

func (*MemcachedAutoscalerSpec) ProtoMessage 

func (*MemcachedAutoscalerSpec) ProtoMessage()

func (*MemcachedAutoscalerSpec) Reset 

func (m *MemcachedAutoscalerSpec) Reset()

func (*MemcachedAutoscalerSpec) Size 

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

func (*MemcachedAutoscalerSpec) String 

func (this *MemcachedAutoscalerSpec) String() string

func (*MemcachedAutoscalerSpec) Unmarshal 

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

func (*MemcachedAutoscalerSpec) XXX_DiscardUnknown 

func (m *MemcachedAutoscalerSpec) XXX_DiscardUnknown()

func (*MemcachedAutoscalerSpec) XXX_Marshal 

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

func (*MemcachedAutoscalerSpec) XXX_Merge 

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

func (*MemcachedAutoscalerSpec) XXX_Size 

func (m *MemcachedAutoscalerSpec) XXX_Size() int

func (*MemcachedAutoscalerSpec) XXX_Unmarshal 

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

type MemcachedAutoscalerStatus 

type MemcachedAutoscalerStatus struct {
	// observedGeneration is the most recent generation observed by this autoscaler.
	// +optional
	ObservedGeneration *int64 `json:"observedGeneration,omitempty" protobuf:"varint,1,opt,name=observedGeneration"`

	// lastScaleTime is the last time the MemcachedAutoscaler scaled the number of pods,
	// used by the autoscaler to control how often the number of pods is changed.
	// +optional
	LastScaleTime *metav1.Time `json:"lastScaleTime,omitempty" protobuf:"bytes,2,opt,name=lastScaleTime"`

	// currentReplicas is current number of replicas of pods managed by this autoscaler,
	// as last seen by the autoscaler.
	CurrentReplicas int32 `json:"currentReplicas" protobuf:"varint,3,opt,name=currentReplicas"`

	// desiredReplicas is the desired number of replicas of pods managed by this autoscaler,
	// as last calculated by the autoscaler.
	DesiredReplicas int32 `json:"desiredReplicas" protobuf:"varint,4,opt,name=desiredReplicas"`

	// currentMetrics is the last read state of the metrics used by this autoscaler.
	// +optional
	CurrentMetrics []v2beta2.MetricStatus `json:"currentMetrics" protobuf:"bytes,5,rep,name=currentMetrics"`

	// conditions is the set of conditions required for this autoscaler to scale its target,
	// and indicates whether or not those conditions are met.
	Conditions []kmapi.Condition `json:"conditions" protobuf:"bytes,6,rep,name=conditions"`
}

MemcachedAutoscalerStatus describes the current status of a horizontal pod autoscaler.

func (*MemcachedAutoscalerStatus) DeepCopy 

func (in *MemcachedAutoscalerStatus) DeepCopy() *MemcachedAutoscalerStatus

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

func (*MemcachedAutoscalerStatus) DeepCopyInto 

func (in *MemcachedAutoscalerStatus) DeepCopyInto(out *MemcachedAutoscalerStatus)

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

func (*MemcachedAutoscalerStatus) Descriptor 

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

func (*MemcachedAutoscalerStatus) Marshal 

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

func (*MemcachedAutoscalerStatus) MarshalTo 

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

func (*MemcachedAutoscalerStatus) MarshalToSizedBuffer 

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

func (*MemcachedAutoscalerStatus) ProtoMessage 

func (*MemcachedAutoscalerStatus) ProtoMessage()

func (*MemcachedAutoscalerStatus) Reset 

func (m *MemcachedAutoscalerStatus) Reset()

func (*MemcachedAutoscalerStatus) Size 

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

func (*MemcachedAutoscalerStatus) String 

func (this *MemcachedAutoscalerStatus) String() string

func (*MemcachedAutoscalerStatus) Unmarshal 

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

func (*MemcachedAutoscalerStatus) XXX_DiscardUnknown 

func (m *MemcachedAutoscalerStatus) XXX_DiscardUnknown()

func (*MemcachedAutoscalerStatus) XXX_Marshal 

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

func (*MemcachedAutoscalerStatus) XXX_Merge 

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

func (*MemcachedAutoscalerStatus) XXX_Size 

func (m *MemcachedAutoscalerStatus) XXX_Size() int

func (*MemcachedAutoscalerStatus) XXX_Unmarshal 

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

type MemcachedScalingPolicy 

type MemcachedScalingPolicy struct {
	// Type is used to specify the scaling policy.
	Type v2beta2.HPAScalingPolicyType `json:"type" protobuf:"bytes,1,opt,name=type,casttype=HPAScalingPolicyType"`
	// Value contains the amount of change which is permitted by the policy.
	// It must be greater than zero
	Value int32 `json:"value" protobuf:"varint,2,opt,name=value"`
	// PeriodSeconds specifies the window of time for which the policy should hold true.
	// PeriodSeconds must be greater than zero and less than or equal to 1800 (30 min).
	PeriodSeconds int32 `json:"periodSeconds" protobuf:"varint,3,opt,name=periodSeconds"`
}

MemcachedScalingPolicy is a single policy which must hold true for a specified past interval.

func (*MemcachedScalingPolicy) DeepCopy 

func (in *MemcachedScalingPolicy) DeepCopy() *MemcachedScalingPolicy

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

func (*MemcachedScalingPolicy) DeepCopyInto 

func (in *MemcachedScalingPolicy) DeepCopyInto(out *MemcachedScalingPolicy)

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

func (*MemcachedScalingPolicy) Descriptor 

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

func (*MemcachedScalingPolicy) Marshal 

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

func (*MemcachedScalingPolicy) MarshalTo 

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

func (*MemcachedScalingPolicy) MarshalToSizedBuffer 

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

func (*MemcachedScalingPolicy) ProtoMessage 

func (*MemcachedScalingPolicy) ProtoMessage()

func (*MemcachedScalingPolicy) Reset 

func (m *MemcachedScalingPolicy) Reset()

func (*MemcachedScalingPolicy) Size 

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

func (*MemcachedScalingPolicy) String 

func (this *MemcachedScalingPolicy) String() string

func (*MemcachedScalingPolicy) Unmarshal 

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

func (*MemcachedScalingPolicy) XXX_DiscardUnknown 

func (m *MemcachedScalingPolicy) XXX_DiscardUnknown()

func (*MemcachedScalingPolicy) XXX_Marshal 

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

func (*MemcachedScalingPolicy) XXX_Merge 

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

func (*MemcachedScalingPolicy) XXX_Size 

func (m *MemcachedScalingPolicy) XXX_Size() int

func (*MemcachedScalingPolicy) XXX_Unmarshal 

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

type MemcachedScalingRules 

type MemcachedScalingRules struct {
	// StabilizationWindowSeconds is the number of seconds for which past recommendations should be
	// considered while scaling up or scaling down.
	// StabilizationWindowSeconds must be greater than or equal to zero and less than or equal to 3600 (one hour).
	// If not set, use the default values:
	// - For scale up: 0 (i.e. no stabilization is done).
	// - For scale down: 300 (i.e. the stabilization window is 300 seconds long).
	// +optional
	StabilizationWindowSeconds *int32 `json:"stabilizationWindowSeconds" protobuf:"varint,3,opt,name=stabilizationWindowSeconds"`
	// selectPolicy is used to specify which policy should be used.
	// If not set, the default value MaxPolicySelect is used.
	// +optional
	SelectPolicy *v2beta2.ScalingPolicySelect `json:"selectPolicy,omitempty" protobuf:"bytes,1,opt,name=selectPolicy"`
	// policies is a list of potential scaling polices which can be used during scaling.
	// At least one policy must be specified, otherwise the MemcachedScalingRules will be discarded as invalid
	// +optional
	Policies []MemcachedScalingPolicy `json:"policies,omitempty" protobuf:"bytes,2,rep,name=policies"`
}

MemcachedScalingRules configures the scaling behavior for one direction. These Rules are applied after calculating DesiredReplicas from metrics for the HPA. They can limit the scaling velocity by specifying scaling policies. They can prevent flapping by specifying the stabilization window, so that the number of replicas is not set instantly, instead, the safest value from the stabilization window is chosen.

func (*MemcachedScalingRules) DeepCopy 

func (in *MemcachedScalingRules) DeepCopy() *MemcachedScalingRules

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

func (*MemcachedScalingRules) DeepCopyInto 

func (in *MemcachedScalingRules) DeepCopyInto(out *MemcachedScalingRules)

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

func (*MemcachedScalingRules) Descriptor 

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

func (*MemcachedScalingRules) Marshal 

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

func (*MemcachedScalingRules) MarshalTo 

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

func (*MemcachedScalingRules) MarshalToSizedBuffer 

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

func (*MemcachedScalingRules) ProtoMessage 

func (*MemcachedScalingRules) ProtoMessage()

func (*MemcachedScalingRules) Reset 

func (m *MemcachedScalingRules) Reset()

func (*MemcachedScalingRules) Size 

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

func (*MemcachedScalingRules) String 

func (this *MemcachedScalingRules) String() string

func (*MemcachedScalingRules) Unmarshal 

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

func (*MemcachedScalingRules) XXX_DiscardUnknown 

func (m *MemcachedScalingRules) XXX_DiscardUnknown()

func (*MemcachedScalingRules) XXX_Marshal 

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

func (*MemcachedScalingRules) XXX_Merge 

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

func (*MemcachedScalingRules) XXX_Size 

func (m *MemcachedScalingRules) XXX_Size() int

func (*MemcachedScalingRules) XXX_Unmarshal 

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

type MongoDBAutoscaler 

type MongoDBAutoscaler struct {
	metav1.TypeMeta `json:",inline"`
	// metadata is the standard object metadata.
	// More info: https://git.k8s.io/community/contributors/devel/sig-architecture/api-conventions.md#metadata
	// +optional
	metav1.ObjectMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`

	// spec is the specification for the behaviour of the autoscaler.
	// More info: https://git.k8s.io/community/contributors/devel/sig-architecture/api-conventions.md#spec-and-status.
	// +optional
	Spec MongoDBAutoscalerSpec `json:"spec,omitempty" protobuf:"bytes,2,opt,name=spec"`

	// status is the current information about the autoscaler.
	// +optional
	Status MongoDBAutoscalerStatus `json:"status,omitempty" protobuf:"bytes,3,opt,name=status"`
}

+kubebuilder:object:root=true +kubebuilder:resource:path=mongodbautoscalers,singular=mongodbautoscaler,shortName=mgscaler,categories={datastore,kubedb,appscode} +kubebuilder:subresource:status

func (MongoDBAutoscaler) CustomResourceDefinition 

func (_ MongoDBAutoscaler) CustomResourceDefinition() *apiextensions.CustomResourceDefinition

func (*MongoDBAutoscaler) DeepCopy 

func (in *MongoDBAutoscaler) DeepCopy() *MongoDBAutoscaler

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

func (*MongoDBAutoscaler) DeepCopyInto 

func (in *MongoDBAutoscaler) DeepCopyInto(out *MongoDBAutoscaler)

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

func (*MongoDBAutoscaler) DeepCopyObject 

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

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

func (*MongoDBAutoscaler) Descriptor 

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

func (*MongoDBAutoscaler) Marshal 

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

func (*MongoDBAutoscaler) MarshalTo 

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

func (*MongoDBAutoscaler) MarshalToSizedBuffer 

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

func (*MongoDBAutoscaler) ProtoMessage 

func (*MongoDBAutoscaler) ProtoMessage()

func (*MongoDBAutoscaler) Reset 

func (m *MongoDBAutoscaler) Reset()

func (MongoDBAutoscaler) ResourceKind 

func (m MongoDBAutoscaler) ResourceKind() string

func (MongoDBAutoscaler) ResourcePlural 

func (m MongoDBAutoscaler) ResourcePlural() string

func (MongoDBAutoscaler) ResourceShortCode 

func (m MongoDBAutoscaler) ResourceShortCode() string

func (MongoDBAutoscaler) ResourceSingular 

func (m MongoDBAutoscaler) ResourceSingular() string

func (*MongoDBAutoscaler) Size 

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

func (*MongoDBAutoscaler) String 

func (this *MongoDBAutoscaler) String() string

func (*MongoDBAutoscaler) Unmarshal 

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

func (MongoDBAutoscaler) ValidateSpecs 

func (m MongoDBAutoscaler) ValidateSpecs() error

func (*MongoDBAutoscaler) XXX_DiscardUnknown 

func (m *MongoDBAutoscaler) XXX_DiscardUnknown()

func (*MongoDBAutoscaler) XXX_Marshal 

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

func (*MongoDBAutoscaler) XXX_Merge 

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

func (*MongoDBAutoscaler) XXX_Size 

func (m *MongoDBAutoscaler) XXX_Size() int

func (*MongoDBAutoscaler) XXX_Unmarshal 

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

type MongoDBAutoscalerBehavior 

type MongoDBAutoscalerBehavior struct {
	// scaleUp is scaling policy for scaling Up.
	// If not set, the default value is the higher of:
	//   * increase no more than 4 pods per 60 seconds
	//   * double the number of pods per 60 seconds
	// No stabilization is used.
	// +optional
	ScaleUp *MongoDBScalingRules `json:"scaleUp,omitempty" protobuf:"bytes,1,opt,name=scaleUp"`
	// scaleDown is scaling policy for scaling Down.
	// If not set, the default value is to allow to scale down to minReplicas pods, with a
	// 300 second stabilization window (i.e., the highest recommendation for
	// the last 300sec is used).
	// +optional
	ScaleDown *MongoDBScalingRules `json:"scaleDown,omitempty" protobuf:"bytes,2,opt,name=scaleDown"`
}

MongoDBAutoscalerBehavior configures the scaling behavior of the target in both Up and Down directions (scaleUp and scaleDown fields respectively).

func (*MongoDBAutoscalerBehavior) DeepCopy 

func (in *MongoDBAutoscalerBehavior) DeepCopy() *MongoDBAutoscalerBehavior

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

func (*MongoDBAutoscalerBehavior) DeepCopyInto 

func (in *MongoDBAutoscalerBehavior) DeepCopyInto(out *MongoDBAutoscalerBehavior)

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

func (*MongoDBAutoscalerBehavior) Descriptor 

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

func (*MongoDBAutoscalerBehavior) Marshal 

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

func (*MongoDBAutoscalerBehavior) MarshalTo 

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

func (*MongoDBAutoscalerBehavior) MarshalToSizedBuffer 

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

func (*MongoDBAutoscalerBehavior) ProtoMessage 

func (*MongoDBAutoscalerBehavior) ProtoMessage()

func (*MongoDBAutoscalerBehavior) Reset 

func (m *MongoDBAutoscalerBehavior) Reset()

func (*MongoDBAutoscalerBehavior) Size 

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

func (*MongoDBAutoscalerBehavior) String 

func (this *MongoDBAutoscalerBehavior) String() string

func (*MongoDBAutoscalerBehavior) Unmarshal 

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

func (*MongoDBAutoscalerBehavior) XXX_DiscardUnknown 

func (m *MongoDBAutoscalerBehavior) XXX_DiscardUnknown()

func (*MongoDBAutoscalerBehavior) XXX_Marshal 

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

func (*MongoDBAutoscalerBehavior) XXX_Merge 

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

func (*MongoDBAutoscalerBehavior) XXX_Size 

func (m *MongoDBAutoscalerBehavior) XXX_Size() int

func (*MongoDBAutoscalerBehavior) XXX_Unmarshal 

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

type MongoDBAutoscalerList 

type MongoDBAutoscalerList struct {
	metav1.TypeMeta `json:",inline"`
	// metadata is the standard list metadata.
	// +optional
	metav1.ListMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`

	// items is the list of horizontal pod autoscaler objects.
	Items []MongoDBAutoscaler `json:"items" protobuf:"bytes,2,rep,name=items"`
}

MongoDBAutoscalerList is a list of horizontal pod autoscaler objects.

func (*MongoDBAutoscalerList) DeepCopy 

func (in *MongoDBAutoscalerList) DeepCopy() *MongoDBAutoscalerList

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

func (*MongoDBAutoscalerList) DeepCopyInto 

func (in *MongoDBAutoscalerList) DeepCopyInto(out *MongoDBAutoscalerList)

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

func (*MongoDBAutoscalerList) DeepCopyObject 

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

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

func (*MongoDBAutoscalerList) Descriptor 

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

func (*MongoDBAutoscalerList) Marshal 

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

func (*MongoDBAutoscalerList) MarshalTo 

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

func (*MongoDBAutoscalerList) MarshalToSizedBuffer 

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

func (*MongoDBAutoscalerList) ProtoMessage 

func (*MongoDBAutoscalerList) ProtoMessage()

func (*MongoDBAutoscalerList) Reset 

func (m *MongoDBAutoscalerList) Reset()

func (*MongoDBAutoscalerList) Size 

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

func (*MongoDBAutoscalerList) String 

func (this *MongoDBAutoscalerList) String() string

func (*MongoDBAutoscalerList) Unmarshal 

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

func (*MongoDBAutoscalerList) XXX_DiscardUnknown 

func (m *MongoDBAutoscalerList) XXX_DiscardUnknown()

func (*MongoDBAutoscalerList) XXX_Marshal 

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

func (*MongoDBAutoscalerList) XXX_Merge 

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

func (*MongoDBAutoscalerList) XXX_Size 

func (m *MongoDBAutoscalerList) XXX_Size() int

func (*MongoDBAutoscalerList) XXX_Unmarshal 

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

type MongoDBAutoscalerSpec 

type MongoDBAutoscalerSpec struct {
	// scaleTargetRef points to the target resource to scale, and is used to the pods for which metrics
	// should be collected, as well as to actually change the replica count.
	ScaleTargetRef core.LocalObjectReference `json:"scaleTargetRef" protobuf:"bytes,1,opt,name=scaleTargetRef"`
	// minReplicas is the lower limit for the number of replicas to which the autoscaler
	// can scale down.  It defaults to 1 pod.  minReplicas is allowed to be 0 if the
	// alpha feature gate HPAScaleToZero is enabled and at least one Object or External
	// metric is configured.  Scaling is active as long as at least one metric value is
	// available.
	// +optional
	MinReplicas *int32 `json:"minReplicas,omitempty" protobuf:"varint,2,opt,name=minReplicas"`
	// maxReplicas is the upper limit for the number of replicas to which the autoscaler can scale up.
	// It cannot be less that minReplicas.
	MaxReplicas int32 `json:"maxReplicas" protobuf:"varint,3,opt,name=maxReplicas"`
	// metrics contains the specifications for which to use to calculate the
	// desired replica count (the maximum replica count across all metrics will
	// be used).  The desired replica count is calculated multiplying the
	// ratio between the target value and the current value by the current
	// number of pods.  Ergo, metrics used must decrease as the pod count is
	// increased, and vice-versa.  See the individual metric source types for
	// more information about how each type of metric must respond.
	// If not set, the default metric will be set to 80% average CPU utilization.
	// +optional
	Metrics []v2beta2.MetricSpec `json:"metrics,omitempty" protobuf:"bytes,4,rep,name=metrics"`

	// behavior configures the scaling behavior of the target
	// in both Up and Down directions (scaleUp and scaleDown fields respectively).
	// If not set, the default MongoDBScalingRules for scale up and scale down are used.
	// +optional
	Behavior *MongoDBAutoscalerBehavior `json:"behavior,omitempty" protobuf:"bytes,5,opt,name=behavior"`
}

MongoDBAutoscalerSpec describes the desired functionality of the MongoDBAutoscaler.

func (*MongoDBAutoscalerSpec) DeepCopy 

func (in *MongoDBAutoscalerSpec) DeepCopy() *MongoDBAutoscalerSpec

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

func (*MongoDBAutoscalerSpec) DeepCopyInto 

func (in *MongoDBAutoscalerSpec) DeepCopyInto(out *MongoDBAutoscalerSpec)

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

func (*MongoDBAutoscalerSpec) Descriptor 

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

func (*MongoDBAutoscalerSpec) Marshal 

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

func (*MongoDBAutoscalerSpec) MarshalTo 

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

func (*MongoDBAutoscalerSpec) MarshalToSizedBuffer 

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

func (*MongoDBAutoscalerSpec) ProtoMessage 

func (*MongoDBAutoscalerSpec) ProtoMessage()

func (*MongoDBAutoscalerSpec) Reset 

func (m *MongoDBAutoscalerSpec) Reset()

func (*MongoDBAutoscalerSpec) Size 

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

func (*MongoDBAutoscalerSpec) String 

func (this *MongoDBAutoscalerSpec) String() string

func (*MongoDBAutoscalerSpec) Unmarshal 

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

func (*MongoDBAutoscalerSpec) XXX_DiscardUnknown 

func (m *MongoDBAutoscalerSpec) XXX_DiscardUnknown()

func (*MongoDBAutoscalerSpec) XXX_Marshal 

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

func (*MongoDBAutoscalerSpec) XXX_Merge 

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

func (*MongoDBAutoscalerSpec) XXX_Size 

func (m *MongoDBAutoscalerSpec) XXX_Size() int

func (*MongoDBAutoscalerSpec) XXX_Unmarshal 

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

type MongoDBAutoscalerStatus 

type MongoDBAutoscalerStatus struct {
	// observedGeneration is the most recent generation observed by this autoscaler.
	// +optional
	ObservedGeneration *int64 `json:"observedGeneration,omitempty" protobuf:"varint,1,opt,name=observedGeneration"`

	// lastScaleTime is the last time the MongoDBAutoscaler scaled the number of pods,
	// used by the autoscaler to control how often the number of pods is changed.
	// +optional
	LastScaleTime *metav1.Time `json:"lastScaleTime,omitempty" protobuf:"bytes,2,opt,name=lastScaleTime"`

	// currentReplicas is current number of replicas of pods managed by this autoscaler,
	// as last seen by the autoscaler.
	CurrentReplicas int32 `json:"currentReplicas" protobuf:"varint,3,opt,name=currentReplicas"`

	// desiredReplicas is the desired number of replicas of pods managed by this autoscaler,
	// as last calculated by the autoscaler.
	DesiredReplicas int32 `json:"desiredReplicas" protobuf:"varint,4,opt,name=desiredReplicas"`

	// currentMetrics is the last read state of the metrics used by this autoscaler.
	// +optional
	CurrentMetrics []v2beta2.MetricStatus `json:"currentMetrics" protobuf:"bytes,5,rep,name=currentMetrics"`

	// conditions is the set of conditions required for this autoscaler to scale its target,
	// and indicates whether or not those conditions are met.
	Conditions []kmapi.Condition `json:"conditions" protobuf:"bytes,6,rep,name=conditions"`
}

MongoDBAutoscalerStatus describes the current status of a horizontal pod autoscaler.

func (*MongoDBAutoscalerStatus) DeepCopy 

func (in *MongoDBAutoscalerStatus) DeepCopy() *MongoDBAutoscalerStatus

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

func (*MongoDBAutoscalerStatus) DeepCopyInto 

func (in *MongoDBAutoscalerStatus) DeepCopyInto(out *MongoDBAutoscalerStatus)

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

func (*MongoDBAutoscalerStatus) Descriptor 

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

func (*MongoDBAutoscalerStatus) Marshal 

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

func (*MongoDBAutoscalerStatus) MarshalTo 

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

func (*MongoDBAutoscalerStatus) MarshalToSizedBuffer 

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

func (*MongoDBAutoscalerStatus) ProtoMessage 

func (*MongoDBAutoscalerStatus) ProtoMessage()

func (*MongoDBAutoscalerStatus) Reset 

func (m *MongoDBAutoscalerStatus) Reset()

func (*MongoDBAutoscalerStatus) Size 

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

func (*MongoDBAutoscalerStatus) String 

func (this *MongoDBAutoscalerStatus) String() string

func (*MongoDBAutoscalerStatus) Unmarshal 

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

func (*MongoDBAutoscalerStatus) XXX_DiscardUnknown 

func (m *MongoDBAutoscalerStatus) XXX_DiscardUnknown()

func (*MongoDBAutoscalerStatus) XXX_Marshal 

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

func (*MongoDBAutoscalerStatus) XXX_Merge 

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

func (*MongoDBAutoscalerStatus) XXX_Size 

func (m *MongoDBAutoscalerStatus) XXX_Size() int

func (*MongoDBAutoscalerStatus) XXX_Unmarshal 

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

type MongoDBScalingPolicy 

type MongoDBScalingPolicy struct {
	// Type is used to specify the scaling policy.
	Type v2beta2.HPAScalingPolicyType `json:"type" protobuf:"bytes,1,opt,name=type,casttype=HPAScalingPolicyType"`
	// Value contains the amount of change which is permitted by the policy.
	// It must be greater than zero
	Value int32 `json:"value" protobuf:"varint,2,opt,name=value"`
	// PeriodSeconds specifies the window of time for which the policy should hold true.
	// PeriodSeconds must be greater than zero and less than or equal to 1800 (30 min).
	PeriodSeconds int32 `json:"periodSeconds" protobuf:"varint,3,opt,name=periodSeconds"`
}

MongoDBScalingPolicy is a single policy which must hold true for a specified past interval.

func (*MongoDBScalingPolicy) DeepCopy 

func (in *MongoDBScalingPolicy) DeepCopy() *MongoDBScalingPolicy

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

func (*MongoDBScalingPolicy) DeepCopyInto 

func (in *MongoDBScalingPolicy) DeepCopyInto(out *MongoDBScalingPolicy)

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

func (*MongoDBScalingPolicy) Descriptor 

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

func (*MongoDBScalingPolicy) Marshal 

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

func (*MongoDBScalingPolicy) MarshalTo 

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

func (*MongoDBScalingPolicy) MarshalToSizedBuffer 

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

func (*MongoDBScalingPolicy) ProtoMessage 

func (*MongoDBScalingPolicy) ProtoMessage()

func (*MongoDBScalingPolicy) Reset 

func (m *MongoDBScalingPolicy) Reset()

func (*MongoDBScalingPolicy) Size 

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

func (*MongoDBScalingPolicy) String 

func (this *MongoDBScalingPolicy) String() string

func (*MongoDBScalingPolicy) Unmarshal 

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

func (*MongoDBScalingPolicy) XXX_DiscardUnknown 

func (m *MongoDBScalingPolicy) XXX_DiscardUnknown()

func (*MongoDBScalingPolicy) XXX_Marshal 

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

func (*MongoDBScalingPolicy) XXX_Merge 

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

func (*MongoDBScalingPolicy) XXX_Size 

func (m *MongoDBScalingPolicy) XXX_Size() int

func (*MongoDBScalingPolicy) XXX_Unmarshal 

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

type MongoDBScalingRules 

type MongoDBScalingRules struct {
	// StabilizationWindowSeconds is the number of seconds for which past recommendations should be
	// considered while scaling up or scaling down.
	// StabilizationWindowSeconds must be greater than or equal to zero and less than or equal to 3600 (one hour).
	// If not set, use the default values:
	// - For scale up: 0 (i.e. no stabilization is done).
	// - For scale down: 300 (i.e. the stabilization window is 300 seconds long).
	// +optional
	StabilizationWindowSeconds *int32 `json:"stabilizationWindowSeconds" protobuf:"varint,3,opt,name=stabilizationWindowSeconds"`
	// selectPolicy is used to specify which policy should be used.
	// If not set, the default value MaxPolicySelect is used.
	// +optional
	SelectPolicy *v2beta2.ScalingPolicySelect `json:"selectPolicy,omitempty" protobuf:"bytes,1,opt,name=selectPolicy"`
	// policies is a list of potential scaling polices which can be used during scaling.
	// At least one policy must be specified, otherwise the MongoDBScalingRules will be discarded as invalid
	// +optional
	Policies []MongoDBScalingPolicy `json:"policies,omitempty" protobuf:"bytes,2,rep,name=policies"`
}

MongoDBScalingRules configures the scaling behavior for one direction. These Rules are applied after calculating DesiredReplicas from metrics for the HPA. They can limit the scaling velocity by specifying scaling policies. They can prevent flapping by specifying the stabilization window, so that the number of replicas is not set instantly, instead, the safest value from the stabilization window is chosen.

func (*MongoDBScalingRules) DeepCopy 

func (in *MongoDBScalingRules) DeepCopy() *MongoDBScalingRules

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

func (*MongoDBScalingRules) DeepCopyInto 

func (in *MongoDBScalingRules) DeepCopyInto(out *MongoDBScalingRules)

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

func (*MongoDBScalingRules) Descriptor 

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

func (*MongoDBScalingRules) Marshal 

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

func (*MongoDBScalingRules) MarshalTo 

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

func (*MongoDBScalingRules) MarshalToSizedBuffer 

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

func (*MongoDBScalingRules) ProtoMessage 

func (*MongoDBScalingRules) ProtoMessage()

func (*MongoDBScalingRules) Reset 

func (m *MongoDBScalingRules) Reset()

func (*MongoDBScalingRules) Size 

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

func (*MongoDBScalingRules) String 

func (this *MongoDBScalingRules) String() string

func (*MongoDBScalingRules) Unmarshal 

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

func (*MongoDBScalingRules) XXX_DiscardUnknown 

func (m *MongoDBScalingRules) XXX_DiscardUnknown()

func (*MongoDBScalingRules) XXX_Marshal 

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

func (*MongoDBScalingRules) XXX_Merge 

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

func (*MongoDBScalingRules) XXX_Size 

func (m *MongoDBScalingRules) XXX_Size() int

func (*MongoDBScalingRules) XXX_Unmarshal 

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

type MySQLAutoscaler 

type MySQLAutoscaler struct {
	metav1.TypeMeta `json:",inline"`
	// metadata is the standard object metadata.
	// More info: https://git.k8s.io/community/contributors/devel/sig-architecture/api-conventions.md#metadata
	// +optional
	metav1.ObjectMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`

	// spec is the specification for the behaviour of the autoscaler.
	// More info: https://git.k8s.io/community/contributors/devel/sig-architecture/api-conventions.md#spec-and-status.
	// +optional
	Spec MySQLAutoscalerSpec `json:"spec,omitempty" protobuf:"bytes,2,opt,name=spec"`

	// status is the current information about the autoscaler.
	// +optional
	Status MySQLAutoscalerStatus `json:"status,omitempty" protobuf:"bytes,3,opt,name=status"`
}

+kubebuilder:object:root=true +kubebuilder:resource:path=mysqlautoscalers,singular=mysqlautoscaler,shortName=myscaler,categories={datastore,kubedb,appscode} +kubebuilder:subresource:status

func (MySQLAutoscaler) CustomResourceDefinition 

func (_ MySQLAutoscaler) CustomResourceDefinition() *apiextensions.CustomResourceDefinition

func (*MySQLAutoscaler) DeepCopy 

func (in *MySQLAutoscaler) DeepCopy() *MySQLAutoscaler

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

func (*MySQLAutoscaler) DeepCopyInto 

func (in *MySQLAutoscaler) DeepCopyInto(out *MySQLAutoscaler)

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

func (*MySQLAutoscaler) DeepCopyObject 

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

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

func (*MySQLAutoscaler) Descriptor 

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

func (*MySQLAutoscaler) Marshal 

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

func (*MySQLAutoscaler) MarshalTo 

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

func (*MySQLAutoscaler) MarshalToSizedBuffer 

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

func (*MySQLAutoscaler) ProtoMessage 

func (*MySQLAutoscaler) ProtoMessage()

func (*MySQLAutoscaler) Reset 

func (m *MySQLAutoscaler) Reset()

func (MySQLAutoscaler) ResourceKind 

func (m MySQLAutoscaler) ResourceKind() string

func (MySQLAutoscaler) ResourcePlural 

func (m MySQLAutoscaler) ResourcePlural() string

func (MySQLAutoscaler) ResourceShortCode 

func (m MySQLAutoscaler) ResourceShortCode() string

func (MySQLAutoscaler) ResourceSingular 

func (m MySQLAutoscaler) ResourceSingular() string

func (*MySQLAutoscaler) Size 

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

func (*MySQLAutoscaler) String 

func (this *MySQLAutoscaler) String() string

func (*MySQLAutoscaler) Unmarshal 

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

func (MySQLAutoscaler) ValidateSpecs 

func (m MySQLAutoscaler) ValidateSpecs() error

func (*MySQLAutoscaler) XXX_DiscardUnknown 

func (m *MySQLAutoscaler) XXX_DiscardUnknown()

func (*MySQLAutoscaler) XXX_Marshal 

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

func (*MySQLAutoscaler) XXX_Merge 

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

func (*MySQLAutoscaler) XXX_Size 

func (m *MySQLAutoscaler) XXX_Size() int

func (*MySQLAutoscaler) XXX_Unmarshal 

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

type MySQLAutoscalerBehavior 

type MySQLAutoscalerBehavior struct {
	// scaleUp is scaling policy for scaling Up.
	// If not set, the default value is the higher of:
	//   * increase no more than 4 pods per 60 seconds
	//   * double the number of pods per 60 seconds
	// No stabilization is used.
	// +optional
	ScaleUp *MySQLScalingRules `json:"scaleUp,omitempty" protobuf:"bytes,1,opt,name=scaleUp"`
	// scaleDown is scaling policy for scaling Down.
	// If not set, the default value is to allow to scale down to minReplicas pods, with a
	// 300 second stabilization window (i.e., the highest recommendation for
	// the last 300sec is used).
	// +optional
	ScaleDown *MySQLScalingRules `json:"scaleDown,omitempty" protobuf:"bytes,2,opt,name=scaleDown"`
}

MySQLAutoscalerBehavior configures the scaling behavior of the target in both Up and Down directions (scaleUp and scaleDown fields respectively).

func (*MySQLAutoscalerBehavior) DeepCopy 

func (in *MySQLAutoscalerBehavior) DeepCopy() *MySQLAutoscalerBehavior

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

func (*MySQLAutoscalerBehavior) DeepCopyInto 

func (in *MySQLAutoscalerBehavior) DeepCopyInto(out *MySQLAutoscalerBehavior)

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

func (*MySQLAutoscalerBehavior) Descriptor 

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

func (*MySQLAutoscalerBehavior) Marshal 

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

func (*MySQLAutoscalerBehavior) MarshalTo 

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

func (*MySQLAutoscalerBehavior) MarshalToSizedBuffer 

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

func (*MySQLAutoscalerBehavior) ProtoMessage 

func (*MySQLAutoscalerBehavior) ProtoMessage()

func (*MySQLAutoscalerBehavior) Reset 

func (m *MySQLAutoscalerBehavior) Reset()

func (*MySQLAutoscalerBehavior) Size 

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

func (*MySQLAutoscalerBehavior) String 

func (this *MySQLAutoscalerBehavior) String() string

func (*MySQLAutoscalerBehavior) Unmarshal 

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

func (*MySQLAutoscalerBehavior) XXX_DiscardUnknown 

func (m *MySQLAutoscalerBehavior) XXX_DiscardUnknown()

func (*MySQLAutoscalerBehavior) XXX_Marshal 

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

func (*MySQLAutoscalerBehavior) XXX_Merge 

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

func (*MySQLAutoscalerBehavior) XXX_Size 

func (m *MySQLAutoscalerBehavior) XXX_Size() int

func (*MySQLAutoscalerBehavior) XXX_Unmarshal 

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

type MySQLAutoscalerList 

type MySQLAutoscalerList struct {
	metav1.TypeMeta `json:",inline"`
	// metadata is the standard list metadata.
	// +optional
	metav1.ListMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`

	// items is the list of horizontal pod autoscaler objects.
	Items []MySQLAutoscaler `json:"items" protobuf:"bytes,2,rep,name=items"`
}

MySQLAutoscalerList is a list of horizontal pod autoscaler objects.

func (*MySQLAutoscalerList) DeepCopy 

func (in *MySQLAutoscalerList) DeepCopy() *MySQLAutoscalerList

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

func (*MySQLAutoscalerList) DeepCopyInto 

func (in *MySQLAutoscalerList) DeepCopyInto(out *MySQLAutoscalerList)

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

func (*MySQLAutoscalerList) DeepCopyObject 

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

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

func (*MySQLAutoscalerList) Descriptor 

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

func (*MySQLAutoscalerList) Marshal 

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

func (*MySQLAutoscalerList) MarshalTo 

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

func (*MySQLAutoscalerList) MarshalToSizedBuffer 

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

func (*MySQLAutoscalerList) ProtoMessage 

func (*MySQLAutoscalerList) ProtoMessage()

func (*MySQLAutoscalerList) Reset 

func (m *MySQLAutoscalerList) Reset()

func (*MySQLAutoscalerList) Size 

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

func (*MySQLAutoscalerList) String 

func (this *MySQLAutoscalerList) String() string

func (*MySQLAutoscalerList) Unmarshal 

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

func (*MySQLAutoscalerList) XXX_DiscardUnknown 

func (m *MySQLAutoscalerList) XXX_DiscardUnknown()

func (*MySQLAutoscalerList) XXX_Marshal 

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

func (*MySQLAutoscalerList) XXX_Merge 

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

func (*MySQLAutoscalerList) XXX_Size 

func (m *MySQLAutoscalerList) XXX_Size() int

func (*MySQLAutoscalerList) XXX_Unmarshal 

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

type MySQLAutoscalerSpec 

type MySQLAutoscalerSpec struct {
	// scaleTargetRef points to the target resource to scale, and is used to the pods for which metrics
	// should be collected, as well as to actually change the replica count.
	ScaleTargetRef core.LocalObjectReference `json:"scaleTargetRef" protobuf:"bytes,1,opt,name=scaleTargetRef"`
	// minReplicas is the lower limit for the number of replicas to which the autoscaler
	// can scale down.  It defaults to 1 pod.  minReplicas is allowed to be 0 if the
	// alpha feature gate HPAScaleToZero is enabled and at least one Object or External
	// metric is configured.  Scaling is active as long as at least one metric value is
	// available.
	// +optional
	MinReplicas *int32 `json:"minReplicas,omitempty" protobuf:"varint,2,opt,name=minReplicas"`
	// maxReplicas is the upper limit for the number of replicas to which the autoscaler can scale up.
	// It cannot be less that minReplicas.
	MaxReplicas int32 `json:"maxReplicas" protobuf:"varint,3,opt,name=maxReplicas"`
	// metrics contains the specifications for which to use to calculate the
	// desired replica count (the maximum replica count across all metrics will
	// be used).  The desired replica count is calculated multiplying the
	// ratio between the target value and the current value by the current
	// number of pods.  Ergo, metrics used must decrease as the pod count is
	// increased, and vice-versa.  See the individual metric source types for
	// more information about how each type of metric must respond.
	// If not set, the default metric will be set to 80% average CPU utilization.
	// +optional
	Metrics []v2beta2.MetricSpec `json:"metrics,omitempty" protobuf:"bytes,4,rep,name=metrics"`

	// behavior configures the scaling behavior of the target
	// in both Up and Down directions (scaleUp and scaleDown fields respectively).
	// If not set, the default MySQLScalingRules for scale up and scale down are used.
	// +optional
	Behavior *MySQLAutoscalerBehavior `json:"behavior,omitempty" protobuf:"bytes,5,opt,name=behavior"`
}

MySQLAutoscalerSpec describes the desired functionality of the MySQLAutoscaler.

func (*MySQLAutoscalerSpec) DeepCopy 

func (in *MySQLAutoscalerSpec) DeepCopy() *MySQLAutoscalerSpec

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

func (*MySQLAutoscalerSpec) DeepCopyInto 

func (in *MySQLAutoscalerSpec) DeepCopyInto(out *MySQLAutoscalerSpec)

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

func (*MySQLAutoscalerSpec) Descriptor 

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

func (*MySQLAutoscalerSpec) Marshal 

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

func (*MySQLAutoscalerSpec) MarshalTo 

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

func (*MySQLAutoscalerSpec) MarshalToSizedBuffer 

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

func (*MySQLAutoscalerSpec) ProtoMessage 

func (*MySQLAutoscalerSpec) ProtoMessage()

func (*MySQLAutoscalerSpec) Reset 

func (m *MySQLAutoscalerSpec) Reset()

func (*MySQLAutoscalerSpec) Size 

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

func (*MySQLAutoscalerSpec) String 

func (this *MySQLAutoscalerSpec) String() string

func (*MySQLAutoscalerSpec) Unmarshal 

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

func (*MySQLAutoscalerSpec) XXX_DiscardUnknown 

func (m *MySQLAutoscalerSpec) XXX_DiscardUnknown()

func (*MySQLAutoscalerSpec) XXX_Marshal 

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

func (*MySQLAutoscalerSpec) XXX_Merge 

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

func (*MySQLAutoscalerSpec) XXX_Size 

func (m *MySQLAutoscalerSpec) XXX_Size() int

func (*MySQLAutoscalerSpec) XXX_Unmarshal 

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

type MySQLAutoscalerStatus 

type MySQLAutoscalerStatus struct {
	// observedGeneration is the most recent generation observed by this autoscaler.
	// +optional
	ObservedGeneration *int64 `json:"observedGeneration,omitempty" protobuf:"varint,1,opt,name=observedGeneration"`

	// lastScaleTime is the last time the MySQLAutoscaler scaled the number of pods,
	// used by the autoscaler to control how often the number of pods is changed.
	// +optional
	LastScaleTime *metav1.Time `json:"lastScaleTime,omitempty" protobuf:"bytes,2,opt,name=lastScaleTime"`

	// currentReplicas is current number of replicas of pods managed by this autoscaler,
	// as last seen by the autoscaler.
	CurrentReplicas int32 `json:"currentReplicas" protobuf:"varint,3,opt,name=currentReplicas"`

	// desiredReplicas is the desired number of replicas of pods managed by this autoscaler,
	// as last calculated by the autoscaler.
	DesiredReplicas int32 `json:"desiredReplicas" protobuf:"varint,4,opt,name=desiredReplicas"`

	// currentMetrics is the last read state of the metrics used by this autoscaler.
	// +optional
	CurrentMetrics []v2beta2.MetricStatus `json:"currentMetrics" protobuf:"bytes,5,rep,name=currentMetrics"`

	// conditions is the set of conditions required for this autoscaler to scale its target,
	// and indicates whether or not those conditions are met.
	Conditions []kmapi.Condition `json:"conditions" protobuf:"bytes,6,rep,name=conditions"`
}

MySQLAutoscalerStatus describes the current status of a horizontal pod autoscaler.

func (*MySQLAutoscalerStatus) DeepCopy 

func (in *MySQLAutoscalerStatus) DeepCopy() *MySQLAutoscalerStatus

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

func (*MySQLAutoscalerStatus) DeepCopyInto 

func (in *MySQLAutoscalerStatus) DeepCopyInto(out *MySQLAutoscalerStatus)

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

func (*MySQLAutoscalerStatus) Descriptor 

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

func (*MySQLAutoscalerStatus) Marshal 

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

func (*MySQLAutoscalerStatus) MarshalTo 

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

func (*MySQLAutoscalerStatus) MarshalToSizedBuffer 

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

func (*MySQLAutoscalerStatus) ProtoMessage 

func (*MySQLAutoscalerStatus) ProtoMessage()

func (*MySQLAutoscalerStatus) Reset 

func (m *MySQLAutoscalerStatus) Reset()

func (*MySQLAutoscalerStatus) Size 

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

func (*MySQLAutoscalerStatus) String 

func (this *MySQLAutoscalerStatus) String() string

func (*MySQLAutoscalerStatus) Unmarshal 

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

func (*MySQLAutoscalerStatus) XXX_DiscardUnknown 

func (m *MySQLAutoscalerStatus) XXX_DiscardUnknown()

func (*MySQLAutoscalerStatus) XXX_Marshal 

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

func (*MySQLAutoscalerStatus) XXX_Merge 

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

func (*MySQLAutoscalerStatus) XXX_Size 

func (m *MySQLAutoscalerStatus) XXX_Size() int

func (*MySQLAutoscalerStatus) XXX_Unmarshal 

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

type MySQLScalingPolicy 

type MySQLScalingPolicy struct {
	// Type is used to specify the scaling policy.
	Type v2beta2.HPAScalingPolicyType `json:"type" protobuf:"bytes,1,opt,name=type,casttype=HPAScalingPolicyType"`
	// Value contains the amount of change which is permitted by the policy.
	// It must be greater than zero
	Value int32 `json:"value" protobuf:"varint,2,opt,name=value"`
	// PeriodSeconds specifies the window of time for which the policy should hold true.
	// PeriodSeconds must be greater than zero and less than or equal to 1800 (30 min).
	PeriodSeconds int32 `json:"periodSeconds" protobuf:"varint,3,opt,name=periodSeconds"`
}

MySQLScalingPolicy is a single policy which must hold true for a specified past interval.

func (*MySQLScalingPolicy) DeepCopy 

func (in *MySQLScalingPolicy) DeepCopy() *MySQLScalingPolicy

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

func (*MySQLScalingPolicy) DeepCopyInto 

func (in *MySQLScalingPolicy) DeepCopyInto(out *MySQLScalingPolicy)

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

func (*MySQLScalingPolicy) Descriptor 

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

func (*MySQLScalingPolicy) Marshal 

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

func (*MySQLScalingPolicy) MarshalTo 

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

func (*MySQLScalingPolicy) MarshalToSizedBuffer 

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

func (*MySQLScalingPolicy) ProtoMessage 

func (*MySQLScalingPolicy) ProtoMessage()

func (*MySQLScalingPolicy) Reset 

func (m *MySQLScalingPolicy) Reset()

func (*MySQLScalingPolicy) Size 

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

func (*MySQLScalingPolicy) String 

func (this *MySQLScalingPolicy) String() string

func (*MySQLScalingPolicy) Unmarshal 

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

func (*MySQLScalingPolicy) XXX_DiscardUnknown 

func (m *MySQLScalingPolicy) XXX_DiscardUnknown()

func (*MySQLScalingPolicy) XXX_Marshal 

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

func (*MySQLScalingPolicy) XXX_Merge 

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

func (*MySQLScalingPolicy) XXX_Size 

func (m *MySQLScalingPolicy) XXX_Size() int

func (*MySQLScalingPolicy) XXX_Unmarshal 

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

type MySQLScalingRules 

type MySQLScalingRules struct {
	// StabilizationWindowSeconds is the number of seconds for which past recommendations should be
	// considered while scaling up or scaling down.
	// StabilizationWindowSeconds must be greater than or equal to zero and less than or equal to 3600 (one hour).
	// If not set, use the default values:
	// - For scale up: 0 (i.e. no stabilization is done).
	// - For scale down: 300 (i.e. the stabilization window is 300 seconds long).
	// +optional
	StabilizationWindowSeconds *int32 `json:"stabilizationWindowSeconds" protobuf:"varint,3,opt,name=stabilizationWindowSeconds"`
	// selectPolicy is used to specify which policy should be used.
	// If not set, the default value MaxPolicySelect is used.
	// +optional
	SelectPolicy *v2beta2.ScalingPolicySelect `json:"selectPolicy,omitempty" protobuf:"bytes,1,opt,name=selectPolicy"`
	// policies is a list of potential scaling polices which can be used during scaling.
	// At least one policy must be specified, otherwise the MySQLScalingRules will be discarded as invalid
	// +optional
	Policies []MySQLScalingPolicy `json:"policies,omitempty" protobuf:"bytes,2,rep,name=policies"`
}

MySQLScalingRules configures the scaling behavior for one direction. These Rules are applied after calculating DesiredReplicas from metrics for the HPA. They can limit the scaling velocity by specifying scaling policies. They can prevent flapping by specifying the stabilization window, so that the number of replicas is not set instantly, instead, the safest value from the stabilization window is chosen.

func (*MySQLScalingRules) DeepCopy 

func (in *MySQLScalingRules) DeepCopy() *MySQLScalingRules

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

func (*MySQLScalingRules) DeepCopyInto 

func (in *MySQLScalingRules) DeepCopyInto(out *MySQLScalingRules)

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

func (*MySQLScalingRules) Descriptor 

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

func (*MySQLScalingRules) Marshal 

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

func (*MySQLScalingRules) MarshalTo 

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

func (*MySQLScalingRules) MarshalToSizedBuffer 

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

func (*MySQLScalingRules) ProtoMessage 

func (*MySQLScalingRules) ProtoMessage()

func (*MySQLScalingRules) Reset 

func (m *MySQLScalingRules) Reset()

func (*MySQLScalingRules) Size 

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

func (*MySQLScalingRules) String 

func (this *MySQLScalingRules) String() string

func (*MySQLScalingRules) Unmarshal 

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

func (*MySQLScalingRules) XXX_DiscardUnknown 

func (m *MySQLScalingRules) XXX_DiscardUnknown()

func (*MySQLScalingRules) XXX_Marshal 

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

func (*MySQLScalingRules) XXX_Merge 

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

func (*MySQLScalingRules) XXX_Size 

func (m *MySQLScalingRules) XXX_Size() int

func (*MySQLScalingRules) XXX_Unmarshal 

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

type PerconaXtraDBAutoscaler 

type PerconaXtraDBAutoscaler struct {
	metav1.TypeMeta `json:",inline"`
	// metadata is the standard object metadata.
	// More info: https://git.k8s.io/community/contributors/devel/sig-architecture/api-conventions.md#metadata
	// +optional
	metav1.ObjectMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`

	// spec is the specification for the behaviour of the autoscaler.
	// More info: https://git.k8s.io/community/contributors/devel/sig-architecture/api-conventions.md#spec-and-status.
	// +optional
	Spec PerconaXtraDBAutoscalerSpec `json:"spec,omitempty" protobuf:"bytes,2,opt,name=spec"`

	// status is the current information about the autoscaler.
	// +optional
	Status PerconaXtraDBAutoscalerStatus `json:"status,omitempty" protobuf:"bytes,3,opt,name=status"`
}

+kubebuilder:object:root=true +kubebuilder:resource:path=perconaxtradbautoscalers,singular=perconaxtradbautoscaler,shortName=pxcscaler,categories={datastore,kubedb,appscode} +kubebuilder:subresource:status

func (PerconaXtraDBAutoscaler) CustomResourceDefinition 

func (_ PerconaXtraDBAutoscaler) CustomResourceDefinition() *apiextensions.CustomResourceDefinition

func (*PerconaXtraDBAutoscaler) DeepCopy 

func (in *PerconaXtraDBAutoscaler) DeepCopy() *PerconaXtraDBAutoscaler

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

func (*PerconaXtraDBAutoscaler) DeepCopyInto 

func (in *PerconaXtraDBAutoscaler) DeepCopyInto(out *PerconaXtraDBAutoscaler)

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

func (*PerconaXtraDBAutoscaler) DeepCopyObject 

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

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

func (*PerconaXtraDBAutoscaler) Descriptor 

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

func (*PerconaXtraDBAutoscaler) Marshal 

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

func (*PerconaXtraDBAutoscaler) MarshalTo 

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

func (*PerconaXtraDBAutoscaler) MarshalToSizedBuffer 

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

func (*PerconaXtraDBAutoscaler) ProtoMessage 

func (*PerconaXtraDBAutoscaler) ProtoMessage()

func (*PerconaXtraDBAutoscaler) Reset 

func (m *PerconaXtraDBAutoscaler) Reset()

func (PerconaXtraDBAutoscaler) ResourceKind 

func (p PerconaXtraDBAutoscaler) ResourceKind() string

func (PerconaXtraDBAutoscaler) ResourcePlural 

func (p PerconaXtraDBAutoscaler) ResourcePlural() string

func (PerconaXtraDBAutoscaler) ResourceShortCode 

func (p PerconaXtraDBAutoscaler) ResourceShortCode() string

func (PerconaXtraDBAutoscaler) ResourceSingular 

func (p PerconaXtraDBAutoscaler) ResourceSingular() string

func (*PerconaXtraDBAutoscaler) Size 

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

func (*PerconaXtraDBAutoscaler) String 

func (this *PerconaXtraDBAutoscaler) String() string

func (*PerconaXtraDBAutoscaler) Unmarshal 

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

func (PerconaXtraDBAutoscaler) ValidateSpecs 

func (p PerconaXtraDBAutoscaler) ValidateSpecs() error

func (*PerconaXtraDBAutoscaler) XXX_DiscardUnknown 

func (m *PerconaXtraDBAutoscaler) XXX_DiscardUnknown()

func (*PerconaXtraDBAutoscaler) XXX_Marshal 

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

func (*PerconaXtraDBAutoscaler) XXX_Merge 

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

func (*PerconaXtraDBAutoscaler) XXX_Size 

func (m *PerconaXtraDBAutoscaler) XXX_Size() int

func (*PerconaXtraDBAutoscaler) XXX_Unmarshal 

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

type PerconaXtraDBAutoscalerBehavior 

type PerconaXtraDBAutoscalerBehavior struct {
	// scaleUp is scaling policy for scaling Up.
	// If not set, the default value is the higher of:
	//   * increase no more than 4 pods per 60 seconds
	//   * double the number of pods per 60 seconds
	// No stabilization is used.
	// +optional
	ScaleUp *PerconaXtraDBScalingRules `json:"scaleUp,omitempty" protobuf:"bytes,1,opt,name=scaleUp"`
	// scaleDown is scaling policy for scaling Down.
	// If not set, the default value is to allow to scale down to minReplicas pods, with a
	// 300 second stabilization window (i.e., the highest recommendation for
	// the last 300sec is used).
	// +optional
	ScaleDown *PerconaXtraDBScalingRules `json:"scaleDown,omitempty" protobuf:"bytes,2,opt,name=scaleDown"`
}

PerconaXtraDBAutoscalerBehavior configures the scaling behavior of the target in both Up and Down directions (scaleUp and scaleDown fields respectively).

func (*PerconaXtraDBAutoscalerBehavior) DeepCopy 

func (in *PerconaXtraDBAutoscalerBehavior) DeepCopy() *PerconaXtraDBAutoscalerBehavior

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

func (*PerconaXtraDBAutoscalerBehavior) DeepCopyInto 

func (in *PerconaXtraDBAutoscalerBehavior) DeepCopyInto(out *PerconaXtraDBAutoscalerBehavior)

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

func (*PerconaXtraDBAutoscalerBehavior) Descriptor 

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

func (*PerconaXtraDBAutoscalerBehavior) Marshal 

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

func (*PerconaXtraDBAutoscalerBehavior) MarshalTo 

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

func (*PerconaXtraDBAutoscalerBehavior) MarshalToSizedBuffer 

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

func (*PerconaXtraDBAutoscalerBehavior) ProtoMessage 

func (*PerconaXtraDBAutoscalerBehavior) ProtoMessage()

func (*PerconaXtraDBAutoscalerBehavior) Reset 

func (m *PerconaXtraDBAutoscalerBehavior) Reset()

func (*PerconaXtraDBAutoscalerBehavior) Size 

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

func (*PerconaXtraDBAutoscalerBehavior) String 

func (this *PerconaXtraDBAutoscalerBehavior) String() string

func (*PerconaXtraDBAutoscalerBehavior) Unmarshal 

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

func (*PerconaXtraDBAutoscalerBehavior) XXX_DiscardUnknown 

func (m *PerconaXtraDBAutoscalerBehavior) XXX_DiscardUnknown()

func (*PerconaXtraDBAutoscalerBehavior) XXX_Marshal 

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

func (*PerconaXtraDBAutoscalerBehavior) XXX_Merge 

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

func (*PerconaXtraDBAutoscalerBehavior) XXX_Size 

func (m *PerconaXtraDBAutoscalerBehavior) XXX_Size() int

func (*PerconaXtraDBAutoscalerBehavior) XXX_Unmarshal 

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

type PerconaXtraDBAutoscalerList 

type PerconaXtraDBAutoscalerList struct {
	metav1.TypeMeta `json:",inline"`
	// metadata is the standard list metadata.
	// +optional
	metav1.ListMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`

	// items is the list of horizontal pod autoscaler objects.
	Items []PerconaXtraDBAutoscaler `json:"items" protobuf:"bytes,2,rep,name=items"`
}

PerconaXtraDBAutoscalerList is a list of horizontal pod autoscaler objects.

func (*PerconaXtraDBAutoscalerList) DeepCopy 

func (in *PerconaXtraDBAutoscalerList) DeepCopy() *PerconaXtraDBAutoscalerList

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

func (*PerconaXtraDBAutoscalerList) DeepCopyInto 

func (in *PerconaXtraDBAutoscalerList) DeepCopyInto(out *PerconaXtraDBAutoscalerList)

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

func (*PerconaXtraDBAutoscalerList) DeepCopyObject 

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

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

func (*PerconaXtraDBAutoscalerList) Descriptor 

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

func (*PerconaXtraDBAutoscalerList) Marshal 

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

func (*PerconaXtraDBAutoscalerList) MarshalTo 

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

func (*PerconaXtraDBAutoscalerList) MarshalToSizedBuffer 

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

func (*PerconaXtraDBAutoscalerList) ProtoMessage 

func (*PerconaXtraDBAutoscalerList) ProtoMessage()

func (*PerconaXtraDBAutoscalerList) Reset 

func (m *PerconaXtraDBAutoscalerList) Reset()

func (*PerconaXtraDBAutoscalerList) Size 

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

func (*PerconaXtraDBAutoscalerList) String 

func (this *PerconaXtraDBAutoscalerList) String() string

func (*PerconaXtraDBAutoscalerList) Unmarshal 

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

func (*PerconaXtraDBAutoscalerList) XXX_DiscardUnknown 

func (m *PerconaXtraDBAutoscalerList) XXX_DiscardUnknown()

func (*PerconaXtraDBAutoscalerList) XXX_Marshal 

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

func (*PerconaXtraDBAutoscalerList) XXX_Merge 

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

func (*PerconaXtraDBAutoscalerList) XXX_Size 

func (m *PerconaXtraDBAutoscalerList) XXX_Size() int

func (*PerconaXtraDBAutoscalerList) XXX_Unmarshal 

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

type PerconaXtraDBAutoscalerSpec 

type PerconaXtraDBAutoscalerSpec struct {
	// scaleTargetRef points to the target resource to scale, and is used to the pods for which metrics
	// should be collected, as well as to actually change the replica count.
	ScaleTargetRef core.LocalObjectReference `json:"scaleTargetRef" protobuf:"bytes,1,opt,name=scaleTargetRef"`
	// minReplicas is the lower limit for the number of replicas to which the autoscaler
	// can scale down.  It defaults to 1 pod.  minReplicas is allowed to be 0 if the
	// alpha feature gate HPAScaleToZero is enabled and at least one Object or External
	// metric is configured.  Scaling is active as long as at least one metric value is
	// available.
	// +optional
	MinReplicas *int32 `json:"minReplicas,omitempty" protobuf:"varint,2,opt,name=minReplicas"`
	// maxReplicas is the upper limit for the number of replicas to which the autoscaler can scale up.
	// It cannot be less that minReplicas.
	MaxReplicas int32 `json:"maxReplicas" protobuf:"varint,3,opt,name=maxReplicas"`
	// metrics contains the specifications for which to use to calculate the
	// desired replica count (the maximum replica count across all metrics will
	// be used).  The desired replica count is calculated multiplying the
	// ratio between the target value and the current value by the current
	// number of pods.  Ergo, metrics used must decrease as the pod count is
	// increased, and vice-versa.  See the individual metric source types for
	// more information about how each type of metric must respond.
	// If not set, the default metric will be set to 80% average CPU utilization.
	// +optional
	Metrics []v2beta2.MetricSpec `json:"metrics,omitempty" protobuf:"bytes,4,rep,name=metrics"`

	// behavior configures the scaling behavior of the target
	// in both Up and Down directions (scaleUp and scaleDown fields respectively).
	// If not set, the default PerconaXtraDBScalingRules for scale up and scale down are used.
	// +optional
	Behavior *PerconaXtraDBAutoscalerBehavior `json:"behavior,omitempty" protobuf:"bytes,5,opt,name=behavior"`
}

PerconaXtraDBAutoscalerSpec describes the desired functionality of the PerconaXtraDBAutoscaler.

func (*PerconaXtraDBAutoscalerSpec) DeepCopy 

func (in *PerconaXtraDBAutoscalerSpec) DeepCopy() *PerconaXtraDBAutoscalerSpec

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

func (*PerconaXtraDBAutoscalerSpec) DeepCopyInto 

func (in *PerconaXtraDBAutoscalerSpec) DeepCopyInto(out *PerconaXtraDBAutoscalerSpec)

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

func (*PerconaXtraDBAutoscalerSpec) Descriptor 

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

func (*PerconaXtraDBAutoscalerSpec) Marshal 

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

func (*PerconaXtraDBAutoscalerSpec) MarshalTo 

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

func (*PerconaXtraDBAutoscalerSpec) MarshalToSizedBuffer 

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

func (*PerconaXtraDBAutoscalerSpec) ProtoMessage 

func (*PerconaXtraDBAutoscalerSpec) ProtoMessage()

func (*PerconaXtraDBAutoscalerSpec) Reset 

func (m *PerconaXtraDBAutoscalerSpec) Reset()

func (*PerconaXtraDBAutoscalerSpec) Size 

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

func (*PerconaXtraDBAutoscalerSpec) String 

func (this *PerconaXtraDBAutoscalerSpec) String() string

func (*PerconaXtraDBAutoscalerSpec) Unmarshal 

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

func (*PerconaXtraDBAutoscalerSpec) XXX_DiscardUnknown 

func (m *PerconaXtraDBAutoscalerSpec) XXX_DiscardUnknown()

func (*PerconaXtraDBAutoscalerSpec) XXX_Marshal 

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

func (*PerconaXtraDBAutoscalerSpec) XXX_Merge 

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

func (*PerconaXtraDBAutoscalerSpec) XXX_Size 

func (m *PerconaXtraDBAutoscalerSpec) XXX_Size() int

func (*PerconaXtraDBAutoscalerSpec) XXX_Unmarshal 

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

type PerconaXtraDBAutoscalerStatus 

type PerconaXtraDBAutoscalerStatus struct {
	// observedGeneration is the most recent generation observed by this autoscaler.
	// +optional
	ObservedGeneration *int64 `json:"observedGeneration,omitempty" protobuf:"varint,1,opt,name=observedGeneration"`

	// lastScaleTime is the last time the PerconaXtraDBAutoscaler scaled the number of pods,
	// used by the autoscaler to control how often the number of pods is changed.
	// +optional
	LastScaleTime *metav1.Time `json:"lastScaleTime,omitempty" protobuf:"bytes,2,opt,name=lastScaleTime"`

	// currentReplicas is current number of replicas of pods managed by this autoscaler,
	// as last seen by the autoscaler.
	CurrentReplicas int32 `json:"currentReplicas" protobuf:"varint,3,opt,name=currentReplicas"`

	// desiredReplicas is the desired number of replicas of pods managed by this autoscaler,
	// as last calculated by the autoscaler.
	DesiredReplicas int32 `json:"desiredReplicas" protobuf:"varint,4,opt,name=desiredReplicas"`

	// currentMetrics is the last read state of the metrics used by this autoscaler.
	// +optional
	CurrentMetrics []v2beta2.MetricStatus `json:"currentMetrics" protobuf:"bytes,5,rep,name=currentMetrics"`

	// conditions is the set of conditions required for this autoscaler to scale its target,
	// and indicates whether or not those conditions are met.
	Conditions []kmapi.Condition `json:"conditions" protobuf:"bytes,6,rep,name=conditions"`
}

PerconaXtraDBAutoscalerStatus describes the current status of a horizontal pod autoscaler.

func (*PerconaXtraDBAutoscalerStatus) DeepCopy 

func (in *PerconaXtraDBAutoscalerStatus) DeepCopy() *PerconaXtraDBAutoscalerStatus

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

func (*PerconaXtraDBAutoscalerStatus) DeepCopyInto 

func (in *PerconaXtraDBAutoscalerStatus) DeepCopyInto(out *PerconaXtraDBAutoscalerStatus)

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

func (*PerconaXtraDBAutoscalerStatus) Descriptor 

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

func (*PerconaXtraDBAutoscalerStatus) Marshal 

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

func (*PerconaXtraDBAutoscalerStatus) MarshalTo 

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

func (*PerconaXtraDBAutoscalerStatus) MarshalToSizedBuffer 

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

func (*PerconaXtraDBAutoscalerStatus) ProtoMessage 

func (*PerconaXtraDBAutoscalerStatus) ProtoMessage()

func (*PerconaXtraDBAutoscalerStatus) Reset 

func (m *PerconaXtraDBAutoscalerStatus) Reset()

func (*PerconaXtraDBAutoscalerStatus) Size 

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

func (*PerconaXtraDBAutoscalerStatus) String 

func (this *PerconaXtraDBAutoscalerStatus) String() string

func (*PerconaXtraDBAutoscalerStatus) Unmarshal 

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

func (*PerconaXtraDBAutoscalerStatus) XXX_DiscardUnknown 

func (m *PerconaXtraDBAutoscalerStatus) XXX_DiscardUnknown()

func (*PerconaXtraDBAutoscalerStatus) XXX_Marshal 

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

func (*PerconaXtraDBAutoscalerStatus) XXX_Merge 

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

func (*PerconaXtraDBAutoscalerStatus) XXX_Size 

func (m *PerconaXtraDBAutoscalerStatus) XXX_Size() int

func (*PerconaXtraDBAutoscalerStatus) XXX_Unmarshal 

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

type PerconaXtraDBScalingPolicy 

type PerconaXtraDBScalingPolicy struct {
	// Type is used to specify the scaling policy.
	Type v2beta2.HPAScalingPolicyType `json:"type" protobuf:"bytes,1,opt,name=type,casttype=HPAScalingPolicyType"`
	// Value contains the amount of change which is permitted by the policy.
	// It must be greater than zero
	Value int32 `json:"value" protobuf:"varint,2,opt,name=value"`
	// PeriodSeconds specifies the window of time for which the policy should hold true.
	// PeriodSeconds must be greater than zero and less than or equal to 1800 (30 min).
	PeriodSeconds int32 `json:"periodSeconds" protobuf:"varint,3,opt,name=periodSeconds"`
}

PerconaXtraDBScalingPolicy is a single policy which must hold true for a specified past interval.

func (*PerconaXtraDBScalingPolicy) DeepCopy 

func (in *PerconaXtraDBScalingPolicy) DeepCopy() *PerconaXtraDBScalingPolicy

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

func (*PerconaXtraDBScalingPolicy) DeepCopyInto 

func (in *PerconaXtraDBScalingPolicy) DeepCopyInto(out *PerconaXtraDBScalingPolicy)

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

func (*PerconaXtraDBScalingPolicy) Descriptor 

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

func (*PerconaXtraDBScalingPolicy) Marshal 

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

func (*PerconaXtraDBScalingPolicy) MarshalTo 

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

func (*PerconaXtraDBScalingPolicy) MarshalToSizedBuffer 

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

func (*PerconaXtraDBScalingPolicy) ProtoMessage 

func (*PerconaXtraDBScalingPolicy) ProtoMessage()

func (*PerconaXtraDBScalingPolicy) Reset 

func (m *PerconaXtraDBScalingPolicy) Reset()

func (*PerconaXtraDBScalingPolicy) Size 

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

func (*PerconaXtraDBScalingPolicy) String 

func (this *PerconaXtraDBScalingPolicy) String() string

func (*PerconaXtraDBScalingPolicy) Unmarshal 

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

func (*PerconaXtraDBScalingPolicy) XXX_DiscardUnknown 

func (m *PerconaXtraDBScalingPolicy) XXX_DiscardUnknown()

func (*PerconaXtraDBScalingPolicy) XXX_Marshal 

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

func (*PerconaXtraDBScalingPolicy) XXX_Merge 

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

func (*PerconaXtraDBScalingPolicy) XXX_Size 

func (m *PerconaXtraDBScalingPolicy) XXX_Size() int

func (*PerconaXtraDBScalingPolicy) XXX_Unmarshal 

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

type PerconaXtraDBScalingRules 

type PerconaXtraDBScalingRules struct {
	// StabilizationWindowSeconds is the number of seconds for which past recommendations should be
	// considered while scaling up or scaling down.
	// StabilizationWindowSeconds must be greater than or equal to zero and less than or equal to 3600 (one hour).
	// If not set, use the default values:
	// - For scale up: 0 (i.e. no stabilization is done).
	// - For scale down: 300 (i.e. the stabilization window is 300 seconds long).
	// +optional
	StabilizationWindowSeconds *int32 `json:"stabilizationWindowSeconds" protobuf:"varint,3,opt,name=stabilizationWindowSeconds"`
	// selectPolicy is used to specify which policy should be used.
	// If not set, the default value MaxPolicySelect is used.
	// +optional
	SelectPolicy *v2beta2.ScalingPolicySelect `json:"selectPolicy,omitempty" protobuf:"bytes,1,opt,name=selectPolicy"`
	// policies is a list of potential scaling polices which can be used during scaling.
	// At least one policy must be specified, otherwise the PerconaXtraDBScalingRules will be discarded as invalid
	// +optional
	Policies []PerconaXtraDBScalingPolicy `json:"policies,omitempty" protobuf:"bytes,2,rep,name=policies"`
}

PerconaXtraDBScalingRules configures the scaling behavior for one direction. These Rules are applied after calculating DesiredReplicas from metrics for the HPA. They can limit the scaling velocity by specifying scaling policies. They can prevent flapping by specifying the stabilization window, so that the number of replicas is not set instantly, instead, the safest value from the stabilization window is chosen.

func (*PerconaXtraDBScalingRules) DeepCopy 

func (in *PerconaXtraDBScalingRules) DeepCopy() *PerconaXtraDBScalingRules

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

func (*PerconaXtraDBScalingRules) DeepCopyInto 

func (in *PerconaXtraDBScalingRules) DeepCopyInto(out *PerconaXtraDBScalingRules)

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

func (*PerconaXtraDBScalingRules) Descriptor 

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

func (*PerconaXtraDBScalingRules) Marshal 

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

func (*PerconaXtraDBScalingRules) MarshalTo 

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

func (*PerconaXtraDBScalingRules) MarshalToSizedBuffer 

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

func (*PerconaXtraDBScalingRules) ProtoMessage 

func (*PerconaXtraDBScalingRules) ProtoMessage()

func (*PerconaXtraDBScalingRules) Reset 

func (m *PerconaXtraDBScalingRules) Reset()

func (*PerconaXtraDBScalingRules) Size 

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

func (*PerconaXtraDBScalingRules) String 

func (this *PerconaXtraDBScalingRules) String() string

func (*PerconaXtraDBScalingRules) Unmarshal 

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

func (*PerconaXtraDBScalingRules) XXX_DiscardUnknown 

func (m *PerconaXtraDBScalingRules) XXX_DiscardUnknown()

func (*PerconaXtraDBScalingRules) XXX_Marshal 

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

func (*PerconaXtraDBScalingRules) XXX_Merge 

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

func (*PerconaXtraDBScalingRules) XXX_Size 

func (m *PerconaXtraDBScalingRules) XXX_Size() int

func (*PerconaXtraDBScalingRules) XXX_Unmarshal 

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

type PgBouncerAutoscaler 

type PgBouncerAutoscaler struct {
	metav1.TypeMeta `json:",inline"`
	// metadata is the standard object metadata.
	// More info: https://git.k8s.io/community/contributors/devel/sig-architecture/api-conventions.md#metadata
	// +optional
	metav1.ObjectMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`

	// spec is the specification for the behaviour of the autoscaler.
	// More info: https://git.k8s.io/community/contributors/devel/sig-architecture/api-conventions.md#spec-and-status.
	// +optional
	Spec PgBouncerAutoscalerSpec `json:"spec,omitempty" protobuf:"bytes,2,opt,name=spec"`

	// status is the current information about the autoscaler.
	// +optional
	Status PgBouncerAutoscalerStatus `json:"status,omitempty" protobuf:"bytes,3,opt,name=status"`
}

+kubebuilder:object:root=true +kubebuilder:resource:path=pgbouncerautoscalers,singular=pgbouncerautoscaler,shortName=pbscaler,categories={datastore,kubedb,appscode} +kubebuilder:subresource:status

func (PgBouncerAutoscaler) CustomResourceDefinition 

func (_ PgBouncerAutoscaler) CustomResourceDefinition() *apiextensions.CustomResourceDefinition

func (*PgBouncerAutoscaler) DeepCopy 

func (in *PgBouncerAutoscaler) DeepCopy() *PgBouncerAutoscaler

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

func (*PgBouncerAutoscaler) DeepCopyInto 

func (in *PgBouncerAutoscaler) DeepCopyInto(out *PgBouncerAutoscaler)

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

func (*PgBouncerAutoscaler) DeepCopyObject 

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

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

func (*PgBouncerAutoscaler) Descriptor 

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

func (*PgBouncerAutoscaler) Marshal 

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

func (*PgBouncerAutoscaler) MarshalTo 

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

func (*PgBouncerAutoscaler) MarshalToSizedBuffer 

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

func (*PgBouncerAutoscaler) ProtoMessage 

func (*PgBouncerAutoscaler) ProtoMessage()

func (*PgBouncerAutoscaler) Reset 

func (m *PgBouncerAutoscaler) Reset()

func (PgBouncerAutoscaler) ResourceKind 

func (p PgBouncerAutoscaler) ResourceKind() string

func (PgBouncerAutoscaler) ResourcePlural 

func (p PgBouncerAutoscaler) ResourcePlural() string

func (PgBouncerAutoscaler) ResourceShortCode 

func (p PgBouncerAutoscaler) ResourceShortCode() string

func (PgBouncerAutoscaler) ResourceSingular 

func (p PgBouncerAutoscaler) ResourceSingular() string

func (*PgBouncerAutoscaler) Size 

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

func (*PgBouncerAutoscaler) String 

func (this *PgBouncerAutoscaler) String() string

func (*PgBouncerAutoscaler) Unmarshal 

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

func (PgBouncerAutoscaler) ValidateSpecs 

func (p PgBouncerAutoscaler) ValidateSpecs() error

func (*PgBouncerAutoscaler) XXX_DiscardUnknown 

func (m *PgBouncerAutoscaler) XXX_DiscardUnknown()

func (*PgBouncerAutoscaler) XXX_Marshal 

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

func (*PgBouncerAutoscaler) XXX_Merge 

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

func (*PgBouncerAutoscaler) XXX_Size 

func (m *PgBouncerAutoscaler) XXX_Size() int

func (*PgBouncerAutoscaler) XXX_Unmarshal 

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

type PgBouncerAutoscalerBehavior 

type PgBouncerAutoscalerBehavior struct {
	// scaleUp is scaling policy for scaling Up.
	// If not set, the default value is the higher of:
	//   * increase no more than 4 pods per 60 seconds
	//   * double the number of pods per 60 seconds
	// No stabilization is used.
	// +optional
	ScaleUp *PgBouncerScalingRules `json:"scaleUp,omitempty" protobuf:"bytes,1,opt,name=scaleUp"`
	// scaleDown is scaling policy for scaling Down.
	// If not set, the default value is to allow to scale down to minReplicas pods, with a
	// 300 second stabilization window (i.e., the highest recommendation for
	// the last 300sec is used).
	// +optional
	ScaleDown *PgBouncerScalingRules `json:"scaleDown,omitempty" protobuf:"bytes,2,opt,name=scaleDown"`
}

PgBouncerAutoscalerBehavior configures the scaling behavior of the target in both Up and Down directions (scaleUp and scaleDown fields respectively).

func (*PgBouncerAutoscalerBehavior) DeepCopy 

func (in *PgBouncerAutoscalerBehavior) DeepCopy() *PgBouncerAutoscalerBehavior

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

func (*PgBouncerAutoscalerBehavior) DeepCopyInto 

func (in *PgBouncerAutoscalerBehavior) DeepCopyInto(out *PgBouncerAutoscalerBehavior)

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

func (*PgBouncerAutoscalerBehavior) Descriptor 

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

func (*PgBouncerAutoscalerBehavior) Marshal 

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

func (*PgBouncerAutoscalerBehavior) MarshalTo 

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

func (*PgBouncerAutoscalerBehavior) MarshalToSizedBuffer 

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

func (*PgBouncerAutoscalerBehavior) ProtoMessage 

func (*PgBouncerAutoscalerBehavior) ProtoMessage()

func (*PgBouncerAutoscalerBehavior) Reset 

func (m *PgBouncerAutoscalerBehavior) Reset()

func (*PgBouncerAutoscalerBehavior) Size 

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

func (*PgBouncerAutoscalerBehavior) String 

func (this *PgBouncerAutoscalerBehavior) String() string

func (*PgBouncerAutoscalerBehavior) Unmarshal 

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

func (*PgBouncerAutoscalerBehavior) XXX_DiscardUnknown 

func (m *PgBouncerAutoscalerBehavior) XXX_DiscardUnknown()

func (*PgBouncerAutoscalerBehavior) XXX_Marshal 

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

func (*PgBouncerAutoscalerBehavior) XXX_Merge 

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

func (*PgBouncerAutoscalerBehavior) XXX_Size 

func (m *PgBouncerAutoscalerBehavior) XXX_Size() int

func (*PgBouncerAutoscalerBehavior) XXX_Unmarshal 

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

type PgBouncerAutoscalerList 

type PgBouncerAutoscalerList struct {
	metav1.TypeMeta `json:",inline"`
	// metadata is the standard list metadata.
	// +optional
	metav1.ListMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`

	// items is the list of horizontal pod autoscaler objects.
	Items []PgBouncerAutoscaler `json:"items" protobuf:"bytes,2,rep,name=items"`
}

PgBouncerAutoscalerList is a list of horizontal pod autoscaler objects.

func (*PgBouncerAutoscalerList) DeepCopy 

func (in *PgBouncerAutoscalerList) DeepCopy() *PgBouncerAutoscalerList

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

func (*PgBouncerAutoscalerList) DeepCopyInto 

func (in *PgBouncerAutoscalerList) DeepCopyInto(out *PgBouncerAutoscalerList)

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

func (*PgBouncerAutoscalerList) DeepCopyObject 

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

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

func (*PgBouncerAutoscalerList) Descriptor 

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

func (*PgBouncerAutoscalerList) Marshal 

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

func (*PgBouncerAutoscalerList) MarshalTo 

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

func (*PgBouncerAutoscalerList) MarshalToSizedBuffer 

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

func (*PgBouncerAutoscalerList) ProtoMessage 

func (*PgBouncerAutoscalerList) ProtoMessage()

func (*PgBouncerAutoscalerList) Reset 

func (m *PgBouncerAutoscalerList) Reset()

func (*PgBouncerAutoscalerList) Size 

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

func (*PgBouncerAutoscalerList) String 

func (this *PgBouncerAutoscalerList) String() string

func (*PgBouncerAutoscalerList) Unmarshal 

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

func (*PgBouncerAutoscalerList) XXX_DiscardUnknown 

func (m *PgBouncerAutoscalerList) XXX_DiscardUnknown()

func (*PgBouncerAutoscalerList) XXX_Marshal 

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

func (*PgBouncerAutoscalerList) XXX_Merge 

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

func (*PgBouncerAutoscalerList) XXX_Size 

func (m *PgBouncerAutoscalerList) XXX_Size() int

func (*PgBouncerAutoscalerList) XXX_Unmarshal 

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

type PgBouncerAutoscalerSpec 

type PgBouncerAutoscalerSpec struct {
	// scaleTargetRef points to the target resource to scale, and is used to the pods for which metrics
	// should be collected, as well as to actually change the replica count.
	ScaleTargetRef core.LocalObjectReference `json:"scaleTargetRef" protobuf:"bytes,1,opt,name=scaleTargetRef"`
	// minReplicas is the lower limit for the number of replicas to which the autoscaler
	// can scale down.  It defaults to 1 pod.  minReplicas is allowed to be 0 if the
	// alpha feature gate HPAScaleToZero is enabled and at least one Object or External
	// metric is configured.  Scaling is active as long as at least one metric value is
	// available.
	// +optional
	MinReplicas *int32 `json:"minReplicas,omitempty" protobuf:"varint,2,opt,name=minReplicas"`
	// maxReplicas is the upper limit for the number of replicas to which the autoscaler can scale up.
	// It cannot be less that minReplicas.
	MaxReplicas int32 `json:"maxReplicas" protobuf:"varint,3,opt,name=maxReplicas"`
	// metrics contains the specifications for which to use to calculate the
	// desired replica count (the maximum replica count across all metrics will
	// be used).  The desired replica count is calculated multiplying the
	// ratio between the target value and the current value by the current
	// number of pods.  Ergo, metrics used must decrease as the pod count is
	// increased, and vice-versa.  See the individual metric source types for
	// more information about how each type of metric must respond.
	// If not set, the default metric will be set to 80% average CPU utilization.
	// +optional
	Metrics []v2beta2.MetricSpec `json:"metrics,omitempty" protobuf:"bytes,4,rep,name=metrics"`

	// behavior configures the scaling behavior of the target
	// in both Up and Down directions (scaleUp and scaleDown fields respectively).
	// If not set, the default PgBouncerScalingRules for scale up and scale down are used.
	// +optional
	Behavior *PgBouncerAutoscalerBehavior `json:"behavior,omitempty" protobuf:"bytes,5,opt,name=behavior"`
}

PgBouncerAutoscalerSpec describes the desired functionality of the PgBouncerAutoscaler.

func (*PgBouncerAutoscalerSpec) DeepCopy 

func (in *PgBouncerAutoscalerSpec) DeepCopy() *PgBouncerAutoscalerSpec

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

func (*PgBouncerAutoscalerSpec) DeepCopyInto 

func (in *PgBouncerAutoscalerSpec) DeepCopyInto(out *PgBouncerAutoscalerSpec)

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

func (*PgBouncerAutoscalerSpec) Descriptor 

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

func (*PgBouncerAutoscalerSpec) Marshal 

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

func (*PgBouncerAutoscalerSpec) MarshalTo 

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

func (*PgBouncerAutoscalerSpec) MarshalToSizedBuffer 

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

func (*PgBouncerAutoscalerSpec) ProtoMessage 

func (*PgBouncerAutoscalerSpec) ProtoMessage()

func (*PgBouncerAutoscalerSpec) Reset 

func (m *PgBouncerAutoscalerSpec) Reset()

func (*PgBouncerAutoscalerSpec) Size 

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

func (*PgBouncerAutoscalerSpec) String 

func (this *PgBouncerAutoscalerSpec) String() string

func (*PgBouncerAutoscalerSpec) Unmarshal 

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

func (*PgBouncerAutoscalerSpec) XXX_DiscardUnknown 

func (m *PgBouncerAutoscalerSpec) XXX_DiscardUnknown()

func (*PgBouncerAutoscalerSpec) XXX_Marshal 

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

func (*PgBouncerAutoscalerSpec) XXX_Merge 

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

func (*PgBouncerAutoscalerSpec) XXX_Size 

func (m *PgBouncerAutoscalerSpec) XXX_Size() int

func (*PgBouncerAutoscalerSpec) XXX_Unmarshal 

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

type PgBouncerAutoscalerStatus 

type PgBouncerAutoscalerStatus struct {
	// observedGeneration is the most recent generation observed by this autoscaler.
	// +optional
	ObservedGeneration *int64 `json:"observedGeneration,omitempty" protobuf:"varint,1,opt,name=observedGeneration"`

	// lastScaleTime is the last time the PgBouncerAutoscaler scaled the number of pods,
	// used by the autoscaler to control how often the number of pods is changed.
	// +optional
	LastScaleTime *metav1.Time `json:"lastScaleTime,omitempty" protobuf:"bytes,2,opt,name=lastScaleTime"`

	// currentReplicas is current number of replicas of pods managed by this autoscaler,
	// as last seen by the autoscaler.
	CurrentReplicas int32 `json:"currentReplicas" protobuf:"varint,3,opt,name=currentReplicas"`

	// desiredReplicas is the desired number of replicas of pods managed by this autoscaler,
	// as last calculated by the autoscaler.
	DesiredReplicas int32 `json:"desiredReplicas" protobuf:"varint,4,opt,name=desiredReplicas"`

	// currentMetrics is the last read state of the metrics used by this autoscaler.
	// +optional
	CurrentMetrics []v2beta2.MetricStatus `json:"currentMetrics" protobuf:"bytes,5,rep,name=currentMetrics"`

	// conditions is the set of conditions required for this autoscaler to scale its target,
	// and indicates whether or not those conditions are met.
	Conditions []kmapi.Condition `json:"conditions" protobuf:"bytes,6,rep,name=conditions"`
}

PgBouncerAutoscalerStatus describes the current status of a horizontal pod autoscaler.

func (*PgBouncerAutoscalerStatus) DeepCopy 

func (in *PgBouncerAutoscalerStatus) DeepCopy() *PgBouncerAutoscalerStatus

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

func (*PgBouncerAutoscalerStatus) DeepCopyInto 

func (in *PgBouncerAutoscalerStatus) DeepCopyInto(out *PgBouncerAutoscalerStatus)

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

func (*PgBouncerAutoscalerStatus) Descriptor 

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

func (*PgBouncerAutoscalerStatus) Marshal 

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

func (*PgBouncerAutoscalerStatus) MarshalTo 

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

func (*PgBouncerAutoscalerStatus) MarshalToSizedBuffer 

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

func (*PgBouncerAutoscalerStatus) ProtoMessage 

func (*PgBouncerAutoscalerStatus) ProtoMessage()

func (*PgBouncerAutoscalerStatus) Reset 

func (m *PgBouncerAutoscalerStatus) Reset()

func (*PgBouncerAutoscalerStatus) Size 

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

func (*PgBouncerAutoscalerStatus) String 

func (this *PgBouncerAutoscalerStatus) String() string

func (*PgBouncerAutoscalerStatus) Unmarshal 

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

func (*PgBouncerAutoscalerStatus) XXX_DiscardUnknown 

func (m *PgBouncerAutoscalerStatus) XXX_DiscardUnknown()

func (*PgBouncerAutoscalerStatus) XXX_Marshal 

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

func (*PgBouncerAutoscalerStatus) XXX_Merge 

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

func (*PgBouncerAutoscalerStatus) XXX_Size 

func (m *PgBouncerAutoscalerStatus) XXX_Size() int

func (*PgBouncerAutoscalerStatus) XXX_Unmarshal 

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

type PgBouncerScalingPolicy 

type PgBouncerScalingPolicy struct {
	// Type is used to specify the scaling policy.
	Type v2beta2.HPAScalingPolicyType `json:"type" protobuf:"bytes,1,opt,name=type,casttype=HPAScalingPolicyType"`
	// Value contains the amount of change which is permitted by the policy.
	// It must be greater than zero
	Value int32 `json:"value" protobuf:"varint,2,opt,name=value"`
	// PeriodSeconds specifies the window of time for which the policy should hold true.
	// PeriodSeconds must be greater than zero and less than or equal to 1800 (30 min).
	PeriodSeconds int32 `json:"periodSeconds" protobuf:"varint,3,opt,name=periodSeconds"`
}

PgBouncerScalingPolicy is a single policy which must hold true for a specified past interval.

func (*PgBouncerScalingPolicy) DeepCopy 

func (in *PgBouncerScalingPolicy) DeepCopy() *PgBouncerScalingPolicy

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

func (*PgBouncerScalingPolicy) DeepCopyInto 

func (in *PgBouncerScalingPolicy) DeepCopyInto(out *PgBouncerScalingPolicy)

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

func (*PgBouncerScalingPolicy) Descriptor 

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

func (*PgBouncerScalingPolicy) Marshal 

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

func (*PgBouncerScalingPolicy) MarshalTo 

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

func (*PgBouncerScalingPolicy) MarshalToSizedBuffer 

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

func (*PgBouncerScalingPolicy) ProtoMessage 

func (*PgBouncerScalingPolicy) ProtoMessage()

func (*PgBouncerScalingPolicy) Reset 

func (m *PgBouncerScalingPolicy) Reset()

func (*PgBouncerScalingPolicy) Size 

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

func (*PgBouncerScalingPolicy) String 

func (this *PgBouncerScalingPolicy) String() string

func (*PgBouncerScalingPolicy) Unmarshal 

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

func (*PgBouncerScalingPolicy) XXX_DiscardUnknown 

func (m *PgBouncerScalingPolicy) XXX_DiscardUnknown()

func (*PgBouncerScalingPolicy) XXX_Marshal 

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

func (*PgBouncerScalingPolicy) XXX_Merge 

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

func (*PgBouncerScalingPolicy) XXX_Size 

func (m *PgBouncerScalingPolicy) XXX_Size() int

func (*PgBouncerScalingPolicy) XXX_Unmarshal 

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

type PgBouncerScalingRules 

type PgBouncerScalingRules struct {
	// StabilizationWindowSeconds is the number of seconds for which past recommendations should be
	// considered while scaling up or scaling down.
	// StabilizationWindowSeconds must be greater than or equal to zero and less than or equal to 3600 (one hour).
	// If not set, use the default values:
	// - For scale up: 0 (i.e. no stabilization is done).
	// - For scale down: 300 (i.e. the stabilization window is 300 seconds long).
	// +optional
	StabilizationWindowSeconds *int32 `json:"stabilizationWindowSeconds" protobuf:"varint,3,opt,name=stabilizationWindowSeconds"`
	// selectPolicy is used to specify which policy should be used.
	// If not set, the default value MaxPolicySelect is used.
	// +optional
	SelectPolicy *v2beta2.ScalingPolicySelect `json:"selectPolicy,omitempty" protobuf:"bytes,1,opt,name=selectPolicy"`
	// policies is a list of potential scaling polices which can be used during scaling.
	// At least one policy must be specified, otherwise the PgBouncerScalingRules will be discarded as invalid
	// +optional
	Policies []PgBouncerScalingPolicy `json:"policies,omitempty" protobuf:"bytes,2,rep,name=policies"`
}

PgBouncerScalingRules configures the scaling behavior for one direction. These Rules are applied after calculating DesiredReplicas from metrics for the HPA. They can limit the scaling velocity by specifying scaling policies. They can prevent flapping by specifying the stabilization window, so that the number of replicas is not set instantly, instead, the safest value from the stabilization window is chosen.

func (*PgBouncerScalingRules) DeepCopy 

func (in *PgBouncerScalingRules) DeepCopy() *PgBouncerScalingRules

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

func (*PgBouncerScalingRules) DeepCopyInto 

func (in *PgBouncerScalingRules) DeepCopyInto(out *PgBouncerScalingRules)

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

func (*PgBouncerScalingRules) Descriptor 

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

func (*PgBouncerScalingRules) Marshal 

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

func (*PgBouncerScalingRules) MarshalTo 

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

func (*PgBouncerScalingRules) MarshalToSizedBuffer 

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

func (*PgBouncerScalingRules) ProtoMessage 

func (*PgBouncerScalingRules) ProtoMessage()

func (*PgBouncerScalingRules) Reset 

func (m *PgBouncerScalingRules) Reset()

func (*PgBouncerScalingRules) Size 

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

func (*PgBouncerScalingRules) String 

func (this *PgBouncerScalingRules) String() string

func (*PgBouncerScalingRules) Unmarshal 

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

func (*PgBouncerScalingRules) XXX_DiscardUnknown 

func (m *PgBouncerScalingRules) XXX_DiscardUnknown()

func (*PgBouncerScalingRules) XXX_Marshal 

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

func (*PgBouncerScalingRules) XXX_Merge 

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

func (*PgBouncerScalingRules) XXX_Size 

func (m *PgBouncerScalingRules) XXX_Size() int

func (*PgBouncerScalingRules) XXX_Unmarshal 

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

type PostgresAutoscaler 

type PostgresAutoscaler struct {
	metav1.TypeMeta `json:",inline"`
	// metadata is the standard object metadata.
	// More info: https://git.k8s.io/community/contributors/devel/sig-architecture/api-conventions.md#metadata
	// +optional
	metav1.ObjectMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`

	// spec is the specification for the behaviour of the autoscaler.
	// More info: https://git.k8s.io/community/contributors/devel/sig-architecture/api-conventions.md#spec-and-status.
	// +optional
	Spec PostgresAutoscalerSpec `json:"spec,omitempty" protobuf:"bytes,2,opt,name=spec"`

	// status is the current information about the autoscaler.
	// +optional
	Status PostgresAutoscalerStatus `json:"status,omitempty" protobuf:"bytes,3,opt,name=status"`
}

+kubebuilder:object:root=true +kubebuilder:resource:path=postgresautoscalers,singular=postgresautoscaler,shortName=pgscaler,categories={datastore,kubedb,appscode} +kubebuilder:subresource:status

func (PostgresAutoscaler) CustomResourceDefinition 

func (_ PostgresAutoscaler) CustomResourceDefinition() *apiextensions.CustomResourceDefinition

func (*PostgresAutoscaler) DeepCopy 

func (in *PostgresAutoscaler) DeepCopy() *PostgresAutoscaler

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

func (*PostgresAutoscaler) DeepCopyInto 

func (in *PostgresAutoscaler) DeepCopyInto(out *PostgresAutoscaler)

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

func (*PostgresAutoscaler) DeepCopyObject 

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

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

func (*PostgresAutoscaler) Descriptor 

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

func (*PostgresAutoscaler) Marshal 

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

func (*PostgresAutoscaler) MarshalTo 

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

func (*PostgresAutoscaler) MarshalToSizedBuffer 

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

func (*PostgresAutoscaler) ProtoMessage 

func (*PostgresAutoscaler) ProtoMessage()

func (*PostgresAutoscaler) Reset 

func (m *PostgresAutoscaler) Reset()

func (PostgresAutoscaler) ResourceKind 

func (p PostgresAutoscaler) ResourceKind() string

func (PostgresAutoscaler) ResourcePlural 

func (p PostgresAutoscaler) ResourcePlural() string

func (PostgresAutoscaler) ResourceShortCode 

func (p PostgresAutoscaler) ResourceShortCode() string

func (PostgresAutoscaler) ResourceSingular 

func (p PostgresAutoscaler) ResourceSingular() string

func (*PostgresAutoscaler) Size 

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

func (*PostgresAutoscaler) String 

func (this *PostgresAutoscaler) String() string

func (*PostgresAutoscaler) Unmarshal 

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

func (PostgresAutoscaler) ValidateSpecs 

func (p PostgresAutoscaler) ValidateSpecs() error

func (*PostgresAutoscaler) XXX_DiscardUnknown 

func (m *PostgresAutoscaler) XXX_DiscardUnknown()

func (*PostgresAutoscaler) XXX_Marshal 

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

func (*PostgresAutoscaler) XXX_Merge 

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

func (*PostgresAutoscaler) XXX_Size 

func (m *PostgresAutoscaler) XXX_Size() int

func (*PostgresAutoscaler) XXX_Unmarshal 

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

type PostgresAutoscalerBehavior 

type PostgresAutoscalerBehavior struct {
	// scaleUp is scaling policy for scaling Up.
	// If not set, the default value is the higher of:
	//   * increase no more than 4 pods per 60 seconds
	//   * double the number of pods per 60 seconds
	// No stabilization is used.
	// +optional
	ScaleUp *PostgresScalingRules `json:"scaleUp,omitempty" protobuf:"bytes,1,opt,name=scaleUp"`
	// scaleDown is scaling policy for scaling Down.
	// If not set, the default value is to allow to scale down to minReplicas pods, with a
	// 300 second stabilization window (i.e., the highest recommendation for
	// the last 300sec is used).
	// +optional
	ScaleDown *PostgresScalingRules `json:"scaleDown,omitempty" protobuf:"bytes,2,opt,name=scaleDown"`
}

PostgresAutoscalerBehavior configures the scaling behavior of the target in both Up and Down directions (scaleUp and scaleDown fields respectively).

func (*PostgresAutoscalerBehavior) DeepCopy 

func (in *PostgresAutoscalerBehavior) DeepCopy() *PostgresAutoscalerBehavior

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

func (*PostgresAutoscalerBehavior) DeepCopyInto 

func (in *PostgresAutoscalerBehavior) DeepCopyInto(out *PostgresAutoscalerBehavior)

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

func (*PostgresAutoscalerBehavior) Descriptor 

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

func (*PostgresAutoscalerBehavior) Marshal 

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

func (*PostgresAutoscalerBehavior) MarshalTo 

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

func (*PostgresAutoscalerBehavior) MarshalToSizedBuffer 

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

func (*PostgresAutoscalerBehavior) ProtoMessage 

func (*PostgresAutoscalerBehavior) ProtoMessage()

func (*PostgresAutoscalerBehavior) Reset 

func (m *PostgresAutoscalerBehavior) Reset()

func (*PostgresAutoscalerBehavior) Size 

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

func (*PostgresAutoscalerBehavior) String 

func (this *PostgresAutoscalerBehavior) String() string

func (*PostgresAutoscalerBehavior) Unmarshal 

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

func (*PostgresAutoscalerBehavior) XXX_DiscardUnknown 

func (m *PostgresAutoscalerBehavior) XXX_DiscardUnknown()

func (*PostgresAutoscalerBehavior) XXX_Marshal 

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

func (*PostgresAutoscalerBehavior) XXX_Merge 

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

func (*PostgresAutoscalerBehavior) XXX_Size 

func (m *PostgresAutoscalerBehavior) XXX_Size() int

func (*PostgresAutoscalerBehavior) XXX_Unmarshal 

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

type PostgresAutoscalerList 

type PostgresAutoscalerList struct {
	metav1.TypeMeta `json:",inline"`
	// metadata is the standard list metadata.
	// +optional
	metav1.ListMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`

	// items is the list of horizontal pod autoscaler objects.
	Items []PostgresAutoscaler `json:"items" protobuf:"bytes,2,rep,name=items"`
}

PostgresAutoscalerList is a list of horizontal pod autoscaler objects.

func (*PostgresAutoscalerList) DeepCopy 

func (in *PostgresAutoscalerList) DeepCopy() *PostgresAutoscalerList

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

func (*PostgresAutoscalerList) DeepCopyInto 

func (in *PostgresAutoscalerList) DeepCopyInto(out *PostgresAutoscalerList)

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

func (*PostgresAutoscalerList) DeepCopyObject 

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

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

func (*PostgresAutoscalerList) Descriptor 

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

func (*PostgresAutoscalerList) Marshal 

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

func (*PostgresAutoscalerList) MarshalTo 

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

func (*PostgresAutoscalerList) MarshalToSizedBuffer 

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

func (*PostgresAutoscalerList) ProtoMessage 

func (*PostgresAutoscalerList) ProtoMessage()

func (*PostgresAutoscalerList) Reset 

func (m *PostgresAutoscalerList) Reset()

func (*PostgresAutoscalerList) Size 

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

func (*PostgresAutoscalerList) String 

func (this *PostgresAutoscalerList) String() string

func (*PostgresAutoscalerList) Unmarshal 

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

func (*PostgresAutoscalerList) XXX_DiscardUnknown 

func (m *PostgresAutoscalerList) XXX_DiscardUnknown()

func (*PostgresAutoscalerList) XXX_Marshal 

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

func (*PostgresAutoscalerList) XXX_Merge 

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

func (*PostgresAutoscalerList) XXX_Size 

func (m *PostgresAutoscalerList) XXX_Size() int

func (*PostgresAutoscalerList) XXX_Unmarshal 

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

type PostgresAutoscalerSpec 

type PostgresAutoscalerSpec struct {
	// scaleTargetRef points to the target resource to scale, and is used to the pods for which metrics
	// should be collected, as well as to actually change the replica count.
	ScaleTargetRef core.LocalObjectReference `json:"scaleTargetRef" protobuf:"bytes,1,opt,name=scaleTargetRef"`
	// minReplicas is the lower limit for the number of replicas to which the autoscaler
	// can scale down.  It defaults to 1 pod.  minReplicas is allowed to be 0 if the
	// alpha feature gate HPAScaleToZero is enabled and at least one Object or External
	// metric is configured.  Scaling is active as long as at least one metric value is
	// available.
	// +optional
	MinReplicas *int32 `json:"minReplicas,omitempty" protobuf:"varint,2,opt,name=minReplicas"`
	// maxReplicas is the upper limit for the number of replicas to which the autoscaler can scale up.
	// It cannot be less that minReplicas.
	MaxReplicas int32 `json:"maxReplicas" protobuf:"varint,3,opt,name=maxReplicas"`
	// metrics contains the specifications for which to use to calculate the
	// desired replica count (the maximum replica count across all metrics will
	// be used).  The desired replica count is calculated multiplying the
	// ratio between the target value and the current value by the current
	// number of pods.  Ergo, metrics used must decrease as the pod count is
	// increased, and vice-versa.  See the individual metric source types for
	// more information about how each type of metric must respond.
	// If not set, the default metric will be set to 80% average CPU utilization.
	// +optional
	Metrics []v2beta2.MetricSpec `json:"metrics,omitempty" protobuf:"bytes,4,rep,name=metrics"`

	// behavior configures the scaling behavior of the target
	// in both Up and Down directions (scaleUp and scaleDown fields respectively).
	// If not set, the default PostgresScalingRules for scale up and scale down are used.
	// +optional
	Behavior *PostgresAutoscalerBehavior `json:"behavior,omitempty" protobuf:"bytes,5,opt,name=behavior"`
}

PostgresAutoscalerSpec describes the desired functionality of the PostgresAutoscaler.

func (*PostgresAutoscalerSpec) DeepCopy 

func (in *PostgresAutoscalerSpec) DeepCopy() *PostgresAutoscalerSpec

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

func (*PostgresAutoscalerSpec) DeepCopyInto 

func (in *PostgresAutoscalerSpec) DeepCopyInto(out *PostgresAutoscalerSpec)

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

func (*PostgresAutoscalerSpec) Descriptor 

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

func (*PostgresAutoscalerSpec) Marshal 

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

func (*PostgresAutoscalerSpec) MarshalTo 

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

func (*PostgresAutoscalerSpec) MarshalToSizedBuffer 

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

func (*PostgresAutoscalerSpec) ProtoMessage 

func (*PostgresAutoscalerSpec) ProtoMessage()

func (*PostgresAutoscalerSpec) Reset 

func (m *PostgresAutoscalerSpec) Reset()

func (*PostgresAutoscalerSpec) Size 

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

func (*PostgresAutoscalerSpec) String 

func (this *PostgresAutoscalerSpec) String() string

func (*PostgresAutoscalerSpec) Unmarshal 

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

func (*PostgresAutoscalerSpec) XXX_DiscardUnknown 

func (m *PostgresAutoscalerSpec) XXX_DiscardUnknown()

func (*PostgresAutoscalerSpec) XXX_Marshal 

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

func (*PostgresAutoscalerSpec) XXX_Merge 

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

func (*PostgresAutoscalerSpec) XXX_Size 

func (m *PostgresAutoscalerSpec) XXX_Size() int

func (*PostgresAutoscalerSpec) XXX_Unmarshal 

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

type PostgresAutoscalerStatus 

type PostgresAutoscalerStatus struct {
	// observedGeneration is the most recent generation observed by this autoscaler.
	// +optional
	ObservedGeneration *int64 `json:"observedGeneration,omitempty" protobuf:"varint,1,opt,name=observedGeneration"`

	// lastScaleTime is the last time the PostgresAutoscaler scaled the number of pods,
	// used by the autoscaler to control how often the number of pods is changed.
	// +optional
	LastScaleTime *metav1.Time `json:"lastScaleTime,omitempty" protobuf:"bytes,2,opt,name=lastScaleTime"`

	// currentReplicas is current number of replicas of pods managed by this autoscaler,
	// as last seen by the autoscaler.
	CurrentReplicas int32 `json:"currentReplicas" protobuf:"varint,3,opt,name=currentReplicas"`

	// desiredReplicas is the desired number of replicas of pods managed by this autoscaler,
	// as last calculated by the autoscaler.
	DesiredReplicas int32 `json:"desiredReplicas" protobuf:"varint,4,opt,name=desiredReplicas"`

	// currentMetrics is the last read state of the metrics used by this autoscaler.
	// +optional
	CurrentMetrics []v2beta2.MetricStatus `json:"currentMetrics" protobuf:"bytes,5,rep,name=currentMetrics"`

	// conditions is the set of conditions required for this autoscaler to scale its target,
	// and indicates whether or not those conditions are met.
	Conditions []kmapi.Condition `json:"conditions" protobuf:"bytes,6,rep,name=conditions"`
}

PostgresAutoscalerStatus describes the current status of a horizontal pod autoscaler.

func (*PostgresAutoscalerStatus) DeepCopy 

func (in *PostgresAutoscalerStatus) DeepCopy() *PostgresAutoscalerStatus

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

func (*PostgresAutoscalerStatus) DeepCopyInto 

func (in *PostgresAutoscalerStatus) DeepCopyInto(out *PostgresAutoscalerStatus)

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

func (*PostgresAutoscalerStatus) Descriptor 

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

func (*PostgresAutoscalerStatus) Marshal 

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

func (*PostgresAutoscalerStatus) MarshalTo 

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

func (*PostgresAutoscalerStatus) MarshalToSizedBuffer 

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

func (*PostgresAutoscalerStatus) ProtoMessage 

func (*PostgresAutoscalerStatus) ProtoMessage()

func (*PostgresAutoscalerStatus) Reset 

func (m *PostgresAutoscalerStatus) Reset()

func (*PostgresAutoscalerStatus) Size 

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

func (*PostgresAutoscalerStatus) String 

func (this *PostgresAutoscalerStatus) String() string

func (*PostgresAutoscalerStatus) Unmarshal 

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

func (*PostgresAutoscalerStatus) XXX_DiscardUnknown 

func (m *PostgresAutoscalerStatus) XXX_DiscardUnknown()

func (*PostgresAutoscalerStatus) XXX_Marshal 

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

func (*PostgresAutoscalerStatus) XXX_Merge 

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

func (*PostgresAutoscalerStatus) XXX_Size 

func (m *PostgresAutoscalerStatus) XXX_Size() int

func (*PostgresAutoscalerStatus) XXX_Unmarshal 

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

type PostgresScalingPolicy 

type PostgresScalingPolicy struct {
	// Type is used to specify the scaling policy.
	Type v2beta2.HPAScalingPolicyType `json:"type" protobuf:"bytes,1,opt,name=type,casttype=HPAScalingPolicyType"`
	// Value contains the amount of change which is permitted by the policy.
	// It must be greater than zero
	Value int32 `json:"value" protobuf:"varint,2,opt,name=value"`
	// PeriodSeconds specifies the window of time for which the policy should hold true.
	// PeriodSeconds must be greater than zero and less than or equal to 1800 (30 min).
	PeriodSeconds int32 `json:"periodSeconds" protobuf:"varint,3,opt,name=periodSeconds"`
}

PostgresScalingPolicy is a single policy which must hold true for a specified past interval.

func (*PostgresScalingPolicy) DeepCopy 

func (in *PostgresScalingPolicy) DeepCopy() *PostgresScalingPolicy

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

func (*PostgresScalingPolicy) DeepCopyInto 

func (in *PostgresScalingPolicy) DeepCopyInto(out *PostgresScalingPolicy)

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

func (*PostgresScalingPolicy) Descriptor 

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

func (*PostgresScalingPolicy) Marshal 

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

func (*PostgresScalingPolicy) MarshalTo 

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

func (*PostgresScalingPolicy) MarshalToSizedBuffer 

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

func (*PostgresScalingPolicy) ProtoMessage 

func (*PostgresScalingPolicy) ProtoMessage()

func (*PostgresScalingPolicy) Reset 

func (m *PostgresScalingPolicy) Reset()

func (*PostgresScalingPolicy) Size 

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

func (*PostgresScalingPolicy) String 

func (this *PostgresScalingPolicy) String() string

func (*PostgresScalingPolicy) Unmarshal 

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

func (*PostgresScalingPolicy) XXX_DiscardUnknown 

func (m *PostgresScalingPolicy) XXX_DiscardUnknown()

func (*PostgresScalingPolicy) XXX_Marshal 

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

func (*PostgresScalingPolicy) XXX_Merge 

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

func (*PostgresScalingPolicy) XXX_Size 

func (m *PostgresScalingPolicy) XXX_Size() int

func (*PostgresScalingPolicy) XXX_Unmarshal 

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

type PostgresScalingRules 

type PostgresScalingRules struct {
	// StabilizationWindowSeconds is the number of seconds for which past recommendations should be
	// considered while scaling up or scaling down.
	// StabilizationWindowSeconds must be greater than or equal to zero and less than or equal to 3600 (one hour).
	// If not set, use the default values:
	// - For scale up: 0 (i.e. no stabilization is done).
	// - For scale down: 300 (i.e. the stabilization window is 300 seconds long).
	// +optional
	StabilizationWindowSeconds *int32 `json:"stabilizationWindowSeconds" protobuf:"varint,3,opt,name=stabilizationWindowSeconds"`
	// selectPolicy is used to specify which policy should be used.
	// If not set, the default value MaxPolicySelect is used.
	// +optional
	SelectPolicy *v2beta2.ScalingPolicySelect `json:"selectPolicy,omitempty" protobuf:"bytes,1,opt,name=selectPolicy"`
	// policies is a list of potential scaling polices which can be used during scaling.
	// At least one policy must be specified, otherwise the PostgresScalingRules will be discarded as invalid
	// +optional
	Policies []PostgresScalingPolicy `json:"policies,omitempty" protobuf:"bytes,2,rep,name=policies"`
}

PostgresScalingRules configures the scaling behavior for one direction. These Rules are applied after calculating DesiredReplicas from metrics for the HPA. They can limit the scaling velocity by specifying scaling policies. They can prevent flapping by specifying the stabilization window, so that the number of replicas is not set instantly, instead, the safest value from the stabilization window is chosen.

func (*PostgresScalingRules) DeepCopy 

func (in *PostgresScalingRules) DeepCopy() *PostgresScalingRules

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

func (*PostgresScalingRules) DeepCopyInto 

func (in *PostgresScalingRules) DeepCopyInto(out *PostgresScalingRules)

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

func (*PostgresScalingRules) Descriptor 

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

func (*PostgresScalingRules) Marshal 

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

func (*PostgresScalingRules) MarshalTo 

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

func (*PostgresScalingRules) MarshalToSizedBuffer 

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

func (*PostgresScalingRules) ProtoMessage 

func (*PostgresScalingRules) ProtoMessage()

func (*PostgresScalingRules) Reset 

func (m *PostgresScalingRules) Reset()

func (*PostgresScalingRules) Size 

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

func (*PostgresScalingRules) String 

func (this *PostgresScalingRules) String() string

func (*PostgresScalingRules) Unmarshal 

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

func (*PostgresScalingRules) XXX_DiscardUnknown 

func (m *PostgresScalingRules) XXX_DiscardUnknown()

func (*PostgresScalingRules) XXX_Marshal 

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

func (*PostgresScalingRules) XXX_Merge 

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

func (*PostgresScalingRules) XXX_Size 

func (m *PostgresScalingRules) XXX_Size() int

func (*PostgresScalingRules) XXX_Unmarshal 

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

type ProxySQLAutoscaler 

type ProxySQLAutoscaler struct {
	metav1.TypeMeta `json:",inline"`
	// metadata is the standard object metadata.
	// More info: https://git.k8s.io/community/contributors/devel/sig-architecture/api-conventions.md#metadata
	// +optional
	metav1.ObjectMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`

	// spec is the specification for the behaviour of the autoscaler.
	// More info: https://git.k8s.io/community/contributors/devel/sig-architecture/api-conventions.md#spec-and-status.
	// +optional
	Spec ProxySQLAutoscalerSpec `json:"spec,omitempty" protobuf:"bytes,2,opt,name=spec"`

	// status is the current information about the autoscaler.
	// +optional
	Status ProxySQLAutoscalerStatus `json:"status,omitempty" protobuf:"bytes,3,opt,name=status"`
}

+kubebuilder:object:root=true +kubebuilder:resource:path=proxysqlautoscalers,singular=proxysqlautoscaler,shortName=pxscaler,categories={datastore,kubedb,appscode} +kubebuilder:subresource:status

func (ProxySQLAutoscaler) CustomResourceDefinition 

func (_ ProxySQLAutoscaler) CustomResourceDefinition() *apiextensions.CustomResourceDefinition

func (*ProxySQLAutoscaler) DeepCopy 

func (in *ProxySQLAutoscaler) DeepCopy() *ProxySQLAutoscaler

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

func (*ProxySQLAutoscaler) DeepCopyInto 

func (in *ProxySQLAutoscaler) DeepCopyInto(out *ProxySQLAutoscaler)

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

func (*ProxySQLAutoscaler) DeepCopyObject 

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

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

func (*ProxySQLAutoscaler) Descriptor 

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

func (*ProxySQLAutoscaler) Marshal 

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

func (*ProxySQLAutoscaler) MarshalTo 

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

func (*ProxySQLAutoscaler) MarshalToSizedBuffer 

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

func (*ProxySQLAutoscaler) ProtoMessage 

func (*ProxySQLAutoscaler) ProtoMessage()

func (*ProxySQLAutoscaler) Reset 

func (m *ProxySQLAutoscaler) Reset()

func (ProxySQLAutoscaler) ResourceKind 

func (p ProxySQLAutoscaler) ResourceKind() string

func (ProxySQLAutoscaler) ResourcePlural 

func (p ProxySQLAutoscaler) ResourcePlural() string

func (ProxySQLAutoscaler) ResourceShortCode 

func (p ProxySQLAutoscaler) ResourceShortCode() string

func (ProxySQLAutoscaler) ResourceSingular 

func (p ProxySQLAutoscaler) ResourceSingular() string

func (*ProxySQLAutoscaler) Size 

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

func (*ProxySQLAutoscaler) String 

func (this *ProxySQLAutoscaler) String() string

func (*ProxySQLAutoscaler) Unmarshal 

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

func (*ProxySQLAutoscaler) XXX_DiscardUnknown 

func (m *ProxySQLAutoscaler) XXX_DiscardUnknown()

func (*ProxySQLAutoscaler) XXX_Marshal 

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

func (*ProxySQLAutoscaler) XXX_Merge 

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

func (*ProxySQLAutoscaler) XXX_Size 

func (m *ProxySQLAutoscaler) XXX_Size() int

func (*ProxySQLAutoscaler) XXX_Unmarshal 

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

type ProxySQLAutoscalerBehavior 

type ProxySQLAutoscalerBehavior struct {
	// scaleUp is scaling policy for scaling Up.
	// If not set, the default value is the higher of:
	//   * increase no more than 4 pods per 60 seconds
	//   * double the number of pods per 60 seconds
	// No stabilization is used.
	// +optional
	ScaleUp *ProxySQLScalingRules `json:"scaleUp,omitempty" protobuf:"bytes,1,opt,name=scaleUp"`
	// scaleDown is scaling policy for scaling Down.
	// If not set, the default value is to allow to scale down to minReplicas pods, with a
	// 300 second stabilization window (i.e., the highest recommendation for
	// the last 300sec is used).
	// +optional
	ScaleDown *ProxySQLScalingRules `json:"scaleDown,omitempty" protobuf:"bytes,2,opt,name=scaleDown"`
}

ProxySQLAutoscalerBehavior configures the scaling behavior of the target in both Up and Down directions (scaleUp and scaleDown fields respectively).

func (*ProxySQLAutoscalerBehavior) DeepCopy 

func (in *ProxySQLAutoscalerBehavior) DeepCopy() *ProxySQLAutoscalerBehavior

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

func (*ProxySQLAutoscalerBehavior) DeepCopyInto 

func (in *ProxySQLAutoscalerBehavior) DeepCopyInto(out *ProxySQLAutoscalerBehavior)

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

func (*ProxySQLAutoscalerBehavior) Descriptor 

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

func (*ProxySQLAutoscalerBehavior) Marshal 

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

func (*ProxySQLAutoscalerBehavior) MarshalTo 

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

func (*ProxySQLAutoscalerBehavior) MarshalToSizedBuffer 

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

func (*ProxySQLAutoscalerBehavior) ProtoMessage 

func (*ProxySQLAutoscalerBehavior) ProtoMessage()

func (*ProxySQLAutoscalerBehavior) Reset 

func (m *ProxySQLAutoscalerBehavior) Reset()

func (*ProxySQLAutoscalerBehavior) Size 

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

func (*ProxySQLAutoscalerBehavior) String 

func (this *ProxySQLAutoscalerBehavior) String() string

func (*ProxySQLAutoscalerBehavior) Unmarshal 

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

func (*ProxySQLAutoscalerBehavior) XXX_DiscardUnknown 

func (m *ProxySQLAutoscalerBehavior) XXX_DiscardUnknown()

func (*ProxySQLAutoscalerBehavior) XXX_Marshal 

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

func (*ProxySQLAutoscalerBehavior) XXX_Merge 

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

func (*ProxySQLAutoscalerBehavior) XXX_Size 

func (m *ProxySQLAutoscalerBehavior) XXX_Size() int

func (*ProxySQLAutoscalerBehavior) XXX_Unmarshal 

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

type ProxySQLAutoscalerList 

type ProxySQLAutoscalerList struct {
	metav1.TypeMeta `json:",inline"`
	// metadata is the standard list metadata.
	// +optional
	metav1.ListMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`

	// items is the list of horizontal pod autoscaler objects.
	Items []ProxySQLAutoscaler `json:"items" protobuf:"bytes,2,rep,name=items"`
}

ProxySQLAutoscalerList is a list of horizontal pod autoscaler objects.

func (*ProxySQLAutoscalerList) DeepCopy 

func (in *ProxySQLAutoscalerList) DeepCopy() *ProxySQLAutoscalerList

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

func (*ProxySQLAutoscalerList) DeepCopyInto 

func (in *ProxySQLAutoscalerList) DeepCopyInto(out *ProxySQLAutoscalerList)

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

func (*ProxySQLAutoscalerList) DeepCopyObject 

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

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

func (*ProxySQLAutoscalerList) Descriptor 

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

func (*ProxySQLAutoscalerList) Marshal 

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

func (*ProxySQLAutoscalerList) MarshalTo 

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

func (*ProxySQLAutoscalerList) MarshalToSizedBuffer 

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

func (*ProxySQLAutoscalerList) ProtoMessage 

func (*ProxySQLAutoscalerList) ProtoMessage()

func (*ProxySQLAutoscalerList) Reset 

func (m *ProxySQLAutoscalerList) Reset()

func (*ProxySQLAutoscalerList) Size 

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

func (*ProxySQLAutoscalerList) String 

func (this *ProxySQLAutoscalerList) String() string

func (*ProxySQLAutoscalerList) Unmarshal 

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

func (*ProxySQLAutoscalerList) XXX_DiscardUnknown 

func (m *ProxySQLAutoscalerList) XXX_DiscardUnknown()

func (*ProxySQLAutoscalerList) XXX_Marshal 

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

func (*ProxySQLAutoscalerList) XXX_Merge 

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

func (*ProxySQLAutoscalerList) XXX_Size 

func (m *ProxySQLAutoscalerList) XXX_Size() int

func (*ProxySQLAutoscalerList) XXX_Unmarshal 

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

type ProxySQLAutoscalerSpec 

type ProxySQLAutoscalerSpec struct {
	// scaleTargetRef points to the target resource to scale, and is used to the pods for which metrics
	// should be collected, as well as to actually change the replica count.
	ScaleTargetRef core.LocalObjectReference `json:"scaleTargetRef" protobuf:"bytes,1,opt,name=scaleTargetRef"`
	// minReplicas is the lower limit for the number of replicas to which the autoscaler
	// can scale down.  It defaults to 1 pod.  minReplicas is allowed to be 0 if the
	// alpha feature gate HPAScaleToZero is enabled and at least one Object or External
	// metric is configured.  Scaling is active as long as at least one metric value is
	// available.
	// +optional
	MinReplicas *int32 `json:"minReplicas,omitempty" protobuf:"varint,2,opt,name=minReplicas"`
	// maxReplicas is the upper limit for the number of replicas to which the autoscaler can scale up.
	// It cannot be less that minReplicas.
	MaxReplicas int32 `json:"maxReplicas" protobuf:"varint,3,opt,name=maxReplicas"`
	// metrics contains the specifications for which to use to calculate the
	// desired replica count (the maximum replica count across all metrics will
	// be used).  The desired replica count is calculated multiplying the
	// ratio between the target value and the current value by the current
	// number of pods.  Ergo, metrics used must decrease as the pod count is
	// increased, and vice-versa.  See the individual metric source types for
	// more information about how each type of metric must respond.
	// If not set, the default metric will be set to 80% average CPU utilization.
	// +optional
	Metrics []v2beta2.MetricSpec `json:"metrics,omitempty" protobuf:"bytes,4,rep,name=metrics"`

	// behavior configures the scaling behavior of the target
	// in both Up and Down directions (scaleUp and scaleDown fields respectively).
	// If not set, the default ProxySQLScalingRules for scale up and scale down are used.
	// +optional
	Behavior *ProxySQLAutoscalerBehavior `json:"behavior,omitempty" protobuf:"bytes,5,opt,name=behavior"`
}

ProxySQLAutoscalerSpec describes the desired functionality of the ProxySQLAutoscaler.

func (*ProxySQLAutoscalerSpec) DeepCopy 

func (in *ProxySQLAutoscalerSpec) DeepCopy() *ProxySQLAutoscalerSpec

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

func (*ProxySQLAutoscalerSpec) DeepCopyInto 

func (in *ProxySQLAutoscalerSpec) DeepCopyInto(out *ProxySQLAutoscalerSpec)

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

func (*ProxySQLAutoscalerSpec) Descriptor 

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

func (*ProxySQLAutoscalerSpec) Marshal 

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

func (*ProxySQLAutoscalerSpec) MarshalTo 

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

func (*ProxySQLAutoscalerSpec) MarshalToSizedBuffer 

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

func (*ProxySQLAutoscalerSpec) ProtoMessage 

func (*ProxySQLAutoscalerSpec) ProtoMessage()

func (*ProxySQLAutoscalerSpec) Reset 

func (m *ProxySQLAutoscalerSpec) Reset()

func (*ProxySQLAutoscalerSpec) Size 

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

func (*ProxySQLAutoscalerSpec) String 

func (this *ProxySQLAutoscalerSpec) String() string

func (*ProxySQLAutoscalerSpec) Unmarshal 

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

func (*ProxySQLAutoscalerSpec) XXX_DiscardUnknown 

func (m *ProxySQLAutoscalerSpec) XXX_DiscardUnknown()

func (*ProxySQLAutoscalerSpec) XXX_Marshal 

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

func (*ProxySQLAutoscalerSpec) XXX_Merge 

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

func (*ProxySQLAutoscalerSpec) XXX_Size 

func (m *ProxySQLAutoscalerSpec) XXX_Size() int

func (*ProxySQLAutoscalerSpec) XXX_Unmarshal 

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

type ProxySQLAutoscalerStatus 

type ProxySQLAutoscalerStatus struct {
	// observedGeneration is the most recent generation observed by this autoscaler.
	// +optional
	ObservedGeneration *int64 `json:"observedGeneration,omitempty" protobuf:"varint,1,opt,name=observedGeneration"`

	// lastScaleTime is the last time the ProxySQLAutoscaler scaled the number of pods,
	// used by the autoscaler to control how often the number of pods is changed.
	// +optional
	LastScaleTime *metav1.Time `json:"lastScaleTime,omitempty" protobuf:"bytes,2,opt,name=lastScaleTime"`

	// currentReplicas is current number of replicas of pods managed by this autoscaler,
	// as last seen by the autoscaler.
	CurrentReplicas int32 `json:"currentReplicas" protobuf:"varint,3,opt,name=currentReplicas"`

	// desiredReplicas is the desired number of replicas of pods managed by this autoscaler,
	// as last calculated by the autoscaler.
	DesiredReplicas int32 `json:"desiredReplicas" protobuf:"varint,4,opt,name=desiredReplicas"`

	// currentMetrics is the last read state of the metrics used by this autoscaler.
	// +optional
	CurrentMetrics []v2beta2.MetricStatus `json:"currentMetrics" protobuf:"bytes,5,rep,name=currentMetrics"`

	// conditions is the set of conditions required for this autoscaler to scale its target,
	// and indicates whether or not those conditions are met.
	Conditions []kmapi.Condition `json:"conditions" protobuf:"bytes,6,rep,name=conditions"`
}

ProxySQLAutoscalerStatus describes the current status of a horizontal pod autoscaler.

func (*ProxySQLAutoscalerStatus) DeepCopy 

func (in *ProxySQLAutoscalerStatus) DeepCopy() *ProxySQLAutoscalerStatus

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

func (*ProxySQLAutoscalerStatus) DeepCopyInto 

func (in *ProxySQLAutoscalerStatus) DeepCopyInto(out *ProxySQLAutoscalerStatus)

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

func (*ProxySQLAutoscalerStatus) Descriptor 

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

func (*ProxySQLAutoscalerStatus) Marshal 

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

func (*ProxySQLAutoscalerStatus) MarshalTo 

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

func (*ProxySQLAutoscalerStatus) MarshalToSizedBuffer 

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

func (*ProxySQLAutoscalerStatus) ProtoMessage 

func (*ProxySQLAutoscalerStatus) ProtoMessage()

func (*ProxySQLAutoscalerStatus) Reset 

func (m *ProxySQLAutoscalerStatus) Reset()

func (*ProxySQLAutoscalerStatus) Size 

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

func (*ProxySQLAutoscalerStatus) String 

func (this *ProxySQLAutoscalerStatus) String() string

func (*ProxySQLAutoscalerStatus) Unmarshal 

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

func (*ProxySQLAutoscalerStatus) XXX_DiscardUnknown 

func (m *ProxySQLAutoscalerStatus) XXX_DiscardUnknown()

func (*ProxySQLAutoscalerStatus) XXX_Marshal 

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

func (*ProxySQLAutoscalerStatus) XXX_Merge 

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

func (*ProxySQLAutoscalerStatus) XXX_Size 

func (m *ProxySQLAutoscalerStatus) XXX_Size() int

func (*ProxySQLAutoscalerStatus) XXX_Unmarshal 

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

type ProxySQLScalingPolicy 

type ProxySQLScalingPolicy struct {
	// Type is used to specify the scaling policy.
	Type v2beta2.HPAScalingPolicyType `json:"type" protobuf:"bytes,1,opt,name=type,casttype=HPAScalingPolicyType"`
	// Value contains the amount of change which is permitted by the policy.
	// It must be greater than zero
	Value int32 `json:"value" protobuf:"varint,2,opt,name=value"`
	// PeriodSeconds specifies the window of time for which the policy should hold true.
	// PeriodSeconds must be greater than zero and less than or equal to 1800 (30 min).
	PeriodSeconds int32 `json:"periodSeconds" protobuf:"varint,3,opt,name=periodSeconds"`
}

ProxySQLScalingPolicy is a single policy which must hold true for a specified past interval.

func (*ProxySQLScalingPolicy) DeepCopy 

func (in *ProxySQLScalingPolicy) DeepCopy() *ProxySQLScalingPolicy

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

func (*ProxySQLScalingPolicy) DeepCopyInto 

func (in *ProxySQLScalingPolicy) DeepCopyInto(out *ProxySQLScalingPolicy)

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

func (*ProxySQLScalingPolicy) Descriptor 

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

func (*ProxySQLScalingPolicy) Marshal 

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

func (*ProxySQLScalingPolicy) MarshalTo 

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

func (*ProxySQLScalingPolicy) MarshalToSizedBuffer 

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

func (*ProxySQLScalingPolicy) ProtoMessage 

func (*ProxySQLScalingPolicy) ProtoMessage()

func (*ProxySQLScalingPolicy) Reset 

func (m *ProxySQLScalingPolicy) Reset()

func (*ProxySQLScalingPolicy) Size 

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

func (*ProxySQLScalingPolicy) String 

func (this *ProxySQLScalingPolicy) String() string

func (*ProxySQLScalingPolicy) Unmarshal 

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

func (*ProxySQLScalingPolicy) XXX_DiscardUnknown 

func (m *ProxySQLScalingPolicy) XXX_DiscardUnknown()

func (*ProxySQLScalingPolicy) XXX_Marshal 

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

func (*ProxySQLScalingPolicy) XXX_Merge 

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

func (*ProxySQLScalingPolicy) XXX_Size 

func (m *ProxySQLScalingPolicy) XXX_Size() int

func (*ProxySQLScalingPolicy) XXX_Unmarshal 

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

type ProxySQLScalingRules 

type ProxySQLScalingRules struct {
	// StabilizationWindowSeconds is the number of seconds for which past recommendations should be
	// considered while scaling up or scaling down.
	// StabilizationWindowSeconds must be greater than or equal to zero and less than or equal to 3600 (one hour).
	// If not set, use the default values:
	// - For scale up: 0 (i.e. no stabilization is done).
	// - For scale down: 300 (i.e. the stabilization window is 300 seconds long).
	// +optional
	StabilizationWindowSeconds *int32 `json:"stabilizationWindowSeconds" protobuf:"varint,3,opt,name=stabilizationWindowSeconds"`
	// selectPolicy is used to specify which policy should be used.
	// If not set, the default value MaxPolicySelect is used.
	// +optional
	SelectPolicy *v2beta2.ScalingPolicySelect `json:"selectPolicy,omitempty" protobuf:"bytes,1,opt,name=selectPolicy"`
	// policies is a list of potential scaling polices which can be used during scaling.
	// At least one policy must be specified, otherwise the ProxySQLScalingRules will be discarded as invalid
	// +optional
	Policies []ProxySQLScalingPolicy `json:"policies,omitempty" protobuf:"bytes,2,rep,name=policies"`
}

ProxySQLScalingRules configures the scaling behavior for one direction. These Rules are applied after calculating DesiredReplicas from metrics for the HPA. They can limit the scaling velocity by specifying scaling policies. They can prevent flapping by specifying the stabilization window, so that the number of replicas is not set instantly, instead, the safest value from the stabilization window is chosen.

func (*ProxySQLScalingRules) DeepCopy 

func (in *ProxySQLScalingRules) DeepCopy() *ProxySQLScalingRules

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

func (*ProxySQLScalingRules) DeepCopyInto 

func (in *ProxySQLScalingRules) DeepCopyInto(out *ProxySQLScalingRules)

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

func (*ProxySQLScalingRules) Descriptor 

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

func (*ProxySQLScalingRules) Marshal 

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

func (*ProxySQLScalingRules) MarshalTo 

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

func (*ProxySQLScalingRules) MarshalToSizedBuffer 

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

func (*ProxySQLScalingRules) ProtoMessage 

func (*ProxySQLScalingRules) ProtoMessage()

func (*ProxySQLScalingRules) Reset 

func (m *ProxySQLScalingRules) Reset()

func (*ProxySQLScalingRules) Size 

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

func (*ProxySQLScalingRules) String 

func (this *ProxySQLScalingRules) String() string

func (*ProxySQLScalingRules) Unmarshal 

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

func (*ProxySQLScalingRules) XXX_DiscardUnknown 

func (m *ProxySQLScalingRules) XXX_DiscardUnknown()

func (*ProxySQLScalingRules) XXX_Marshal 

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

func (*ProxySQLScalingRules) XXX_Merge 

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

func (*ProxySQLScalingRules) XXX_Size 

func (m *ProxySQLScalingRules) XXX_Size() int

func (*ProxySQLScalingRules) XXX_Unmarshal 

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

type RedisAutoscaler 

type RedisAutoscaler struct {
	metav1.TypeMeta `json:",inline"`
	// metadata is the standard object metadata.
	// More info: https://git.k8s.io/community/contributors/devel/sig-architecture/api-conventions.md#metadata
	// +optional
	metav1.ObjectMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`

	// spec is the specification for the behaviour of the autoscaler.
	// More info: https://git.k8s.io/community/contributors/devel/sig-architecture/api-conventions.md#spec-and-status.
	// +optional
	Spec RedisAutoscalerSpec `json:"spec,omitempty" protobuf:"bytes,2,opt,name=spec"`

	// status is the current information about the autoscaler.
	// +optional
	Status RedisAutoscalerStatus `json:"status,omitempty" protobuf:"bytes,3,opt,name=status"`
}

+kubebuilder:object:root=true +kubebuilder:resource:path=redisautoscalers,singular=redisautoscaler,shortName=rdscaler,categories={datastore,kubedb,appscode} +kubebuilder:subresource:status

func (RedisAutoscaler) CustomResourceDefinition 

func (_ RedisAutoscaler) CustomResourceDefinition() *apiextensions.CustomResourceDefinition

func (*RedisAutoscaler) DeepCopy 

func (in *RedisAutoscaler) DeepCopy() *RedisAutoscaler

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

func (*RedisAutoscaler) DeepCopyInto 

func (in *RedisAutoscaler) DeepCopyInto(out *RedisAutoscaler)

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

func (*RedisAutoscaler) DeepCopyObject 

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

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

func (*RedisAutoscaler) Descriptor 

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

func (*RedisAutoscaler) Marshal 

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

func (*RedisAutoscaler) MarshalTo 

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

func (*RedisAutoscaler) MarshalToSizedBuffer 

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

func (*RedisAutoscaler) ProtoMessage 

func (*RedisAutoscaler) ProtoMessage()

func (*RedisAutoscaler) Reset 

func (m *RedisAutoscaler) Reset()

func (RedisAutoscaler) ResourceKind 

func (r RedisAutoscaler) ResourceKind() string

func (RedisAutoscaler) ResourcePlural 

func (r RedisAutoscaler) ResourcePlural() string

func (RedisAutoscaler) ResourceShortCode 

func (r RedisAutoscaler) ResourceShortCode() string

func (RedisAutoscaler) ResourceSingular 

func (r RedisAutoscaler) ResourceSingular() string

func (*RedisAutoscaler) Size 

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

func (*RedisAutoscaler) String 

func (this *RedisAutoscaler) String() string

func (*RedisAutoscaler) Unmarshal 

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

func (RedisAutoscaler) ValidateSpecs 

func (r RedisAutoscaler) ValidateSpecs() error

func (*RedisAutoscaler) XXX_DiscardUnknown 

func (m *RedisAutoscaler) XXX_DiscardUnknown()

func (*RedisAutoscaler) XXX_Marshal 

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

func (*RedisAutoscaler) XXX_Merge 

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

func (*RedisAutoscaler) XXX_Size 

func (m *RedisAutoscaler) XXX_Size() int

func (*RedisAutoscaler) XXX_Unmarshal 

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

type RedisAutoscalerBehavior 

type RedisAutoscalerBehavior struct {
	// scaleUp is scaling policy for scaling Up.
	// If not set, the default value is the higher of:
	//   * increase no more than 4 pods per 60 seconds
	//   * double the number of pods per 60 seconds
	// No stabilization is used.
	// +optional
	ScaleUp *RedisScalingRules `json:"scaleUp,omitempty" protobuf:"bytes,1,opt,name=scaleUp"`
	// scaleDown is scaling policy for scaling Down.
	// If not set, the default value is to allow to scale down to minReplicas pods, with a
	// 300 second stabilization window (i.e., the highest recommendation for
	// the last 300sec is used).
	// +optional
	ScaleDown *RedisScalingRules `json:"scaleDown,omitempty" protobuf:"bytes,2,opt,name=scaleDown"`
}

RedisAutoscalerBehavior configures the scaling behavior of the target in both Up and Down directions (scaleUp and scaleDown fields respectively).

func (*RedisAutoscalerBehavior) DeepCopy 

func (in *RedisAutoscalerBehavior) DeepCopy() *RedisAutoscalerBehavior

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

func (*RedisAutoscalerBehavior) DeepCopyInto 

func (in *RedisAutoscalerBehavior) DeepCopyInto(out *RedisAutoscalerBehavior)

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

func (*RedisAutoscalerBehavior) Descriptor 

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

func (*RedisAutoscalerBehavior) Marshal 

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

func (*RedisAutoscalerBehavior) MarshalTo 

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

func (*RedisAutoscalerBehavior) MarshalToSizedBuffer 

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

func (*RedisAutoscalerBehavior) ProtoMessage 

func (*RedisAutoscalerBehavior) ProtoMessage()

func (*RedisAutoscalerBehavior) Reset 

func (m *RedisAutoscalerBehavior) Reset()

func (*RedisAutoscalerBehavior) Size 

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

func (*RedisAutoscalerBehavior) String 

func (this *RedisAutoscalerBehavior) String() string

func (*RedisAutoscalerBehavior) Unmarshal 

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

func (*RedisAutoscalerBehavior) XXX_DiscardUnknown 

func (m *RedisAutoscalerBehavior) XXX_DiscardUnknown()

func (*RedisAutoscalerBehavior) XXX_Marshal 

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

func (*RedisAutoscalerBehavior) XXX_Merge 

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

func (*RedisAutoscalerBehavior) XXX_Size 

func (m *RedisAutoscalerBehavior) XXX_Size() int

func (*RedisAutoscalerBehavior) XXX_Unmarshal 

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

type RedisAutoscalerList 

type RedisAutoscalerList struct {
	metav1.TypeMeta `json:",inline"`
	// metadata is the standard list metadata.
	// +optional
	metav1.ListMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`

	// items is the list of horizontal pod autoscaler objects.
	Items []RedisAutoscaler `json:"items" protobuf:"bytes,2,rep,name=items"`
}

RedisAutoscalerList is a list of horizontal pod autoscaler objects.

func (*RedisAutoscalerList) DeepCopy 

func (in *RedisAutoscalerList) DeepCopy() *RedisAutoscalerList

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

func (*RedisAutoscalerList) DeepCopyInto 

func (in *RedisAutoscalerList) DeepCopyInto(out *RedisAutoscalerList)

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

func (*RedisAutoscalerList) DeepCopyObject 

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

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

func (*RedisAutoscalerList) Descriptor 

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

func (*RedisAutoscalerList) Marshal 

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

func (*RedisAutoscalerList) MarshalTo 

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

func (*RedisAutoscalerList) MarshalToSizedBuffer 

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

func (*RedisAutoscalerList) ProtoMessage 

func (*RedisAutoscalerList) ProtoMessage()

func (*RedisAutoscalerList) Reset 

func (m *RedisAutoscalerList) Reset()

func (*RedisAutoscalerList) Size 

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

func (*RedisAutoscalerList) String 

func (this *RedisAutoscalerList) String() string

func (*RedisAutoscalerList) Unmarshal 

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

func (*RedisAutoscalerList) XXX_DiscardUnknown 

func (m *RedisAutoscalerList) XXX_DiscardUnknown()

func (*RedisAutoscalerList) XXX_Marshal 

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

func (*RedisAutoscalerList) XXX_Merge 

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

func (*RedisAutoscalerList) XXX_Size 

func (m *RedisAutoscalerList) XXX_Size() int

func (*RedisAutoscalerList) XXX_Unmarshal 

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

type RedisAutoscalerSpec 

type RedisAutoscalerSpec struct {
	// scaleTargetRef points to the target resource to scale, and is used to the pods for which metrics
	// should be collected, as well as to actually change the replica count.
	ScaleTargetRef core.LocalObjectReference `json:"scaleTargetRef" protobuf:"bytes,1,opt,name=scaleTargetRef"`
	// minReplicas is the lower limit for the number of replicas to which the autoscaler
	// can scale down.  It defaults to 1 pod.  minReplicas is allowed to be 0 if the
	// alpha feature gate HPAScaleToZero is enabled and at least one Object or External
	// metric is configured.  Scaling is active as long as at least one metric value is
	// available.
	// +optional
	MinReplicas *int32 `json:"minReplicas,omitempty" protobuf:"varint,2,opt,name=minReplicas"`
	// maxReplicas is the upper limit for the number of replicas to which the autoscaler can scale up.
	// It cannot be less that minReplicas.
	MaxReplicas int32 `json:"maxReplicas" protobuf:"varint,3,opt,name=maxReplicas"`
	// metrics contains the specifications for which to use to calculate the
	// desired replica count (the maximum replica count across all metrics will
	// be used).  The desired replica count is calculated multiplying the
	// ratio between the target value and the current value by the current
	// number of pods.  Ergo, metrics used must decrease as the pod count is
	// increased, and vice-versa.  See the individual metric source types for
	// more information about how each type of metric must respond.
	// If not set, the default metric will be set to 80% average CPU utilization.
	// +optional
	Metrics []v2beta2.MetricSpec `json:"metrics,omitempty" protobuf:"bytes,4,rep,name=metrics"`

	// behavior configures the scaling behavior of the target
	// in both Up and Down directions (scaleUp and scaleDown fields respectively).
	// If not set, the default RedisScalingRules for scale up and scale down are used.
	// +optional
	Behavior *RedisAutoscalerBehavior `json:"behavior,omitempty" protobuf:"bytes,5,opt,name=behavior"`
}

RedisAutoscalerSpec describes the desired functionality of the RedisAutoscaler.

func (*RedisAutoscalerSpec) DeepCopy 

func (in *RedisAutoscalerSpec) DeepCopy() *RedisAutoscalerSpec

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

func (*RedisAutoscalerSpec) DeepCopyInto 

func (in *RedisAutoscalerSpec) DeepCopyInto(out *RedisAutoscalerSpec)

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

func (*RedisAutoscalerSpec) Descriptor 

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

func (*RedisAutoscalerSpec) Marshal 

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

func (*RedisAutoscalerSpec) MarshalTo 

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

func (*RedisAutoscalerSpec) MarshalToSizedBuffer 

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

func (*RedisAutoscalerSpec) ProtoMessage 

func (*RedisAutoscalerSpec) ProtoMessage()

func (*RedisAutoscalerSpec) Reset 

func (m *RedisAutoscalerSpec) Reset()

func (*RedisAutoscalerSpec) Size 

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

func (*RedisAutoscalerSpec) String 

func (this *RedisAutoscalerSpec) String() string

func (*RedisAutoscalerSpec) Unmarshal 

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

func (*RedisAutoscalerSpec) XXX_DiscardUnknown 

func (m *RedisAutoscalerSpec) XXX_DiscardUnknown()

func (*RedisAutoscalerSpec) XXX_Marshal 

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

func (*RedisAutoscalerSpec) XXX_Merge 

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

func (*RedisAutoscalerSpec) XXX_Size 

func (m *RedisAutoscalerSpec) XXX_Size() int

func (*RedisAutoscalerSpec) XXX_Unmarshal 

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

type RedisAutoscalerStatus 

type RedisAutoscalerStatus struct {
	// observedGeneration is the most recent generation observed by this autoscaler.
	// +optional
	ObservedGeneration *int64 `json:"observedGeneration,omitempty" protobuf:"varint,1,opt,name=observedGeneration"`

	// lastScaleTime is the last time the RedisAutoscaler scaled the number of pods,
	// used by the autoscaler to control how often the number of pods is changed.
	// +optional
	LastScaleTime *metav1.Time `json:"lastScaleTime,omitempty" protobuf:"bytes,2,opt,name=lastScaleTime"`

	// currentReplicas is current number of replicas of pods managed by this autoscaler,
	// as last seen by the autoscaler.
	CurrentReplicas int32 `json:"currentReplicas" protobuf:"varint,3,opt,name=currentReplicas"`

	// desiredReplicas is the desired number of replicas of pods managed by this autoscaler,
	// as last calculated by the autoscaler.
	DesiredReplicas int32 `json:"desiredReplicas" protobuf:"varint,4,opt,name=desiredReplicas"`

	// currentMetrics is the last read state of the metrics used by this autoscaler.
	// +optional
	CurrentMetrics []v2beta2.MetricStatus `json:"currentMetrics" protobuf:"bytes,5,rep,name=currentMetrics"`

	// conditions is the set of conditions required for this autoscaler to scale its target,
	// and indicates whether or not those conditions are met.
	Conditions []kmapi.Condition `json:"conditions" protobuf:"bytes,6,rep,name=conditions"`
}

RedisAutoscalerStatus describes the current status of a horizontal pod autoscaler.

func (*RedisAutoscalerStatus) DeepCopy 

func (in *RedisAutoscalerStatus) DeepCopy() *RedisAutoscalerStatus

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

func (*RedisAutoscalerStatus) DeepCopyInto 

func (in *RedisAutoscalerStatus) DeepCopyInto(out *RedisAutoscalerStatus)

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

func (*RedisAutoscalerStatus) Descriptor 

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

func (*RedisAutoscalerStatus) Marshal 

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

func (*RedisAutoscalerStatus) MarshalTo 

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

func (*RedisAutoscalerStatus) MarshalToSizedBuffer 

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

func (*RedisAutoscalerStatus) ProtoMessage 

func (*RedisAutoscalerStatus) ProtoMessage()

func (*RedisAutoscalerStatus) Reset 

func (m *RedisAutoscalerStatus) Reset()

func (*RedisAutoscalerStatus) Size 

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

func (*RedisAutoscalerStatus) String 

func (this *RedisAutoscalerStatus) String() string

func (*RedisAutoscalerStatus) Unmarshal 

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

func (*RedisAutoscalerStatus) XXX_DiscardUnknown 

func (m *RedisAutoscalerStatus) XXX_DiscardUnknown()

func (*RedisAutoscalerStatus) XXX_Marshal 

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

func (*RedisAutoscalerStatus) XXX_Merge 

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

func (*RedisAutoscalerStatus) XXX_Size 

func (m *RedisAutoscalerStatus) XXX_Size() int

func (*RedisAutoscalerStatus) XXX_Unmarshal 

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

type RedisScalingPolicy 

type RedisScalingPolicy struct {
	// Type is used to specify the scaling policy.
	Type v2beta2.HPAScalingPolicyType `json:"type" protobuf:"bytes,1,opt,name=type,casttype=HPAScalingPolicyType"`
	// Value contains the amount of change which is permitted by the policy.
	// It must be greater than zero
	Value int32 `json:"value" protobuf:"varint,2,opt,name=value"`
	// PeriodSeconds specifies the window of time for which the policy should hold true.
	// PeriodSeconds must be greater than zero and less than or equal to 1800 (30 min).
	PeriodSeconds int32 `json:"periodSeconds" protobuf:"varint,3,opt,name=periodSeconds"`
}

RedisScalingPolicy is a single policy which must hold true for a specified past interval.

func (*RedisScalingPolicy) DeepCopy 

func (in *RedisScalingPolicy) DeepCopy() *RedisScalingPolicy

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

func (*RedisScalingPolicy) DeepCopyInto 

func (in *RedisScalingPolicy) DeepCopyInto(out *RedisScalingPolicy)

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

func (*RedisScalingPolicy) Descriptor 

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

func (*RedisScalingPolicy) Marshal 

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

func (*RedisScalingPolicy) MarshalTo 

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

func (*RedisScalingPolicy) MarshalToSizedBuffer 

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

func (*RedisScalingPolicy) ProtoMessage 

func (*RedisScalingPolicy) ProtoMessage()

func (*RedisScalingPolicy) Reset 

func (m *RedisScalingPolicy) Reset()

func (*RedisScalingPolicy) Size 

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

func (*RedisScalingPolicy) String 

func (this *RedisScalingPolicy) String() string

func (*RedisScalingPolicy) Unmarshal 

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

func (*RedisScalingPolicy) XXX_DiscardUnknown 

func (m *RedisScalingPolicy) XXX_DiscardUnknown()

func (*RedisScalingPolicy) XXX_Marshal 

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

func (*RedisScalingPolicy) XXX_Merge 

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

func (*RedisScalingPolicy) XXX_Size 

func (m *RedisScalingPolicy) XXX_Size() int

func (*RedisScalingPolicy) XXX_Unmarshal 

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

type RedisScalingRules 

type RedisScalingRules struct {
	// StabilizationWindowSeconds is the number of seconds for which past recommendations should be
	// considered while scaling up or scaling down.
	// StabilizationWindowSeconds must be greater than or equal to zero and less than or equal to 3600 (one hour).
	// If not set, use the default values:
	// - For scale up: 0 (i.e. no stabilization is done).
	// - For scale down: 300 (i.e. the stabilization window is 300 seconds long).
	// +optional
	StabilizationWindowSeconds *int32 `json:"stabilizationWindowSeconds" protobuf:"varint,3,opt,name=stabilizationWindowSeconds"`
	// selectPolicy is used to specify which policy should be used.
	// If not set, the default value MaxPolicySelect is used.
	// +optional
	SelectPolicy *v2beta2.ScalingPolicySelect `json:"selectPolicy,omitempty" protobuf:"bytes,1,opt,name=selectPolicy"`
	// policies is a list of potential scaling polices which can be used during scaling.
	// At least one policy must be specified, otherwise the RedisScalingRules will be discarded as invalid
	// +optional
	Policies []RedisScalingPolicy `json:"policies,omitempty" protobuf:"bytes,2,rep,name=policies"`
}

RedisScalingRules configures the scaling behavior for one direction. These Rules are applied after calculating DesiredReplicas from metrics for the HPA. They can limit the scaling velocity by specifying scaling policies. They can prevent flapping by specifying the stabilization window, so that the number of replicas is not set instantly, instead, the safest value from the stabilization window is chosen.

func (*RedisScalingRules) DeepCopy 

func (in *RedisScalingRules) DeepCopy() *RedisScalingRules

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new RedisScalingRules.

func (*RedisScalingRules) DeepCopyInto 

func (in *RedisScalingRules) DeepCopyInto(out *RedisScalingRules)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*RedisScalingRules) Descriptor 

func (*RedisScalingRules) Descriptor() ([]byte, []int)

func (*RedisScalingRules) Marshal 

func (m *RedisScalingRules) Marshal() (dAtA []byte, err error)

func (*RedisScalingRules) MarshalTo 

func (m *RedisScalingRules) MarshalTo(dAtA []byte) (int, error)

func (*RedisScalingRules) MarshalToSizedBuffer 

func (m *RedisScalingRules) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RedisScalingRules) ProtoMessage 

func (*RedisScalingRules) ProtoMessage()

func (*RedisScalingRules) Reset 

func (m *RedisScalingRules) Reset()

func (*RedisScalingRules) Size 

func (m *RedisScalingRules) Size() (n int)

func (*RedisScalingRules) String 

func (this *RedisScalingRules) String() string

func (*RedisScalingRules) Unmarshal 

func (m *RedisScalingRules) Unmarshal(dAtA []byte) error

func (*RedisScalingRules) XXX_DiscardUnknown 

func (m *RedisScalingRules) XXX_DiscardUnknown()

func (*RedisScalingRules) XXX_Marshal 

func (m *RedisScalingRules) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RedisScalingRules) XXX_Merge 

func (m *RedisScalingRules) XXX_Merge(src proto.Message)

func (*RedisScalingRules) XXX_Size 

func (m *RedisScalingRules) XXX_Size() int

func (*RedisScalingRules) XXX_Unmarshal 

func (m *RedisScalingRules) XXX_Unmarshal(b []byte) error

type UpgradeSpec 

type UpgradeSpec struct {
	// Specifies the target version name from catalog
	TargetVersion string `json:"targetVersion,omitempty" protobuf:"bytes,1,opt,name=targetVersion"`
}

func (*UpgradeSpec) DeepCopy 

func (in *UpgradeSpec) DeepCopy() *UpgradeSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new UpgradeSpec.

func (*UpgradeSpec) DeepCopyInto 

func (in *UpgradeSpec) DeepCopyInto(out *UpgradeSpec)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*UpgradeSpec) Descriptor 

func (*UpgradeSpec) Descriptor() ([]byte, []int)

func (*UpgradeSpec) Marshal 

func (m *UpgradeSpec) Marshal() (dAtA []byte, err error)

func (*UpgradeSpec) MarshalTo 

func (m *UpgradeSpec) MarshalTo(dAtA []byte) (int, error)

func (*UpgradeSpec) MarshalToSizedBuffer 

func (m *UpgradeSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*UpgradeSpec) ProtoMessage 

func (*UpgradeSpec) ProtoMessage()

func (*UpgradeSpec) Reset 

func (m *UpgradeSpec) Reset()

func (*UpgradeSpec) Size 

func (m *UpgradeSpec) Size() (n int)

func (*UpgradeSpec) String 

func (this *UpgradeSpec) String() string

func (*UpgradeSpec) Unmarshal 

func (m *UpgradeSpec) Unmarshal(dAtA []byte) error

func (*UpgradeSpec) XXX_DiscardUnknown 

func (m *UpgradeSpec) XXX_DiscardUnknown()

func (*UpgradeSpec) XXX_Marshal 

func (m *UpgradeSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UpgradeSpec) XXX_Merge 

func (m *UpgradeSpec) XXX_Merge(src proto.Message)

func (*UpgradeSpec) XXX_Size 

func (m *UpgradeSpec) XXX_Size() int

func (*UpgradeSpec) XXX_Unmarshal 

func (m *UpgradeSpec) XXX_Unmarshal(b []byte) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.