Versions in this module Expand all Collapse all v0 v0.0.1 Jul 4, 2023 Changes in this version + const BytesInInt + const ChecksumSize + const EntrySize + var ErrValidation = validationError("unknown") + func ComputeDealPlacement(dealInfos []abi.PieceInfo) ([]merkletree.CommAndLoc, uint64, error) + func DataSegmentIndexStartOffset(dealSize abi.PaddedPieceSize) uint64 + func MakeSegDescs(segments []merkletree.Node, segmentSizes []uint64) ([]merkletree.Node, error) + func MaxIndexEntriesInDeal(dealSize abi.PaddedPieceSize) uint + func SegmentRoot(treeDepth int, segmentSize uint64, segmentOffset uint64) (int, uint64) + func SerializeIndex(index *IndexData) ([]byte, error) + type Aggregate struct + DealSize abi.PaddedPieceSize + Index IndexData + Tree merkletree.Hybrid + func NewAggregate(dealSize abi.PaddedPieceSize, subdeals []abi.PieceInfo) (*Aggregate, error) + func (a Aggregate) AggregateObjectReader(subPieceReaders []io.Reader) (io.Reader, error) + func (a Aggregate) IndexPieceCID() (cid.Cid, error) + func (a Aggregate) IndexReader() (io.Reader, error) + func (a Aggregate) IndexSize() (abi.PaddedPieceSize, error) + func (a Aggregate) IndexStartPosition() (uint64, error) + func (a Aggregate) PieceCID() (cid.Cid, error) + func (a Aggregate) ProofForIndexEntry(idx int) (*InclusionProof, error) + func (a Aggregate) ProofForPieceInfo(d abi.PieceInfo) (*InclusionProof, error) + type DataAggregationProof struct + AuxDataSource SingletonMarketSource + AuxDataType uint64 + Inclusion InclusionProof + func (dap DataAggregationProof) ComputeExpectedAuxData(verifierData InclusionVerifierData) (*InclusionAuxData, error) + func (dap DataAggregationProof) VerifyActive(verifierData InclusionVerifierData, auxDataFetch MarketAuxDataFetch) error + func (t *DataAggregationProof) MarshalCBOR(w io.Writer) error + func (t *DataAggregationProof) UnmarshalCBOR(r io.Reader) (err error) + type InclusionAuxData struct + CommPa cid.Cid + SizePa abi.PaddedPieceSize + func (t *InclusionAuxData) MarshalCBOR(w io.Writer) error + func (t *InclusionAuxData) UnmarshalCBOR(r io.Reader) (err error) + type InclusionProof struct + ProofIndex merkletree.ProofData + ProofSubtree merkletree.ProofData + func CollectInclusionProof(ht *merkletree.Hybrid, dealSize abi.PaddedPieceSize, ...) (*InclusionProof, error) + func (ip InclusionProof) ComputeExpectedAuxData(veriferData InclusionVerifierData) (*InclusionAuxData, error) + func (t *InclusionProof) MarshalCBOR(w io.Writer) error + func (t *InclusionProof) UnmarshalCBOR(r io.Reader) (err error) + type InclusionVerifierData struct + CommPc cid.Cid + SizePc abi.PaddedPieceSize + func VerifierDataForPieceInfo(pi abi.PieceInfo) InclusionVerifierData + func (t *InclusionVerifierData) MarshalCBOR(w io.Writer) error + func (t *InclusionVerifierData) UnmarshalCBOR(r io.Reader) (err error) + type IndexData struct + Entries []SegmentDesc + func MakeIndex(entries []SegmentDesc) (*IndexData, error) + func MakeIndexFromCommLoc(dealInfos []merkletree.CommAndLoc) (*IndexData, error) + func ParseDataSegmentIndex(unpaddedReader io.Reader) (IndexData, error) + func (i IndexData) IndexSize() uint64 + func (i IndexData) NumberEntries() int + func (i IndexData) SegmentDesc(index int) *SegmentDesc + func (id *IndexData) UnmarshalBinary(data []byte) error + func (id IndexData) MarshalBinary() (data []byte, err error) + func (id IndexData) ValidEntries() ([]SegmentDesc, error) + func (id IndexData) Validate() error + func (t *IndexData) MarshalCBOR(w io.Writer) error + func (t *IndexData) UnmarshalCBOR(r io.Reader) (err error) + type MarketAuxDataFetch func(SingletonMarketSource) (SingletonMarketAuxData, error) + type SegmentDesc struct + Checksum [ChecksumSize]byte + CommDs merkletree.Node + Offset uint64 + Size uint64 + func MakeDataSegmentIdx(commDs *fr32.Fr32, offset uint64, size uint64) (SegmentDesc, error) + func MakeDataSegmentIdxWithChecksum(commDs *fr32.Fr32, offset uint64, size uint64, checksum *[ChecksumSize]byte) (SegmentDesc, error) + func MakeDataSegmentIndexEntry(CommP *fr32.Fr32, offset uint64, size uint64) (*SegmentDesc, error) + func (ds SegmentDesc) MakeNode() (merkletree.Node, merkletree.Node, error) + func (sd *SegmentDesc) UnmarshalBinary(data []byte) error + func (sd SegmentDesc) CommAndLoc() merkletree.CommAndLoc + func (sd SegmentDesc) IntoNodes() [2]merkletree.Node + func (sd SegmentDesc) MarshalBinary() ([]byte, error) + func (sd SegmentDesc) PieceCID() cid.Cid + func (sd SegmentDesc) SerializeFr32() []byte + func (sd SegmentDesc) SerializeFr32Into(slice []byte) + func (sd SegmentDesc) UnpaddedLength() uint64 + func (sd SegmentDesc) UnpaddedOffest() uint64 + func (sd SegmentDesc) Validate() error + func (t *SegmentDesc) MarshalCBOR(w io.Writer) error + func (t *SegmentDesc) UnmarshalCBOR(r io.Reader) (err error) + type SingletonMarketAuxData struct + AuxData InclusionAuxData + DealActive bool + type SingletonMarketSource struct + DealID abi.DealID + func (t *SingletonMarketSource) MarshalCBOR(w io.Writer) error + func (t *SingletonMarketSource) UnmarshalCBOR(r io.Reader) (err error)