consul

Documentation

Overview

*

• by huqiuyun
• 启动一个服务时，注册到consul中心，从而可以收到配置信息的变化通知

Index

• func NewClientWithPoints(eps config.EndPoints) (*consul.Client, error)
• func NewConsulClient(conf config.Config, endPoints config.EndPoints, resol resolver.Resolver) (service.Client, error)
• func NewService(cfg config.Config, points config.EndPoints, registry registry.Registry) (service.Service, error)
• type Base
  • func (base *Base) AttachWatcher(watcher *Watcher)
  • func (base *Base) Get(key service.Key) ([]*service.Data, error)
  • func (base *Base) Set(data service.Data) error
• type Watcher
  • func NewWatcher(client *consul2.Client, sizeChan int) (*Watcher, error)
  • func (watcher *Watcher) Changed(cmd discoveryWatch.Changed)
  • func (watcher *Watcher) Stop() error
  • func (watcher *Watcher) Watch(key discoveryWatch.Key) (discoveryWatch.Chan, error)

Functions

func NewClientWithPoints

func NewClientWithPoints(eps config.EndPoints) (*consul.Client, error)

func NewConsulClient

func NewConsulClient(conf config.Config, endPoints config.EndPoints, resol resolver.Resolver) (service.Client, error)

func NewService

func NewService(cfg config.Config, points config.EndPoints, registry registry.Registry) (service.Service, error)

Types

type Base

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

func (*Base) AttachWatcher

func (base *Base) AttachWatcher(watcher *Watcher)

func (*Base) Get

func (base *Base) Get(key service.Key) ([]*service.Data, error)

Get interface

func (*Base) Set

func (base *Base) Set(data service.Data) error

Set interface

type Watcher

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

func NewWatcher

func NewWatcher(client *consul2.Client, sizeChan int) (*Watcher, error)

func (*Watcher) Changed

func (watcher *Watcher) Changed(cmd discoveryWatch.Changed)

func (*Watcher) Stop

func (watcher *Watcher) Stop() error

func (*Watcher) Watch

func (watcher *Watcher) Watch(key discoveryWatch.Key) (discoveryWatch.Chan, error)