testutil

Documentation

Index

• func GenerateBlocksOfSize(n int, size int64) []blocks.Block
• func GenerateCid() cid.Cid
• func GenerateCids(n int) []cid.Cid
• func GeneratePeers(n int) []peer.ID
• func GenerateRetrievalCandidates(n int) []types.RetrievalCandidate
• func GenerateRetrievalIDs(t *testing.T, n int) []types.RetrievalID
• func RandomBytes(n int64) []byte
• func VerifyCollectedEvent(t *testing.T, actual types.RetrievalEvent, expected types.RetrievalEvent)
• func VerifyCollectedEventTimings(t *testing.T, events []types.RetrievalEvent)
• func VerifyContainsCollectedEvent(t *testing.T, actualList []types.RetrievalEvent, expected types.RetrievalEvent)
• type CollectingEventsListener
  • func NewCollectingEventsListener() *CollectingEventsListener
  • func (el *CollectingEventsListener) Collect(event types.RetrievalEvent)
• type DelayedQueryReturn
• type DelayedRetrievalReturn
• type MockCandidateFinder
  • func (me *MockCandidateFinder) FindCandidates(ctx context.Context, cid cid.Cid) ([]types.RetrievalCandidate, error)
  • func (me *MockCandidateFinder) FindCandidatesAsync(ctx context.Context, c cid.Cid) (<-chan types.FindCandidatesResult, error)
• type MockClient
  • func NewMockClient(queryReturns map[string]DelayedQueryReturn, ...) *MockClient
  • func (mc *MockClient) GetQueryReturns() map[string]DelayedQueryReturn
  • func (mc *MockClient) GetReceivedLinkSystems() []ipld.LinkSystem
  • func (mc *MockClient) GetReceivedQueries() []peer.ID
  • func (mc *MockClient) GetReceivedRetrievals() []peer.ID
  • func (mc *MockClient) GetRetrievalReturns() map[string]DelayedRetrievalReturn
  • func (mc *MockClient) RetrievalQueryToPeer(ctx context.Context, minerPeer peer.AddrInfo, pcid cid.Cid, onConnected func()) (*retrievalmarket.QueryResponse, error)
  • func (mc *MockClient) RetrieveFromPeer(ctx context.Context, linkSystem ipld.LinkSystem, peerID peer.ID, ...) (*types.RetrievalStats, error)
  • func (mc *MockClient) SetQueryReturns(queryReturns map[string]DelayedQueryReturn)
  • func (mc *MockClient) SetRetrievalReturns(retrievalReturns map[string]DelayedRetrievalReturn)

Functions

func GenerateBlocksOfSize

func GenerateBlocksOfSize(n int, size int64) []blocks.Block

GenerateBlocksOfSize generates a series of blocks of the given byte size

func GenerateCid

func GenerateCid() cid.Cid

GenerateCid produces a content identifier.

func GenerateCids

func GenerateCids(n int) []cid.Cid

GenerateCids produces n content identifiers.

func GeneratePeers

func GeneratePeers(n int) []peer.ID

GeneratePeers creates n peer ids.

func GenerateRetrievalCandidates

func GenerateRetrievalCandidates(n int) []types.RetrievalCandidate

GenerateRetrievalCandidates produces n retrieval candidates

func GenerateRetrievalIDs

func GenerateRetrievalIDs(t *testing.T, n int) []types.RetrievalID

func RandomBytes

func RandomBytes(n int64) []byte

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

func VerifyCollectedEvent

func VerifyCollectedEvent(t *testing.T, actual types.RetrievalEvent, expected types.RetrievalEvent)

func VerifyCollectedEventTimings

func VerifyCollectedEventTimings(t *testing.T, events []types.RetrievalEvent)

func VerifyContainsCollectedEvent

func VerifyContainsCollectedEvent(t *testing.T, actualList []types.RetrievalEvent, expected types.RetrievalEvent)

Types

type CollectingEventsListener

type CollectingEventsListener struct {
	CollectedEvents []types.RetrievalEvent
	// contains filtered or unexported fields
}

func NewCollectingEventsListener

func NewCollectingEventsListener() *CollectingEventsListener

func (*CollectingEventsListener) Collect

func (el *CollectingEventsListener) Collect(event types.RetrievalEvent)

type DelayedQueryReturn

type DelayedQueryReturn struct {
	QueryResponse *retrievalmarket.QueryResponse
	Err           error
	Delay         time.Duration
}

type DelayedRetrievalReturn

type DelayedRetrievalReturn struct {
	ResultStats *types.RetrievalStats
	ResultErr   error
	Delay       time.Duration
}

type MockCandidateFinder

type MockCandidateFinder struct {
	Error      error
	Candidates map[cid.Cid][]types.RetrievalCandidate
}

func (*MockCandidateFinder) FindCandidates

func (me *MockCandidateFinder) FindCandidates(ctx context.Context, cid cid.Cid) ([]types.RetrievalCandidate, error)

func (*MockCandidateFinder) FindCandidatesAsync

func (me *MockCandidateFinder) FindCandidatesAsync(ctx context.Context, c cid.Cid) (<-chan types.FindCandidatesResult, error)

type MockClient

type MockClient struct {
	// contains filtered or unexported fields
}

func NewMockClient

func NewMockClient(queryReturns map[string]DelayedQueryReturn, retrievalReturns map[string]DelayedRetrievalReturn) *MockClient

func (*MockClient) GetQueryReturns

func (mc *MockClient) GetQueryReturns() map[string]DelayedQueryReturn

func (*MockClient) GetReceivedLinkSystems

func (mc *MockClient) GetReceivedLinkSystems() []ipld.LinkSystem

func (*MockClient) GetReceivedQueries

func (mc *MockClient) GetReceivedQueries() []peer.ID

func (*MockClient) GetReceivedRetrievals

func (mc *MockClient) GetReceivedRetrievals() []peer.ID

func (*MockClient) GetRetrievalReturns

func (mc *MockClient) GetRetrievalReturns() map[string]DelayedRetrievalReturn

func (*MockClient) RetrievalQueryToPeer

func (mc *MockClient) RetrievalQueryToPeer(
	ctx context.Context,
	minerPeer peer.AddrInfo,
	pcid cid.Cid,
	onConnected func(),
) (*retrievalmarket.QueryResponse, error)

func (*MockClient) RetrieveFromPeer

func (mc *MockClient) RetrieveFromPeer(
	ctx context.Context,
	linkSystem ipld.LinkSystem,
	peerID peer.ID,
	minerWallet address.Address,
	proposal *retrievalmarket.DealProposal,
	eventsCallback datatransfer.Subscriber,
	gracefulShutdownRequested <-chan struct{},
) (*types.RetrievalStats, error)

func (*MockClient) SetQueryReturns

func (mc *MockClient) SetQueryReturns(queryReturns map[string]DelayedQueryReturn)

func (*MockClient) SetRetrievalReturns

func (mc *MockClient) SetRetrievalReturns(retrievalReturns map[string]DelayedRetrievalReturn)