consul

Documentation

Index

• type ConsulDiscovery
  • func NewConsulDiscovery(options *regOps.DiscoveryOptions) *ConsulDiscovery
  • func (d *ConsulDiscovery) GetService(ctx context.Context, serviceName string) ([]*registry.ServiceInstance, error)
  • func (d *ConsulDiscovery) ListServices() (allServices map[string][]*registry.ServiceInstance, err error)
  • func (d *ConsulDiscovery) Service(ctx context.Context, service string, index uint64, passingOnly bool) ([]*registry.ServiceInstance, uint64, error)
  • func (d *ConsulDiscovery) Watch(_ context.Context, serviceName string) (registry.Watcher, error)

Types

type ConsulDiscovery

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

func NewConsulDiscovery

func NewConsulDiscovery(options *regOps.DiscoveryOptions) *ConsulDiscovery

func (*ConsulDiscovery) GetService

func (d *ConsulDiscovery) GetService(ctx context.Context, serviceName string) ([]*registry.ServiceInstance, error)

GetService return service by name ，该方法主要用于第一次获取全量的服务对象，后期的增量标准是从watcher中获取

func (*ConsulDiscovery) ListServices

func (d *ConsulDiscovery) ListServices() (allServices map[string][]*registry.ServiceInstance, err error)

ListServices return service list. ListServices 返回 所有服务的 列表

func (*ConsulDiscovery) Service

func (d *ConsulDiscovery) Service(ctx context.Context, service string, index uint64, passingOnly bool) ([]*registry.ServiceInstance, uint64, error)

Service get services from consul

func (*ConsulDiscovery) Watch

func (d *ConsulDiscovery) Watch(_ context.Context, serviceName string) (registry.Watcher, error)

Watch 获取一个增量的监听器