balancer

Documentation

Index

• Variables
• type Balancer
  • func New(ctx context.Context, driverConfig *config.Config, pool *conn.Pool, ...) (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{}, ...) error
  • func (b *Balancer) NewStream(ctx context.Context, desc *grpc.StreamDesc, method string, ...) (_ grpc.ClientStream, err error)

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)