engine

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

type Config struct {
	DBPath               string
	MaxConcurrentQueries int
	SchemaProbeTimeout   time.Duration
	ReadOnly             bool
	Logger               *slog.Logger
	DevMode              bool
	ADBCManager          *adbc.Manager
	Telemetry            telemetry.Publisher
}

type Engine interface {
	BuildStream(ctx context.Context, sql string, params arrow.RecordBatch) (*arrow.Schema, <-chan StreamChunk, error)
	IngestStream(ctx context.Context, table string, reader array.RecordReader, opts IngestOptions) (int64, 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
}

type IngestOptions struct {
	Catalog       string
	DBSchema      string
	Temporary     bool
	TransactionID []byte
	IngestMode    string
	ExtraOptions  map[string]string
	// MaxUncommittedBytes bounds in-memory uncommitted segment storage.
	// Zero uses a safe default.
	MaxUncommittedBytes int64
}

type StreamChunk = flight.StreamChunk