query

Documentation

Overview

Executes a SQL request

Index

• Variables
• type NewQuery
  • func NewQueryFunc(tp elastictransport.Interface) NewQuery
• type Query
  • func New(tp elastictransport.Interface) *Query
  • func (r Query) Do(ctx context.Context) (*http.Response, error)
  • func (r *Query) Format(value string) *Query
  • func (r *Query) Header(key, value string) *Query
  • func (r *Query) HttpRequest(ctx context.Context) (*http.Request, error)
  • func (r *Query) Raw(raw json.RawMessage) *Query
  • func (r *Query) Request(req *Request) *Query
• type Request
  • func NewRequest() *Request
  • func (rb *Request) FromJSON(data string) (*Request, error)

Variables

var ErrBuildPath = errors.New("cannot build path, check for missing path parameters")

ErrBuildPath is returned in case of missing parameters within the build of the request.

Types

type NewQuery

type NewQuery func() *Query

NewQuery type alias for index.

func NewQueryFunc

func NewQueryFunc(tp elastictransport.Interface) NewQuery

NewQueryFunc returns a new instance of Query with the provided transport. Used in the index of the library this allows to retrieve every apis in once place.

type Query

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

func New

func New(tp elastictransport.Interface) *Query

Executes a SQL request

https://www.elastic.co/guide/en/elasticsearch/reference/current/sql-search-api.html

func (Query) Do

func (r Query) Do(ctx context.Context) (*http.Response, error)

Do runs the http.Request through the provided transport.

func (*Query) Format

func (r *Query) Format(value string) *Query

Format a short version of the Accept header, e.g. json, yaml API name: format

func (*Query) Header

func (r *Query) Header(key, value string) *Query

Header set a key, value pair in the Query headers map.

func (*Query) HttpRequest

func (r *Query) HttpRequest(ctx context.Context) (*http.Request, error)

HttpRequest returns the http.Request object built from the given parameters.

func (*Query) Raw

func (r *Query) Raw(raw json.RawMessage) *Query

Raw takes a json payload as input which is then passed to the http.Request If specified Raw takes precedence on Request method.

func (*Query) Request

func (r *Query) Request(req *Request) *Query

Request allows to set the request property with the appropriate payload.

type Request

type Request struct {

	// Catalog Default catalog (cluster) for queries. If unspecified, the queries execute on
	// the data in the local cluster only.
	Catalog  *string `json:"catalog,omitempty"`
	Columnar *bool   `json:"columnar,omitempty"`
	Cursor   *string `json:"cursor,omitempty"`
	// FetchSize The maximum number of rows (or entries) to return in one response
	FetchSize *int `json:"fetch_size,omitempty"`
	// FieldMultiValueLeniency Throw an exception when encountering multiple values for a field (default) or
	// be lenient and return the first value from the list (without any guarantees
	// of what that will be - typically the first in natural ascending order).
	FieldMultiValueLeniency *bool `json:"field_multi_value_leniency,omitempty"`
	// Filter Optional Elasticsearch query DSL for additional filtering.
	Filter *types.Query `json:"filter,omitempty"`
	// IndexUsingFrozen If true, the search can run on frozen indices. Defaults to false.
	IndexUsingFrozen *bool `json:"index_using_frozen,omitempty"`
	// KeepAlive Retention period for an async or saved synchronous search.
	KeepAlive *types.Duration `json:"keep_alive,omitempty"`
	// KeepOnCompletion If true, Elasticsearch stores synchronous searches if you also specify the
	// wait_for_completion_timeout parameter. If false, Elasticsearch only stores
	// async searches that don’t finish before the wait_for_completion_timeout.
	KeepOnCompletion *bool `json:"keep_on_completion,omitempty"`
	// PageTimeout The timeout before a pagination request fails.
	PageTimeout *types.Duration `json:"page_timeout,omitempty"`
	// Params Values for parameters in the query.
	Params map[string]interface{} `json:"params,omitempty"`
	// Query SQL query to execute
	Query *string `json:"query,omitempty"`
	// RequestTimeout The timeout before the request fails.
	RequestTimeout *types.Duration `json:"request_timeout,omitempty"`
	// RuntimeMappings Defines one or more runtime fields in the search request. These fields take
	// precedence over mapped fields with the same name.
	RuntimeMappings map[string]types.RuntimeField `json:"runtime_mappings,omitempty"`
	// TimeZone Time-zone in ISO 8601 used for executing the query on the server. More
	// information available here.
	TimeZone *string `json:"time_zone,omitempty"`
	// WaitForCompletionTimeout Period to wait for complete results. Defaults to no timeout, meaning the
	// request waits for complete search results. If the search doesn’t finish
	// within this period, the search becomes async.
	WaitForCompletionTimeout *types.Duration `json:"wait_for_completion_timeout,omitempty"`
}

Request holds the request body struct for the package query

https://github.com/elastic/elasticsearch-specification/blob/555082f38110f65b60d470107d211fc354a5c55a/specification/sql/query/QuerySqlRequest.ts#L28-L111

func NewRequest

func NewRequest() *Request

NewRequest returns a Request

func (*Request) FromJSON

func (rb *Request) FromJSON(data string) (*Request, error)

FromJSON allows to load an arbitrary json into the request structure