HTTPPostNode

stream
  |window()
    .period(10s)
    .every(5s)
  |top('value', 10)
  //Post the top 10 results over the last 10s updated every 5s.
  |httpPost('http://example.com/api/top10')

stream
  |window()
    .period(10s)
    .every(5s)
  |top('value', 10)
  //Post the top 10 results over the last 10s updated every 5s.
  |httpPost()
    .endpoint('example')

httpPost.captureResponse()

httpPost.codeField(value string)

    stream
         |httpPost()
            .endpoint('example')

httpPost.endpoint(endpoint string)

    stream
         |httpPost()
            .endpoint('example')
              .header('my', 'header')

httpPost.header(k string, v string)

httpPost.quiet()

httpPost.timeout(value time.Duration)

httpPost|alert()

httpPost|barrier()

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

httpPost|changeDetect(field string)

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

httpPost|count(field string)

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

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

httpPost|default()

httpPost|delete()

httpPost|derivative(field string)

httpPost|difference(field string)

httpPost|distinct(field string)

httpPost|ec2Autoscale()

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

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

httpPost|first(field string)

httpPost|flatten()

    |groupBy(*)

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

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

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

httpPost|httpOut(endpoint string)

httpPost|httpPost(url ...string)

httpPost|influxDBOut()

httpPost|join(others ...Node)

httpPost|k8sAutoscale()

httpPost|kapacitorLoopback()

httpPost|last(field string)

httpPost|log()

httpPost|max(field string)

httpPost|mean(field string)

httpPost|median(field string)

httpPost|min(field string)

httpPost|mode(field string)

httpPost|movingAverage(field string, window int64)

httpPost|percentile(field string, percentile float64)

httpPost|sample(rate interface{})

httpPost|shift(shift time.Duration)

httpPost|sideload()

httpPost|spread(field string)

httpPost|stateCount(expression ast.LambdaNode)

httpPost|stateDuration(expression ast.LambdaNode)

httpPost|stats(interval time.Duration)

httpPost|stddev(field string)

httpPost|sum(field string)

httpPost|swarmAutoscale()

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

httpPost|trickle()

httpPost|union(node ...Node)

httpPost|where(expression ast.LambdaNode)

httpPost|window()