query

type BaseDataset interface {
	Context() context.Context
	Op() errors.Op

	PrimaryResultKind() string
}

type BaseTable interface {
	Id() string
	Index() int64
	Name() string
	Columns() []Column
	Kind() string
	ColumnByName(name string) Column
	Op() errors.Op
	IsPrimaryResult() bool
}

type Column interface {
	// Ordinal returns the column's index in the table.
	Index() int
	// Name returns the column's name.
	Name() string
	// Type returns the column's kusto data type.
	Type() types.Column
}

type Columns []Column

type Dataset interface {
	BaseDataset
	Tables() []Table
}

type IterativeDataset interface {
	BaseDataset
	Tables() <-chan TableResult
	ToDataset() (Dataset, error)
	Close() error
}

type IterativeTable interface {
	BaseTable
	// Rows returns a channel that will be populated with rows as they are read.
	Rows() <-chan RowResult
	// SkipToEnd skips all remaining rows in the table.
	SkipToEnd() []error
	ToTable() (Table, error)
}

type Row interface {
	// Index returns the index of the row.
	Index() int

	// Columns returns the columns of the table that the row belongs to.
	Columns() Columns

	// Values returns all the values in the row.
	Values() value.Values

	// Value returns the value at the specified index.
	Value(i int) (value.Kusto, error)

	ValueByColumn(c Column) (value.Kusto, error)

	// ValueByName returns the value with the specified column name.
	ValueByName(name string) (value.Kusto, error)

	// ToStruct converts the row into a struct and assigns it to the provided pointer.
	// It returns an error if the conversion fails.
	ToStruct(p interface{}) error

	// String returns a string representation of the row.
	String() string

	BoolByIndex(i int) (*bool, error)
	IntByIndex(i int) (*int32, error)
	LongByIndex(i int) (*int64, error)
	RealByIndex(i int) (*float64, error)
	DecimalByIndex(i int) (*decimal.Decimal, error)
	StringByIndex(i int) (string, error)
	DynamicByIndex(i int) ([]byte, error)
	DateTimeByIndex(i int) (*time.Time, error)
	TimespanByIndex(i int) (*time.Duration, error)
	GuidByIndex(i int) (*uuid.UUID, error)

	BoolByName(name string) (*bool, error)
	IntByName(name string) (*int32, error)
	LongByName(name string) (*int64, error)
	RealByName(name string) (*float64, error)
	DecimalByName(name string) (*decimal.Decimal, error)
	StringByName(name string) (string, error)
	DynamicByName(name string) ([]byte, error)
	DateTimeByName(name string) (*time.Time, error)
	TimespanByName(name string) (*time.Duration, error)
	GuidByName(name string) (*uuid.UUID, error)
}

type RowResult interface {
	Row() Row
	Err() error
}

type StructResult[T any] struct {
	Out T
	Err error
}

type Table interface {
	BaseTable
	Rows() []Row
}

type TableResult interface {
	Table() IterativeTable
	Err() error
}