Versions in this module Expand all Collapse all v0 v0.5.0 Mar 23, 2021 Changes in this version + type Client struct + func (rb *Client) Init(peerSub interfaces.PeerSubscription) error + func (rb *Client) RequestP2PGetBlockHeaders(ctx context.Context, blockNums []uint32) ([]*objs.BlockHeader, error) + func (rb *Client) RequestP2PGetMinedTxs(ctx context.Context, txHashes [][]byte) ([][]byte, error) + func (rb *Client) RequestP2PGetPendingTx(ctx context.Context, txHashes [][]byte) ([][]byte, error) + func (rb *Client) RequestP2PGetSnapShotHdrNode(ctx context.Context, key []byte) ([]byte, error) + func (rb *Client) RequestP2PGetSnapShotNode(ctx context.Context, height uint32, key []byte) ([]byte, error) + func (rb *Client) RequestP2PGetSnapShotStateData(ctx context.Context, key []byte) ([]byte, error) + type Handler struct + func (rb *Handler) Done() <-chan struct{} + func (rb *Handler) Exit() + func (rb *Handler) HandleP2PGetBlockHeaders(ctx context.Context, r *pb.GetBlockHeadersRequest) (*pb.GetBlockHeadersResponse, error) + func (rb *Handler) HandleP2PGetMinedTxs(ctx context.Context, r *pb.GetMinedTxsRequest) (*pb.GetMinedTxsResponse, error) + func (rb *Handler) HandleP2PGetPendingTxs(ctx context.Context, r *pb.GetPendingTxsRequest) (*pb.GetPendingTxsResponse, error) + func (rb *Handler) HandleP2PGetSnapShotHdrNode(ctx context.Context, r *pb.GetSnapShotHdrNodeRequest) (*pb.GetSnapShotHdrNodeResponse, error) + func (rb *Handler) HandleP2PGetSnapShotNode(ctx context.Context, r *pb.GetSnapShotNodeRequest) (*pb.GetSnapShotNodeResponse, error) + func (rb *Handler) HandleP2PGetSnapShotStateData(ctx context.Context, r *pb.GetSnapShotStateDataRequest) (*pb.GetSnapShotStateDataResponse, error) + func (rb *Handler) Init(database *db.Database, app appHandler) error + func (rb *Handler) Start()
Go to main page