aarifullin/frostfs-sdk-go
1
0
Fork 0
forked from TrueCloudLab/frostfs-sdk-go
Code Pull requests Activity

[#4] pool: Rename exported structs in pool pkg

Browse source 
Renamed PoolBuilderOptions to BuilderOptions and PoolBuilder to Builder
because usages of them with prefix pool.* in other packages stutter.

Signed-off-by: Angira Kekteeva <kira@nspcc.ru>
This commit is contained in:
Angira Kekteeva 2021-05-25 14:46:58 +03:00
parent d62b4534db
commit 7cfe91fac7
1 changed files with 7 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

14
pkg/pool/pool.go
View file

@ -15,8 +15,8 @@ import (
"google.golang.org/grpc/keepalive" "google.golang.org/grpc/keepalive"
) )
// PoolBuilderOptions contains options used to build connection pool. // BuilderOptions contains options used to build connection pool.
type PoolBuilderOptions struct { type BuilderOptions struct {
Key *ecdsa.PrivateKey Key *ecdsa.PrivateKey
NodeConnectionTimeout time.Duration NodeConnectionTimeout time.Duration
NodeRequestTimeout time.Duration NodeRequestTimeout time.Duration
@ -29,22 +29,22 @@ type PoolBuilderOptions struct {
connections []*grpc.ClientConn connections []*grpc.ClientConn
} }
// PoolBuilder is an interim structure used to collect node addresses/weights and // Builder is an interim structure used to collect node addresses/weights and
// build connection pool subsequently. // build connection pool subsequently.
type PoolBuilder struct { type Builder struct {
addresses []string addresses []string
weights []float64 weights []float64
} }
// AddNode adds address/weight pair to node PoolBuilder list. // AddNode adds address/weight pair to node PoolBuilder list.
func (pb *PoolBuilder) AddNode(address string, weight float64) *PoolBuilder { func (pb *Builder) AddNode(address string, weight float64) *Builder {
pb.addresses = append(pb.addresses, address) pb.addresses = append(pb.addresses, address)
pb.weights = append(pb.weights, weight) pb.weights = append(pb.weights, weight)
return pb return pb
} }
// Build creates new pool based on current PoolBuilder state and options. // Build creates new pool based on current PoolBuilder state and options.
func (pb *PoolBuilder) Build(ctx context.Context, options *PoolBuilderOptions) (Pool, error) { func (pb *Builder) Build(ctx context.Context, options *BuilderOptions) (Pool, error) {
if len(pb.addresses) == 0 { if len(pb.addresses) == 0 {
return nil, errors.New("no NeoFS peers configured") return nil, errors.New("no NeoFS peers configured")
} }
@ -97,7 +97,7 @@ type pool struct {
clientPacks []*clientPack clientPacks []*clientPack
} }
func new(ctx context.Context, options *PoolBuilderOptions) (Pool, error) { func new(ctx context.Context, options *BuilderOptions) (Pool, error) {
clientPacks := make([]*clientPack, len(options.weights)) clientPacks := make([]*clientPack, len(options.weights))
for i, con := range options.connections { for i, con := range options.connections {
c, err := client.New(client.WithDefaultPrivateKey(options.Key), client.WithGRPCConnection(con)) c, err := client.New(client.WithDefaultPrivateKey(options.Key), client.WithGRPCConnection(con))