Documentation ¶
Index ¶
Constants ¶
View Source
const ( ReadKindMap = 0 ReadKindStorage = 1 )
View Source
const FlagDone = 0
View Source
const FlagEstimate = 1
Variables ¶
View Source
var ( ErrLowerIncarnation = errors.New("existing transaction value does not have lower incarnation") ErrInvalidKeyCellPath = errors.New("invalid key cell path, must already exist") )
Functions ¶
This section is empty.
Types ¶
type BaseReadWrite ¶
type ExecResult ¶
type ExecResult struct {
// contains filtered or unexported fields
}
type ExecTask ¶
type ExecTask interface {
Execute(rw BaseReadWrite) error
}
type ExecVersionView ¶
type ExecVersionView struct {
// contains filtered or unexported fields
}
func (*ExecVersionView) Execute ¶
func (ev *ExecVersionView) Execute() (er ExecResult)
func (*ExecVersionView) Write ¶
func (ev *ExecVersionView) Write(k, v []byte) error
type MVHashMap ¶
type MVHashMap struct {
// contains filtered or unexported fields
}
func MakeMVHashMap ¶
func MakeMVHashMap() *MVHashMap
func (*MVHashMap) MarkEstimate ¶
type ReadDescriptor ¶
type Scheduler ¶
type Scheduler struct {
// contains filtered or unexported fields
}
func MakeScheduler ¶
func MakeScheduler() *Scheduler
func (*Scheduler) NextTask ¶
func (s *Scheduler) NextTask() SchedulerTask
type SchedulerTask ¶
type SchedulerTask interface{}
type SchedulerTaskDone ¶
type SchedulerTaskDone struct{}
type TxnIndexCells ¶
type TxnIndexCells struct {
// contains filtered or unexported fields
}
Structure of tm (treemap): Key: TxnIndex Value: &WriteCell example: map[10:&{0 1 [53 48 101 114 58 49 49 101 114 58 53 101 114]}] map[TxnIndex:&{flag incarnation data}]
type TxnInput ¶
type TxnInput []ReadDescriptor
type TxnInputOutput ¶
type TxnInputOutput struct {
// contains filtered or unexported fields
}
func ExecuteParallel ¶
func ExecuteParallel(tasks []ExecTask, rw BaseReadWrite) (lastTxIO *TxnInputOutput, err error)
func MakeTxnInputOutput ¶
func MakeTxnInputOutput(numTx int) *TxnInputOutput
type TxnOutput ¶
type TxnOutput []WriteDescriptor
type WriteDescriptor ¶
Click to show internal directories.
Click to hide internal directories.