package balancer

import "github.com/ydb-platform/ydb-go-sdk/v3/internal/balancer"

Index

Variables 

var ErrNoEndpoints = xerrors.Wrap(fmt.Errorf("no endpoints"))

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 (b *Balancer) Close(ctx context.Context) (err error)

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

PathSynopsis
internal/balancer/cluster
internal/balancer/config
Version
v3.96.2
Published
Jan 15, 2025
Platform
linux/amd64
Imports
28 packages
Last checked
4 minutes ago –

Tools for package owners.