Versions in this module Expand all Collapse all v1 v1.8.12 Jul 4, 2018 Changes in this version + func CheckResult(t *testing.T, result *simulations.StepResult, startedAt, finishedAt time.Time) + func NewAdapter(adapterType string, services adapters.Services) (adapter adapters.NodeAdapter, teardown func(), err error) + func SetStores(addrs ...network.Addr) ([]storage.ChunkStore, func(), error) + func Trigger(d time.Duration, quitC chan struct{}, ids ...discover.NodeID) chan discover.NodeID + func WatchDisconnections(id discover.NodeID, client *rpc.Client, errc chan error, quitC chan struct{}) (doneC <-chan struct{}, err error) + type RunConfig struct + Adapter string + ConnLevel int + DefaultService string + EnableMsgEvents bool + NodeCount int + Services adapters.Services + Step *simulations.Step + ToAddr func(discover.NodeID) *network.BzzAddr + type Simulation struct + Addrs []network.Addr + IDs []discover.NodeID + Net *simulations.Network + Stores []storage.ChunkStore + func NewSimulation(conf *RunConfig) (*Simulation, func(), error) + func (s *Simulation) Run(ctx context.Context, conf *RunConfig) (*simulations.StepResult, error) + func (sim *Simulation) CallClient(id discover.NodeID, f func(*rpc.Client) error) error
Go to main page