loadbalance

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 = "proglog"

Types

type Picker

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

Picker handle the RPC balancing logic by picking a server from the servers discovered by the resolver to handel each RPC.

func (*Picker) Build

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

Build sets up a Picker using the map of sub connections given in buildInfo.

func (*Picker) Pick

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

Pick gets info containing the RPC's name and context from gRPC to help the picker know what subconnection to pick, and returns the subconnection to handle the call in the result.

type Resolver

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

Resolver is the type that implements gRPC's resolver.Builder interface.

func (*Resolver) Build

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

Build implements the resolver.Builder interface for the Resolver type.

func (*Resolver) Close

func (r *Resolver) Close()

Close implements the Close methods of gRPC's resolver.Resolver interface.

func (*Resolver) ResolveNow

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

ResolveNow implements gRPC's resolver.Resolver interface.

func (*Resolver) Scheme

func (r *Resolver) Scheme() string

Scheme returns the resolver's scheme identifier, it implements the resolver.Scheme method for the Resolver type to satisfy the resolver.Builder interface.