Versions in this module Expand all Collapse all v3 v3.3.102 Mar 9, 2021 v3.3.101 Mar 3, 2021 Changes in this version + func NewConcurrentKVTest(clusterID uint64, nodeID uint64) sm.IConcurrentStateMachine + func NewKVTest(clusterID uint64, nodeID uint64) sm.IStateMachine + type ConcurrentKVTest struct + ClusterID uint64 + NodeID uint64 + func (s *ConcurrentKVTest) Close() error + func (s *ConcurrentKVTest) GetHash() (uint64, error) + func (s *ConcurrentKVTest) Lookup(key interface{}) (interface{}, error) + func (s *ConcurrentKVTest) PrepareSnapshot() (interface{}, error) + func (s *ConcurrentKVTest) RecoverFromSnapshot(r io.Reader, files []sm.SnapshotFile, done <-chan struct{}) error + func (s *ConcurrentKVTest) SaveSnapshot(ctx interface{}, w io.Writer, fileCollection sm.ISnapshotFileCollection, ...) error + func (s *ConcurrentKVTest) Update(ents []sm.Entry) ([]sm.Entry, error) + type ConcurrentSnapshot struct + func (c *ConcurrentSnapshot) Close() error + func (c *ConcurrentSnapshot) GetHash() (uint64, error) + func (c *ConcurrentSnapshot) Lookup(query interface{}) (interface{}, error) + func (c *ConcurrentSnapshot) PrepareSnapshot() (interface{}, error) + func (c *ConcurrentSnapshot) RecoverFromSnapshot(r io.Reader, files []sm.SnapshotFile, stopc <-chan struct{}) error + func (c *ConcurrentSnapshot) SaveSnapshot(ctx interface{}, w io.Writer, fc sm.ISnapshotFileCollection, ...) error + func (c *ConcurrentSnapshot) Update(entries []sm.Entry) ([]sm.Entry, error) + type ConcurrentUpdate struct + UpdateCount int + func (c *ConcurrentUpdate) Close() error + func (c *ConcurrentUpdate) GetHash() (uint64, error) + func (c *ConcurrentUpdate) Lookup(query interface{}) (interface{}, error) + func (c *ConcurrentUpdate) PrepareSnapshot() (interface{}, error) + func (c *ConcurrentUpdate) RecoverFromSnapshot(r io.Reader, files []sm.SnapshotFile, stopc <-chan struct{}) error + func (c *ConcurrentUpdate) SaveSnapshot(ctx interface{}, w io.Writer, fc sm.ISnapshotFileCollection, ...) error + func (c *ConcurrentUpdate) Update(entries []sm.Entry) ([]sm.Entry, error) + type FakeDiskSM struct + SlowOpen uint32 + func NewFakeDiskSM(initialApplied uint64) *FakeDiskSM + func (f *FakeDiskSM) Aborted() bool + func (f *FakeDiskSM) ClearAborted() + func (f *FakeDiskSM) Close() error + func (f *FakeDiskSM) GetHash() (uint64, error) + func (f *FakeDiskSM) Lookup(query interface{}) (interface{}, error) + func (f *FakeDiskSM) Open(stopc <-chan struct{}) (uint64, error) + func (f *FakeDiskSM) PrepareSnapshot() (interface{}, error) + func (f *FakeDiskSM) RecoverFromSnapshot(r io.Reader, stopc <-chan struct{}) error + func (f *FakeDiskSM) Recovered() bool + func (f *FakeDiskSM) SaveSnapshot(ctx interface{}, w io.Writer, stopc <-chan struct{}) error + func (f *FakeDiskSM) SetAborted() + func (f *FakeDiskSM) Sync() error + func (f *FakeDiskSM) Update(ents []sm.Entry) ([]sm.Entry, error) + type KVJson struct + Count uint64 + Junk []byte + KVStore map[string]string + type KVTest struct + ClusterID uint64 + Count uint64 + Junk []byte + KVStore map[string]string + NodeID uint64 + func (s *KVTest) Close() error + func (s *KVTest) DisableLargeDelay() + func (s *KVTest) GetHash() (uint64, error) + func (s *KVTest) Lookup(key interface{}) (interface{}, error) + func (s *KVTest) RecoverFromSnapshot(r io.Reader, files []sm.SnapshotFile, done <-chan struct{}) error + func (s *KVTest) SaveSnapshot(w io.Writer, fileCollection sm.ISnapshotFileCollection, done <-chan struct{}) error + func (s *KVTest) Update(data []byte) (sm.Result, error) + type NoOP struct + MillisecondToSleep uint64 + NoAlloc bool + func (n *NoOP) Close() error + func (n *NoOP) GetHash() (uint64, error) + func (n *NoOP) Lookup(key interface{}) (interface{}, error) + func (n *NoOP) NALookup(key []byte) ([]byte, error) + func (n *NoOP) RecoverFromSnapshot(r io.Reader, files []sm.SnapshotFile, done <-chan struct{}) error + func (n *NoOP) SaveSnapshot(w io.Writer, fileCollection sm.ISnapshotFileCollection, done <-chan struct{}) error + func (n *NoOP) SetSleepTime(v uint64) + func (n *NoOP) Update(data []byte) (sm.Result, error) + type SimDiskSM struct + func NewSimDiskSM(applied uint64) *SimDiskSM + func (s *SimDiskSM) Close() error + func (s *SimDiskSM) GetApplied() uint64 + func (s *SimDiskSM) GetRecovered() uint64 + func (s *SimDiskSM) Lookup(query interface{}) (interface{}, error) + func (s *SimDiskSM) Open(stopc <-chan struct{}) (uint64, error) + func (s *SimDiskSM) PrepareSnapshot() (interface{}, error) + func (s *SimDiskSM) RecoverFromSnapshot(r io.Reader, stopc <-chan struct{}) error + func (s *SimDiskSM) SaveSnapshot(ctx interface{}, w io.Writer, stopc <-chan struct{}) error + func (s *SimDiskSM) Sync() error + func (s *SimDiskSM) Update(ents []sm.Entry) ([]sm.Entry, error) + type TestSnapshot struct + func (c *TestSnapshot) Close() error + func (c *TestSnapshot) GetHash() (uint64, error) + func (c *TestSnapshot) Lookup(query interface{}) (interface{}, error) + func (c *TestSnapshot) RecoverFromSnapshot(r io.Reader, files []sm.SnapshotFile, stopc <-chan struct{}) error + func (c *TestSnapshot) SaveSnapshot(w io.Writer, fc sm.ISnapshotFileCollection, stopc <-chan struct{}) error + func (c *TestSnapshot) Update(data []byte) (sm.Result, error) + type TestUpdate struct + func (c *TestUpdate) Close() error + func (c *TestUpdate) GetHash() (uint64, error) + func (c *TestUpdate) Lookup(query interface{}) (interface{}, error) + func (c *TestUpdate) RecoverFromSnapshot(r io.Reader, files []sm.SnapshotFile, stopc <-chan struct{}) error + func (c *TestUpdate) SaveSnapshot(w io.Writer, fc sm.ISnapshotFileCollection, stopc <-chan struct{}) error + func (c *TestUpdate) Update(data []byte) (sm.Result, error) + type VerboseSnapshotSM struct + func (v *VerboseSnapshotSM) Close() error + func (v *VerboseSnapshotSM) Lookup(q interface{}) (interface{}, error) + func (v *VerboseSnapshotSM) RecoverFromSnapshot(r io.Reader, collection []sm.SnapshotFile, stopc <-chan struct{}) error + func (v *VerboseSnapshotSM) SaveSnapshot(w io.Writer, collection sm.ISnapshotFileCollection, stopc <-chan struct{}) error + func (v *VerboseSnapshotSM) Update(data []byte) (sm.Result, error) Other modules containing this package github.com/vyevenko/dragonboat
Go to main page