mocknet

Documentation

Index

• Variables
• func SetupRetrieval(t *testing.T, remote testpeer.TestPeer) chan []datatransfer.Event
• func WaitForFinish(ctx context.Context, t *testing.T, finishChan chan []datatransfer.Event, ...) []datatransfer.Event
• type MockRetrievalNet
  • func NewMockRetrievalNet(ctx context.Context, t *testing.T) *MockRetrievalNet
  • func (mrn *MockRetrievalNet) AddBitswapPeers(n int)
  • func (mrn *MockRetrievalNet) AddGraphsyncPeers(n int)
  • func (mrn *MockRetrievalNet) AddHttpPeers(n int)
  • func (mrn *MockRetrievalNet) TearDown() error

Variables

var QueryErrorTriggerCid = cid.MustParse("bafkqaalb")

Functions

func SetupRetrieval

func SetupRetrieval(t *testing.T, remote testpeer.TestPeer) chan []datatransfer.Event

func WaitForFinish

func WaitForFinish(ctx context.Context, t *testing.T, finishChan chan []datatransfer.Event, timeout time.Duration) []datatransfer.Event

Types

type MockRetrievalNet

type MockRetrievalNet struct {
	RemoteEvents [][]datatransfer.Event
	FinishedChan []chan struct{}
	MN           lpmock.Mocknet
	Self         host.Host
	Remotes      []testpeer.TestPeer
	Finder       retriever.CandidateFinder
	// contains filtered or unexported fields
}

func NewMockRetrievalNet

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

func (*MockRetrievalNet) AddBitswapPeers

func (mrn *MockRetrievalNet) AddBitswapPeers(n int)

func (*MockRetrievalNet) AddGraphsyncPeers

func (mrn *MockRetrievalNet) AddGraphsyncPeers(n int)

func (*MockRetrievalNet) AddHttpPeers

func (mrn *MockRetrievalNet) AddHttpPeers(n int)

func (*MockRetrievalNet) TearDown

func (mrn *MockRetrievalNet) TearDown() error