Documentation
¶
Index ¶
- type Config
- type 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 (e *EtcdRegistry) List(ctx context.Context, name string, scheme string) (services []*registry.ServiceInfo, err 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
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 (*EtcdRegistry) Build ¶
func (e *EtcdRegistry) Build(target resolver.Target, cc resolver.ClientConn, opts resolver.BuildOptions) (resolver.Resolver, error)
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.
Source Files
Click to show internal directories.
Click to hide internal directories.