hugr

Jun 5, 2025

Changes in this version

type Client

+ func (c *Client) DescribeDataSource(ctx context.Context, name string, self bool) (string, error)

type Service

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

May 13, 2025

Changes in this version

+ type Client struct

+ func NewClient(url string, opts ...Option) *Client

+ func (c *Client) DataSourceStatus(ctx context.Context, name string) (string, error)

+ func (c *Client) LoadDataSource(ctx context.Context, name string) error

+ func (c *Client) Ping(ctx context.Context) (string, error)

+ func (c *Client) Query(ctx context.Context, query string, vars map[string]any) (*types.Response, error)

+ func (c *Client) RegisterDataSource(ctx context.Context, ds types.DataSource) error

+ func (c *Client) UnloadDataSource(ctx context.Context, name string) error

+ type ClientConfig struct

+ Timeout time.Duration

+ Transport http.RoundTripper

+ type Info struct

+ AdminUI bool

+ AllowParallel bool

+ Auth []auth.ProviderInfo

+ Cache cache.Config

+ CoreDB coredb.Info

+ Debug bool

+ DuckDB db.Config

+ MaxDepth int

+ MaxParallelQueries int

+ type Option func(*ClientConfig)

+ func WithApiKey(apiKey string) Option

+ func WithApiKeyCustomHeader(apiKey, header string) Option

+ func WithTimeout(timeout time.Duration) Option

+ func WithToken(token string) Option

+ func WithTransport(transport http.RoundTripper) Option

+ func WithUserInfo(id, name string) Option

+ func WithUserInfoCustomHeader(id, name, idHeader, nameHeader string) Option

+ func WithUserRole(role string) Option

+ func WithUserRoleCustomHeader(role, header string) Option

type Service

+ func (s *Service) CoreDBVersion() coredb.Info

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

+ func (s *Service) Info() Info

Apr 30, 2025

Changes in this version

type Service

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

+ func (s *Service) RegisterDataSource(ctx context.Context, ds types.DataSource) error

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

Apr 9, 2025

Changes in this version

+ var ErrParallelMutationNotSupported = errors.New("parallel mutation queries are not supported")

+ type Config struct

+ AdminUI bool

+ AdminUIFetchPath string

+ AllowParallel bool

+ Auth *auth.Config

+ Cache cache.Config

+ CoreDB *coredb.Source

+ DB db.Config

+ Debug bool

+ MaxDepth int

+ MaxParallelQueries int

+ type JQRequest struct

+ JQ string

+ Query Request

+ type Request struct

+ OperationName string

+ Query string

+ Variables map[string]interface{}

+ type Service struct

+ func New(config Config) *Service

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

+ func (s *Service) Close() error

+ func (s *Service) Commit(ctx context.Context) error

+ func (s *Service) ContextWithTx(ctx context.Context) (context.Context, error)

+ func (s *Service) Init(ctx context.Context) (err error)

+ func (s *Service) ProcessQuery(ctx context.Context, catalog string, req Request) types.Response

+ func (s *Service) Query(ctx context.Context, query string, vars map[string]any) (*types.Response, error)

+ func (s *Service) QueryCatalog(ctx context.Context, catalog, query string, vars map[string]any) (*types.Response, error)

+ func (s *Service) Rollback(ctx context.Context) error

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

+ func (s *Service) ServeHTTP(w http.ResponseWriter, r *http.Request)