Versions in this module Expand all Collapse all v3 v3.4.6 Mar 19, 2020 Changes in this version + type Case interface + Desc func() string + Inject func(clus *Cluster) error + Recover func(clus *Cluster) error + TestCase func() rpcpb.Case + type Checker interface + Check func() error + EtcdClientEndpoints func() []string + Type func() rpcpb.Checker + type Cluster struct + Members []*rpcpb.Member + Tester *rpcpb.Tester + func NewCluster(lg *zap.Logger, fpath string) (*Cluster, error) + func (clus *Cluster) EtcdClientEndpoints() (css []string) + func (clus *Cluster) GetCaseDelayDuration() time.Duration + func (clus *Cluster) GetLeader() (int, error) + func (clus *Cluster) Report() int64 + func (clus *Cluster) Run() + func (clus *Cluster) Send_INITIAL_START_ETCD() error + func (clus *Cluster) Send_SIGQUIT_ETCD_AND_REMOVE_DATA_AND_STOP_AGENT() + func (clus *Cluster) UpdateDelayLatencyMs() + func (clus *Cluster) WaitHealth() error + type Stresser interface + Close func() map[string]int + ModifiedKeys func() int64 + Pause func() map[string]int + Stress func() error
Go to main page