fsm

type Config struct {
	SnapshotCompression      string `yaml:"snapshot_compression"`
	SnapshotRateLimit        int    `yaml:"snapshot_rate_limit"`
	SnapshotCompactOnRestore bool   `yaml:"snapshot_compact_on_restore"`
	// Where the FSM BoltDB data is located.
	// Does not have to be a persistent volume.
	DataDir string `yaml:"data_dir"`
}

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

type RaftHandler[Req, Resp proto.Message] func(*bbolt.Tx, *raft.Log, Req) (Resp, error)

type RaftLogEntry struct {
	Type RaftLogEntryType
	Data []byte
}

type RaftLogEntryType uint32

type Response struct {
	Data proto.Message
	Err  error
}

type StateRestorer interface {
	// Init is provided with a write transaction to initialize the state.
	// FSM guarantees that Init is called synchronously and has exclusive
	// access to the database.
	Init(*bbolt.Tx) error
	// Restore is provided with a read transaction to restore the state.
	// Restore might be called concurrently with other StateRestorer
	// instances.
	Restore(*bbolt.Tx) error
}