cloudquery

type ExecInput struct {
	SQL       string
	PageSize  int
	PageToken string
}

type ExecResult struct {
	Columns     []string
	Rows        []Row
	NextPage    string
	GeneratedAt time.Time
}

type ExecRunner interface {
	Exec(ctx context.Context, in ExecInput) (*ExecResult, error)
}

type Row map[string]any

type Schema struct {
	Tables []SchemaTable
}

type SchemaColumn struct {
	Name         string
	Description  string
	Selectable   bool
	Filterable   bool
	Required     bool
	ReferenceURL string
}

type SchemaFetcher interface {
	Schema(ctx context.Context) (*Schema, error)
}

type SchemaTable struct {
	Name    string
	Columns []SchemaColumn
}

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