fsm

Documentation

Index

• type FSM
  • func (f *FSM) Apply(log *raft.Log) interface{}
  • func (f *FSM) Restore(closer io.ReadCloser) error
  • func (f *FSM) Snapshot() (raft.FSMSnapshot, error)
  • func (f *FSM) Validate() error
• type Snapshot
  • func (s *Snapshot) Persist(sink raft.SnapshotSink) error
  • func (s *Snapshot) Release()

Types

type FSM

type FSM struct {
	ApplyFunc    func(log *raft.Log) interface{}
	SnapshotFunc func() (*Snapshot, error)
	RestoreFunc  func(closer io.ReadCloser) error
}

func (*FSM) Apply

func (f *FSM) Apply(log *raft.Log) interface{}

func (*FSM) Restore

func (f *FSM) Restore(closer io.ReadCloser) error

func (*FSM) Snapshot

func (f *FSM) Snapshot() (raft.FSMSnapshot, error)

func (*FSM) Validate

func (f *FSM) Validate() error

type Snapshot

type Snapshot struct {
	PersistFunc func(sink raft.SnapshotSink) error
	ReleaseFunc func()
}

func (*Snapshot) Persist

func (s *Snapshot) Persist(sink raft.SnapshotSink) error

func (*Snapshot) Release

func (s *Snapshot) Release()