tx

Documentation

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