topotest

Documentation

Index

• Constants
• func CommonResultFunc(result []any) [][]map[string]any
• func CompareMetrics(tp *topo.Topo, m map[string]interface{}) (err error)
• func DoCheckpointRuleTest(t *testing.T, tests []RuleCheckpointTest, opt *def.RuleOption, w int)
• func DoRuleTest(t *testing.T, tests []RuleTest, opt *def.RuleOption, w int)
• func DoRuleTestWithResultFunc(t *testing.T, tests []RuleTest, opt *def.RuleOption, w int, ...)
• func HandleStream(createOrDrop bool, names []string, t *testing.T)
• type RuleCheckpointTest
• 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 DoCheckpointRuleTest

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

func DoRuleTest

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

func DoRuleTestWithResultFunc

func DoRuleTestWithResultFunc(t *testing.T, tests []RuleTest, opt *def.RuleOption, w int, resultFunc func(result []any) [][]map[string]any)

func HandleStream

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

HandleStream Create or drop streams

Types

type RuleCheckpointTest

type RuleCheckpointTest struct {
	RuleTest
	PauseSize int // Stop stream after sending pauseSize source to test checkpoint resume
	Cc        int // checkpoint count when paused

}

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
}