topotest

Documentation

Index

• Constants
• func CommonResultFunc(result [][]byte) interface{}
• func CompareMetrics(tp *topo.Topo, m map[string]interface{}) (err error)
• func CreateRule(name, sql string) (*api.Rule, error)
• func DoCheckpointRuleTest(t *testing.T, tests []RuleCheckpointTest, j int, opt *api.RuleOption)
• func DoRuleTest(t *testing.T, tests []RuleTest, j int, opt *api.RuleOption, wait 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 [][]byte) interface{}

func CompareMetrics

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

func CreateRule

func CreateRule(name, sql string) (*api.Rule, error)

func DoCheckpointRuleTest

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

func DoRuleTest

func DoRuleTest(t *testing.T, tests []RuleTest, j int, opt *api.RuleOption, wait int)

func HandleStream

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

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
	PauseMetric map[string]interface{} // The metric to check when paused
}

type RuleTest

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