client

Apr 9, 2026

Changes in this version

+ func AsUser(ctx context.Context, userId, userName, role string) context.Context

type Client

+ func (c *Client) VerifyAdmin(ctx context.Context) error

type Option

+ func WithSecretKeyAuth(key string) Option

Apr 8, 2026

Changes in this version

type Client

+ func (c *Client) CloseSubscriptions()

+ func (c *Client) NewSubscriptionConn(ctx context.Context) (*SubscriptionConn, error)

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

type ClientConfig

+ SubPool SubscriptionPoolConfig

type Option

+ func WithSubscriptionPool(max, idle int) Option

+ type SubscriptionConn struct

+ func (sc *SubscriptionConn) Close()

+ func (sc *SubscriptionConn) Count() int

+ func (sc *SubscriptionConn) Subscribe(ctx context.Context, query string, vars map[string]any) (*types.Subscription, error)

+ type SubscriptionPoolConfig struct

+ IdleConn int

+ MaxConns int

Apr 2, 2026

Changes in this version

+ type ApplicationOptions func(*serveConfig)

+ func WithAllocator(alloc memory.Allocator) ApplicationOptions

+ func WithLogLevel(level *slog.Level) ApplicationOptions

+ func WithLogger(logger *slog.Logger) ApplicationOptions

+ func WithMaxMessageSize(size int) ApplicationOptions

+ func WithSecretKey(key string) ApplicationOptions

+ func WithStartupTimeout(timeout time.Duration) ApplicationOptions

type Client

+ func (c *Client) RunApplication(ctx context.Context, application app.Application, opts ...ApplicationOptions) error

type Option

+ func WithTimezone(timezone string) Option

+ func WithoutTimezone() Option

Mar 17, 2026

Changes in this version

type ClientConfig

+ ArrowStructFlatten bool

type Option

+ func WithArrowStructFlatten() Option

Mar 13, 2026

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) DescribeDataSource(ctx context.Context, name string, self bool) (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) QueryJSON(ctx context.Context, req types.JQRequest) (*types.JsonValue, error)

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

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

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

+ func (c *Client) ValidateQueryJSON(ctx context.Context, req types.JQRequest) error

+ type ClientConfig struct

+ HttpUrl string

+ JQQueryUrl string

+ Timeout time.Duration

+ Transport http.RoundTripper

+ type Option func(*ClientConfig)

+ func WithApiKey(apiKey string) Option

+ func WithApiKeyCustomHeader(apiKey, header string) Option

+ func WithHttpUrl(httpUrl string) Option

+ func WithJQQueryUrl(jq 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