mocknet

Documentation

Index

• Variables
• func ChanCheck(ctx context.Context, t *testing.T, ch <-chan struct{}) func() bool
• type MockRetrievalNet
  • func NewMockRetrievalNet() *MockRetrievalNet
  • func (mrn *MockRetrievalNet) SetupNet(ctx context.Context, t *testing.T)
  • func (mrn *MockRetrievalNet) SetupQuery(ctx context.Context, t *testing.T, expectCid cid.Cid, ...)
  • func (mrn *MockRetrievalNet) SetupRetrieval(ctx context.Context, t *testing.T)
  • func (mrn *MockRetrievalNet) TearDown() error
  • func (mrn *MockRetrievalNet) WaitForFinish(ctx context.Context, t *testing.T)

Variables

var QueryErrorTriggerCid = cid.MustParse("bafkqaalb")

Functions

func ChanCheck

func ChanCheck(ctx context.Context, t *testing.T, ch <-chan struct{}) func() bool

Types

type MockRetrievalNet

type MockRetrievalNet struct {
	RemoteEvents []datatransfer.Event

	FinishedChan     chan struct{}
	MN               lpmock.Mocknet
	HostLocal        host.Host
	HostRemote       host.Host
	LinkSystemRemote linking.LinkSystem
	Finder           retriever.CandidateFinder
}

func NewMockRetrievalNet

func NewMockRetrievalNet() *MockRetrievalNet

func (*MockRetrievalNet) SetupNet

func (mrn *MockRetrievalNet) SetupNet(ctx context.Context, t *testing.T)

func (*MockRetrievalNet) SetupQuery

func (mrn *MockRetrievalNet) SetupQuery(ctx context.Context, t *testing.T, expectCid cid.Cid, qr retrievalmarket.QueryResponse)

func (*MockRetrievalNet) SetupRetrieval

func (mrn *MockRetrievalNet) SetupRetrieval(ctx context.Context, t *testing.T)

func (*MockRetrievalNet) TearDown

func (mrn *MockRetrievalNet) TearDown() error

func (*MockRetrievalNet) WaitForFinish

func (mrn *MockRetrievalNet) WaitForFinish(ctx context.Context, t *testing.T)