balancer

Documentation

Index

• Variables
• func WithEndpoint(ctx context.Context, endpoint Endpoint) context.Context
• type Balancer
  • func New(ctx context.Context, driverConfig *config.Config, pool *conn.Pool, ...) (b *Balancer, err error)
  • func (b *Balancer) Close(ctx context.Context) (err error)
  • func (b *Balancer) HasNode(id uint32) bool
  • 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)
  • func (b *Balancer) OnUpdate(...)
• type Endpoint
  • func ContextEndpoint(ctx context.Context) (e Endpoint, ok bool)

Variables

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

Functions

func WithEndpoint

func WithEndpoint(ctx context.Context, endpoint Endpoint) context.Context

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, err error)

func (*Balancer) Close

func (b *Balancer) Close(ctx context.Context) (err error)

func (*Balancer) HasNode

func (b *Balancer) HasNode(id uint32) bool

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))

type Endpoint

type Endpoint interface {
	NodeID() uint32
}

func ContextEndpoint

func ContextEndpoint(ctx context.Context) (e Endpoint, ok bool)