test

Documentation

Index

• func MkBlockedLinkSystem(ds datastore.Batching) (ipld.LinkSystem, <-chan chan<- struct{})
• func MkChain(lsys ipld.LinkSystem, full bool) []ipld.Link
• func MkLinkSystem(ds datastore.Batching) ipld.LinkSystem
• func MkTestHost(t *testing.T, options ...libp2p.Option) host.Host
• func MkTestHostPK(t *testing.T) (host.Host, crypto.PrivKey)
• 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 MkBlockedLinkSystem

func MkBlockedLinkSystem(ds datastore.Batching) (ipld.LinkSystem, <-chan chan<- struct{})

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(t *testing.T, options ...libp2p.Option) host.Host

func MkTestHostPK

func MkTestHostPK(t *testing.T) (host.Host, crypto.PrivKey)

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
}