pbft

Documentation

Index

• Constants
• func GetPlugin(c consensus_pbft.Stack) consensus_pbft.Consenter
• func New(stack consensus_pbft.Stack) consensus_pbft.Consenter
• func NewValidatorIdentify(stack consensus_pbft.Stack) consensusInterface.ValidatorIdentifyInterface
• type NetValidator
  • func (nv *NetValidator) GetValidatorID(handle *pbftTypes.PeerID) (pbftTypes.ReplicaID, error)
  • func (nv *NetValidator) GetValidatorNode(id pbftTypes.ReplicaID) (pbftTypes.Peer, error)
  • func (nv *NetValidator) GetValidatorNodeId(id pbftTypes.ReplicaID) (*pbftTypes.PeerID, error)
  • func (nv *NetValidator) GetValidatorNodeIds(ids []pbftTypes.ReplicaID) ([]*pbftTypes.PeerID, error)
  • func (nv *NetValidator) GetValidatorNodes(ids []pbftTypes.ReplicaID) ([]pbftTypes.Peer, error)
• type PbftIdentify
  • func (pi *PbftIdentify) GetValidatorID(handle *pbftTypes.PeerID) (pbftTypes.ReplicaID, error)
  • func (pi *PbftIdentify) GetValidatorNode(id pbftTypes.ReplicaID) (pbftTypes.Peer, error)
  • func (pi *PbftIdentify) GetValidatorNodeId(id pbftTypes.ReplicaID) (*pbftTypes.PeerID, error)
  • func (pi *PbftIdentify) GetValidatorNodeIds(ids []pbftTypes.ReplicaID) ([]*pbftTypes.PeerID, error)
  • func (pi *PbftIdentify) GetValidatorNodes(ids []pbftTypes.ReplicaID) ([]pbftTypes.Peer, error)
• type PbftInfo
• type PbftPeer
  • func (pp *PbftPeer) GetPeerId() *pbftTypes.PeerID
  • func (pp *PbftPeer) GetType() pbftTypes.Peer_Type
• type ValidatorIndexer

Constants

const (
	// UnreasonableTimeout is an ugly thing, we need to create timers, then stop them before they expire, so use a large timeout
	UnreasonableTimeout = 100 * time.Hour
)

Functions

func GetPlugin

func GetPlugin(c consensus_pbft.Stack) consensus_pbft.Consenter

GetPlugin returns the handle to the Consenter singleton

func New

func New(stack consensus_pbft.Stack) consensus_pbft.Consenter

调用controller获取一个plugin，当选择是pbft算法时，它会调用pbft.go 里的 GetPlugin(c consensus.Stack)方法， 在pbft.go里面把所有的外部参数读进算法内部。 New creates a new Obc* instance that provides the Consenter interface. Internally, it uses an opaque pbft-core instance.

func NewValidatorIdentify

func NewValidatorIdentify(stack consensus_pbft.Stack) consensusInterface.ValidatorIdentifyInterface

Types

type NetValidator

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

func (*NetValidator) GetValidatorID

func (nv *NetValidator) GetValidatorID(handle *pbftTypes.PeerID) (pbftTypes.ReplicaID, error)

func (*NetValidator) GetValidatorNode

func (nv *NetValidator) GetValidatorNode(id pbftTypes.ReplicaID) (pbftTypes.Peer, error)

func (*NetValidator) GetValidatorNodeId

func (nv *NetValidator) GetValidatorNodeId(id pbftTypes.ReplicaID) (*pbftTypes.PeerID, error)

func (*NetValidator) GetValidatorNodeIds

func (nv *NetValidator) GetValidatorNodeIds(ids []pbftTypes.ReplicaID) ([]*pbftTypes.PeerID, error)

func (*NetValidator) GetValidatorNodes

func (nv *NetValidator) GetValidatorNodes(ids []pbftTypes.ReplicaID) ([]pbftTypes.Peer, error)

type PbftIdentify

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

func (*PbftIdentify) GetValidatorID

func (pi *PbftIdentify) GetValidatorID(handle *pbftTypes.PeerID) (pbftTypes.ReplicaID, error)

func (*PbftIdentify) GetValidatorNode

func (pi *PbftIdentify) GetValidatorNode(id pbftTypes.ReplicaID) (pbftTypes.Peer, error)

func (*PbftIdentify) GetValidatorNodeId

func (pi *PbftIdentify) GetValidatorNodeId(id pbftTypes.ReplicaID) (*pbftTypes.PeerID, error)

func (*PbftIdentify) GetValidatorNodeIds

func (pi *PbftIdentify) GetValidatorNodeIds(ids []pbftTypes.ReplicaID) ([]*pbftTypes.PeerID, error)

func (*PbftIdentify) GetValidatorNodes

func (pi *PbftIdentify) GetValidatorNodes(ids []pbftTypes.ReplicaID) ([]pbftTypes.Peer, error)

type PbftInfo

type PbftInfo struct {
	ReplicaId pbftTypes.ReplicaID
	// contains filtered or unexported fields
}

type PbftPeer

type PbftPeer struct {
	Node *discover.Node
	Type pbftTypes.Peer_Type
}

func (*PbftPeer) GetPeerId

func (pp *PbftPeer) GetPeerId() *pbftTypes.PeerID

func (*PbftPeer) GetType

func (pp *PbftPeer) GetType() pbftTypes.Peer_Type

type ValidatorIndexer

type ValidatorIndexer interface {
	ChangeToReplicaID(index int) pbftTypes.ReplicaID
	ChangeToIndex(id pbftTypes.ReplicaID) int
}