client

package

v0.0.0-...-3a65784 Latest Latest Go to latest Published: Apr 16, 2024 License: Apache-2.0 Imports: 17 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

View Source

const (
	Read = iota
	Write
)

This section is empty.

func NewClient(rateLimit *RateLimit, tracer trace.Tracer, routerRPCClients RouterClients, requests []Request) *client

func WriteOutputToFile(outputFilePath string, responseCount []ResponseStatus) error

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

RateLimit is a simple rate limiter that allows a maximum of tokensLimit requests at a time.

func NewRateLimit(tokensLimit int) *RateLimit

func (r *RateLimit) Acquire()

Aquire blocks until a token is available.

func (r *RateLimit) Release()

Release releases a token.

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

type Request struct {
	Block         string
	OperationType int
	NewValue      string
}

func ReadTraceFile(traceFilePath string, blockSizeBytes int) ([]Request, error)

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

type RouterClients map[int]RouterRPCClient

func StartRouterRPCClients(endpoints []config.RouterEndpoint) (RouterClients, error)

func (r RouterClients) GetRandomRouter() RouterRPCClient

type RouterRPCClient struct {
	ClientAPI routerpb.RouterClient
	Conn      *grpc.ClientConn
}

func (c *RouterRPCClient) Read(ctx context.Context, block string) (value string, err error)

func (c *RouterRPCClient) Write(ctx context.Context, block string, value string) (success bool, err error)

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