loadbalancer

Documentation

Index

• Constants
• type Picker
  • func (p *Picker) Build(buildInfo base.PickerBuildInfo) balancer.Picker
  • func (p *Picker) Pick(info balancer.PickInfo) (balancer.PickResult, error)
• type Resolver
  • func (r *Resolver) Build(target resolver.Target, cc resolver.ClientConn, opts resolver.BuildOptions) (resolver.Resolver, error)
  • func (r *Resolver) Close()
  • func (r *Resolver) ResolveNow(resolver.ResolveNowOptions)
  • func (r *Resolver) Scheme() string

Constants

const Name = "dlog"

Types

type Picker

type Picker struct {
	// contains filtered or unexported fields
}

func (*Picker) Build

func (p *Picker) Build(buildInfo base.PickerBuildInfo) balancer.Picker

Build set up the picker, gRPC connected to the addresses that our resolver discovered.

func (*Picker) Pick

func (p *Picker) Pick(info balancer.PickInfo) (
	balancer.PickResult, error)

Pick returns a balancer.PickResult with the subconnection to handle the call.

type Resolver

type Resolver struct {
	// contains filtered or unexported fields
}

func (*Resolver) Build

func (r *Resolver) Build(target resolver.Target,
	cc resolver.ClientConn, opts resolver.BuildOptions,
) (resolver.Resolver, error)

Build sets up a client connection to our server so the resolver can call the GetServers() API.

func (*Resolver) Close

func (r *Resolver) Close()

Close closes the resolver.

func (*Resolver) ResolveNow

func (r *Resolver) ResolveNow(resolver.ResolveNowOptions)

gRPC calls ResolveNow to resolve the target, discover the servers, and update the client connection with servers.

func (*Resolver) Scheme

func (r *Resolver) Scheme() string

Scheme returns the resolver's scheme identifier.