Versions in this module Expand all Collapse all v0 v0.0.1 Sep 1, 2021 Changes in this version + type FakeAsyncLoader struct + func NewFakeAsyncLoader() *FakeAsyncLoader + func (fal *FakeAsyncLoader) AsyncLoad(requestID graphsync.RequestID, link ld.Link) <-chan types.AsyncLoadResult + func (fal *FakeAsyncLoader) CleanupRequest(requestID graphsync.RequestID) + func (fal *FakeAsyncLoader) CompleteResponsesFor(requestID graphsync.RequestID) + func (fal *FakeAsyncLoader) OnAsyncLoad(cb func(graphsync.RequestID, ld.Link, <-chan types.AsyncLoadResult)) + func (fal *FakeAsyncLoader) ProcessResponse(responses map[graphsync.RequestID]metadata.Metadata, blks []blocks.Block) + func (fal *FakeAsyncLoader) ResponseOn(requestID graphsync.RequestID, link ld.Link, result types.AsyncLoadResult) + func (fal *FakeAsyncLoader) StartRequest(requestID graphsync.RequestID, name string) error + func (fal *FakeAsyncLoader) SuccessResponseOn(requestID graphsync.RequestID, blks []blocks.Block) + func (fal *FakeAsyncLoader) VerifyLastProcessedBlocks(ctx context.Context, t *testing.T, expectedBlocks []blocks.Block) + func (fal *FakeAsyncLoader) VerifyLastProcessedResponses(ctx context.Context, t *testing.T, ...) + func (fal *FakeAsyncLoader) VerifyNoRemainingData(t *testing.T, requestID graphsync.RequestID) + func (fal *FakeAsyncLoader) VerifyStoreUsed(t *testing.T, requestID graphsync.RequestID, storeName string)
Go to main page