etcd

Documentation

Index

• func JSONDecode(val string) (*registry.Node, error)
• func JSONEncode(node *registry.Node) (string, error)
• func NewDiscovery(opts ...DiscoverOption) (registry.Discovery, error)
• type DiscoverOption
  • func WithCmdTimeOut(t time.Duration) DiscoverOption
  • func WithDiscoverClient(cli *clientv3.Client) DiscoverOption
  • func WithRefreshDuration(d int) DiscoverOption
  • func WithServierName(serviceName string) DiscoverOption
• type EtcdDiscovery
  • func (s *EtcdDiscovery) Close() error
  • func (s *EtcdDiscovery) GetNodes() []*registry.Node
  • func (s *EtcdDiscovery) GetUpdateTime() time.Time
• 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.Node, error)

func JSONEncode

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

func NewDiscovery

func NewDiscovery(opts ...DiscoverOption) (registry.Discovery, error)

NewDiscovery

Types

type DiscoverOption

type DiscoverOption func(*EtcdDiscovery)

func WithCmdTimeOut

func WithCmdTimeOut(t time.Duration) DiscoverOption

func WithDiscoverClient

func WithDiscoverClient(cli *clientv3.Client) DiscoverOption

func WithRefreshDuration

func WithRefreshDuration(d int) DiscoverOption

func WithServierName

func WithServierName(serviceName string) DiscoverOption

type EtcdDiscovery

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

EtcdDiscovery 服务发现

func (*EtcdDiscovery) Close

func (s *EtcdDiscovery) Close() error

Close

func (*EtcdDiscovery) GetNodes

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

GetNodes

func (*EtcdDiscovery) GetUpdateTime

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

GetUpdateTime

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