datasources

package

v0.1.11 Latest Latest Go to latest Published: May 14, 2025 License: MIT Imports: 23 Imported by: 0

Details

This section is empty.

This section is empty.

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

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

func New(qe types.Querier, db *db.Pool, cs *catalogs.Service) *Service

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

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

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

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

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

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

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

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

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

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

func (s *Service) Schema() *ast.Schema

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

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