fsm

Jan 5, 2024

Changes in this version

+ type IteratorRequest struct

+ RangeOp *regattapb.RequestOp_Range

Aug 9, 2023

Changes in this version

+ type SnapshotRecoveryType uint8

+ const RecoveryTypeCheckpoint

+ const RecoveryTypeSnapshot

Nov 22, 2022

Changes in this version

+ func New(tableName, stateMachineDir string, fs vfs.FS, blockCache *pebble.Cache) sm.CreateOnDiskStateMachineFunc

+ type FSM struct

+ func (p *FSM) Close() error

+ func (p *FSM) Collect(ch chan<- prometheus.Metric)

+ func (p *FSM) Describe(ch chan<- *prometheus.Desc)

+ func (p *FSM) GetHash() (uint64, error)

+ func (p *FSM) Lookup(l interface{}) (interface{}, error)

+ func (p *FSM) Open(_ <-chan struct{}) (uint64, error)

+ func (p *FSM) PrepareSnapshot() (interface{}, error)

+ func (p *FSM) RecoverFromSnapshot(r io.Reader, stopc <-chan struct{}) (er error)

+ func (p *FSM) SaveSnapshot(ctx interface{}, w io.Writer, stopc <-chan struct{}) error

+ func (p *FSM) Sync() error

+ func (p *FSM) Update(updates []sm.Entry) ([]sm.Entry, error)

+ type IndexResponse struct

+ Index uint64

+ type LeaderIndexRequest struct

+ type LocalIndexRequest struct

+ type PathRequest struct

+ type PathResponse struct

+ Path string

+ type SnapshotRequest struct

+ Stopper <-chan struct{}

+ Writer io.Writer

+ type SnapshotResponse struct

+ Index uint64

+ type UpdateResult uint64

+ const ResultFailure

+ const ResultSuccess