package tx

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

Index ¶

• func BeginTx(opts ...Option) beginTxOptions
• func WithOnlineReadOnly(opts ...OnlineReadOnlyOption) onlineReadOnlySettingsOption
• func WithTx(t tx.Identifier) txIDTxControlOption
• func WithTxID(txID string) txIDTxControlOption
• type Control
• func DefaultTxControl() *Control
• func NewControl(opts ...ControlOption) *Control
• func NoTx() *Control
• func OnlineReadOnlyTxControl(opts ...OnlineReadOnlyOption) *Control
• func SerializableReadWriteTxControl(opts ...ControlOption) *Control
• func SnapshotReadOnlyTxControl() *Control
• func StaleReadOnlyTxControl() *Control
• func (ctrl *Control) Selector() Selector
• func (ctrl *Control) ToYDB(a *allocator.Allocator) *Ydb_Query.TransactionControl
• type ControlOption
• func CommitTx() ControlOption
• type OnlineReadOnlyOption
• func WithInconsistentReads() OnlineReadOnlyOption
• type Option
• func WithDefaultTxMode() Option
• func WithSerializableReadWrite() Option
• func WithSnapshotReadOnly() Option
• func WithStaleReadOnly() Option
• type Selector
• type Settings
• func NewSettings(opts ...Option) Settings
• func (opts Settings) ToYDB(a *allocator.Allocator) *Ydb_Query.TransactionSettings

Functions ¶

func BeginTx ¶

func BeginTx(opts ...Option) beginTxOptions

BeginTx returns selector transaction control option

func WithOnlineReadOnly ¶

func WithOnlineReadOnly(opts ...OnlineReadOnlyOption) onlineReadOnlySettingsOption

func WithTx ¶

func WithTx(t tx.Identifier) txIDTxControlOption

func WithTxID ¶

func WithTxID(txID string) txIDTxControlOption

Types ¶

type Control ¶

type Control struct {
	Commit bool
	// contains filtered or unexported fields
}

func DefaultTxControl ¶

func DefaultTxControl() *Control

DefaultTxControl returns default transaction control with serializable read-write isolation mode and auto-commit

func NewControl ¶

func NewControl(opts ...ControlOption) *Control

NewControl makes transaction control from given options

func NoTx ¶

func NoTx() *Control

func OnlineReadOnlyTxControl ¶

func OnlineReadOnlyTxControl(opts ...OnlineReadOnlyOption) *Control

OnlineReadOnlyTxControl returns online read-only transaction control

func SerializableReadWriteTxControl ¶

func SerializableReadWriteTxControl(opts ...ControlOption) *Control

SerializableReadWriteTxControl returns transaction control with serializable read-write isolation mode

func SnapshotReadOnlyTxControl ¶

func SnapshotReadOnlyTxControl() *Control

SnapshotReadOnlyTxControl returns snapshot read-only transaction control

func StaleReadOnlyTxControl ¶

func StaleReadOnlyTxControl() *Control

StaleReadOnlyTxControl returns stale read-only transaction control

func (*Control) Selector ¶

func (ctrl *Control) Selector() Selector

func (*Control) ToYDB ¶

func (ctrl *Control) ToYDB(a *allocator.Allocator) *Ydb_Query.TransactionControl

type ControlOption ¶

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

func CommitTx ¶

func CommitTx() ControlOption

CommitTx returns commit transaction control option

type OnlineReadOnlyOption ¶

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

func WithInconsistentReads ¶

func WithInconsistentReads() OnlineReadOnlyOption

type Option ¶

type Option interface {
	ApplyTxSettingsOption(a *allocator.Allocator, txSettings *Ydb_Query.TransactionSettings)
}

Transaction settings options

func WithDefaultTxMode ¶

func WithDefaultTxMode() Option

func WithSerializableReadWrite ¶

func WithSerializableReadWrite() Option

func WithSnapshotReadOnly ¶

func WithSnapshotReadOnly() Option

func WithStaleReadOnly ¶

func WithStaleReadOnly() Option

type Selector ¶

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

type Settings ¶

type Settings []Option

Transaction settings options

func NewSettings ¶

func NewSettings(opts ...Option) Settings

NewSettings returns transaction settings

func (Settings) ToYDB ¶

func (opts Settings) ToYDB(a *allocator.Allocator) *Ydb_Query.TransactionSettings

Source Files ¶

control.go settings.go