etcd

Documentation

Index

• type Config
• type EtcdRegistry
  • func New(config *Config) *EtcdRegistry
  • func (e *EtcdRegistry) Build(target resolver.Target, cc resolver.ClientConn, opts resolver.BuildOptions) (resolver.Resolver, error)
  • func (e *EtcdRegistry) Close()
  • func (e *EtcdRegistry) DeRegister(ctx context.Context, info *registry.ServiceInfo) error
  • func (er *EtcdRegistry) NewMutex(key string, opts ...concurrency.SessionOption) (m *mutex, err error)
  • func (e *EtcdRegistry) Register(ctx context.Context, info *registry.ServiceInfo) error
  • func (e *EtcdRegistry) ResolveNow(rn resolver.ResolveNowOptions)
  • func (e *EtcdRegistry) Scheme() string

Types

type Config

type Config struct {
	Prefix      string
	Endpoints   []string
	DialTimeout time.Duration
	RegisterTTL time.Duration
	Username    string
	Password    string
}

type EtcdRegistry

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

func New

func New(config *Config) *EtcdRegistry

func (*EtcdRegistry) Build

func (e *EtcdRegistry) Build(target resolver.Target, cc resolver.ClientConn, opts resolver.BuildOptions) (resolver.Resolver, error)

Resolver Segment

func (*EtcdRegistry) Close

func (e *EtcdRegistry) Close()

func (*EtcdRegistry) DeRegister

func (e *EtcdRegistry) DeRegister(ctx context.Context, info *registry.ServiceInfo) error

func (*EtcdRegistry) NewMutex

func (er *EtcdRegistry) NewMutex(key string, opts ...concurrency.SessionOption) (m *mutex, err error)

func (*EtcdRegistry) Register

func (e *EtcdRegistry) Register(ctx context.Context, info *registry.ServiceInfo) error

func (*EtcdRegistry) ResolveNow

func (e *EtcdRegistry) ResolveNow(rn resolver.ResolveNowOptions)

ResolveNow is a noop for Resolver.

func (*EtcdRegistry) Scheme

func (e *EtcdRegistry) Scheme() string

Scheme return etcd's scheme