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)

func (*Balancer) OnUpdate 

func (b *Balancer) OnUpdate(onApplyDiscoveredEndpoints func(ctx context.Context, endpoints []endpoint.Info))

Source Files

balancer.go connections_state.go local_dc.go

Directories

PathSynopsis
internal/balancer/cluster
internal/balancer/config
Version
v3.85.2
Published
Oct 22, 2024
Platform
linux/amd64
Imports
27 packages
Last checked
4 minutes ago –

Tools for package owners.