recovery

Documentation

Index

• Constants
• type Manager
  • func ConstructManager() (*Manager, error)
  • func (this *Manager) RecoverCurrentProposalId(roleId uint64) (proposal.Id, error)
  • func (this *Manager) RecoverLog(roleId uint64) ([]string, []proposal.Id, error)
  • func (this *Manager) RecoverMinProposalId(roleId uint64) (proposal.Id, error)
  • func (this *Manager) RetrieveAddresses() (map[uint64]string, error)
  • func (this *Manager) UpdateCurrentProposalId(roleId uint64, id proposal.Id) error
  • func (this *Manager) UpdateLogRecord(roleId uint64, index int, value string, id proposal.Id) error
  • func (this *Manager) UpdateMinProposalId(roleId uint64, id proposal.Id) error

Constants

const CURRENT_PROPOSAL_FILENAME = "currentproposalid.csv"

const LOG_FILENAME string = "log.csv"

const MIN_PROPOSAL_FILENAME string = "minproposalid.csv"

const PEERS_FILENAME string = "peers.csv"

const RECOVERY_DIR string = "coldstorage"

const RECOVERY_DIR_PATTERN string = RECOVERY_DIR + "/%d"

const RECOVERY_FILE_PATTERN string = RECOVERY_DIR_PATTERN + "/%s"

Types

type Manager

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

func ConstructManager

func ConstructManager() (*Manager, error)

Creates disk access manager for backup & recovery files

func (*Manager) RecoverCurrentProposalId

func (this *Manager) RecoverCurrentProposalId(roleId uint64) (proposal.Id, error)

func (*Manager) RecoverLog

func (this *Manager) RecoverLog(roleId uint64) ([]string, []proposal.Id, error)

Recovers replicated log from disk.

func (*Manager) RecoverMinProposalId

func (this *Manager) RecoverMinProposalId(roleId uint64) (proposal.Id, error)

Recovers the MinProposalId from disk.

func (*Manager) RetrieveAddresses

func (this *Manager) RetrieveAddresses() (map[uint64]string, error)

Reads the list of peers from a file on disk

func (*Manager) UpdateCurrentProposalId

func (this *Manager) UpdateCurrentProposalId(roleId uint64, id proposal.Id) error

func (*Manager) UpdateLogRecord

func (this *Manager) UpdateLogRecord(roleId uint64, index int, value string, id proposal.Id) error

Updates a record in the replicated log on disk.

func (*Manager) UpdateMinProposalId

func (this *Manager) UpdateMinProposalId(roleId uint64, id proposal.Id) error