etcd

Documentation

Index

• func JSONDecode(val string) (*registry.Node, error)
• func JSONEncode(node *registry.Node) (string, error)
• func NewDiscovery(cli *clientv3.Client, name string, opts ...DiscoveryOptionFunc) (registry.Discovery, error)
• type DiscoveryOption
• type DiscoveryOptionFunc
  • func WithCmdTimeOut(t time.Duration) DiscoveryOptionFunc
  • func WithRefreshDuration(d int) DiscoveryOptionFunc
• type EtcdDiscovery
  • func (s *EtcdDiscovery) Close() error
  • func (s *EtcdDiscovery) GetNodes() []servicer.Node
  • func (s *EtcdDiscovery) GetUpdateTime() time.Time
• type EtcdRegistrar
  • func NewRegistry(cli *clientv3.Client, name, host string, port int, opts ...RegistrarOptionFunc) (*EtcdRegistrar, error)
  • func (s *EtcdRegistrar) DeRegister(ctx context.Context) error
  • func (s *EtcdRegistrar) Register(ctx context.Context) error
• type RegistrarOption
• type RegistrarOptionFunc
  • func WithRegistrarEncode(encode registry.Encode) RegistrarOptionFunc
  • func WithRegistrarLease(lease int64) RegistrarOptionFunc

Functions

func JSONDecode

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

func JSONEncode

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

func NewDiscovery

func NewDiscovery(cli *clientv3.Client, name string, opts ...DiscoveryOptionFunc) (registry.Discovery, error)

NewDiscovery

Types

type DiscoveryOption

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

type DiscoveryOptionFunc

type DiscoveryOptionFunc func(*DiscoveryOption)

func WithCmdTimeOut

func WithCmdTimeOut(t time.Duration) DiscoveryOptionFunc

func WithRefreshDuration

func WithRefreshDuration(d int) DiscoveryOptionFunc

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() []servicer.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(cli *clientv3.Client, name, host string, port int, opts ...RegistrarOptionFunc) (*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 struct {
	// contains filtered or unexported fields
}

type RegistrarOptionFunc

type RegistrarOptionFunc func(*RegistrarOption)

func WithRegistrarEncode

func WithRegistrarEncode(encode registry.Encode) RegistrarOptionFunc

func WithRegistrarLease

func WithRegistrarLease(lease int64) RegistrarOptionFunc