engine

Documentation

Index

• Variables
• type BatchGuard
  • func NewBatchGuard(b arrow.RecordBatch) *BatchGuard
  • func (g *BatchGuard) Release()
  • func (g *BatchGuard) Retain() arrow.RecordBatch
• type Config
• type Engine
  • func New(cfg Config) (Engine, error)
• type StreamChunk

Variables

var (
	ErrInvalidSQL = status.Error(codes.InvalidArgument, "invalid SQL statement")
)

Types

type BatchGuard

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

func NewBatchGuard

func NewBatchGuard(b arrow.RecordBatch) *BatchGuard

func (*BatchGuard) Release

func (g *BatchGuard) Release()

func (*BatchGuard) Retain

func (g *BatchGuard) Retain() arrow.RecordBatch

type Config

type Config struct {
	DBPath               string
	MaxConcurrentQueries int
	SchemaProbeTimeout   time.Duration
	ReadOnly             bool
	Logger               *slog.Logger
	DevMode              bool
}

type Engine

type Engine interface {
	BuildStream(ctx context.Context, sql string, params arrow.RecordBatch) (*arrow.Schema, <-chan StreamChunk, error)
	AcquireQuerySlot(ctx context.Context) error
	ReleaseQuerySlot()
	DeriveSchema(ctx context.Context, sql string) (*arrow.Schema, error)
	ExecuteUpdate(ctx context.Context, sql string) (int64, error)
	Allocator() memory.Allocator
	Close() error
}

func New

func New(cfg Config) (Engine, error)

type StreamChunk

type StreamChunk = flight.StreamChunk