discovery

README

discovery

Documentation

Index

• Variables
• type Config
• type Discovery
  • func New(c *Config, logger log.Logger) *Discovery
  • func (d *Discovery) Close() error
  • func (d *Discovery) Deregister(ctx context.Context, service *registry.ServiceInstance) error
  • func (d *Discovery) GetService(ctx context.Context, serviceName string) ([]*registry.ServiceInstance, error)
  • func (d *Discovery) Logger() *log.Helper
  • func (d *Discovery) Register(ctx context.Context, service *registry.ServiceInstance) (err error)
  • func (d *Discovery) Watch(ctx context.Context, serviceName string) (registry.Watcher, error)
• type Resolve
  • func (r *Resolve) Close() error
  • func (r *Resolve) Fetch(ctx context.Context) (ins *disInstancesInfo, ok bool)
  • func (r *Resolve) Watch() <-chan struct{}

Variables

var (
	ErrDuplication = errors.New("register failed: instance duplicated: ")
	ErrServerError = errors.New("server error")
)

Types

type Config

type Config struct {
	Nodes  []string
	Region string
	Zone   string
	Env    string
	Host   string
}

Config Discovery configures.

type Discovery

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

func New

func New(c *Config, logger log.Logger) *Discovery

New construct a Discovery instance which implements registry.Registrar, registry.Discovery and registry.Watcher.

func (*Discovery) Close

func (d *Discovery) Close() error

Close stop all running process including Discovery and register

func (*Discovery) Deregister

func (d *Discovery) Deregister(ctx context.Context, service *registry.ServiceInstance) error

func (*Discovery) GetService

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

func (*Discovery) Logger

func (d *Discovery) Logger() *log.Helper

func (*Discovery) Register

func (d *Discovery) Register(ctx context.Context, service *registry.ServiceInstance) (err error)

func (*Discovery) Watch

func (d *Discovery) Watch(ctx context.Context, serviceName string) (registry.Watcher, error)

type Resolve

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

Resolve Discovery resolver.

func (*Resolve) Close

func (r *Resolve) Close() error

Close resolver

func (*Resolve) Fetch

func (r *Resolve) Fetch(ctx context.Context) (ins *disInstancesInfo, ok bool)

Fetch resolver instance.

func (*Resolve) Watch

func (r *Resolve) Watch() <-chan struct{}

Watch instance.