topotest

Documentation

Index

• Constants
• func CommonResultFunc(result []any) [][]map[string]any
• func CompareMetrics(tp *topo.Topo, m map[string]interface{}) (err error)
• func DoRuleTest(t *testing.T, tests []RuleTest, opt *def.RuleOption, w int)
• func HandleStream(createOrDrop bool, names []string, t *testing.T)
• type RuleTest

Constants

const POSTLEAP = 1000 // Time change after all data sends out

Functions

func CommonResultFunc

func CommonResultFunc(result []any) [][]map[string]any

CommonResultFunc A function to convert memory sink result to map slice

func CompareMetrics

func CompareMetrics(tp *topo.Topo, m map[string]interface{}) (err error)

func DoRuleTest

func DoRuleTest(t *testing.T, tests []RuleTest, opt *def.RuleOption, w int)

func HandleStream

func HandleStream(createOrDrop bool, names []string, t *testing.T)

HandleStream Create or drop streams

Types

type RuleTest

type RuleTest struct {
	Name string
	Sql  string
	R    [][]map[string]any // The result
	M    map[string]any     // final metrics
	T    *def.PrintableTopo // printable topo, an optional field
	W    int                // wait time for each data sending, in milli
}