node

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 BraftNode

+ func (bn *BraftNode) NotifyHeatbeat(ct context.Context, msg *pb.HeatbeatMsg) (*pb.Void, error)

v1.1.0

Nov 5, 2018

Changes in this version

+ func InitObserver() error

type BraftNode

+ func (node *BraftNode) AddProposal(p *distribution.Proposal) bool

+ func (node *BraftNode) DeleteProposal(proposalID string) bool

+ func (node *BraftNode) ExecuteProposal(proposalID string)

+ func (node *BraftNode) GetAllProposal() []*distribution.DistributionInfo

+ func (node *BraftNode) GetProposal(proposalID string) *distribution.DistributionInfo

v1.0.4

Oct 31, 2018

Changes in this version

type BraftNode

+ func (node *BraftNode) AddSideTx(txID string, chain string) error

v1.0.3

Oct 19, 2018

v1.0.2

Oct 16, 2018

v1.0.1

Oct 16, 2018

Changes in this version

+ var BchConfirms int

+ var BtcConfirms int

+ var CheckOnChainCur int

+ var CheckOnChainInterval time.Duration

+ var ConfirmTolerance time.Duration

+ var EthConfirms int

+ func GetStartMode() int

+ type BlockView struct

+ CreatedUsed int64

+ Height int64

+ ID string

+ Miner string

+ PreID string

+ Size int

+ Time int64

+ TxCnt int

+ Txs []*TxView

+ type BraftNode struct

+ func NewBraftNode(localNodeInfo cluster.NodeInfo) *BraftNode

+ func RunNew(nodeInfo cluster.NodeInfo, multiSigInfos []cluster.MultiSigInfo) (*grpc.Server, *BraftNode)

+ func (bn *BraftNode) Echo(ctx context.Context, req *pb.EchoRequest) (*pb.EchoResponse, error)

+ func (bn *BraftNode) GetClusterNodes(ctx context.Context, msg *pb.Void) (*pb.NodeList, error)

+ func (bn *BraftNode) GetNodeRuntimeInfo(ctx context.Context, msg *pb.Void) (*pb.NodeRuntimeInfo, error)

+ func (bn *BraftNode) IsCommited(ctx context.Context, msg *crypto.Digest256) (*pb.IsCommitedResponse, error)

+ func (bn *BraftNode) LeaveCluster()

+ func (bn *BraftNode) NotifyCommitMsg(ctx context.Context, msg *pb.CommitMsg) (*pb.Void, error)

+ func (bn *BraftNode) NotifyInitMsg(ctx context.Context, msg *pb.InitMsg) (*pb.Void, error)

+ func (bn *BraftNode) NotifyJoin(ctx context.Context, msg *pb.JoinRequest) (*pb.Void, error)

+ func (bn *BraftNode) NotifyJoinCheckSynced(ctx context.Context, msg *pb.JoinRequest) (*pb.JoinResponse, error)

+ func (bn *BraftNode) NotifyLeave(ctx context.Context, msg *pb.LeaveRequest) (*pb.Void, error)

+ func (bn *BraftNode) NotifyPrepareMsg(ctx context.Context, msg *pb.PrepareMsg) (*pb.Void, error)

+ func (bn *BraftNode) NotifySignTx(ctx context.Context, msg *pb.SignTxRequest) (*pb.Void, error)

+ func (bn *BraftNode) NotifySignedResult(ctx context.Context, msg *pb.SignedResult) (*pb.Void, error)

+ func (bn *BraftNode) NotifyStrongAccuse(ctx context.Context, msg *pb.StrongAccuse) (*pb.Void, error)

+ func (bn *BraftNode) NotifyTxs(ctx context.Context, msg *pb.Transactions) (*pb.Void, error)

+ func (bn *BraftNode) NotifyVote(ctx context.Context, msg *pb.Vote) (*pb.Void, error)

+ func (bn *BraftNode) NotifyWeakAccuse(ctx context.Context, msg *pb.WeakAccuse) (*pb.Void, error)

+ func (bn *BraftNode) Run()

+ func (bn *BraftNode) Stop()

+ func (bn *BraftNode) SyncUp(ctx context.Context, msg *pb.SyncUpRequest) (*pb.SyncUpResponse, error)

+ func (bn *BraftNode) WatchSyncUp(ctx context.Context, msg *pb.SyncUpRequest) (*pb.SyncUpResponse, error)

+ func (node *BraftNode) AddWatchedTx(tx *pb.WatchedTxInfo) error

+ func (node *BraftNode) ChainRegister(regInfo *ChainRegInfo)

+ func (node *BraftNode) FakeCommitBlock(blockPack *pb.BlockPack)

+ func (node *BraftNode) GetBlockByID(id string) (*BlockView, error)

+ func (node *BraftNode) GetBlockBytHeight(height int64) *BlockView

+ func (node *BraftNode) GetBlockCurrent() *BlockView

+ func (node *BraftNode) GetBlockHeight() int64

+ func (node *BraftNode) GetBlockInfo(height int64) *pb.BlockInfo

+ func (node *BraftNode) GetBlocks(start, end int64) []*BlockView

+ func (node *BraftNode) GetBurnFeeRate() int64

+ func (node *BraftNode) GetChainRegisterID(newChain string, targetChain string) *ChainRegID

+ func (node *BraftNode) GetMinBCHMintAmount() int64

+ func (node *BraftNode) GetMinBTCMintAmount() int64

+ func (node *BraftNode) GetMinBurnAmount() int64

+ func (node *BraftNode) GetMintFeeRate() int64

+ func (node *BraftNode) GetNodeTerm() int64

+ func (node *BraftNode) GetNodes() []NodeView

+ func (node *BraftNode) GetTokenRegisterID(chain string, contractAddr string) *TokenRegID

+ func (node *BraftNode) GetTransacitonByTxID(txID string) *TxView

+ func (node *BraftNode) GetTxBySidechainTxId(scTxId string) *primitives.TxQueryResult

+ func (node *BraftNode) ManualMint(mintInfo *ManualMintRequest)

+ func (node *BraftNode) SaveSignedResult(msg *pb.SignedResult)

+ func (node *BraftNode) TokenRegister(regInfo *TokenRegInfo)

+ type ChainRegID struct

+ ChainID uint32

+ type ChainRegInfo struct

+ NewChain string

+ TargetChain string

+ type CheckMode int

+ const CheckFull

+ const CheckLite

+ type JoinMsg struct

+ LocalID int32

+ MultiSigInfos []cluster.MultiSigInfo

+ func InitJoin(startMode int32) *JoinMsg

+ type Leader struct

+ BecomeLeaderEvent *util.Event

+ NewInitEvent *util.Event

+ RetireEvent *util.Event

+ func NewLeader(nodeInfo cluster.NodeInfo, bs *primitives.BlockStore, ts *primitives.TxStore, ...) *Leader

+ func (ld *Leader) AddVote(vote *pb.Vote)

+ func (ld *Leader) OnJoinCancel()

+ func (ld *Leader) OnNewNodeJoin(host string)

+ func (ld *Leader) OnNodeJoinedDone(vote *pb.Vote)

+ func (ld *Leader) OnNodeLeave(nodeId int32)

+ func (ld *Leader) OnNodeLeaveDone()

+ func (ld *Leader) Run(ctx context.Context)

+ func (ld *Leader) SetFeeRate(mintFeeRate int64, burnFeeRate int64)

+ type ManualMintRequest struct

+ Address string

+ Amount int64

+ Chain uint32

+ Proposal string

+ Token uint32

+ type NodeView struct

+ BchHeight int64

+ BtcHeight int64

+ EthHeight int64

+ FiredCnt int32

+ HostName string

+ IP string

+ IsLeader bool

+ IsOnline bool

+ type SignedResultCache struct

+ type SyncDaemon struct

+ func NewSyncDaemon(db *dgwdb.LDBDatabase, bs *primitives.BlockStore, pm *cluster.PeerManager) *SyncDaemon

+ func (sd *SyncDaemon) Run(ctx context.Context)

+ func (sd *SyncDaemon) SignalSyncUp(nodeId int32)

+ type TokenRegID struct

+ TokenID uint32

+ type TokenRegInfo struct

+ Chain string

+ ContractAddr string

+ ReceptChain uint32

+ ReceptToken uint32

+ type TxView struct

+ Amount int64

+ AppCode uint32

+ Block string

+ BlockHeight int64

+ DGWFee int64

+ DGWTxHash string

+ FinalAmount int64

+ From string

+ FromFee int64

+ FromTxHash string

+ Time int64

+ To string

+ ToAddrs []string

+ ToFee int64

+ ToTxHash string

+ TokenCode uint32

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