cluster

package

Go to main page

Versions in this module

v1

v1.1.2

Nov 21, 2018

v1.1.1

Nov 14, 2018

Changes in this version

type PeerManager

+ func (pm *PeerManager) NotifyHeatbeat(nodeId int32, msg *pb.HeatbeatMsg) (*pb.Void, error)

v1.1.0

Nov 5, 2018

Changes in this version

+ func GetInitNodeHeight() int64

+ func IsNodeExist(nodeId int32) bool

+ func SetInitNodeHeight(height int64)

type PeerManager

+ func (pm *PeerManager) DeleteNode(id int32)

v1.0.4

Oct 31, 2018

v1.0.3

Oct 19, 2018

v1.0.2

Oct 16, 2018

v1.0.1

Oct 16, 2018

Changes in this version

+ const BlockInterval

+ const ModeJoin

+ const ModeNormal

+ const ModeTest

+ const ModeWatch

+ var AccuseQuorumN int

+ var ClusterSize int

+ var ClusterSnapshot *Snapshot

+ var CurrMultiSig MultiSigInfo

+ var DbCache = 16

+ var DbFileHandles = 16

+ var MaxFaultyN int

+ var MultiSigSnapshot MultiSigInfos

+ var NodeList []NodeInfo

+ var NodeSigners map[int32]*crypto.SecureSigner

+ var QuorumN int

+ var TotalNodeCount int

+ func AddMultiSigInfo(multiSig MultiSigInfo)

+ func AddNode(host string, nodeId int32, pubkey string, pubkeyHash string)

+ func AddNodeInfo(nodeInfo NodeInfo)

+ func DelSnapShot()

+ func DeleteNode(nodeId int32)

+ func GetPubkeyList() []string

+ func Init()

+ func InitWithNodeList(nodeList *pb.NodeList)

+ func LeaderNodeOfTerm(term int64) int32

+ func RecoverNode(nodeId int32)

+ func SetCurrMultiSig(multiSig MultiSigInfo)

+ func SetMultiSigSnapshot(snapshot []MultiSigInfo)

+ type MultiSigInfo struct

+ BchAddress string

+ BchRedeemScript []byte

+ BtcAddress string

+ BtcRedeemScript []byte

+ func (ms MultiSigInfo) Equal(other MultiSigInfo) bool

+ type MultiSigInfos struct

+ SigInfos []MultiSigInfo

+ func (msi MultiSigInfos) GetLatestSigInfo() (MultiSigInfo, error)

+ func (msi MultiSigInfos) GetMultiSigInfos() []MultiSigInfo

+ type NodeInfo struct

+ Id int32

+ IsNormal bool

+ Name string

+ PublicKey []byte

+ Url string

+ func NewNodeInfo(host string, nodeId int32, pubkey string, pubkeyHash string) NodeInfo

+ type PeerManager struct

+ func NewPeerManager(localNodeId int32, txConnPoolSize, blockCoonPoolSize int) *PeerManager

+ func (pm *PeerManager) AddNode(nodeInfo NodeInfo)

+ func (pm *PeerManager) Broadcast(msg interface{}, excludeSelf bool, selectSome bool)

+ func (pm *PeerManager) GetCommitedCnt(msg *crypto.Digest256) int

+ func (pm *PeerManager) GetNode(nodeId int32) *PeerNode

+ func (pm *PeerManager) GetNodeRuntimeInfos() map[int32]*pb.NodeRuntimeInfo

+ func (pm *PeerManager) GetTxConnAvailableCnt(nodes []NodeInfo) int

+ func (pm *PeerManager) LocalNodeId() int32

+ func (pm *PeerManager) NotifyCommitMsg(nodeId int32, msg *pb.CommitMsg) (*pb.Void, error)

+ func (pm *PeerManager) NotifyInitMsg(nodeId int32, msg *pb.InitMsg) (*pb.Void, error)

+ func (pm *PeerManager) NotifyLeave(nodeId int32, msg *pb.LeaveRequest) (*pb.Void, error)

+ func (pm *PeerManager) NotifyPrepareMsg(nodeId int32, msg *pb.PrepareMsg) (*pb.Void, error)

+ func (pm *PeerManager) NotifySignTx(nodeId int32, msg *pb.SignTxRequest) (*pb.SignTxResponse, error)

+ func (pm *PeerManager) NotifySignedResult(nodeId int32, msg *pb.SignedResult) (*pb.Void, error)

+ func (pm *PeerManager) NotifyStrongAccuse(nodeId int32, msg *pb.StrongAccuse) (*pb.Void, error)

+ func (pm *PeerManager) NotifyTxs(nodeId int32, msg *pb.Transactions) (*pb.Void, error)

+ func (pm *PeerManager) NotifyVote(nodeId int32, msg *pb.Vote) (*pb.Void, error)

+ func (pm *PeerManager) NotifyWeakAccuse(nodeId int32, msg *pb.WeakAccuse) (*pb.Void, error)

+ func (pm *PeerManager) SyncUp(nodeId int32, req *pb.SyncUpRequest) (*pb.SyncUpResponse, error)

+ func (pm *PeerManager) WatchSyncUp(nodeId int32, req *pb.SyncUpRequest) (*pb.SyncUpResponse, error)

+ type PeerNode struct

+ func NewPeerNode(nodeInfo NodeInfo, txPoolSize, blockPoolSize int) *PeerNode

+ type Snapshot struct

+ AccuseQuorumN int

+ ClusterSize int

+ NodeList []NodeInfo

+ QuorumN int

+ TotalNodeCount int

+ func CreateSnapShot() *Snapshot

+ func GetSnapshot() Snapshot

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL