Versions in this module Expand all Collapse all v1 v1.0.0 Dec 17, 2020 Changes in this version + type ClientCreator struct + Concurrency int + TableNum int + func (c ClientCreator) Create(node cluster.ClientNode) core.Client + type WriterClient struct + func (c *WriterClient) DumpState(ctx context.Context) (interface{}, error) + func (c *WriterClient) Invoke(ctx context.Context, node cluster.ClientNode, r interface{}) core.UnknownResponse + func (c *WriterClient) NextRequest() interface{} + func (c *WriterClient) SetUp(ctx context.Context, _ []cluster.Node, clientNodes []cluster.ClientNode, ...) error + func (c *WriterClient) Start(ctx context.Context, cfg interface{}, clientNodes []cluster.ClientNode) error + func (c *WriterClient) String() string + func (c *WriterClient) TearDown(ctx context.Context, nodes []cluster.ClientNode, idx int) error
Go to main page