AssertDealState asserts equality of StorageDealStatus but with better error messaging.

ContainsBlock returns true if a block is found n a list of blocks.

ContainsPeer returns true if a peer is found n a list of peers.

CreateDenseCARv2 generates a "dense" UnixFS CARv2 from the supplied ordinary file.

CreateRefCARv2 generates a "ref" CARv2 from the supplied ordinary file.

ExpectDealResponseWriter will fail if the written query and expected query don't match.

ExpectPeerOnQueryStreamBuilder fails if the peer used does not match the expected peer.

ExpectQueryResponseWriter will fail if the written query response and expected query response don't match.

ExpectQueryWriter will fail if the written query and expected query don't match.

FailDealPaymentReader always fails.

FailDealPaymentWriter always fails.

FailDealProposalReader always fails.

FailDealProposalWriter always fails.

FailDealResponseReader always fails.

FailDealResponseWriter always fails.

FailNewQueryStream always fails.

FailQueryReader always fails.

FailQueryWriter always fails.

FailResponseReader always fails.

FailResponseWriter always fails.

FailStorageProposalReader always fails.

FailStorageProposalWriter always fails.

FailStorageResponseReader always fails.

FailStorageResponseWriter always fails.

GenerateBlocksOfSize generates a series of blocks of the given byte size.

GenerateCids produces n content identifiers.

GeneratePeers creates n peer ids.

IndexOf returns the index of a given cid in an array of blocks.

MakeIdentityCidWith will create either a dag-pb or dag-cbor identity CID containing the provided list of CIDs and optional byte blocks.

MakeTestChannelID makes a new empty data transfer channel ID.

MakeTestClientDeal returns a storage market client deal.

MakeTestClientDealProposal generates a valid storage deal proposal.

MakeTestDataRef returns a storage market data ref.

MakeTestDealProposal generates a valid, random DealProposal.

MakeTestDealStatusRequest generates a request to get a provider's query.

MakeTestDealStatusResponse generates a response to an query request.

MakeTestMerge generates a random Merge that has all non-zero fields.

MakeTestMinerDeal returns a storage market provider deal.

MakeTestModVerifyParams generates a random ModVerifyParams that has all non-zero fields.

MakeTestQueryResponse generates a valid, random QueryResponse with no non-zero fields.

MakeTestSignature generates a valid yet random Signature with all non-zero fields.

MakeTestSignedStorageAsk generates a signed storage ask.

MakeTestSignedVoucher generates a random SignedVoucher that has all non-zero fields.

MakeTestStorageAsk generates a storage ask.

MakeTestStorageAskRequest generates a request to get a provider's ask.

MakeTestStorageAskResponse generates a response to an ask request.

MakeTestStorageNetworkProposal generates a proposal that can be sent over the network to a provider.

MakeTestStorageNetworkResponse generates a response to a proposal sent over the network.

MakeTestStorageNetworkSignedResponse generates a response to a proposal sent over the network that is signed.

MakeTestTokenAmount generates a valid yet random TokenAmount with a non-zero value.

MakeTestUnsignedDealProposal generates a deal proposal with no signature.

NewTestChannel makes a test channel with default params plus non-zero values for TestChannelParams.

NewTestDataTransfer returns a new test interface implementation of datatransfer.Manager.

NewTestFile generates a mocked filestore.File that has programmed returns.

NewTestFileStore returns a new test file store from the given parameters.

NewTestIPLDTree returns a fake tree of nodes, spread across 5 blocks.

NewTestPieceStore creates a TestPieceStore.

NewTestPieceStoreWithParams creates a TestPieceStore with the given parameters.

NewTestRetrievalMarketNetwork returns a new TestRetrievalMarketNetwork with the behavior specified by the paramaters, or default behaviors if not specified.

NewTestRetrievalQueryStream returns a new TestRetrievalQueryStream with the behavior specified by the paramaters, or default behaviors if not specified.

NewTestStorageDealStream returns a new TestStorageDealStream with the behavior specified by the paramaters, or default behaviors if not specified.

QueryReadWriter will read only if something is written, otherwise it errors.

QueryResponseReadWriter will read only if something is written, otherwise it errors.

RandomBytes returns a byte array of the given size with random values.

StartAndWaitForReady is a utility function to start a module and verify it reaches the ready state.

StartAndWaitForReadyDT is a utility function to start a go-data-transfer and verify it reaches the ready state.

StubbedDealPaymentReader returns the given deal payment when called.

StubbedDealProposalReader returns the given proposal when called.

StubbedDealResponseReader returns the given deal response when called.

StubbedQueryReader returns the given query when called.

StubbedQueryResponseReader returns the given query response when called.

StubbedStorageProposalReader returns the given proposal when called.

StubbedStorageResponseReader returns the given deal response when called.

TestVoucherEquality verifies that two vouchers are equal to one another.

TrivialNewQueryStream succeeds trivially, returning an empty query stream.

TrivialQueryReader succeeds trivially, returning an empty query.

TrivialQueryResponseReader succeeds trivially, returning an empty query response.

TrivialQueryResponseWriter succeeds trivially, returning no error.

TrivialQueryWriter succeeds trivially, returning no error.

TrivialStorageDealProposalReader succeeds trivially, returning an empty proposal.

TrivialStorageDealProposalWriter succeeds trivially, returning no error.

TrivialStorageDealResponseReader succeeds trivially, returning an empty deal response.

TrivialStorageDealResponseWriter succeeds trivially, returning no error.

MockDagStoreWrapper is used to mock out the DAG store wrapper operations for the tests.

RegisteredTransportConfigurer records transport configurer registered for a voucher type.

RegisteredVoucherType records a voucher typed that was registered.

TestChannel implements a datatransfer channel with set values.

TestChannelParams are params for a new test data transfer channel.

TestDataTransfer is a mock implementation of the data transfer libary Most of its functions have no effect.

TestDealStreamParams are parameters used to setup a TestRetrievalDealStream.

TestFile is a mocked version of filestore.File with preset returns and a byte buffer for read/writes.

TestFileParams are parameters for a test file.

TestFileStore is a mocked file store that can provide programmed returns and test expectations.

TestFileStoreParams are parameters for a test file store.

TestIPLDTree is a set of IPLD Data that forms a tree spread across some blocks with a serialized in memory representation.

TestNetworkParams are parameters for setting up a test network.

TestPeerResolver provides a fake retrievalmarket PeerResolver.

TestPieceStore is piecestore who's query results are mocked.

TestPieceStoreParams sets parameters for a piece store.

TestQueryStreamParams are parameters used to setup a TestRetrievalQueryStream.

TestRetrievalDealStream is a retrieval deal stream with predefined stubbed behavior.

TestRetrievalMarketNetwork is a test network that has stubbed behavior for testing the retrieval market implementation.

TestRetrievalQueryStream is a retrieval query stream with predefined stubbed behavior.

TestStorageDealStream is a retrieval deal stream with predefined stubbed behavior.

TestStorageDealStreamParams are parameters used to setup a TestStorageDealStream.

StartAndWaitable is any interface that can be started up and will be asynchronously ready later.

DealPaymentReader is a function to mock reading deal payments.

DealPaymentWriter is a function to mock writing deal payments.

DealProposalReader is a function to mock reading deal proposals.

DealProposalWriter is a function to mock writing deal proposals.

DealResponseReader is a function to mock reading deal responses.

DealResponseWriter is a function to mock writing deal responses.

QueryReader is a function to mock reading queries.

QueryResponseReader is a function to mock reading query responses.

QueryResponseWriter is a function to mock writing query responses.

QueryStreamBuilder is a function that builds retrieval query streams.

QueryWriter is a function to mock writing queries.

StorageDealProposalReader is a function to mock reading deal proposals.

StorageDealProposalWriter is a function to mock writing deal proposals.

StorageDealResponseReader is a function to mock reading deal responses.

StorageDealResponseWriter is a function to mock writing deal responses.