dependencies

Documentation

Index

• type DepGenerator
  • func NewDepGenerator() *DepGenerator
  • func (gen *DepGenerator) New(t *testing.T, ctx context.Context, td *shared_testutil.Libp2pTestData, ...) *StorageDependencies
• type NewDataTransfer
• type StorageDependencies
  • func NewDependenciesWithTestData(t *testing.T, ctx context.Context, td *shared_testutil.Libp2pTestData, ...) *StorageDependencies

Types

type DepGenerator

type DepGenerator struct {
	ClientNewDataTransfer   NewDataTransfer
	ProviderNewDataTransfer NewDataTransfer
}

func NewDepGenerator

func NewDepGenerator() *DepGenerator

func (*DepGenerator) New

func (gen *DepGenerator) New(
	t *testing.T,
	ctx context.Context,
	td *shared_testutil.Libp2pTestData,
	smState *testnodes.StorageMarketState,
	tempPath string,
	cd testnodes.DelayFakeCommonNode,
	pd testnodes.DelayFakeCommonNode,
) *StorageDependencies

type NewDataTransfer

type NewDataTransfer func(ds datastore.Batching, cidListsDir string, dataTransferNetwork network2.DataTransferNetwork, transport datatransfer.Transport, storedCounter *storedcounter.StoredCounter) (datatransfer.Manager, error)

type StorageDependencies

type StorageDependencies struct {
	Ctx                               context.Context
	Epoch                             abi.ChainEpoch
	ProviderAddr                      address.Address
	ClientAddr                        address.Address
	ClientNode                        *testnodes.FakeClientNode
	ProviderNode                      *testnodes.FakeProviderNode
	SMState                           *testnodes.StorageMarketState
	TempFilePath                      string
	ProviderInfo                      storagemarket.StorageProviderInfo
	TestData                          *shared_testutil.Libp2pTestData
	PieceStore                        piecestore.PieceStore
	DTClient                          datatransfer.Manager
	DTProvider                        datatransfer.Manager
	PeerResolver                      *discoveryimpl.Local
	ClientDelayFakeCommonNode         testnodes.DelayFakeCommonNode
	ProviderClientDelayFakeCommonNode testnodes.DelayFakeCommonNode
	Fs                                filestore.FileStore
	StoredAsk                         *storedask.StoredAsk
}

StorageDependencies are the dependencies required to initialize a storage client/provider

func NewDependenciesWithTestData

func NewDependenciesWithTestData(t *testing.T,
	ctx context.Context,
	td *shared_testutil.Libp2pTestData,
	smState *testnodes.StorageMarketState,
	tempPath string,
	cd testnodes.DelayFakeCommonNode,
	pd testnodes.DelayFakeCommonNode,
) *StorageDependencies