Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type AccessMethods ¶
type AccessMethods interface {
}
type BufferPool ¶
type BufferPool interface {
}
type Coordinator ¶
type Coordinator interface {
Statement
// Begin a new transaction.
Begin() (Coordinator, error)
// Commit the current transaction.
Commit() acid_dto.CommitCoDomain
// Rollback the current transaction.
Rollback() acid_dto.CommitCoDomain
// Enqueue a transaction operation.
// This method will return an error
// in the case that the transaction
// context disallows a particular
// operation or type of operation.
Enqueue(Statement) error
// Get the depth of transaction nesting.
Depth() int
// Get the parent transaction manager.
GetParent() (Coordinator, bool)
//
IsRoot() bool
}
The transaction coordinator ensures that undo and redo logs are kept and that 2PC is performed.
type LockManager ¶
type LockManager interface {
}
type LogManager ¶
type LogManager interface {
}
type Orchestrator ¶
type Orchestrator interface {
ProcessQueryOrQueries(
handlerCtx handler.HandlerContext,
) ([]internaldto.ExecutorOutput, bool)
}
func NewOrchestrator ¶ added in v0.9.250
func NewOrchestrator(handlerCtx handler.HandlerContext) (Orchestrator, error)
type Provider ¶
type Provider interface {
GetTSM(handlerCtx handler.HandlerContext) (tsm.TSM, error)
// contains filtered or unexported methods
}
The transaction provider is singleton that orchestrates transaction managers.
func GetProviderInstance ¶
func GetProviderInstance(ctx txn_context.ITransactionCoordinatorContext) (Provider, error)
type Statement ¶
type Statement interface {
Prepare() error
Execute() internaldto.ExecutorOutput
GetAST() (sqlparser.Statement, bool)
GetPrimitiveGraphHolder() (primitivegraph.PrimitiveGraphHolder, bool)
GetUndoLog() (binlog.LogEntry, bool)
GetRedoLog() (binlog.LogEntry, bool)
IsReadOnly() bool
IsBegin() bool
IsCommit() bool
IsExecuted() bool
IsRollback() bool
GetQuery() string
}
func NewStatement ¶
func NewStatement( query string, handlerCtx handler.HandlerContext, transactionContext txn_context.ITransactionContext, ) Statement
Click to show internal directories.
Click to hide internal directories.