Versions in this module Expand all Collapse all v0 v0.0.1 May 7, 2018 Changes in this version + type Registry struct + func New(dir string) *Registry + func (r *Registry) ConnFollower(filename string) *sqlite3.SQLiteConn + func (r *Registry) ConnFollowerAdd(filename string, conn *sqlite3.SQLiteConn) + func (r *Registry) ConnFollowerDel(filename string) + func (r *Registry) ConnFollowerExists(filename string) bool + func (r *Registry) ConnFollowerFilenames() []string + func (r *Registry) ConnLeaderAdd(filename string, conn *sqlite3.SQLiteConn) + func (r *Registry) ConnLeaderDel(conn *sqlite3.SQLiteConn) + func (r *Registry) ConnLeaderFilename(conn *sqlite3.SQLiteConn) string + func (r *Registry) ConnLeaders(filename string) []*sqlite3.SQLiteConn + func (r *Registry) ConnSerial(conn *sqlite3.SQLiteConn) uint64 + func (r *Registry) Dir() string + func (r *Registry) Dump() string + func (r *Registry) Frames() uint64 + func (r *Registry) FramesIncrease(n uint64) + func (r *Registry) FramesReset() + func (r *Registry) HookSyncAdd(data []byte) + func (r *Registry) HookSyncMatches(data []byte) bool + func (r *Registry) HookSyncPresent() bool + func (r *Registry) HookSyncReset() + func (r *Registry) HookSyncSet() + func (r *Registry) HookSyncWait() + func (r *Registry) Index() uint64 + func (r *Registry) IndexUpdate(index uint64) + func (r *Registry) Lock() + func (r *Registry) Testing(t *testing.T, node int) + func (r *Registry) TracerConn(conn *sqlite3.SQLiteConn, hook string) *trace.Tracer + func (r *Registry) TracerFSM() *trace.Tracer + func (r *Registry) TxnByConn(conn *sqlite3.SQLiteConn) *transaction.Txn + func (r *Registry) TxnByFilename(filename string) *transaction.Txn + func (r *Registry) TxnByID(id uint64) *transaction.Txn + func (r *Registry) TxnCommittedAdd(txn *transaction.Txn) + func (r *Registry) TxnCommittedFind(id uint64) bool + func (r *Registry) TxnDel(id uint64) + func (r *Registry) TxnDryRun() + func (r *Registry) TxnFollowerAdd(conn *sqlite3.SQLiteConn, id uint64) *transaction.Txn + func (r *Registry) TxnFollowerResurrected(txn *transaction.Txn) + func (r *Registry) TxnFollowerSurrogate(txn *transaction.Txn) *transaction.Txn + func (r *Registry) TxnLastID(conn *sqlite3.SQLiteConn) uint64 + func (r *Registry) TxnLeaderAdd(conn *sqlite3.SQLiteConn, id uint64) *transaction.Txn + func (r *Registry) TxnLeaderByFilename(filename string) *transaction.Txn + func (r *Registry) Unlock()
Go to main page