schema

type ColumnDef struct {
	Name      string    `json:"name"`
	Type      string    `json:"type"`
	InnerType byte      `json:"inner_type"`
	Key       IndexType `json:"key"`
	Charset   string    `json:"charset"`
	Unsigned  bool      `json:"unsigned"`
	Nullable  bool      `json:"nullable"`
}

type IndexType string

type Iterator interface {
	First() (string, string, mysql.Position, error)
	Next() (string, string, mysql.Position, error)
	End() bool
}

type SchemaStorage interface {
	// SaveSnapshot will be called when schema tracker decides to save a snapshot
	SaveSnapshot(data []byte, pos mysql.Position) error

	// SaveSnapshot will be called when schema tracker decides to save a ddl statement
	SaveStatement(db string, statement string, pos mysql.Position) error

	// LoadLastSnapshot will be called when schema tracker need to restore snapshot, as base data
	LoadLastSnapshot() ([]byte, mysql.Position, error)

	// Reset will be called to get a empty storage
	Reset() error

	// StatementIterator return an iterator which can iterate all ddl statements after last snapshot
	StatementIterator() Iterator
}

type SchemaTracker struct {
	// contains filtered or unexported fields
}

type TableDef struct {
	Database string       `json:"database"`
	Name     string       `json:"name"`
	Columns  []*ColumnDef `json:"columns"`
	Charset  string       `json:"charset"`
}

type TrackerConfig struct {
	// The charset_set_server of source mysql, we need
	// this charset to handle ddl statement
	CharsetServer string

	// Storage type to store schema data, may be boltdb or mysql
	Storage string

	// Boltdb file path to store data
	Dir string

	// MySQL info to connect
	Addr     string
	User     string
	Password string
	Database string
}