etcd

Apr 28, 2022

Changes in this version

type DiscoverOption

+ func WithCmdTimeOut(t time.Duration) DiscoverOption

Jan 15, 2022

Changes in this version

type DiscoverOption

+ func WithRefreshDuration(d int) DiscoverOption

type EtcdDiscovery

+ func (s *EtcdDiscovery) GetUpdateTime() time.Time

Jan 1, 2022

Changes in this version

type DiscoverOption

+ func WithContext(ctx context.Context) DiscoverOption

+ func WithServierName(serviceName string) DiscoverOption

type EtcdDiscovery

+ func (s *EtcdDiscovery) GetNodes() []*registry.Node

Oct 24, 2021

Changes in this version

+ func JSONDecode(val string) (*registry.ServiceNode, error)

+ func JSONEncode(node *registry.ServiceNode) (string, error)

+ func NewRegistry(opts ...RegistrarOption) (registry.Registrar, error)

+ type DiscoverOption func(*EtcdDiscovery)

+ func WithDiscoverClient(cli *clientv3.Client) DiscoverOption

+ func WithDiscoverConfig(config *registry.DiscoveryConfig) DiscoverOption

+ type EtcdDiscovery struct

+ func NewDiscovery(opts ...DiscoverOption) (*EtcdDiscovery, error)

+ func (s *EtcdDiscovery) Close() error

+ func (s *EtcdDiscovery) DelServiceList(key string)

+ func (s *EtcdDiscovery) GetLoadBalance() string

+ func (s *EtcdDiscovery) GetServices() []*registry.ServiceNode

+ func (s *EtcdDiscovery) SetServiceList(key string, node *registry.ServiceNode)

+ func (s *EtcdDiscovery) WatchService(ctx context.Context) error

+ type EtcdRegistrar struct

+ func (s *EtcdRegistrar) DeRegister(ctx context.Context) error

+ func (s *EtcdRegistrar) Register(ctx context.Context) error

+ type RegistrarOption func(*EtcdRegistrar)

+ func WithRegistarHost(host string) RegistrarOption

+ func WithRegistarPort(port int) RegistrarOption

+ func WithRegistrarClient(cli *clientv3.Client) RegistrarOption

+ func WithRegistrarLease(lease int64) RegistrarOption

+ func WithRegistrarServiceName(serviceName string) RegistrarOption