blockwriter

package

v1.0.0 Latest Latest Go to latest Published: Dec 17, 2020 License: Apache-2.0 Imports: 13 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

This section is empty.

This section is empty.

This section is empty.

type ClientCreator struct {
	TableNum    int
	Concurrency int
}

ClientCreator creates BlockWriteClient

func (c ClientCreator) Create(node cluster.ClientNode) core.Client

Create creates WriterClient

type WriterClient struct {
	// contains filtered or unexported fields
}

WriterClient is for concurrent writing blocks.

func (c *WriterClient) DumpState(ctx context.Context) (interface{}, error)

DumpState does nothing

func (c *WriterClient) Invoke(ctx context.Context, node cluster.ClientNode, r interface{}) core.UnknownResponse

Invoke does nothing

func (c *WriterClient) NextRequest() interface{}

NextRequest does nothing

func (c *WriterClient) SetUp(ctx context.Context, _ []cluster.Node, clientNodes []cluster.ClientNode, idx int) error

SetUp sets up client

func (c *WriterClient) Start(ctx context.Context, cfg interface{}, clientNodes []cluster.ClientNode) error

Start starts test

func (c *WriterClient) String() string

String implements fmt.Stringer interface.

func (c *WriterClient) TearDown(ctx context.Context, nodes []cluster.ClientNode, idx int) error

TearDown tears down client