etcd

Documentation

Index

• Variables
• func Build(c *clientv3.Config, id string) naming.Resolver
• func Builder(c *clientv3.Config) naming.Builder
• type EtcdBuilder
  • func New(c *clientv3.Config) (e *EtcdBuilder, err error)
  • func (e *EtcdBuilder) Build(appid string) naming.Resolver
  • func (e *EtcdBuilder) Close() error
  • func (e *EtcdBuilder) Register(ctx context.Context, ins *naming.Instance) (cancelFunc context.CancelFunc, err error)
  • func (e *EtcdBuilder) Scheme() string
• type Resolve
  • func (r *Resolve) Close() error
  • func (r *Resolve) Fetch(ctx context.Context) (ins *naming.InstancesInfo, ok bool)
  • func (r *Resolve) Watch() <-chan struct{}

Variables

var (

	//ErrDuplication is a register duplication err
	ErrDuplication = errors.New("etcd: instance duplicate registration")
)

Functions

func Build

func Build(c *clientv3.Config, id string) naming.Resolver

Build register resolver into default etcd.

func Builder

func Builder(c *clientv3.Config) naming.Builder

Builder return default etcd resolver builder.

Types

type EtcdBuilder

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

EtcdBuilder is a etcd clientv3 EtcdBuilder

func New

func New(c *clientv3.Config) (e *EtcdBuilder, err error)

New is new a etcdbuilder

func (*EtcdBuilder) Build

func (e *EtcdBuilder) Build(appid string) naming.Resolver

Build disovery resovler builder.

func (*EtcdBuilder) Close

func (e *EtcdBuilder) Close() error

Close stop all running process including etcdfetch and register

func (*EtcdBuilder) Register

func (e *EtcdBuilder) Register(ctx context.Context, ins *naming.Instance) (cancelFunc context.CancelFunc, err error)

Register is register instance

func (*EtcdBuilder) Scheme

func (e *EtcdBuilder) Scheme() string

Scheme return etcd's scheme

type Resolve

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

Resolve etch resolver.

func (*Resolve) Close

func (r *Resolve) Close() error

Close close resolver.

func (*Resolve) Fetch

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

Fetch fetch resolver instance.

func (*Resolve) Watch

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

Watch watch instance.