types

Apr 26, 2026

Changes in this version

type Response

+ func (r *Response) ScanDataJSON(path string, dest any) error

Apr 22, 2026

Changes in this version

+ func Scan[T any](resp *Response, path string) (T, error)

type ArrowTable

+ GeometryInfo func() map[string]GeometryInfo

+ SetGeometryInfo func(info map[string]GeometryInfo)

type ArrowTableChunked

+ func (t *ArrowTableChunked) GeometryInfo() map[string]GeometryInfo

+ func (t *ArrowTableChunked) SetGeometryInfo(info map[string]GeometryInfo)

type ArrowTableStream

+ func (t *ArrowTableStream) GeometryInfo() map[string]GeometryInfo

+ func (t *ArrowTableStream) SetGeometryInfo(info map[string]GeometryInfo)

+ type GeometryInfo struct

+ Format string

+ SRID string

Apr 19, 2026

Changes in this version

+ var ErrGeometryDecode = errors.New("geometry decode")

+ var ErrScanAfterEnd = errors.New("types: Scan called after end of stream")

+ var ErrScanBeforeNext = errors.New("types: Scan called before Next")

+ var ErrScanClosed = errors.New("types: Rows is closed")

+ var ErrScanNilDest = errors.New("types: Scan dest is nil")

+ var ErrScanNotPointer = errors.New("types: Scan dest must be a non-nil pointer")

+ func RegisterGeometryDecoder(name string, fn GeometryDecoder)

type ArrowTable

+ Rows func() (Rows, error)

type ArrowTableChunked

+ func (t *ArrowTableChunked) Rows() (Rows, error)

type ArrowTableStream

+ func (t *ArrowTableStream) Rows() (Rows, error)

+ type GeometryDecoder func(arr arrow.Array, row int, fieldMeta arrow.Metadata) (orb.Geometry, error)

type Response

+ func (r *Response) Objects() []string

+ func (r *Response) ScanObject(path string, dest any) error

+ func (r *Response) ScanTable(path string, dest any) error

+ func (r *Response) Table(path string) (ArrowTable, error)

+ func (r *Response) Tables() []string

+ type Rows interface

+ Close func() error

+ Columns func() []string

+ Err func() error

+ Next func() bool

+ Scan func(dest any) error

Apr 14, 2026

Changes in this version

type LLMMessage

+ Thinking string

+ ThoughtSignature string

type LLMResult

+ Thinking string

+ ThoughtSignature string

type LLMStreamEvent

+ Thinking string

+ ThoughtSignature string

Apr 12, 2026

Changes in this version

type Subscription

+ func (s *Subscription) Err() error

+ func (s *Subscription) SetErr(err error)

Apr 9, 2026

Changes in this version

+ func AsUser(ctx context.Context, userId, userName, role string) context.Context

+ type UserIdentity struct

+ Role string

+ UserId string

+ UserName string

+ func AsUserFromContext(ctx context.Context) *UserIdentity

Apr 8, 2026

Changes in this version

type LLMOptions

+ ThinkingBudget int

+ type LLMStreamEvent struct

+ CompletionTokens int

+ Content string

+ FinishReason string

+ Model string

+ PromptTokens int

+ ToolCalls string

+ Type string

type Querier

+ Subscribe func(ctx context.Context, query string, vars map[string]any) (*Subscription, error)

+ type Subscription struct

+ Cancel func()

+ Events <-chan SubscriptionEvent

+ type SubscriptionEvent struct

+ Path string

+ Reader array.RecordReader

Apr 7, 2026

Changes in this version

+ type UnloadOpt func(*UnloadOpts)

+ func WithHardUnload() UnloadOpt

+ type UnloadOpts struct

+ Hard bool

Apr 6, 2026

Changes in this version

+ type EmbeddingResult struct

+ PromptTokens int

+ TokenCount int

+ Vector Vector

+ type EmbeddingsResult struct

+ PromptTokens int

+ TokenCount int

+ Vectors []Vector

+ type LLMMessage struct

+ Content string

+ Role string

+ ToolCallID string

+ ToolCalls []LLMToolCall

+ type LLMOptions struct

+ MaxTokens int

+ Stop []string

+ Temperature float64

+ ToolChoice string

+ Tools []LLMTool

+ TopP float64

+ type LLMResult struct

+ CompletionTokens int

+ Content string

+ FinishReason string

+ LatencyMs int

+ Model string

+ PromptTokens int

+ Provider string

+ ToolCalls []LLMToolCall

+ TotalTokens int

+ type LLMTool struct

+ Description string

+ Name string

+ Parameters any

+ type LLMToolCall struct

+ Arguments any

+ ID string

+ Name string

+ type ModelInfo struct

+ Model string

+ Name string

+ Provider string

+ Type string

+ type Vector []float64

+ func ParseVector(data any) (Vector, error)

+ func (v *Vector) UnmarshalJSON(data []byte) error

+ func (v Vector) Len() int

+ func (v Vector) MarshalJSON() ([]byte, error)

Apr 2, 2026

Changes in this version

+ type DateTime time.Time

Mar 17, 2026

Changes in this version

+ func FlattenRecord(rec arrow.RecordBatch, mem memory.Allocator) arrow.RecordBatch

+ func FlattenSchema(schema *arrow.Schema) *arrow.Schema

+ func NeedsFlatten(schema *arrow.Schema) bool

Mar 13, 2026

Changes in this version

+ var ErrNoData = errors.New("no data")

+ var ErrWrongDataPath = errors.New("wrong data path")

+ func ColumnValue(a arrow.Array, i int) any

+ func ContextWithValidateOnly(ctx context.Context) context.Context

+ func DataClose(data any)

+ func ExtractResponseData(path string, data map[string]any) any

+ func IsValidateOnlyContext(ctx context.Context) bool

+ func ParseJsonValue(v any) (map[string]interface{}, error)

+ func RecordToJSON(rec arrow.RecordBatch, asArray bool, w io.Writer) error

+ func RecordsColNums(rr []arrow.RecordBatch) int64

+ func RecordsRowNums(rr []arrow.RecordBatch) int64

+ func ReleaseRecords(rr []arrow.RecordBatch)

+ func RetainRecords(rr []arrow.RecordBatch)

+ func WarpGraphQLError(err error) gqlerror.List

+ type ArrowTable interface

+ DecodeMsgpack func(dec *msgpack.Decoder) error

+ EncodeMsgpack func(enc *msgpack.Encoder) error

+ Info func() string

+ MarshalJSON func() ([]byte, error)

+ Reader func(retain bool) (array.RecordReader, error)

+ Records func() ([]arrow.RecordBatch, error)

+ Release func()

+ Retain func()

+ SetInfo func(info string)

+ type ArrowTableChunked struct

+ func NewArrowTable() *ArrowTableChunked

+ func NewArrowTableFromReader(reader array.RecordReader) (*ArrowTableChunked, error)

+ func (t *ArrowTableChunked) Append(rec arrow.RecordBatch)

+ func (t *ArrowTableChunked) Chunk(i int) arrow.RecordBatch

+ func (t *ArrowTableChunked) DecodeMsgpack(dec *msgpack.Decoder) error

+ func (t *ArrowTableChunked) EncodeMsgpack(enc *msgpack.Encoder) error

+ func (t *ArrowTableChunked) Info() string

+ func (t *ArrowTableChunked) MarshalJSON() ([]byte, error)

+ func (t *ArrowTableChunked) NumChunks() int

+ func (t *ArrowTableChunked) NumCols() int

+ func (t *ArrowTableChunked) NumRows() int

+ func (t *ArrowTableChunked) Reader(retain bool) (array.RecordReader, error)

+ func (t *ArrowTableChunked) Records() ([]arrow.RecordBatch, error)

+ func (t *ArrowTableChunked) Release()

+ func (t *ArrowTableChunked) Retain()

+ func (t *ArrowTableChunked) RowData(i int) (map[string]any, bool)

+ func (t *ArrowTableChunked) SetInfo(info string)

+ type ArrowTableStream struct

+ func NewArrowTableStream(reader array.RecordReader) *ArrowTableStream

+ func (t *ArrowTableStream) DecodeMsgpack(dec *msgpack.Decoder) error

+ func (t *ArrowTableStream) EncodeMsgpack(enc *msgpack.Encoder) error

+ func (t *ArrowTableStream) Info() string

+ func (t *ArrowTableStream) MarshalJSON() ([]byte, error)

+ func (t *ArrowTableStream) Reader(retain bool) (array.RecordReader, error)

+ func (t *ArrowTableStream) Records() ([]arrow.RecordBatch, error)

+ func (t *ArrowTableStream) Release()

+ func (t *ArrowTableStream) Retain()

+ func (t *ArrowTableStream) SetInfo(info string)

+ type CatalogSource struct

+ Description string

+ Name string

+ Path string

+ Type CatalogSourceType

+ type CatalogSourceType string

+ type DataSource struct

+ AsModule bool

+ Description string

+ Disabled bool

+ Name string

+ Path string

+ Prefix string

+ ReadOnly bool

+ SelfDefined bool

+ Sources []CatalogSource

+ Type DataSourceType

+ type DataSourceType string

+ type JQRequest struct

+ JQ string

+ Query Request

+ type JsonValue string

+ func (v *JsonValue) MarshalJSON() ([]byte, error)

+ type OperationResult struct

+ LastId int

+ Msg string

+ Rows int

+ Succeed bool

+ func ErrResult(err error) *OperationResult

+ func Result(msg string, rows, lastId int) *OperationResult

+ func SQLError(msg string, err error) *OperationResult

+ func SQLResult(msg string, res sql.Result) *OperationResult

+ func (r *OperationResult) CollectSQL(res sql.Result)

+ func (r *OperationResult) ToDuckdb() map[string]any

+ type Querier interface

+ DataSourceStatus func(ctx context.Context, name string) (string, error)

+ DescribeDataSource func(ctx context.Context, name string, self bool) (string, error)

+ LoadDataSource func(ctx context.Context, name string) error

+ Query func(ctx context.Context, query string, vars map[string]any) (*Response, error)

+ RegisterDataSource func(ctx context.Context, ds DataSource) error

+ UnloadDataSource func(ctx context.Context, name string) error

+ type Request struct

+ OperationName string

+ Query string

+ ValidateOnly bool

+ Variables map[string]any

+ type Response struct

+ Data map[string]any

+ Errors gqlerror.List

+ Extensions map[string]any

+ func ErrResponse(err error) Response

+ func (r *Response) Close()

+ func (r *Response) DataPart(path string) any

+ func (r *Response) Err() error

+ func (r *Response) ScanData(path string, dest interface{}) error