testutil

Documentation

Index

• func CheckCanonizedDebeziumEvent(t *testing.T, changeItem *abstract.ChangeItem, ...)
• func CheckCanonizedDebeziumEvent2(t *testing.T, key string, value *string, canonEvent debeziumcommon.KeyValue)
• func Compare(t *testing.T, expected, actual string)
• func CompareYTTypesOriginalAndRecovered(t *testing.T, l, r *abstract.ChangeItem)
• func FixTestSuite(t *testing.T, testSuite []debeziumcommon.ChangeItemCanon, ...) []debeziumcommon.ChangeItemCanon
• type Message

Functions

func CheckCanonizedDebeziumEvent

func CheckCanonizedDebeziumEvent(t *testing.T, changeItem *abstract.ChangeItem, databaseServerName, database, sourceType string, isSnapshot bool, canonEvents []debeziumcommon.KeyValue)

func CheckCanonizedDebeziumEvent2

func CheckCanonizedDebeziumEvent2(t *testing.T, key string, value *string, canonEvent debeziumcommon.KeyValue)

func Compare

func Compare(t *testing.T, expected, actual string)

func CompareYTTypesOriginalAndRecovered

func CompareYTTypesOriginalAndRecovered(t *testing.T, l, r *abstract.ChangeItem)

func FixTestSuite

func FixTestSuite(t *testing.T, testSuite []debeziumcommon.ChangeItemCanon, databaseServerName, database, sourceType string) []debeziumcommon.ChangeItemCanon

Types

type Message

type Message struct {
	Payload map[string]interface{} `json:"payload"`
	Schema  map[string]interface{} `json:"schema"`
}