rename

liteapi/client.go

@@ -81,8 +81,8 @@ type Options struct {
 	LiteServers []config.LiteServer
 	Timeout     time.Duration
 	// MaxConnections specifies a number of connections to lite servers for a connections pool.
-	MaxConnections   int
-	NumPerConnection int
+	MaxConnections       int
+	WorkersPerConnection int
 	// InitCtx is used when opening a new connection to lite servers during the initialization.
 	InitCtx context.Context
 	// ProofPolicy specifies a policy for proof checks.
@@ -115,9 +115,9 @@ func WithMaxConnectionsNumber(maxConns int) Option {
 	}
 }
 
-func WithNumPerConnection(numPerConn int) Option {
+func WithWorkersPerConnection(workersNum int) Option {
 	return func(o *Options) error {
-		o.NumPerConnection = numPerConn
+		o.WorkersPerConnection = workersNum
 		return nil
 	}
 }
@@ -277,7 +277,7 @@ func NewClient(options ...Option) (*Client, error) {
 		DetectArchiveNodes:            false,
 		SyncConnectionsInitialization: true,
 		PoolStrategy:                  pool.BestPingStrategy,
-		NumPerConnection:              1,
+		WorkersPerConnection:          1,
 	}
 	for _, o := range options {
 		if err := o(opts); err != nil {
@@ -288,7 +288,7 @@ func NewClient(options ...Option) (*Client, error) {
 		return nil, fmt.Errorf("server list empty")
 	}
 	connPool := pool.New(opts.PoolStrategy)
-	initCh := connPool.InitializeConnections(opts.InitCtx, opts.Timeout, opts.MaxConnections, opts.NumPerConnection, opts.DetectArchiveNodes, opts.LiteServers)
+	initCh := connPool.InitializeConnections(opts.InitCtx, opts.Timeout, opts.MaxConnections, opts.WorkersPerConnection, opts.DetectArchiveNodes, opts.LiteServers)
 	if opts.SyncConnectionsInitialization {
 		if err := <-initCh; err != nil {
 			return nil, err

liteapi/pool/conn_pool.go

@@ -71,13 +71,13 @@ func New(strategy Strategy) *ConnPool {
 	}
 }
 
-func (p *ConnPool) InitializeConnections(ctx context.Context, timeout time.Duration, maxConnections int, numPerConnection int, detectArchiveNodes bool, servers []config.LiteServer) chan error {
+func (p *ConnPool) InitializeConnections(ctx context.Context, timeout time.Duration, maxConnections int, workersPerConnection int, detectArchiveNodes bool, servers []config.LiteServer) chan error {
 	ch := make(chan error, 1)
 	go func() {
 		clientsCh := make(chan clientWrapper, len(servers))
 		for connID, server := range servers {
 			go func(connID int, server config.LiteServer) {
-				cli, _ := connect(ctx, timeout, server, numPerConnection)
+				cli, _ := connect(ctx, timeout, server, workersPerConnection)
 				// TODO: log error
 				clientsCh <- clientWrapper{
 					connID:     connID,
@@ -128,7 +128,7 @@ func connect(ctx context.Context, timeout time.Duration, server config.LiteServe
 	if err != nil {
 		return nil, err
 	}
-	cli := liteclient.NewClient(c, liteclient.OptionTimeout(timeout), liteclient.OptionConnectionsNum(n))
+	cli := liteclient.NewClient(c, liteclient.OptionTimeout(timeout), liteclient.OptionWorkersPerConnection(n))
 	if _, err := cli.LiteServerGetMasterchainInfo(ctx); err != nil {
 		return nil, err
 	}

liteclient/client.go

@@ -46,7 +46,7 @@ func OptionTimeout(t time.Duration) Options {
 	}
 }
 
-func OptionConnectionsNum(n int) Options {
+func OptionWorkersPerConnection(n int) Options {
 	return func(c *Client) {
 		if n < 1 {
 			n = 1