availability_test

Documentation

Index

• func FillBS(t *testing.T, bServ blockservice.BlockService, shares []libshare.Share) *share.AxisRoots
• func RandFillBS(t *testing.T, n int, bServ blockservice.BlockService) *share.AxisRoots
• type SubNet
  • func (sn *SubNet) AddNode(nd *TestNode)
  • func (sn *SubNet) ConnectAll()
• type TestDagNet
  • func NewTestDAGNet(ctx context.Context, t *testing.T) *TestDagNet
  • func (dn *TestDagNet) Connect(peerA, peerB peer.ID)
  • func (dn *TestDagNet) ConnectAll()
  • func (dn *TestDagNet) Disconnect(peerA, peerB peer.ID)
  • func (dn *TestDagNet) NewTestNode() *TestNode
  • func (dn *TestDagNet) NewTestNodeWithBlockstore(dstore ds.Datastore, bstore blockstore.Blockstore) *TestNode
  • func (dn *TestDagNet) SubNet() *SubNet
• type TestNode
  • func (n *TestNode) ClearStorage()

Functions

func FillBS

func FillBS(t *testing.T, bServ blockservice.BlockService, shares []libshare.Share) *share.AxisRoots

FillBS fills the given BlockService with the given shares.

func RandFillBS

func RandFillBS(t *testing.T, n int, bServ blockservice.BlockService) *share.AxisRoots

RandFillBS fills the given BlockService with a random block of a given size.

Types

type SubNet

type SubNet struct {
	*TestDagNet
	// contains filtered or unexported fields
}

func (*SubNet) AddNode

func (sn *SubNet) AddNode(nd *TestNode)

func (*SubNet) ConnectAll

func (sn *SubNet) ConnectAll()

type TestDagNet

type TestDagNet struct {
	T *testing.T
	// contains filtered or unexported fields
}

func NewTestDAGNet

func NewTestDAGNet(ctx context.Context, t *testing.T) *TestDagNet

NewTestDAGNet creates a new testing swarm utility to spawn different nodes and test how they interact and/or exchange data.

func (*TestDagNet) Connect

func (dn *TestDagNet) Connect(peerA, peerB peer.ID)

Connect connects two given peers.

func (*TestDagNet) ConnectAll

func (dn *TestDagNet) ConnectAll()

ConnectAll connects all the peers on registered on the TestDagNet.

func (*TestDagNet) Disconnect

func (dn *TestDagNet) Disconnect(peerA, peerB peer.ID)

Disconnect disconnects two peers. It does a hard disconnect, meaning that disconnected peers won't be able to reconnect on their own but only with DagNet.Connect or TestDagNet.ConnectAll.

func (*TestDagNet) NewTestNode

func (dn *TestDagNet) NewTestNode() *TestNode

NewTestNode creates a plain network node that can serve and request data.

func (*TestDagNet) NewTestNodeWithBlockstore

func (dn *TestDagNet) NewTestNodeWithBlockstore(dstore ds.Datastore, bstore blockstore.Blockstore) *TestNode

NewTestNodeWithBlockstore creates a new plain TestNode with the given blockstore that can serve and request data.

func (*TestDagNet) SubNet

func (dn *TestDagNet) SubNet() *SubNet

type TestNode

type TestNode struct {
	shwap.Getter
	share.Availability
	blockservice.BlockService
	host.Host
	// contains filtered or unexported fields
}

func (*TestNode) ClearStorage

func (n *TestNode) ClearStorage()

ClearStorage cleans up the storage of the node.