raft

Documentation

Index

• func NewRaftCluster(cfg *types.Consensus, sub []byte) queue.Module
• func NewRaftNode(ctx context.Context, id int, join bool, peers []string, readOnlyPeers []string, ...) (<-chan *types.Block, <-chan error, <-chan *snap.Snapshotter, <-chan bool)
• type Client
  • func NewBlockstore(ctx context.Context, cfg *types.Consensus, snapshotter *snap.Snapshotter, ...) *Client
  • func (client *Client) CheckBlock(parent *types.Block, current *types.BlockDetail) error
  • func (client *Client) Close()
  • func (client *Client) CmpBestBlock(newBlock *types.Block, cmpBlock *types.Block) bool
  • func (client *Client) CreateBlock()
  • func (client *Client) CreateGenesisTx() (ret []*types.Transaction)
  • func (client *Client) GetGenesisBlockTime() int64
  • func (client *Client) ProcEvent(msg *queue.Message) bool
  • func (client *Client) SetQueueClient(c queue.Client)
• type Node
  • func (rc Node) IsIDRemoved(id uint64) bool
  • func (rc Node) Process(ctx context.Context, m raftpb.Message) error
  • func (rc Node) ReportSnapshot(id uint64, status raft.SnapshotStatus)
  • func (rc Node) ReportUnreachable(id uint64)
  • func (rc Node) Status() raft.Status

Functions

func NewRaftCluster

func NewRaftCluster(cfg *types.Consensus, sub []byte) queue.Module

NewRaftCluster create raft cluster

func NewRaftNode

func NewRaftNode(ctx context.Context, id int, join bool, peers []string, readOnlyPeers []string, addPeers []string, getSnapshot func() ([]byte, error), proposeC <-chan *types.Block,
	confChangeC <-chan raftpb.ConfChange) (<-chan *types.Block, <-chan error, <-chan *snap.Snapshotter, <-chan bool)

NewRaftNode create raft node

Types

type Client

type Client struct {
	*drivers.BaseClient
	// contains filtered or unexported fields
}

Client Raft implementation

func NewBlockstore

func NewBlockstore(ctx context.Context, cfg *types.Consensus, snapshotter *snap.Snapshotter, proposeC chan<- *types.Block, commitC <-chan *types.Block, errorC <-chan error, validatorC <-chan bool, cancel context.CancelFunc) *Client

NewBlockstore create Raft Client

func (*Client) CheckBlock

func (client *Client) CheckBlock(parent *types.Block, current *types.BlockDetail) error

CheckBlock method

func (*Client) Close

func (client *Client) Close()

Close method

func (*Client) CmpBestBlock

func (client *Client) CmpBestBlock(newBlock *types.Block, cmpBlock *types.Block) bool

CmpBestBlock 比较newBlock是不是最优区块

func (*Client) CreateBlock

func (client *Client) CreateBlock()

CreateBlock method

func (*Client) CreateGenesisTx

func (client *Client) CreateGenesisTx() (ret []*types.Transaction)

CreateGenesisTx get genesis tx

func (*Client) GetGenesisBlockTime

func (client *Client) GetGenesisBlockTime() int64

GetGenesisBlockTime get genesis blocktime

func (*Client) ProcEvent

func (client *Client) ProcEvent(msg *queue.Message) bool

ProcEvent method

func (*Client) SetQueueClient

func (client *Client) SetQueueClient(c queue.Client)

SetQueueClient method

type Node

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

Node ...

func (Node) IsIDRemoved

func (rc Node) IsIDRemoved(id uint64) bool

func (Node) Process

func (rc Node) Process(ctx context.Context, m raftpb.Message) error

func (Node) ReportSnapshot

func (rc Node) ReportSnapshot(id uint64, status raft.SnapshotStatus)

func (Node) ReportUnreachable

func (rc Node) ReportUnreachable(id uint64)

func (Node) Status

func (rc Node) Status() raft.Status