pbft

Documentation

Index

• Constants
• func EQ(d1 []byte, d2 []byte) bool
• func NewPbft(cfg *pb.Consensus, sub []byte) queue.Module
• func NewReplica(id uint32, PeersURL string, addr string) (chan *pb.ClientReply, chan *pb.Request, bool)
• func ReadMessage(conn io.Reader, msg proto.Message) error
• func RepDigest(reply fmt.Stringer) []byte
• func ReqDigest(req *types.Request) []byte
• func ToCheckpoint(sequence uint32, digest []byte) *types.Checkpoint
• func ToEntry(sequence uint32, digest []byte, view uint32) *types.Entry
• func ToReply(view uint32, timestamp, client string, replica uint32, result *types.Result) *types.ClientReply
• func ToRequestAck(view, replica, viewchanger uint32, digest []byte) *types.Request
• func ToRequestCheckpoint(sequence uint32, digest []byte, replica uint32) *types.Request
• func ToRequestClient(op *types.Operation, timestamp, client string) *types.Request
• func ToRequestCommit(view, sequence, replica uint32) *types.Request
• func ToRequestNewView(view uint32, viewChanges []*types.ViewChange, summaries []*types.Summary, ...) *types.Request
• func ToRequestPrepare(view, sequence uint32, digest []byte, replica uint32) *types.Request
• func ToRequestPreprepare(view, sequence uint32, digest []byte, replica uint32) *types.Request
• func ToRequestViewChange(view, sequence uint32, checkpoints []*types.Checkpoint, ...) *types.Request
• func ToSummary(sequence uint32, digest []byte) *types.Summary
• func ToViewChange(viewchanger uint32, digest []byte) *types.ViewChange
• func WriteMessage(addr string, msg proto.Message) error
• type Client
  • func NewBlockstore(cfg *types.Consensus, replyChan chan *types.ClientReply, ...) *Client
  • func (client *Client) CheckBlock(parent *types.Block, current *types.BlockDetail) error
  • 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) Propose(block *types.Block)
  • func (client *Client) SetQueueClient(c queue.Client)
• type Replica
  • func (rep *Replica) Startnode(addr string)

Constants

const (
	CheckPointPeriod uint32 = 128
	ConstantFactor   uint32 = 2
)

constant

Functions

func EQ

func EQ(d1 []byte, d2 []byte) bool

EQ Digest

func NewPbft

func NewPbft(cfg *pb.Consensus, sub []byte) queue.Module

NewPbft create pbft cluster

func NewReplica

func NewReplica(id uint32, PeersURL string, addr string) (chan *pb.ClientReply, chan *pb.Request, bool)

NewReplica create Replica instance

func ReadMessage

func ReadMessage(conn io.Reader, msg proto.Message) error

ReadMessage read proto message

func RepDigest

func RepDigest(reply fmt.Stringer) []byte

RepDigest method

func ReqDigest

func ReqDigest(req *types.Request) []byte

ReqDigest method

func ToCheckpoint

func ToCheckpoint(sequence uint32, digest []byte) *types.Checkpoint

ToCheckpoint method

func ToEntry

func ToEntry(sequence uint32, digest []byte, view uint32) *types.Entry

ToEntry method

func ToReply

func ToReply(view uint32, timestamp, client string, replica uint32, result *types.Result) *types.ClientReply

ToReply method

func ToRequestAck

func ToRequestAck(view, replica, viewchanger uint32, digest []byte) *types.Request

ToRequestAck method

func ToRequestCheckpoint

func ToRequestCheckpoint(sequence uint32, digest []byte, replica uint32) *types.Request

ToRequestCheckpoint method

func ToRequestClient

func ToRequestClient(op *types.Operation, timestamp, client string) *types.Request

ToRequestClient method

func ToRequestCommit

func ToRequestCommit(view, sequence, replica uint32) *types.Request

ToRequestCommit method

func ToRequestNewView

func ToRequestNewView(view uint32, viewChanges []*types.ViewChange, summaries []*types.Summary, replica uint32) *types.Request

ToRequestNewView method

func ToRequestPrepare

func ToRequestPrepare(view, sequence uint32, digest []byte, replica uint32) *types.Request

ToRequestPrepare method

func ToRequestPreprepare

func ToRequestPreprepare(view, sequence uint32, digest []byte, replica uint32) *types.Request

ToRequestPreprepare method

func ToRequestViewChange

func ToRequestViewChange(view, sequence uint32, checkpoints []*types.Checkpoint, preps, prePreps []*types.Entry, replica uint32) *types.Request

ToRequestViewChange method

func ToSummary

func ToSummary(sequence uint32, digest []byte) *types.Summary

ToSummary method

func ToViewChange

func ToViewChange(viewchanger uint32, digest []byte) *types.ViewChange

ToViewChange method

func WriteMessage

func WriteMessage(addr string, msg proto.Message) error

WriteMessage write proto message

Types

type Client

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

Client Pbft implementation

func NewBlockstore

func NewBlockstore(cfg *types.Consensus, replyChan chan *types.ClientReply, requestChan chan *types.Request, isPrimary bool) *Client

NewBlockstore create Pbft Client

func (*Client) CheckBlock

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

CheckBlock method

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) Propose

func (client *Client) Propose(block *types.Block)

Propose method

func (*Client) SetQueueClient

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

SetQueueClient method

type Replica

type Replica struct {
	ID uint32
	// contains filtered or unexported fields
}

Replica struct

func (*Replica) Startnode

func (rep *Replica) Startnode(addr string)

Startnode method