test

Documentation

Index

• func MkChain(lsys ipld.LinkSystem, full bool) []ipld.Link
• func MkLinkSystem(ds datastore.Batching) ipld.LinkSystem
• func MkTestHost(options ...libp2p.Option) host.Host
• func RandomCids(n int) []cid.Cid
• func Store(srcStore datastore.Batching, n ipld.Node) (ipld.Link, error)
• func WaitForHttpPublisher(publisher TestPublisher) error
• func WaitForMeshWithMessage(t *testing.T, topic string, hosts ...host.Host) []*pubsub.Topic
• func WaitForP2PPublisher(publisher TestPublisher, clientHost host.Host, topic string) error
• type TestPublisher

Functions

func MkChain

func MkChain(lsys ipld.LinkSystem, full bool) []ipld.Link

Return the chain with all nodes or just half of it for testing

func MkLinkSystem

func MkLinkSystem(ds datastore.Batching) ipld.LinkSystem

func MkTestHost

func MkTestHost(options ...libp2p.Option) host.Host

func RandomCids

func RandomCids(n int) []cid.Cid

func Store

func Store(srcStore datastore.Batching, n ipld.Node) (ipld.Link, error)

func WaitForHttpPublisher

func WaitForHttpPublisher(publisher TestPublisher) error

func WaitForMeshWithMessage

func WaitForMeshWithMessage(t *testing.T, topic string, hosts ...host.Host) []*pubsub.Topic

func WaitForP2PPublisher

func WaitForP2PPublisher(publisher TestPublisher, clientHost host.Host, topic string) error

Types

type TestPublisher

type TestPublisher interface {
	// Addrs returns the addresses that the publisher is listening on.
	Addrs() []multiaddr.Multiaddr
	// ID returns the peer ID associated with the publisher.
	ID() peer.ID
}