Function TestSchemaMutator

controller/mutators/etcd/schema_mutator_test.go:28–260

(t *testing.T)

)

func TestSchemaMutator(t *testing.T) {

	defaultConfig := metaCom.TableConfig{
		BatchSize:                metastore.DefaultBatchSize,
		ArchivingIntervalMinutes: metastore.DefaultArchivingIntervalMinutes,
		ArchivingDelayMinutes:    metastore.DefaultArchivingDelayMinutes,
		BackfillMaxBufferSize:    metastore.DefaultBackfillMaxBufferSize,
		BackfillIntervalMinutes:  metastore.DefaultBackfillIntervalMinutes,
		BackfillThresholdInBytes: metastore.DefaultBackfillThresholdInBytes,
		BackfillStoreBatchSize:   metastore.DefaultBackfillStoreBatchSize,
		RecordRetentionInDays:    metastore.DefaultRecordRetentionInDays,
		SnapshotIntervalMinutes:  metastore.DefaultSnapshotIntervalMinutes,
		SnapshotThreshold:        metastore.DefaultSnapshotThreshold,
		RedoLogRotationInterval:  metastore.DefaultRedologRotationInterval,
		MaxRedoLogFileSize:       metastore.DefaultMaxRedoLogSize,
	}

	testTable := metaCom.Table{
		Version: 0,
		Name:    "test1",
		Columns: []metaCom.Column{
			{
				Name: "col1",
				Type: "Int32",
			},
		},
		PrimaryKeyColumns: []int{0},
		Config:            metastore.DefaultTableConfig,
	}
	testTable2 := metaCom.Table{
		Version: 0,
		Name:    "test1",
		Columns: []metaCom.Column{
			{
				Name: "col1",
				Type: "Int32",
			},
			{
				Name: "col2",
				Type: "Int32",
			},
		},
		Config:            metastore.DefaultTableConfig,
		PrimaryKeyColumns: []int{0},
	}
	testTable2.Config.BatchSize = 100

	defaultValue := "default"
	testTable3 := metaCom.Table{
		Version: 0,
		Name:    "test3",
		Columns: []metaCom.Column{
			{
				Name: "col1",
				Type: "SmallEnum",
				DefaultValue: &defaultValue,
			},
		},