tester

May 17, 2023

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