Warning! This page documents an earlier version of Flux, which is no longer actively developed. Flux v0.50 is the most recent stable version of Flux.
The testing.assertEquals()
function tests whether two streams have identical data.
If equal, the function outputs the tested data stream unchanged.
If unequal, the function returns an error.
import "testing"
testing.assertEquals(
name: "streamEquality",
got: got,
want: want
)
The testing.assertEquals()
function can be used to perform in-line tests in a query.
Parameters
name
Unique name given to the assertion.
Data type: String
got
The stream containing data to test.
Defaults to piped-forward data (<-
).
Data type: Object
want
The stream that contains the expected data to test against.
Data type: Object
Examples
Assert of separate streams
import "testing"
want = from(bucket: "backup-telegraf/autogen")
|> range(start: -5m)
got = from(bucket: "telegraf/autogen")
|> range(start: -5m)
testing.assertEquals(got: got, want: want)
Inline assertion
import "testing"
want = from(bucket: "backup-telegraf/autogen")
|> range(start: -5m)
from(bucket: "telegraf/autogen")
|> range(start: -5m)
|> testing.assertEquals(want: want)