cloudquery

type Column struct {
	Name string
	Type string
}

type EnumValue struct {
	Name   string
	Number int32
}

type ExecInput struct {
	SQL       string
	PageSize  int
	PageToken string
}

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

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

type JoinEdge struct {
	From        string
	To          string
	Cardinality string
}

type Row map[string]any

type Schema struct {
	Tables []SchemaTable
	Edges  []JoinEdge
	Usage  Usage
}

type SchemaColumn struct {
	Name         string
	Type         string
	Description  string
	Selectable   bool
	Filterable   bool
	Groupable    bool
	Aggregatable bool
	Indexed      bool
	ReferenceURL string
	EnumValues   []EnumValue
}

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

type SchemaTable struct {
	Name              string
	Description       string
	Columns           []SchemaColumn
	TimeColumn        string
	TimeWindowMaxDays int64
}

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

type Stats struct {
	EstimatedCost float64
	EstimatedRows int64
	ElapsedMs     int64
}

type Usage struct {
	Rules          []string
	ExampleQueries []string
}