canon

Documentation

Index

• Variables
• func AllSubsequences(sequence []abstract.ChangeItem) [][]abstract.ChangeItem
• type CanonizedCase
  • func All(sources ...abstract.ProviderType) []CanonizedCase
  • func (c CanonizedCase) String() string
• type CanonizedSequenceCase
  • func AllReplicationSequences() []CanonizedSequenceCase

Variables

var (
	//go:embed postgres/gotest/canondata/*/extracted
	PostgresCanon embed.FS
	//go:embed clickhouse/canondata/*
	ClickhouseCanon embed.FS
	//go:embed mysql/canondata/*/extracted
	MysqlCanon embed.FS
	//go:embed ydb/canondata/*/extracted
	YdbCanon embed.FS
	//go:embed yt/canondata/*/extracted
	YtCanon embed.FS
)

var (
	AllCanon = map[abstract.ProviderType]embed.FS{
		postgres.ProviderType:   PostgresCanon,
		mysql.ProviderType:      MysqlCanon,
		clickhouse.ProviderType: ClickhouseCanon,
		ytprovider.ProviderType: YtCanon,
		ydb.ProviderType:        YdbCanon,
	}
	Roots = map[abstract.ProviderType]string{
		postgres.ProviderType:   "postgres",
		clickhouse.ProviderType: "clickhouse",
	}
)

var SequenceTestCases = []string{
	"insert_update_delete",
	"updatepk",
	"insert_update_insert",
}

SequenceTestCases contains a list of all sequence test cases. Each new case must be added here

Functions

func AllSubsequences

func AllSubsequences(sequence []abstract.ChangeItem) [][]abstract.ChangeItem

AllSubsequences produces all possible subsequences from the given sequence which all have the common beginning and start from the first item in the given sequence. Non-row items do not form sequences which begin from them or end with them. Instead, they are "attached" to the row items that follow them.

Types

type CanonizedCase

type CanonizedCase struct {
	Name string
	Type abstract.ProviderType
	Data []abstract.ChangeItem
}

func All

func All(sources ...abstract.ProviderType) []CanonizedCase

func (CanonizedCase) String

func (c CanonizedCase) String() string

type CanonizedSequenceCase

type CanonizedSequenceCase struct {
	Name   string
	Tables abstract.TableMap
	Items  []abstract.ChangeItem
}

func AllReplicationSequences

func AllReplicationSequences() []CanonizedSequenceCase