Versions in this module Expand all Collapse all v0 v0.9.4 May 21, 2019 Changes in this version + type DTestHarness struct + func New(cliOpts *config.Args, rawLogger *zap.Logger) *DTestHarness + func (dt *DTestHarness) AllShardsAvailable() bool + func (dt *DTestHarness) AnyInstanceShardHasState(id string, state shard.State) bool + func (dt *DTestHarness) BootstrapTimeout() time.Duration + func (dt *DTestHarness) Close() error + func (dt *DTestHarness) Cluster() cluster.Cluster + func (dt *DTestHarness) ClusterOptions() cluster.Options + func (dt *DTestHarness) Configuration() *config.Configuration + func (dt *DTestHarness) Nodes() []m3emnode.Node + func (dt *DTestHarness) Seed(nodes []node.ServiceNode) error + func (dt *DTestHarness) SetClusterOptions(co cluster.Options) + func (dt *DTestHarness) WaitUntilAllBootstrapped(nodes []node.ServiceNode) error + func (dt *DTestHarness) WaitUntilAllShardsAvailable() error