package balancer
import "github.com/ydb-platform/ydb-go-sdk/v3/internal/balancer"
Index ¶
- Variables
- type Balancer
- func New(ctx context.Context, driverConfig *config.Config, pool *conn.Pool, opts ...discoveryConfig.Option) ( b *Balancer, finalErr error, )
- func (b *Balancer) Close(ctx context.Context) (err error)
- func (b *Balancer) Invoke( ctx context.Context, method string, args interface{}, reply interface{}, opts ...grpc.CallOption, ) error
- func (b *Balancer) NewStream( ctx context.Context, desc *grpc.StreamDesc, method string, opts ...grpc.CallOption, ) (_ grpc.ClientStream, err error)
Variables ¶
var ( ErrNoEndpoints = xerrors.Wrap(xerrors.Retryable(fmt.Errorf("no endpoints"), xerrors.WithBackoff(backoff.TypeSlow))) )
Types ¶
type Balancer ¶
type Balancer struct {
// contains filtered or unexported fields
}
func New ¶
func New(ctx context.Context, driverConfig *config.Config, pool *conn.Pool, opts ...discoveryConfig.Option) ( b *Balancer, finalErr error, )
func (*Balancer) Close ¶
func (*Balancer) Invoke ¶
func (b *Balancer) Invoke( ctx context.Context, method string, args interface{}, reply interface{}, opts ...grpc.CallOption, ) error
func (*Balancer) NewStream ¶
func (b *Balancer) NewStream( ctx context.Context, desc *grpc.StreamDesc, method string, opts ...grpc.CallOption, ) (_ grpc.ClientStream, err error)
Source Files ¶
balancer.go connections_state.go local_dc.go
Directories ¶
| Path | Synopsis |
|---|---|
| internal/balancer/cluster | |
| internal/balancer/config |
- Version
- v3.99.7
- Published
- Feb 7, 2025
- Platform
- linux/amd64
- Imports
- 30 packages
- Last checked
- 4 minutes ago –
Tools for package owners.