Versions in this module Expand all Collapse all v1 v1.12.0 Jul 26, 2016 Changes in this version + type Picker struct + func NewPicker(r Remotes, initial ...string) *Picker + func (p *Picker) Close() error + func (p *Picker) Init(cc *grpc.ClientConn) error + func (p *Picker) Pick(ctx context.Context) (transport.ClientTransport, error) + func (p *Picker) PickAddr() (string, error) + func (p *Picker) Reset() error + func (p *Picker) State() (grpc.ConnectivityState, error) + func (p *Picker) WaitForStateChange(ctx context.Context, sourceState grpc.ConnectivityState) (grpc.ConnectivityState, error) + type Remotes interface + Observe func(peer api.Peer, weight int) + ObserveIfExists func(peer api.Peer, weight int) + Remove func(addrs ...api.Peer) + Select func(...string) (api.Peer, error) + Weights func() map[api.Peer]int + func NewRemotes(peers ...api.Peer) Remotes
Go to main page