raft

May 30, 2018

Changes in this version

+ var DefaultBackupsRotate = 6

type Config

+ BackupsRotate int

+ InitPeerset []peer.ID

+ func (cfg *Config) GetDataFolder() string

Jan 26, 2018

Changes in this version

+ func CleanupRaft(dataFolder string) error

Dec 11, 2017

Changes in this version

+ func LastStateRaw(cfg *Config) (io.Reader, bool, error)

+ func SnapshotSave(cfg *Config, newState state.State, pid peer.ID) error

Nov 15, 2017

Changes in this version

+ var DefaultCommitRetries = 1

+ var DefaultCommitRetryDelay = 200 * time.Millisecond

+ var DefaultNetworkTimeout = 10 * time.Second

+ var DefaultWaitForLeaderTimeout = 15 * time.Second

+ var RaftDataBackupKeep = 5

+ var RaftLogCacheSize = 512

type Config

+ CommitRetries int

+ CommitRetryDelay time.Duration

+ NetworkTimeout time.Duration

+ RaftConfig *hraft.Config

+ WaitForLeaderTimeout time.Duration

type Consensus

+ func (cc *Consensus) AddPeer(pid peer.ID) error

+ func (cc *Consensus) Clean() error

+ func (cc *Consensus) Peers() ([]peer.ID, error)

+ func (cc *Consensus) RmPeer(pid peer.ID) error

Oct 23, 2017

Changes in this version

+ var DefaultDataSubFolder = "ipfs-cluster-data"

+ type Config struct

+ DataFolder string

+ HashiraftCfg *hashiraft.Config

+ func (cfg *Config) ConfigKey() string

+ func (cfg *Config) Default() error

+ func (cfg *Config) LoadJSON(raw []byte) error

+ func (cfg *Config) ToJSON() ([]byte, error)

+ func (cfg *Config) Validate() error

Mar 28, 2017

Changes in this version

+ const LogOpAddPeer

+ const LogOpPin

+ const LogOpRmPeer

+ const LogOpUnpin

+ var CommitRetries = 2

+ var DefaultRaftConfig = hashiraft.DefaultConfig()

+ var LeaderTimeout = 15 * time.Second

+ var RaftMaxSnapshots = 5

+ type Consensus struct

+ func NewConsensus(clusterPeers []peer.ID, host host.Host, dataFolder string, state state.State) (*Consensus, error)

+ func (cc *Consensus) Leader() (peer.ID, error)

+ func (cc *Consensus) LogAddPeer(addr ma.Multiaddr) error

+ func (cc *Consensus) LogPin(c api.Pin) error

+ func (cc *Consensus) LogRmPeer(pid peer.ID) error

+ func (cc *Consensus) LogUnpin(c api.Pin) error

+ func (cc *Consensus) Ready() <-chan struct{}

+ func (cc *Consensus) Rollback(state state.State) error

+ func (cc *Consensus) SetClient(c *rpc.Client)

+ func (cc *Consensus) Shutdown() error

+ func (cc *Consensus) State() (state.State, error)

+ func (cc *Consensus) WaitForSync() error

+ type LogOp struct

+ Cid api.PinSerial

+ Peer api.MultiaddrSerial

+ Type LogOpType

+ func (op *LogOp) ApplyTo(cstate consensus.State) (consensus.State, error)

+ type LogOpType int

+ type Raft struct

+ func NewRaft(peers []peer.ID, host host.Host, dataFolder string, fsm hashiraft.FSM) (*Raft, error)

+ func (r *Raft) AddPeer(peer string) error

+ func (r *Raft) Leader() string

+ func (r *Raft) RemovePeer(peer string) error

+ func (r *Raft) Shutdown() error

+ func (r *Raft) Snapshot() error

+ func (r *Raft) WaitForLeader(ctx context.Context) error

+ func (r *Raft) WaitForUpdates(ctx context.Context) error