testinstance

Oct 15, 2025

Changes in this version

+ func Close(instances []Instance) error

+ func ConnectInstances(instances []Instance)

+ type Instance struct

+ Adapter dtnet.DataTransferNetwork

+ BlockStore blockstore.Blockstore

+ Graphsync graphsync.GraphExchange

+ LinkSystem ipld.LinkSystem

+ Manager datatransfer.Manager

+ Peer peer.ID

+ func NewInstance(ctx context.Context, net tn.Network, tempDir string, diskBasedDatastore bool) (Instance, error)

+ func (i *Instance) Blockstore() blockstore.Blockstore

+ func (i *Instance) Close() error

+ func (i *Instance) SetBlockstoreLatency(t time.Duration) time.Duration

+ type InstanceGenerator struct

+ func NewTestInstanceGenerator(ctx context.Context, net tn.Network, tempDirGenerator TempDirGenerator, ...) InstanceGenerator

+ func (g *InstanceGenerator) Close() error

+ func (g *InstanceGenerator) Instances(n int) ([]Instance, error)

+ func (g *InstanceGenerator) Next() (Instance, error)

+ type TempDirGenerator interface

+ TempDir func() string