ha

Documentation

Index

• type Client
  • func New(client ...Querier) *Client
  • func (ha *Client) Query(ctx context.Context, query string, options ...option.QueryOption) (openapi.QueryResponse, []error)
• type Querier

Types

type Client

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

func New

func New(client ...Querier) *Client

New creates a new HA query client, and takes a list of rockset.RockClient which will be used for running queries in parallel.

func (*Client) Query

func (ha *Client) Query(ctx context.Context, query string,
	options ...option.QueryOption) (openapi.QueryResponse, []error)

Query executes a SQL query in parallel, and returns the first response.

type Querier

type Querier interface {
	Query(context.Context, string, ...option.QueryOption) (openapi.QueryResponse, error)
}

Querier is an interface implemented by the rockset.RockClient