lb

Documentation

Index

• type Resolver
  • func NewResolver(client *api.Client, service, tag string) (*Resolver, error)
  • func (r *Resolver) Close()
  • func (r *Resolver) Next() ([]*naming.Update, error)
  • func (r *Resolver) Resolve(target string) (naming.Watcher, error)

Types

type Resolver

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

Resolver implements the gRPC Resolver interface using a Consul backend.

See the gRPC load balancing documentation for details about Balancer and Resolver: https://github.com/grpc/grpc/blob/master/doc/load-balancing.md.

func NewResolver

func NewResolver(client *api.Client, service, tag string) (*Resolver, error)

NewResolver initializes and returns a new Resolver.

It resolves addresses for gRPC connections to the given service and tag. If the tag is irrelevant, use an empty string.

func (*Resolver) Close

func (r *Resolver) Close()

Close closes the watcher.

func (*Resolver) Next

func (r *Resolver) Next() ([]*naming.Update, error)

Next blocks until an update or error happens. It may return one or more updates. The first call will return the full set of instances available as NewResolver will look those up. Subsequent calls to Next() will block until the resolver finds any new or removed instance.

An error is returned if and only if the watcher cannot recover.

func (*Resolver) Resolve

func (r *Resolver) Resolve(target string) (naming.Watcher, error)

Resolve creates a watcher for target. The watcher interface is implemented by Resolver as well, see Next and Close.