schemer

type CollectionsProvider interface {
	// GetCollections returns root collections if parentKey is nil or sub-collection if parenKey is provided
	GetCollections(c context.Context, parentKey *dal.Key) (CollectionsReader, error)
}

type CollectionsReader interface {
	NextCollection() (*datatug.CollectionInfo, error)
}

type Column struct {
	TableRef
	datatug.ColumnInfo
}

type ColumnsProvider interface {
	GetColumns(c context.Context, catalog, schemaName, tableName string) (ColumnsReader, error)
}

type ColumnsReader interface {
	// NextColumn returns next column
	NextColumn() (Column, error)
}

type Constraint struct {
	TableRef
	ColumnName                                                            string
	UniqueConstraintCatalog, UniqueConstraintSchema, UniqueConstraintName string // can be null
	MatchOption, UpdateRule, DeleteRule                                   string // can be null
	RefTableCatalog, RefTableSchema, RefTableName, RefColName             string // can be null
	*datatug.Constraint
}

type ConstraintsProvider interface {
	// GetConstraints returns constrains
	GetConstraints(c context.Context, catalog, schema, table string) (ConstraintsReader, error)
}

type ConstraintsReader interface {
	NextConstraint() (*Constraint, error)
}

type Index struct {
	TableRef
	*datatug.Index
}

type IndexColumn struct {
	TableRef
	IndexName string
	*datatug.IndexColumn
}

type IndexColumnsProvider interface {
	// GetIndexColumns returns index columns
	GetIndexColumns(c context.Context, catalog, schema, table, index string) (IndexColumnsReader, error)
}

type IndexColumnsReader interface {
	// NextIndexColumn returns index column
	NextIndexColumn() (*IndexColumn, error)
}

type IndexesProvider interface {
	// GetIndexes returns next index
	GetIndexes(c context.Context, catalog, schema, table string) (IndexesReader, error)
}

type IndexesReader interface {
	// NextIndex returns next index
	NextIndex() (*Index, error)
}

type RecordsCountProvider interface {
	RecordsCount(c context.Context, catalog, schema, table string) (*int, error)
}

type Scanner interface {
	ScanCatalog(c context.Context, name string) (database *datatug.DbCatalog, err error)
}

type SchemaProvider interface {
	IsBulkProvider() bool // TODO: Needs clarification what it does and how it is used
	CollectionsProvider
	ColumnsProvider
	IndexesProvider
	IndexColumnsProvider
	ConstraintsProvider
	RecordsCountProvider
}

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

type SortedTables struct {
	Tables []*datatug.CollectionInfo
	// contains filtered or unexported fields
}

type TableRef struct {
	SchemaName string
	TableName  string
	TableType  string
}