etcdv3

Documentation

Index

• Constants
• Variables
• func HandleClientRestart(r clientFacade)
• func ValidateClient(container clientFacade, opts ...Option) error
• type Client
  • func (c *Client) CleanKV() error
  • func (c *Client) Close()
  • func (c *Client) Create(k string, v string) error
  • func (c *Client) Delete(k string) error
  • func (c *Client) Done() <-chan struct{}
  • func (c *Client) Get(k string) (string, error)
  • func (c *Client) GetChildrenKVList(k string) ([]string, []string, error)
  • func (c *Client) RegisterTemp(basePath string, node string) (string, error)
  • func (c *Client) Valid() bool
  • func (c *Client) Watch(k string) (clientv3.WatchChan, error)
  • func (c *Client) WatchWithPrefix(prefix string) (clientv3.WatchChan, error)
• type EventListener
  • func NewEventListener(client *Client) *EventListener
  • func (l *EventListener) Close()
  • func (l *EventListener) ListenServiceEvent(key string, listener remoting.DataListener)
  • func (l *EventListener) ListenServiceNodeEvent(key string, listener ...remoting.DataListener) bool
  • func (l *EventListener) ListenServiceNodeEventWithPrefix(prefix string, listener ...remoting.DataListener)
• type Option
  • func WithEndpoints(endpoints ...string) Option
  • func WithHeartbeat(heartbeat int) Option
  • func WithName(name string) Option
  • func WithTimeout(timeout time.Duration) Option
• type Options

Constants

const (
	ConnDelay            = 3
	MaxFailTimes         = 15
	RegistryETCDV3Client = "etcd registry"
)

Variables

var (
	ErrNilETCDV3Client = perrors.New("etcd raw client is nil") // full describe the ERR
	ErrKVPairNotFound  = perrors.New("k/v pair not found")
)

Functions

func HandleClientRestart

func HandleClientRestart(r clientFacade)

func ValidateClient

func ValidateClient(container clientFacade, opts ...Option) error

Types

type Client

type Client struct {
	Wait sync.WaitGroup
	// contains filtered or unexported fields
}

func (*Client) CleanKV

func (c *Client) CleanKV() error

func (*Client) Close

func (c *Client) Close()

func (*Client) Create

func (c *Client) Create(k string, v string) error

func (*Client) Delete

func (c *Client) Delete(k string) error

func (*Client) Done

func (c *Client) Done() <-chan struct{}

func (*Client) Get

func (c *Client) Get(k string) (string, error)

func (*Client) GetChildrenKVList

func (c *Client) GetChildrenKVList(k string) ([]string, []string, error)

func (*Client) RegisterTemp

func (c *Client) RegisterTemp(basePath string, node string) (string, error)

func (*Client) Valid

func (c *Client) Valid() bool

func (*Client) Watch

func (c *Client) Watch(k string) (clientv3.WatchChan, error)

func (*Client) WatchWithPrefix

func (c *Client) WatchWithPrefix(prefix string) (clientv3.WatchChan, error)

type EventListener

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

func NewEventListener

func NewEventListener(client *Client) *EventListener

func (*EventListener) Close

func (l *EventListener) Close()

func (*EventListener) ListenServiceEvent

func (l *EventListener) ListenServiceEvent(key string, listener remoting.DataListener)

this func is invoked by etcdv3 ConsumerRegistry::Registe/ etcdv3 ConsumerRegistry::get/etcdv3 ConsumerRegistry::getListener registry.go:Listen -> listenServiceEvent -> listenDirEvent -> ListenServiceNodeEvent

|
--------> ListenServiceNodeEvent

func (*EventListener) ListenServiceNodeEvent

func (l *EventListener) ListenServiceNodeEvent(key string, listener ...remoting.DataListener) bool

Listen on a spec key this method will return true when spec key deleted, this method will return false when deep layer connection lose

func (*EventListener) ListenServiceNodeEventWithPrefix

func (l *EventListener) ListenServiceNodeEventWithPrefix(prefix string, listener ...remoting.DataListener)

Listen on a set of key with spec prefix

type Option

type Option func(*Options)

func WithEndpoints

func WithEndpoints(endpoints ...string) Option

func WithHeartbeat

func WithHeartbeat(heartbeat int) Option

func WithName

func WithName(name string) Option

func WithTimeout

func WithTimeout(timeout time.Duration) Option

type Options

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