# Functions
Create a pipeline from a given script.
Create a template pipeline tick:ignore.
NewJSONNode decodes JSON bytes into a JSONNode.
# Constants
Data are transferred in batches as soon as the data are ready.
NodeID is used by all Node as a unique ID duration Marshal and Unmarshal.
NodeTypeOf is used by all Node to identify the node duration Marshal and Unmarshal.
No data are transferred.
Data are transferred immediately and one point at a time.
# Structs
tick:embedded:AlertNode.Alerta.
tick:embedded:AlertNode.Post.
AlertNode struct wraps the default AlertNodeData tick:wraps:AlertNodeData.
An AlertNode can trigger an event of varying severity levels, and pass the event to alert handlers.
A BarrierNode will emit a barrier with the current time, according to the system clock.
tick:embedded:AlertNode.BigPanda.
Compute the changeDetect of a stream or batch.
Combine the data from a single node with itself.
Defaults fields and tags on data points.
Deletes fields and tags from data points.
Compute the derivative of a stream or batch.
tick:embedded:AlertNode.Discord.
EC2AutoscaleNode triggers autoscale events for a group on a AWS Autoscaling group.
Edge is a connection between a parent ID and a ChildID tick:ignore.
Email AlertHandler tick:embedded:AlertNode.Email.
Evaluates expressions on each data point it receives.
tick:embedded:AlertNode.Exec.
Flatten a set of points on specific dimensions.
A FromNode selects a subset of the data flowing through a StreamNode.
A GroupByNode will group the incoming data.
tick:embedded:AlertNode.HipChat.
An HTTPOutNode caches the most recent data for each group it has received.
An HTTPPostNode will take the incoming data stream and POST it to an HTTP endpoint.
Writes the data to InfluxDB as it is received.
An InfluxQLNode performs the available function from the InfluxQL language.
Inhibitor represents a single alert inhibitor tick:ignore.
IRNode is the intermediate representation of a node between JSON unmarshaling and a pipeline Node tick:ignore.
Joins the data from any number of nodes.
JSONPipeline is the JSON serialization format for Pipeline tick:ignore.
K8sAutoscaleNode triggers autoscale events for a resource on a Kubernetes cluster.
Kafka alert Handler tick:embedded:AlertNode.Kafka.
Writes the data back into the Kapacitor stream.
tick:ignore.
tick:embedded:AlertNode.Log.
A node that logs all data that passes through the node.
tick:embedded:AlertNode.Mqtt.
A node that does not perform any operation.
tick:embedded:AlertNode.OpsGenie2.
tick:embedded:AlertNode.OpsGenie.
tick:embedded:AlertNode.PagerDuty.
tick:embedded:AlertNode.PagerDuty.
A complete data processing pipeline.
PipelineSorter performs topological sort on the Edges of JSONPipeline.
tick:embedded:AlertNode.Pushover.
A QueryFluxNode defines a source and a schedule for processing batch data.
A QueryNode defines a source and a schedule for processing batch data.
tick:ignore.
Sample points or batches.
tick:embedded:AlertNode.Sensu.
tick:embedded:AlertNode.ServiceNow.
Shift points and batches in time, this is useful for comparing batches or points from different times.
Sideload adds fields and tags to points based on hierarchical data from various sources.
tick:embedded:AlertNode.Slack.
tick:ignore.
SNMPTrap AlertHandler tick:embedded:AlertNode.SnmpTrap.
Compute the number of consecutive points in a given state.
Compute the duration of a given state.
A StatsNode emits internal statistics about the another node at a given interval.
A StreamNode represents the source of data being streamed to Kapacitor via any of its inputs.
SwarmAutoscaleNode triggers autoscale events for a service on a Docker Swarm mode cluster.
tick:embedded:AlertNode.Talk.
tick:embedded:AlertNode.Tcp.
tick:embedded:AlertNode.Teams.
tick:embedded:AlertNode.Telegram.
tick:ignore.
tick:ignore.
A node that converts from batchedges to streamedges.
TypeOf is a helper struct to add type information for each pipeline node tick:ignore.
A UDFNode is a node that can run a User Defined Function (UDF) in a separate process.
Takes the union of all of its parents.
tick:embedded:AlertNode.VictorOps.
The WhereNode filters the data stream by a given expression.
A `window` node caches data within a moving time range.
tick:embedded:AlertNode.Zenoss.
# Interfaces
Information relavant to configuring a deadman's swith.
Generic node in a pipeline.