Versions in this module Expand all Collapse all v0 v0.3.5 Mar 13, 2026 v0.3.4 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
Go to main page