K8sAutoscaleNode

// Target 100 requests per second per host
var target = 100.0
var min = 1
var max = 100
var period = 5m
var every = period
stream
  |from()
    .measurement('requests')
    .groupBy('host', 'deployment')
    .truncate(1s)
  |derivative('value')
    .as('requests_per_second')
    .unit(1s)
    .nonNegative()
  |groupBy('deployment')
  |sum('requests_per_second')
    .as('total_requests')
  |window()
    .period(period)
    .every(every)
  |mean('total_requests')
    .as('total_requests')
  |k8sAutoscale()
    // Get the name of the deployment from the 'deployment' tag.
    .resourceNameTag('deployment')
    .min(min)
    .max(max)
    // Set the desired number of replicas based on target.
    .replicas(lambda: int(ceil("total_requests" / target)))
  |influxDBOut()
    .database('deployments')
    .measurement('scale_events')
    .precision('s')

k8sAutoscale.cluster(value string)

    |k8sAutoscale()
        .currentField('replicas')
        // Increase the replicas by 1 if the qps is over the threshold
        .replicas(lambda: if("qps" > threshold, "replicas" + 1, "replicas"))

k8sAutoscale.currentField(value string)

k8sAutoscale.decreaseCooldown(value time.Duration)

k8sAutoscale.increaseCooldown(value time.Duration)

k8sAutoscale.kind(value string)

k8sAutoscale.kindTag(value string)

k8sAutoscale.max(value int64)

k8sAutoscale.min(value int64)

k8sAutoscale.namespace(value string)

k8sAutoscale.namespaceTag(value string)

k8sAutoscale.quiet()

k8sAutoscale.replicas(value ast.LambdaNode)

k8sAutoscale.resourceName(value string)

k8sAutoscale.resourceNameTag(value string)

k8sAutoscale.resourceTag(value string)

k8sAutoscale|alert()

k8sAutoscale|barrier()

k8sAutoscale|bottom(num int64, field string, fieldsAndTags ...string)

k8sAutoscale|changeDetect(field string)

k8sAutoscale|combine(expressions ...ast.LambdaNode)

k8sAutoscale|count(field string)

k8sAutoscale|cumulativeSum(field string)

    var data = stream
        |from()...
    // Trigger critical alert if the throughput drops below 100 points per 10s and checked every 10s.
    data
        |deadman(100.0, 10s)
    //Do normal processing of data
    data...

    var data = stream
        |from()...
    // Trigger critical alert if the throughput drops below 100 points per 10s and checked every 10s.
    data
        |stats(10s)
            .align()
        |derivative('emitted')
            .unit(10s)
            .nonNegative()
        |alert()
            .id('node \'stream0\' in task \'{{ .TaskName }}\'')
            .message('{{ .ID }} is {{ if eq .Level "OK" }}alive{{ else }}dead{{ end }}: {{ index .Fields "emitted" | printf "%0.3f" }} points/10s.')
            .crit(lambda: "emitted" <= 100.0)
    //Do normal processing of data
    data...

    var data = stream
        |from()...
    // Trigger critical alert if the throughput drops below 100 points per 10s and checked every 10s.
    data
        |deadman(100.0, 10s)
            .slack()
            .channel('#dead_tasks')
    //Do normal processing of data
    data...

    var data = stream
        |from()...
    // Trigger critical alert if the throughput drops below 100 points per 10s and checked every 10s.
    // Only trigger the alert if the time of day is between 8am-5pm.
    data
        |deadman(100.0, 10s, lambda: hour("time") >= 8 AND hour("time") <= 17)
    //Do normal processing of data
    data...

k8sAutoscale|deadman(threshold float64, interval time.Duration, expr ...ast.LambdaNode)

k8sAutoscale|default()

k8sAutoscale|delete()

k8sAutoscale|derivative(field string)

k8sAutoscale|difference(field string)

k8sAutoscale|distinct(field string)

k8sAutoscale|ec2Autoscale()

k8sAutoscale|elapsed(field string, unit time.Duration)

k8sAutoscale|eval(expressions ...ast.LambdaNode)

k8sAutoscale|first(field string)

k8sAutoscale|flatten()

    |groupBy(*)

k8sAutoscale|groupBy(tag ...interface{})

k8sAutoscale|holtWinters(field string, h int64, m int64, interval time.Duration)

k8sAutoscale|holtWintersWithFit(field string, h int64, m int64, interval time.Duration)

k8sAutoscale|httpOut(endpoint string)

k8sAutoscale|httpPost(url ...string)

k8sAutoscale|influxDBOut()

k8sAutoscale|join(others ...Node)

k8sAutoscale|k8sAutoscale()

k8sAutoscale|kapacitorLoopback()

k8sAutoscale|last(field string)

k8sAutoscale|log()

k8sAutoscale|mean(field string)

k8sAutoscale|median(field string)

k8sAutoscale|mode(field string)

k8sAutoscale|movingAverage(field string, window int64)

k8sAutoscale|percentile(field string, percentile float64)

k8sAutoscale|sample(rate interface{})

k8sAutoscale|shift(shift time.Duration)

k8sAutoscale|sideload()

k8sAutoscale|spread(field string)

k8sAutoscale|stateCount(expression ast.LambdaNode)

k8sAutoscale|stateDuration(expression ast.LambdaNode)

k8sAutoscale|stats(interval time.Duration)

k8sAutoscale|stddev(field string)

k8sAutoscale|sum(field string)

k8sAutoscale|swarmAutoscale()

k8sAutoscale|top(num int64, field string, fieldsAndTags ...string)

k8sAutoscale|trickle()

k8sAutoscale|union(node ...Node)

k8sAutoscale|where(expression ast.LambdaNode)

k8sAutoscale|window()