testharness

Documentation

Index

• type MeshCreatorStub
  • func (m *MeshCreatorStub) Connect(context.Context) error
• type StorageHarness
  • func NewHarness(t *testing.T, ctx context.Context, useStore bool, ...) *StorageHarness
  • func NewHarnessWithTestData(t *testing.T, td *shared_testutil.Libp2pTestData, ...) *StorageHarness
  • func (h *StorageHarness) CreateNewProvider(t *testing.T, ctx context.Context, td *shared_testutil.Libp2pTestData) storagemarket.StorageProvider
  • func (h *StorageHarness) ProposeStorageDeal(t *testing.T, dataRef *storagemarket.DataRef, fastRetrieval, verifiedDeal bool) *storagemarket.ProposeStorageDealResult
  • func (h *StorageHarness) WaitForClientEvent(wg *sync.WaitGroup, waitEvent storagemarket.ClientEvent)
  • func (h *StorageHarness) WaitForProviderEvent(wg *sync.WaitGroup, waitEvent storagemarket.ProviderEvent)

Types

type MeshCreatorStub

type MeshCreatorStub struct {
}

func (*MeshCreatorStub) Connect

func (m *MeshCreatorStub) Connect(context.Context) error

type StorageHarness

type StorageHarness struct {
	*dependencies.StorageDependencies
	PayloadCid        cid.Cid
	Client            storagemarket.StorageClient
	Provider          storagemarket.StorageProvider
	Data              bstore.Blockstore
	ReferenceProvider *shared_testutil.MockIndexProvider
}

func NewHarness

func NewHarness(t *testing.T, ctx context.Context, useStore bool, cd testnodes.DelayFakeCommonNode, pd testnodes.DelayFakeCommonNode,
	disableNewDeals bool, fName ...string) *StorageHarness

func NewHarnessWithTestData

func NewHarnessWithTestData(t *testing.T, td *shared_testutil.Libp2pTestData, deps *dependencies.StorageDependencies, useStore bool, disableNewDeals bool, files ...string) *StorageHarness

func (*StorageHarness) CreateNewProvider

func (h *StorageHarness) CreateNewProvider(t *testing.T, ctx context.Context, td *shared_testutil.Libp2pTestData) storagemarket.StorageProvider

func (*StorageHarness) ProposeStorageDeal

func (h *StorageHarness) ProposeStorageDeal(t *testing.T, dataRef *storagemarket.DataRef, fastRetrieval, verifiedDeal bool) *storagemarket.ProposeStorageDealResult

func (*StorageHarness) WaitForClientEvent

func (h *StorageHarness) WaitForClientEvent(wg *sync.WaitGroup, waitEvent storagemarket.ClientEvent)

func (*StorageHarness) WaitForProviderEvent

func (h *StorageHarness) WaitForProviderEvent(wg *sync.WaitGroup, waitEvent storagemarket.ProviderEvent)