debezium

type ColInfo struct {
	Name       string     `yaml:"name"`
	Type       string     `yaml:"type"`
	SourceType SourceType `yaml:"sourceType"`
	Default    string     `yaml:"default"`
	NotNull    bool       `yaml:"notnull"`
	PrimaryKey bool       `yaml:"primarykey"`
}

type Schema struct {
	Type        string        `yaml:"type"`
	Name        string        `yaml:"name"`
	Namespace   string        `yaml:"namespace"`
	Fields      []SchemaField `yaml:"fields"`
	ConnectName string        `yaml:"connect.name"`
}

type SchemaField struct {
	Name    string      `yaml:"name"`
	Type    interface{} `yaml:"type"`
	Default interface{} `yaml:"default"`
}

type SourceType struct {
	ColumnLength string `yaml:"columnLength"`
	ColumnType   string `yaml:"columnType"`
	ColumnScale  string `yaml:"columnScale"`
}