tsm_physio

Documentation

Index

• func GetTSM(handlerCtx handler.HandlerContext) (tsm.TSM, error)
• type AccessMethods
• type BufferPool
• type Coordinator
• type LockManager
• type LogManager
• type Orchestrator
• type Provider
  • func GetProviderInstance(ctx txn_context.ITransactionCoordinatorContext) (Provider, error)
• type Statement
  • func NewStatement(query string, handlerCtx handler.HandlerContext, ...) Statement

Functions

func GetTSM

func GetTSM(handlerCtx handler.HandlerContext) (tsm.TSM, error)

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)
}

type Provider

type Provider interface {
	// Create a new transaction manager.
	GetOrchestrator(handler.HandlerContext) (Orchestrator, error)
	GetTSM(handlerCtx handler.HandlerContext) (tsm.TSM, error)
}

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