datasources

package

v0.3.29 Latest Latest Go to latest Published: Apr 14, 2026 License: MIT Imports: 35 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/hugr-lab/query-engine

Links

Open Source Insights

Documentation ¶

Index ¶

func NewDataSource(ctx context.Context, ds types.DataSource, attached bool) (Source, error)
type EmbedderSettings
type Service
- func New(qe types.Querier, db *db.Pool, cs catalog.Manager, ...) *Service

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func NewDataSource ¶

func NewDataSource(ctx context.Context, ds types.DataSource, attached bool) (Source, error)

Types ¶

type EmbedderSettings ¶ added in v0.3.11

type EmbedderSettings struct {
	IsEnabled  bool
	Name       string
	Model      string
	Dimensions int
}

type Service ¶

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

func New ¶

func New(qe types.Querier, db *db.Pool, cs catalog.Manager, embederSettings EmbedderSettings, hbConfig ...HeartbeatConfig) *Service

func (*Service) Attach ¶

func (s *Service) Attach(ctx context.Context, name string) error

func (*Service) AttachRuntimeSource ¶

func (s *Service) AttachRuntimeSource(ctx context.Context, source RuntimeSource) error

func (*Service) CreateEmbedding ¶ added in v0.1.28

func (s *Service) CreateEmbedding(ctx context.Context, source, input string) (*EmbeddingResult, error)

func (*Service) CreateEmbeddings ¶ added in v0.1.28

func (s *Service) CreateEmbeddings(ctx context.Context, source string, input []string) (*EmbeddingsResult, error)

func (*Service) DataSource ¶

func (s *Service) DataSource(name string) (Source, error)

func (*Service) DescribeDataSource ¶ added in v0.1.14

func (s *Service) DescribeDataSource(ctx context.Context, name string, self bool) (string, error)

func (*Service) Detach ¶

func (s *Service) Detach(ctx context.Context, name string, db *db.Pool, hard bool) error

func (*Service) Engine ¶

func (s *Service) Engine(name string) (engines.Engine, error)

func (*Service) HttpRequest ¶

func (s *Service) HttpRequest(ctx context.Context, source, path, method, headers, params, body, jqq string) (any, error)

func (*Service) IsAttached ¶

func (s *Service) IsAttached(name string) bool

func (*Service) LoadDataSource ¶ added in v0.1.8

func (s *Service) LoadDataSource(ctx context.Context, name string) error

func (*Service) Register ¶

func (s *Service) Register(ctx context.Context, name string, ds Source) error

func (*Service) RegisterUDF ¶

func (s *Service) RegisterUDF(ctx context.Context) error

func (*Service) Resolve ¶ added in v0.3.16

func (s *Service) Resolve(name string) (Source, error)

Resolve implements DataSourceResolver.

func (*Service) ResolveAll ¶ added in v0.3.16

func (s *Service) ResolveAll() []Source

ResolveAll implements DataSourceResolver — returns all registered data sources.

func (*Service) RuntimeSourceByName ¶ added in v0.3.20

func (s *Service) RuntimeSourceByName(name string) (RuntimeSource, bool)

RuntimeSourceByName returns a runtime source by name.

func (*Service) SetSkipCatalogOps ¶ added in v0.3.0

func (s *Service) SetSkipCatalogOps(skip bool)

SetSkipCatalogOps disables schema DB writes on Attach/Detach. Used for read-only CoreDB and cluster worker nodes.

func (*Service) UnloadDataSource ¶ added in v0.1.8

func (s *Service) UnloadDataSource(ctx context.Context, name string, hard bool) error

func (*Service) Unregister ¶

func (s *Service) Unregister(ctx context.Context, name string) error

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
sources
airport
duckdb
ducklake
embedding
extension
http
hugrapp
iceberg
llm Package llm implements LLM data source types for AI model providers.	Package llm implements LLM data source types for AI model providers.
mssql
mysql
postgres
ratelimit Package ratelimit provides request and token rate limiting for LLM sources.	Package ratelimit provides request and token rate limiting for LLM sources.
redis
runtime
runtime/auth
runtime/core-db
runtime/data-sources
runtime/db
runtime/ducklake
runtime/gis
runtime/meta-info
runtime/models
runtime/storage
runtime/store

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL