package options

import "github.com/ydb-platform/ydb-go-sdk/v3/internal/query/options"

Index

Constants

const (
	SyntaxYQL        = Syntax(Ydb_Query.Syntax_SYNTAX_YQL_V1)
	SyntaxPostgreSQL = Syntax(Ydb_Query.Syntax_SYNTAX_PG)
)

Functions

func ExecuteSettings

func ExecuteSettings(opts ...Execute) *executeSettings

func ParseDoOpts

func ParseDoOpts(t *trace.Query, opts ...DoOption) (s *doSettings)

func ParseDoTxOpts

func ParseDoTxOpts(t *trace.Query, opts ...DoTxOption) (s *doTxSettings)

func WithCallOptions

func WithCallOptions(opts ...grpc.CallOption) callOptionsOption

func WithCommit

func WithCommit() txCommitOption

func WithExecMode

func WithExecMode(mode ExecMode) execModeOption

func WithParameters

func WithParameters(params params.Parameters) parametersOption

func WithResourcePool

func WithResourcePool(id string) resourcePool

func WithResponsePartLimitSizeBytes

func WithResponsePartLimitSizeBytes(size int64) responsePartLimitBytes

func WithStatsMode

func WithStatsMode(mode StatsMode, callback func(stats.QueryStats)) statsModeOption

func WithSyntax

func WithSyntax(syntax Syntax) syntaxOption

func WithTxControl

func WithTxControl(txControl *tx.Control) *txControlOption

func WithTxSettings

func WithTxSettings(txSettings tx.Settings) doTxSettingsOption

Types

type DoOption

type DoOption interface {
	// contains filtered or unexported methods
}

type DoTxOption

type DoTxOption interface {
	// contains filtered or unexported methods
}

type ExecMode

type ExecMode Ydb_Query.ExecMode

type Execute

type Execute interface {
	// contains filtered or unexported methods
}

Execute is an interface for execute method options

type ExecuteNoTx

type ExecuteNoTx interface {
	// contains filtered or unexported methods
}

type ExecuteScriptOperation

type ExecuteScriptOperation struct {
	ID            string
	ConsumedUnits float64
	Metadata      *MetadataExecuteQuery
}

type FetchScriptOption

type FetchScriptOption func(request *FetchScriptResultsRequest)

func WithFetchToken

func WithFetchToken(fetchToken string) FetchScriptOption

func WithResultSetIndex

func WithResultSetIndex(resultSetIndex int64) FetchScriptOption

func WithRowsLimit

func WithRowsLimit(rowsLimit int64) FetchScriptOption

type FetchScriptResult

type FetchScriptResult struct {
	ResultSetIndex int64
	ResultSet      result.Set
	NextToken      string
}

type FetchScriptResultsRequest

type FetchScriptResultsRequest struct {
	Ydb_Query.FetchScriptResultsRequest

	Trace *trace.Query
}

type MetadataExecuteQuery

type MetadataExecuteQuery struct {
	ID     string
	Script struct {
		Syntax Syntax
		Query  string
	}
	Mode           ExecMode
	Stats          stats.QueryStats
	ResultSetsMeta []struct {
		Columns []struct {
			Name string
			Type types.Type
		}
	}
}

func ToMetadataExecuteQuery

func ToMetadataExecuteQuery(metadata *anypb.Any) *MetadataExecuteQuery

type RetryOptionsOption

type RetryOptionsOption []retry.Option

func WithIdempotent

func WithIdempotent() RetryOptionsOption

func WithLabel

func WithLabel(lbl string) RetryOptionsOption

func WithRetryBudget

func WithRetryBudget(b budget.Budget) RetryOptionsOption

type StatsMode

type StatsMode Ydb_Query.StatsMode

type Syntax

type Syntax Ydb_Query.Syntax

type TraceOption

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

func WithTrace

func WithTrace(t *trace.Query) TraceOption

Source Files

execute.go execute_script.go retry.go

Version
v3.99.7
Published
Feb 7, 2025
Platform
linux/amd64
Imports
11 packages
Last checked
1 minute ago

Tools for package owners.