etcd

Documentation

Index

• func JSONDecode(val string) (*registry.ServiceNode, error)
• func JSONEncode(node *registry.ServiceNode) (string, error)
• type DiscoverOption
  • func WithDiscoverClient(cli *clientv3.Client) DiscoverOption
  • func WithDiscoverConfig(config *registry.DiscoveryConfig) DiscoverOption
• type EtcdDiscovery
  • 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
  • func NewRegistry(opts ...RegistrarOption) (*EtcdRegistrar, error)
  • func (s *EtcdRegistrar) DeRegister(ctx context.Context) error
  • func (s *EtcdRegistrar) Register(ctx context.Context) error
• type RegistrarOption
  • 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

Functions

func JSONDecode

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

func JSONEncode

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

Types

type DiscoverOption

type DiscoverOption func(*EtcdDiscovery)

func WithDiscoverClient

func WithDiscoverClient(cli *clientv3.Client) DiscoverOption

func WithDiscoverConfig

func WithDiscoverConfig(config *registry.DiscoveryConfig) DiscoverOption

type EtcdDiscovery

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

EtcdDiscovery 服务发现

func NewDiscovery

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

NewDiscovery

func (*EtcdDiscovery) Close

func (s *EtcdDiscovery) Close() error

Close

func (*EtcdDiscovery) DelServiceList

func (s *EtcdDiscovery) DelServiceList(key string)

DelServiceList

func (*EtcdDiscovery) GetLoadBalance

func (s *EtcdDiscovery) GetLoadBalance() string

GetLoadBalance

func (*EtcdDiscovery) GetServices

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

GetServices

func (*EtcdDiscovery) SetServiceList

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

SetServiceList

func (*EtcdDiscovery) WatchService

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

WatchService

type EtcdRegistrar

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

EtcdRegistrar

func NewRegistry

func NewRegistry(opts ...RegistrarOption) (*EtcdRegistrar, error)

NewRegistry

func (*EtcdRegistrar) DeRegister

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

Close

func (*EtcdRegistrar) Register

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

type RegistrarOption

type RegistrarOption func(*EtcdRegistrar)

func WithRegistarHost

func WithRegistarHost(host string) RegistrarOption

func WithRegistarPort

func WithRegistarPort(port int) RegistrarOption

func WithRegistrarClient

func WithRegistrarClient(cli *clientv3.Client) RegistrarOption

func WithRegistrarLease

func WithRegistrarLease(lease int64) RegistrarOption

func WithRegistrarServiceName

func WithRegistrarServiceName(serviceName string) RegistrarOption