autoscaler

Sep 16, 2019

Changes in this version

+ var ErrDidNotReceiveStat = errors.New("did not receive stat from an unscraped pod")

+ var ErrFailedGetEndpoints = errors.New("failed to get endpoints")

type Config

+ MaxScaleDownRate float64

+ RPSTargetDefault float64

+ TargetUtilization float64

type DeciderSpec

+ MaxScaleDownRate float64

+ ScalingMetric string

+ TargetValue float64

+ TotalValue float64

type MetricClient

+ StableAndPanicRPS func(key types.NamespacedName, now time.Time) (float64, float64, error)

type MetricCollector

+ func (c *MetricCollector) StableAndPanicRPS(key types.NamespacedName, now time.Time) (float64, float64, error)

type Reporter

+ func (r *Reporter) ReportPanicRPS(v float64) error

+ func (r *Reporter) ReportStableRPS(v float64) error

+ func (r *Reporter) ReportTargetRPS(v float64) error

type StatsReporter

+ ReportPanicRPS func(v float64) error

+ ReportStableRPS func(v float64) error

+ ReportTargetRPS func(v float64) error

Aug 6, 2019

Changes in this version

+ var ErrNotScraping = errors.New("the requested resource is not being scraped")

+ type Collector interface

+ CreateOrUpdate func(*av1alpha1.Metric) error

+ Delete func(string, string) error

+ Record func(key types.NamespacedName, stat Stat)

type Config

+ TargetBurstCapacity float64

type DeciderSpec

+ TargetBurstCapacity float64

+ TotalConcurrency float64

type DeciderStatus

+ ExcessBurstCapacity int32

type MetricClient

+ StableAndPanicOPS func(key types.NamespacedName, now time.Time) (float64, float64, error)

type MetricCollector

+ func (c *MetricCollector) CreateOrUpdate(metric *av1alpha1.Metric) error

+ func (c *MetricCollector) StableAndPanicOPS(key types.NamespacedName, now time.Time) (float64, float64, error)

type Reporter

+ func (r *Reporter) ReportExcessBurstCapacity(v float64) error

type StatsReporter

+ ReportExcessBurstCapacity func(v float64) error

Jun 25, 2019

Changes in this version

+ const BucketSize

type Config

+ ContainerConcurrencyTargetFraction float64

type DeciderSpec

+ StableWindow time.Duration

+ type MetricProvider struct

+ func NewMetricProvider(metricClient MetricClient) *MetricProvider

+ func (p *MetricProvider) GetMetricByName(name types.NamespacedName, info provider.CustomMetricInfo) (*cmetrics.MetricValue, error)

+ func (p *MetricProvider) GetMetricBySelector(namespace string, selector labels.Selector, info provider.CustomMetricInfo) (*cmetrics.MetricValueList, error)

+ func (p *MetricProvider) ListAllMetrics() []provider.CustomMetricInfo

type MetricSpec

+ ScrapeTarget string

May 14, 2019

Changes in this version

+ var ErrNoData = errors.New("no data available")

type Config

+ PanicThresholdPercentage float64

+ PanicWindowPercentage float64

type DeciderSpec

+ MaxScaleUpRate float64

+ MetricSpec MetricSpec

+ PanicThreshold float64

+ ServiceName string

+ TickInterval time.Duration

+ type MetricClient interface

+ StableAndPanicConcurrency func(key string) (float64, float64, error)

+ type MetricCollector struct

+ func NewMetricCollector(statsScraperFactory StatsScraperFactory, logger *zap.SugaredLogger) *MetricCollector

+ func (c *MetricCollector) Create(ctx context.Context, metric *Metric) (*Metric, error)

+ func (c *MetricCollector) Delete(ctx context.Context, namespace, name string) error

+ func (c *MetricCollector) Get(ctx context.Context, namespace, name string) (*Metric, error)

+ func (c *MetricCollector) Record(key string, stat Stat)

+ func (c *MetricCollector) StableAndPanicConcurrency(key string) (float64, float64, error)

+ func (c *MetricCollector) Update(ctx context.Context, metric *Metric) (*Metric, error)

type MetricSpec

+ PanicWindow time.Duration

+ StableWindow time.Duration

type MultiScaler

+ func (m *MultiScaler) Poke(key string, stat Stat)

Apr 2, 2019

Changes in this version

+ type Decider struct

+ Spec DeciderSpec

+ Status DeciderStatus

+ func (in *Decider) DeepCopy() *Decider

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

+ type DeciderSpec struct

+ TargetConcurrency float64

+ type DeciderStatus struct

+ DesiredScale int32

type Stat

+ AverageProxiedConcurrentRequests float64

+ ProxiedRequestCount int32

+ type StatsScraperFactory func(*Decider) (StatsScraper, error)

Feb 19, 2019

Changes in this version

+ const DefaultScaleToZeroGracePeriod

+ const DefaultStableWindow

type Reporter

+ func (r *Reporter) ReportActualPodCount(v int64) error

+ func (r *Reporter) ReportDesiredPodCount(v int64) error

+ func (r *Reporter) ReportObservedPodCount(v float64) error

+ func (r *Reporter) ReportPanic(v int64) error

+ func (r *Reporter) ReportPanicRequestConcurrency(v float64) error

+ func (r *Reporter) ReportRequestedPodCount(v int64) error

+ func (r *Reporter) ReportStableRequestConcurrency(v float64) error

+ func (r *Reporter) ReportTargetRequestConcurrency(v float64) error

+ type ServiceScraper struct

+ func NewServiceScraper(metric *Metric, logger *zap.SugaredLogger) (*ServiceScraper, error)

+ func (s *ServiceScraper) Scrape(statsCh chan<- *StatMessage)

type StatsReporter

+ ReportActualPodCount func(v int64) error

+ ReportDesiredPodCount func(v int64) error

+ ReportObservedPodCount func(v float64) error

+ ReportPanic func(v int64) error

+ ReportPanicRequestConcurrency func(v float64) error

+ ReportRequestedPodCount func(v int64) error

+ ReportStableRequestConcurrency func(v float64) error

+ ReportTargetRequestConcurrency func(v float64) error

+ type StatsScraper interface

+ Scrape func(statsCh chan<- *StatMessage)

Jan 8, 2019

Changes in this version

+ func NewMetricKey(namespace string, name string) string

type Autoscaler

+ func (a *Autoscaler) Update(spec MetricSpec) error

type Measurement

+ const PanicRequestConcurrencyM

+ const StableRequestConcurrencyM

type Metric

+ Spec MetricSpec

+ Status MetricStatus

+ func (in *Metric) DeepCopy() *Metric

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

+ type MetricSpec struct

+ TargetConcurrency float64

+ type MetricStatus struct

+ DesiredScale int32

type MultiScaler

+ func (m *MultiScaler) Inform(event string) bool

+ func (m *MultiScaler) Update(ctx context.Context, metric *Metric) (*Metric, error)

type UniScaler

+ Update func(MetricSpec) error

Oct 30, 2018

Changes in this version

+ const ActivatorPodName

+ func NewKpaKey(namespace string, name string) string

type Config

+ ContainerConcurrencyTargetDefault float64

+ ContainerConcurrencyTargetPercentage float64

+ ScaleToZeroGracePeriod time.Duration

+ ScaleToZeroIdlePeriod time.Duration

+ TickInterval time.Duration

+ func (in *Config) DeepCopy() *Config

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

+ type DynamicConfig struct

+ func NewDynamicConfig(config *Config, logger *zap.SugaredLogger) *DynamicConfig

+ func NewDynamicConfigFromMap(rawConfig map[string]string, logger *zap.SugaredLogger) (*DynamicConfig, error)

+ func (dc *DynamicConfig) Current() *Config

+ func (dc *DynamicConfig) Update(configMap *corev1.ConfigMap)

+ type Metric struct

+ DesiredScale int32

+ type MultiScaler struct

+ func NewMultiScaler(dynConfig *DynamicConfig, stopCh <-chan struct{}, ...) *MultiScaler

+ func (m *MultiScaler) Create(ctx context.Context, kpa *kpa.PodAutoscaler) (*Metric, error)

+ func (m *MultiScaler) Delete(ctx context.Context, key string) error

+ func (m *MultiScaler) Get(ctx context.Context, key string) (*Metric, error)

+ func (m *MultiScaler) RecordStat(key string, stat Stat)

+ func (m *MultiScaler) Watch(fn func(string))

type Stat

+ LameDuck bool

type StatMessage

+ Key string

+ type UniScaler interface

+ Record func(context.Context, Stat)

+ Scale func(context.Context, time.Time) (int32, bool)

+ type UniScalerFactory func(*kpa.PodAutoscaler, *DynamicConfig) (UniScaler, error)

Jul 17, 2018

Changes in this version

+ const ConfigName

+ type Autoscaler struct

+ func New(config *Config, model v1alpha1.RevisionRequestConcurrencyModelType, ...) *Autoscaler

+ func (a *Autoscaler) Record(ctx context.Context, stat Stat)

+ func (a *Autoscaler) Scale(ctx context.Context, now time.Time) (int32, bool)

+ type Config struct

+ ConcurrencyQuantumOfTime time.Duration

+ EnableScaleToZero bool

+ EnableVPA bool

+ MaxScaleUpRate float64

+ MultiTargetConcurrency float64

+ PanicWindow time.Duration

+ ScaleToZeroThreshold time.Duration

+ SingleTargetConcurrency float64

+ StableWindow time.Duration

+ VPAMultiTargetConcurrency float64

+ func NewConfigFromConfigMap(configMap *corev1.ConfigMap) (*Config, error)

+ func NewConfigFromMap(data map[string]string) (*Config, error)

+ func (c *Config) TargetConcurrency(model v1alpha1.RevisionRequestConcurrencyModelType) float64

+ type Measurement int

+ const ActualPodCountM

+ const DesiredPodCountM

+ const ObservedPanicConcurrencyM

+ const ObservedPodCountM

+ const ObservedStableConcurrencyM

+ const PanicM

+ const RequestedPodCountM

+ const TargetConcurrencyM

+ type Reporter struct

+ func NewStatsReporter(podNamespace string, config string, revision string) (*Reporter, error)

+ func (r *Reporter) Report(m Measurement, v float64) error

+ type Stat struct

+ AverageConcurrentRequests float64

+ PodName string

+ RequestCount int32

+ Time *time.Time

+ type StatMessage struct

+ RevisionKey string

+ Stat Stat

+ type StatsReporter interface

+ Report func(m Measurement, v float64) error