call

Documentation

Index

• func Display(results chan string, flag bool)
• func Handle(handler Handler, num int, results chan<- string)
• func InitClients(addrs []string)
• func Register(handleType string, handle Handler)
• func Run(handleType string, amount int, tps int, prepare int, flag bool)
• func SendTx(stx *tx.Tx, i int) (string, error)
• func ToTxRequest(t *tx.Tx) *rpcpb.TransactionRequest
• type GrpcClient
  • func GetClient(i int) *GrpcClient
  • func (c *GrpcClient) Addr() string
• type Handler

Functions

func Display

func Display(results chan string, flag bool)

Display ...

func Handle

func Handle(handler Handler, num int, results chan<- string)

Handle ...

func InitClients

func InitClients(addrs []string)

InitClients inits rpc clients.

func Register

func Register(handleType string, handle Handler)

Register ...

func Run

func Run(handleType string, amount int, tps int, prepare int, flag bool)

Run ...

func SendTx

func SendTx(stx *tx.Tx, i int) (string, error)

SendTx ...

func ToTxRequest

func ToTxRequest(t *tx.Tx) *rpcpb.TransactionRequest

ToTxRequest ...

Types

type GrpcClient

type GrpcClient struct {
	rpcpb.ApiServiceClient
	// contains filtered or unexported fields
}

GrpcClient wraps ApiServiceClient with a semaphore.

func GetClient

func GetClient(i int) *GrpcClient

GetClient returns the corresponding grpc client.

func (*GrpcClient) Addr

func (c *GrpcClient) Addr() string

Addr returns the address.

type Handler

type Handler interface {
	Prepare() error
	Run(i int) (any, error)
}

Handler ...