consul

Documentation

Index

• type Discoverer
  • func NewDiscoverer(cfg *consulapi.Config) (*Discoverer, error)
  • func (d *Discoverer) Discover(svcName string, add, remove func(api.Remote)) discovery.Getter
• type Discovery
  • func New(serviceName, addr string, cfg *consulapi.Config, srv *grpc.Server) (*Discovery, error)
  • func (d *Discovery) Start() error
  • func (d *Discovery) Stop() error

Types

type Discoverer

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

func NewDiscoverer

func NewDiscoverer(cfg *consulapi.Config) (*Discoverer, error)

TODO: Deactivate a consul API client here, not a cfg.

func (*Discoverer) Discover

func (d *Discoverer) Discover(svcName string, add, remove func(api.Remote)) discovery.Getter

type Discovery

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

func New

func New(serviceName, addr string, cfg *consulapi.Config, srv *grpc.Server) (*Discovery, error)

TODO: Deactivate a consul API here, not a cfg.

func (*Discovery) Start

func (d *Discovery) Start() error

func (*Discovery) Stop

func (d *Discovery) Stop() error