etcd

package
v1.3.6 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jun 12, 2023 License: Apache-2.0 Imports: 14 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Config

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

Config etcd config

type EtcdRegistry

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

EtcdRegistry etcd registry definition

func New

func New(config *Config) *EtcdRegistry

New new a etcd registry

func (*EtcdRegistry) Build

Resolver Segment Build watch service changes

func (*EtcdRegistry) Close

func (e *EtcdRegistry) Close()

Close close connection to etcd and deRegister all service info

func (*EtcdRegistry) DeRegister

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

DeRegister remove a service metadata from etcd

func (*EtcdRegistry) List added in v1.3.0

func (e *EtcdRegistry) List(ctx context.Context, name string, scheme string) (services []*registry.ServiceInfo, err error)

List list services from etcd with name and scheme

func (*EtcdRegistry) NewMutex

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

NewMutex new lock

func (*EtcdRegistry) Register

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

Register register a service metadata to etcd

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL