storage

Documentation

Index

• func RestoreStorage(diskPath string, maxLength int, appConfig string) (bool, int, *consensus.Log, int, *app.StateMachine)
• type FileStorage
  • func MakeFileStorage(diskPath string, persistenceMode string) (*FileStorage, error)
  • func (fs *FileStorage) PersistLogUpdate(log msgs.LogUpdate) error
  • func (fs *FileStorage) PersistSnapshot(index int, bytes []byte) error
  • func (fs *FileStorage) PersistView(view int) error

Functions

func RestoreStorage

func RestoreStorage(diskPath string, maxLength int, appConfig string) (bool, int, *consensus.Log, int, *app.StateMachine)

Types

type FileStorage

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

func MakeFileStorage

func MakeFileStorage(diskPath string, persistenceMode string) (*FileStorage, error)

MakeFileStorage opens the files for persistent storage

func (*FileStorage) PersistLogUpdate

func (fs *FileStorage) PersistLogUpdate(log msgs.LogUpdate) error

PersistLogUpdate writes the specified log update to persistent storage Function returns when write+sync is completed Error is returned if it was not possible to write

func (*FileStorage) PersistSnapshot

func (fs *FileStorage) PersistSnapshot(index int, bytes []byte) error

PersistSnapshot writes the provided snapshot to persistent storage index should be the index of the last request applied to be state machine before snapshoting

func (*FileStorage) PersistView

func (fs *FileStorage) PersistView(view int) error

PersistView writes view update to persistent storage Function returns when write+sync is completed Error is returned if it was not possible to write