Versions in this module Expand all Collapse all v1 v1.0.0 Apr 5, 2021 Changes in this version + var EmptyWriteKeyInfo = WriteKeyInfo + type KeyVersions map[string]types.TxnInternalVersion + func (kvs KeyVersions) Contains(key string) bool + func (kvs KeyVersions) MustFirstKey() string + type WriteKeyInfo struct + Committed bool + CommittedCleared bool + LastTask *types.ListTask + LastWrittenVersion types.TxnInternalVersion + Rollbacked bool + func NewWriteKeyInfo(lastWrittenVersion types.TxnInternalVersion) WriteKeyInfo + func (ks WriteKeyInfo) IsEmpty() bool + type WriteKeyInfos struct + KV types.KVCC + TaskTimeout time.Duration + func (ks *WriteKeyInfos) InitializeWrittenKeys(key2LastWrittenVersion KeyVersions, completed bool) + func (ks *WriteKeyInfos) MarkWrittenKeyCompleted() + func (ks *WriteKeyInfos) WriteKey(s *scheduler.ConcurrentDynamicListScheduler, key string, val types.Value, ...) error + func (ks WriteKeyInfos) AreWrittenKeysCompleted() bool + func (ks WriteKeyInfos) ContainsWrittenKey(key string) bool + func (ks WriteKeyInfos) ForEachWrittenKey(f func(key string, info WriteKeyInfo)) + func (ks WriteKeyInfos) GetCommittedVersion(key string) types.TxnInternalVersion + func (ks WriteKeyInfos) GetCopiedWriteKeyTasks() []*basic.Task + func (ks WriteKeyInfos) GetCopiedWriteKeyTasksEx() ([]*basic.Task, []*types.ListTask) + func (ks WriteKeyInfos) GetLastWriteKeyTask(key string) *types.ListTask + func (ks WriteKeyInfos) GetLastWriteKeyTasks(allWriteKeyTasks []*types.ListTask) []*types.ListTask + func (ks WriteKeyInfos) GetSucceededWrittenKeysUnsafe() map[string]types.ValueCC + func (ks WriteKeyInfos) GetWriteKeyTasks() []*types.ListTask + func (ks WriteKeyInfos) GetWrittenKey2LastVersion() (keys KeyVersions) + func (ks WriteKeyInfos) GetWrittenKeyCount() int + func (ks WriteKeyInfos) IsWrittenKeyRollbacked(key string) bool + func (ks WriteKeyInfos) MarkAllWrittenKeysCommitted() + func (ks WriteKeyInfos) MarkCommitted(key string, value types.Value) + func (ks WriteKeyInfos) MarkCommittedCleared(key string, value types.Value) + func (ks WriteKeyInfos) MarkWrittenKeyRollbacked(key string) + func (ks WriteKeyInfos) MatchWrittenKeys(keysWithWriteIntent KeyVersions) bool
Go to main page