Versions in this module Expand all Collapse all v0 v0.5.0 Mar 23, 2021 Changes in this version + type Client struct + func (mb *Client) Close() + func (mb *Client) Done() <-chan struct{} + func (mb *Client) Init(database *db.Database, peerSub interfaces.PeerSubscription, app appClient) error + func (mb *Client) ReGossip() error + func (mb *Client) Start() error + type Handlers struct + func (mb *Handlers) Close() + func (mb *Handlers) Done() <-chan struct{} + func (mb *Handlers) HandleP2PGossipBlockHeader(pctx context.Context, msg *pb.GossipBlockHeaderMessage) (*pb.GossipBlockHeaderAck, error) + func (mb *Handlers) HandleP2PGossipNextHeight(pctx context.Context, msg *pb.GossipNextHeightMessage) (*pb.GossipNextHeightAck, error) + func (mb *Handlers) HandleP2PGossipNextRound(pctx context.Context, msg *pb.GossipNextRoundMessage) (*pb.GossipNextRoundAck, error) + func (mb *Handlers) HandleP2PGossipPreCommit(pctx context.Context, msg *pb.GossipPreCommitMessage) (*pb.GossipPreCommitAck, error) + func (mb *Handlers) HandleP2PGossipPreCommitNil(pctx context.Context, msg *pb.GossipPreCommitNilMessage) (*pb.GossipPreCommitNilAck, error) + func (mb *Handlers) HandleP2PGossipPreVote(pctx context.Context, msg *pb.GossipPreVoteMessage) (*pb.GossipPreVoteAck, error) + func (mb *Handlers) HandleP2PGossipPreVoteNil(pctx context.Context, msg *pb.GossipPreVoteNilMessage) (*pb.GossipPreVoteNilAck, error) + func (mb *Handlers) HandleP2PGossipProposal(pctx context.Context, msg *pb.GossipProposalMessage) (*pb.GossipProposalAck, error) + func (mb *Handlers) HandleP2PGossipTransaction(pctx context.Context, msg *pb.GossipTransactionMessage) (*pb.GossipTransactionAck, error) + func (mb *Handlers) Init(database *db.Database, peerSub interfaces.PeerSubscription, app appHandler, ...) error + func (mb *Handlers) UpdateBlocksFromGossip() error + func (mb *Handlers) UpdateStateFromGossip(forceExit <-chan struct{}, mut interfaces.Lockable, safe func() bool) error
Go to main page