discover

README

Consul based service discovery for gRPC

Documentation

Index

• func WithResolver(addr, tag string) grpc.DialOption
• type Resolve
  • func (r Resolve) Resolve(service string) (naming.Watcher, error)
• type Watch
  • func (w Watch) Close()
  • func (w *Watch) Next() ([]*naming.Update, error)

Functions

func WithResolver

func WithResolver(addr, tag string) grpc.DialOption

Types

type Resolve

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

func (Resolve) Resolve

func (r Resolve) Resolve(service string) (naming.Watcher, error)

Resolve creates a Watcher for target

type Watch

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

func (Watch) Close

func (w Watch) Close()

Close watcher

func (*Watch) Next

func (w *Watch) Next() ([]*naming.Update, error)

Next blocks until an update or error happens. It may return one or more updates. The first call should get the full set of the results. It should return an error if and onfy if Watcher cannot recover.