v1alpha1

Jun 9, 2020

Changes in this version

type AutoscalerSpec

+ PendingScaleDownDuration *metav1.Duration

+ PendingScaleUpDuration *metav1.Duration

type ConsumerSpec

+ NumPartitionsPerInstance *int32

type ConsumerStatus

+ Redundant *int32

Sep 25, 2019

Changes in this version

+ const ContainerScalingModeAuto

+ const ContainerScalingModeOff

+ type ContainerResourcePolicy struct

+ ContainerName string

+ MaxAllowed corev1.ResourceList

+ MinAllowed corev1.ResourceList

+ Mode *ContainerScalingMode

+ func (in *ContainerResourcePolicy) DeepCopy() *ContainerResourcePolicy

+ func (in *ContainerResourcePolicy) DeepCopyInto(out *ContainerResourcePolicy)

+ type ContainerScalingMode string

+ type GlobalResourcePolicy struct

+ MaxAllowed corev1.ResourceList

+ func (in *GlobalResourcePolicy) DeepCopy() *GlobalResourcePolicy

+ func (in *GlobalResourcePolicy) DeepCopyInto(out *GlobalResourcePolicy)

+ type ResourcePolicy struct

+ ContainerPolicies []ContainerResourcePolicy

+ GlobalPolicy *GlobalResourcePolicy

+ func (in *ResourcePolicy) DeepCopy() *ResourcePolicy

+ func (in *ResourcePolicy) DeepCopyInto(out *ResourcePolicy)

Sep 9, 2019

Changes in this version

type ConsumerStatus

+ Missing *int32

+ Paused *int32

type PrometheusAutoscalerSpec

+ RecoveryTime *metav1.Duration

Jul 23, 2019

Changes in this version

+ var AddToScheme = SchemeBuilder.AddToScheme

+ var GroupVersion = schema.GroupVersion

+ var SchemeBuilder = &scheme.Builder

+ type AutoscalerSpec struct

+ Mode AutoscalerType

+ Prometheus *PrometheusAutoscalerSpec

+ func (in *AutoscalerSpec) DeepCopy() *AutoscalerSpec

+ func (in *AutoscalerSpec) DeepCopyInto(out *AutoscalerSpec)

+ type AutoscalerType string

+ const AutoscalerTypeNone

+ const AutoscalerTypePrometheus

+ const AutoscalerTypeVpa

+ type Consumer struct

+ Spec ConsumerSpec

+ Status ConsumerStatus

+ func (in *Consumer) DeepCopy() *Consumer

+ func (in *Consumer) DeepCopyInto(out *Consumer)

+ func (in *Consumer) DeepCopyObject() runtime.Object

+ type ConsumerList struct

+ Items []Consumer

+ func (in *ConsumerList) DeepCopy() *ConsumerList

+ func (in *ConsumerList) DeepCopyInto(out *ConsumerList)

+ func (in *ConsumerList) DeepCopyObject() runtime.Object

+ type ConsumerSpec struct

+ Autoscaler *AutoscalerSpec

+ DeploymentTemplate appsv1.DeploymentSpec

+ Name string

+ Namespace string

+ NumPartitions *int32

+ PartitionEnvKey string

+ ResourcePolicy *autoscalev1.PodResourcePolicy

+ func (in *ConsumerSpec) DeepCopy() *ConsumerSpec

+ func (in *ConsumerSpec) DeepCopyInto(out *ConsumerSpec)

+ type ConsumerStatus struct

+ Expected *int32

+ Lagging *int32

+ LastSyncState map[string]InstanceState

+ LastSyncTime *metav1.Time

+ ObservedGeneration *int64

+ Outdated *int32

+ Running *int32

+ func (in *ConsumerStatus) DeepCopy() *ConsumerStatus

+ func (in *ConsumerStatus) DeepCopyInto(out *ConsumerStatus)

+ type ConsumptionQuerySpec struct

+ PartitionLabel string

+ Query string

+ func (in *ConsumptionQuerySpec) DeepCopy() *ConsumptionQuerySpec

+ func (in *ConsumptionQuerySpec) DeepCopyInto(out *ConsumptionQuerySpec)

+ type InstanceState struct

+ ConsumptionRate int64

+ MessagesBehind int64

+ ProductionRate int64

+ func (in *InstanceState) DeepCopy() *InstanceState

+ func (in *InstanceState) DeepCopyInto(out *InstanceState)

+ type OffsetQuerySpec struct

+ PartitionLabel string

+ Query string

+ func (in *OffsetQuerySpec) DeepCopy() *OffsetQuerySpec

+ func (in *OffsetQuerySpec) DeepCopyInto(out *OffsetQuerySpec)

+ type ProductionQuerySpec struct

+ PartitionLabel string

+ Query string

+ func (in *ProductionQuerySpec) DeepCopy() *ProductionQuerySpec

+ func (in *ProductionQuerySpec) DeepCopyInto(out *ProductionQuerySpec)

+ type PrometheusAutoscalerSpec struct

+ Address []string

+ Consumption ConsumptionQuerySpec

+ CriticalLag *metav1.Duration

+ MinSyncPeriod *metav1.Duration

+ Offset OffsetQuerySpec

+ PreferableCatchupPeriod *metav1.Duration

+ Production ProductionQuerySpec

+ RamPerCore resource.Quantity

+ RatePerCore *int64

+ TolerableLag *metav1.Duration

+ func (in *PrometheusAutoscalerSpec) DeepCopy() *PrometheusAutoscalerSpec

+ func (in *PrometheusAutoscalerSpec) DeepCopyInto(out *PrometheusAutoscalerSpec)