transact

Aug 17, 2023

Changes in this version

type Coordinator

+ func NewCoordinator(handlerCtx handler.HandlerContext, maxTxnDepth int) Coordinator

+ type Orchestrator interface

+ ProcessQueryOrQueries func(handlerCtx handler.HandlerContext) ([]internaldto.ExecutorOutput, bool)

type Provider

+ GetOrchestrator func(handler.HandlerContext) (Orchestrator, error)

type Statement

+ GetPrimitiveGraphHolder func() (primitivegraph.PrimitiveGraphHolder, bool)

+ GetQuery func() string

+ IsExecuted func() bool

May 29, 2023

Changes in this version

+ type Coordinator interface

+ Begin func() (Coordinator, error)

+ Commit func() acid_dto.CommitCoDomain

+ Depth func() int

+ Enqueue func(Statement) error

+ GetParent func() (Coordinator, bool)

+ IsRoot func() bool

+ Rollback func() error

+ func NewManager(maxTxnDepth int) Coordinator

+ type Provider interface

+ NewTxnCoordinator func() (Coordinator, error)

+ func GetProviderInstance(ctx txn_context.ITransactionCoordinatorContext) (Provider, error)

+ type Statement interface

+ Execute func() internaldto.ExecutorOutput

+ GetAST func() (sqlparser.Statement, bool)

+ GetRedoLog func() (binlog.LogEntry, bool)

+ GetUndoLog func() (binlog.LogEntry, bool)

+ IsBegin func() bool

+ IsCommit func() bool

+ IsReadOnly func() bool

+ IsRollback func() bool

+ Prepare func() error

+ func NewStatement(query string, handlerCtx handler.HandlerContext, ...) Statement