mvcc

Documentation

Index

• type MVCCManager
  • func NewMVCCManager(lastConfirmedTimeTick uint64) *MVCCManager
  • func (cm *MVCCManager) GetMVCCOfVChannel(vchannel string) VChannelMVCC
  • func (cm *MVCCManager) UpdateMVCC(msg message.MutableMessage)
• type VChannelMVCC

Types

type MVCCManager

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

MVCCManager is the manager that manages all the mvcc state of one wal. It keeps the last confirmed timestamp as mvcc of one pchannel and maximum timetick persisted into the wal of each vchannel.

func NewMVCCManager

func NewMVCCManager(lastConfirmedTimeTick uint64) *MVCCManager

NewMVCCManager creates a new mvcc timestamp manager.

func (*MVCCManager) GetMVCCOfVChannel

func (cm *MVCCManager) GetMVCCOfVChannel(vchannel string) VChannelMVCC

GetMVCCOfVChannel gets the mvcc of the vchannel.

func (*MVCCManager) UpdateMVCC

func (cm *MVCCManager) UpdateMVCC(msg message.MutableMessage)

UpdateMVCC updates the mvcc state by incoming message.

type VChannelMVCC

type VChannelMVCC struct {
	Timetick  uint64 // the timetick of the mvcc.
	Confirmed bool   // the mvcc is confirmed by the timeticksync operation.
}

VChannelMVCC is a mvcc of one vchannel which is used to identify the maximum timetick that is persisted into the wal of one vchannel. The state of mvcc that is confirmed if the timetick is synced by timeticksync message, otherwise, the mvcc is not confirmed.