resolver

type ErrAlreadyCommitted ¶

type ErrAlreadyCommitted uint64

ErrAlreadyCommitted is returned specially when client tries to rollback a committed lock.

func (e ErrAlreadyCommitted) Error() string

type ErrRetryable ¶

type ErrRetryable string

ErrRetryable suggests that client may restart the txn.

func (e ErrRetryable) Error() string

type MultiKeysNotifier ¶

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

func (s *MultiKeysNotifier) Notify(err error)

func (s *MultiKeysNotifier) Wait() []error

type Notifier ¶

type Notifier interface {
	Notify(err error)
	Wait() []error
}

Notifier is used to notify the task finished.

func NewMultiKeysNotifier(size int) Notifier

type Scheduler ¶

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

Scheduler is used to schedule Resolve tasks.

func NewScheduler(size int) *Scheduler

func (s *Scheduler) Close()

func (s *Scheduler) Resolve(keys []kv.Key, startVer, commitVer kv.Version, notifier Notifier)

func (s *Scheduler) Run()

func (s *Scheduler) SetDB(db *pebble.DB)

type Task ¶

type Task struct {
	Key       kv.Key
	StartVer  kv.Version
	CommitVer kv.Version
	Notifier  Notifier
}

Task represents a resolve task.

type TxnAction ¶

type TxnAction byte

const (
	TxnActionNone TxnAction = iota
	TxnActionTTLExpireRollback
	TxnActionLockNotExistRollback
	TxnActionLockNotExistDoNothing
)

type TxnStatus ¶

type TxnStatus struct {
	CommitVer kv.Version
	Action    TxnAction
}

func CheckTxnStatus(db *pebble.DB, vp kv.VersionProvider, primaryKey kv.Key, startVer kv.Version) (TxnStatus, error)