datasources

Documentation

Index

• func NewDataSource(ctx context.Context, ds types.DataSource, attached bool) (Source, error)
• type Service
  • 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) DescribeDataSource(ctx context.Context, name string, self bool) (string, 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

Functions

func NewDataSource

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

Types

type Service

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

func New

func New(qe types.Querier, db *db.Pool, cs *catalogs.Service) *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) DataSource

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

func (*Service) DescribeDataSource

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) 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

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) Schema

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

func (*Service) UnloadDataSource

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

func (*Service) Unregister

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