StateDurationNode

stream
  |from()
    .measurement('cpu')
  |where(lambda: "cpu" == 'cpu-total')
  |groupBy('host')
  |stateDuration(lambda: "usage_idle" <= 10)
    .unit(1m)
  |alert()
    // Warn after 1 minute
    .warn(lambda: "state_duration" >= 1)
    // Critical after 5 minutes
    .crit(lambda: "state_duration" >= 5)

stateDuration.as(value string)

stateDuration.quiet()

stateDuration.unit(value time.Duration)

stateDuration|alert()

stateDuration|barrier()

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

stateDuration|changeDetect(field string)

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

stateDuration|count(field string)

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

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

stateDuration|default()

stateDuration|delete()

stateDuration|derivative(field string)

stateDuration|difference(field string)

stateDuration|distinct(field string)

stateDuration|ec2Autoscale()

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

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

stateDuration|first(field string)

stateDuration|flatten()

    |groupBy(*)

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

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

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

stateDuration|httpOut(endpoint string)

stateDuration|httpPost(url ...string)

stateDuration|influxDBOut()

stateDuration|join(others ...Node)

stateDuration|k8sAutoscale()

stateDuration|kapacitorLoopback()

stateDuration|last(field string)

stateDuration|log()

stateDuration|max(field string)

stateDuration|mean(field string)

stateDuration|median(field string)

stateDuration|min(field string)

stateDuration|mode(field string)

stateDuration|movingAverage(field string, window int64)

stateDuration|percentile(field string, percentile float64)

stateDuration|sample(rate interface{})

stateDuration|shift(shift time.Duration)

stateDuration|sideload()

stateDuration|spread(field string)

stateDuration|stateCount(expression ast.LambdaNode)

stateDuration|stateDuration(expression ast.LambdaNode)

stateDuration|stats(interval time.Duration)

stateDuration|stddev(field string)

stateDuration|sum(field string)

stateDuration|swarmAutoscale()

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

stateDuration|trickle()

stateDuration|union(node ...Node)

stateDuration|where(expression ast.LambdaNode)

stateDuration|window()