Versions in this module Expand all Collapse all v1 v1.0.0 Aug 15, 2021 Changes in this version + const BadRequest + const BlockSyncProtocolID + const ChainExchangeProtocolID + const GoAway + const Headers + const InternalError + const Messages + const NotFound + const Ok + const Partial + const ReadResDeadline + const ReadResMinSpeed + const ShufflePeersPrefix + const SuccessPeerTagValue + const WriteReqDeadline + const WriteResDeadline + var MaxRequestLength = uint64(build.ForkLengthThreshold) + type BSTipSet struct + Blocks []*types.BlockHeader + Messages *CompactedMessages + func (t *BSTipSet) MarshalCBOR(w io.Writer) error + func (t *BSTipSet) UnmarshalCBOR(r io.Reader) error + type Client interface + AddPeer func(peer peer.ID) + GetBlocks func(ctx context.Context, tsk types.TipSetKey, count int) ([]*types.TipSet, error) + GetChainMessages func(ctx context.Context, tipsets []*types.TipSet) ([]*CompactedMessages, error) + GetFullTipSet func(ctx context.Context, peer peer.ID, tsk types.TipSetKey) (*store.FullTipSet, error) + RemovePeer func(peer peer.ID) + func NewClient(lc fx.Lifecycle, host host.Host, pmgr peermgr.MaybePeerMgr) Client + type CompactedMessages struct + Bls []*types.Message + BlsIncludes [][]uint64 + Secpk []*types.SignedMessage + SecpkIncludes [][]uint64 + func (t *CompactedMessages) MarshalCBOR(w io.Writer) error + func (t *CompactedMessages) UnmarshalCBOR(r io.Reader) error + type Request struct + Head []cid.Cid + Length uint64 + Options uint64 + func (t *Request) MarshalCBOR(w io.Writer) error + func (t *Request) UnmarshalCBOR(r io.Reader) error + type Response struct + Chain []*BSTipSet + ErrorMessage string + Status status + func (t *Response) MarshalCBOR(w io.Writer) error + func (t *Response) UnmarshalCBOR(r io.Reader) error + type Server interface + HandleStream func(stream network.Stream) + func NewServer(cs *store.ChainStore) Server