concurrency

Documentation

Index

• type CheckpointManager
  • func NewCheckpointManager(transaction_manager *access.TransactionManager, ...) *CheckpointManager
  • func (checkpoint_manager *CheckpointManager) BeginCheckpoint()
  • func (checkpoint_manager *CheckpointManager) EndCheckpoint()
  • func (checkpoint_manager *CheckpointManager) IsCheckpointActive() bool
  • func (checkpoint_manager *CheckpointManager) StartCheckpointTh()
  • func (checkpoint_manager *CheckpointManager) StopCheckpointTh()

Types

type CheckpointManager

type CheckpointManager struct {
	// contains filtered or unexported fields
}

*

• CheckpointManager creates consistent checkpoints by blocking all other transactions temporarily.

func NewCheckpointManager

func NewCheckpointManager(
	transaction_manager *access.TransactionManager,
	log_manager *recovery.LogManager,
	buffer_pool_manager *buffer.BufferPoolManager) *CheckpointManager

func (*CheckpointManager) BeginCheckpoint

func (checkpoint_manager *CheckpointManager) BeginCheckpoint()

func (*CheckpointManager) EndCheckpoint

func (checkpoint_manager *CheckpointManager) EndCheckpoint()

func (*CheckpointManager) IsCheckpointActive

func (checkpoint_manager *CheckpointManager) IsCheckpointActive() bool

func (*CheckpointManager) StartCheckpointTh

func (checkpoint_manager *CheckpointManager) StartCheckpointTh()

func (*CheckpointManager) StopCheckpointTh

func (checkpoint_manager *CheckpointManager) StopCheckpointTh()