Jdiscovery

Documentation

Index

• type Discovery
  • func DiscoveryInit(config DiscoveryInitConfig) (*Discovery, error)
  • func (discovery *Discovery) GetConfig(configKey string) ([]byte, error)
  • func (discovery *Discovery) GetData(key string) ([]byte, error)
  • func (discovery *Discovery) RegisterConfigWatch(config *DiscoveryConfig) error
  • func (discovery *Discovery) RegisterNode(node *DiscoveryNode) error
  • func (discovery *Discovery) RegisterNodeWatch(watchNode *DiscoveryWatchNode) error
  • func (discovery *Discovery) SetConfig(configKey string, data string) error
  • func (discovery *Discovery) SetData(key string, data string, opts ...clientv3.OpOption) error
  • func (discovery *Discovery) UnRegisterConfigWatch(configKey string) error
  • func (discovery *Discovery) UnRegisterNode(nodeKey string) error
  • func (discovery *Discovery) UnRegisterNodeWatch(watchKey string) error
  • func (discovery *Discovery) WatchData(ctx context.Context, key string, call func(e *clientv3.Event))
• type DiscoveryConfig
• type DiscoveryInitConfig
• type DiscoveryNode
• type DiscoveryWatchNode

Types

type Discovery

type Discovery struct {
	Client *clientv3.Client
	Config DiscoveryInitConfig

	DiscoveryWatchConfigMap map[string]*DiscoveryConfig
	DiscoveryWatchNodeMap   map[string]*DiscoveryWatchNode
	// contains filtered or unexported fields
}

func DiscoveryInit

func DiscoveryInit(config DiscoveryInitConfig) (*Discovery, error)

func (*Discovery) GetConfig

func (discovery *Discovery) GetConfig(configKey string) ([]byte, error)

func (*Discovery) GetData

func (discovery *Discovery) GetData(key string) ([]byte, error)

func (*Discovery) RegisterConfigWatch

func (discovery *Discovery) RegisterConfigWatch(config *DiscoveryConfig) error

func (*Discovery) RegisterNode

func (discovery *Discovery) RegisterNode(node *DiscoveryNode) error

func (*Discovery) RegisterNodeWatch

func (discovery *Discovery) RegisterNodeWatch(watchNode *DiscoveryWatchNode) error

func (*Discovery) SetConfig

func (discovery *Discovery) SetConfig(configKey string, data string) error

func (*Discovery) SetData

func (discovery *Discovery) SetData(key string, data string, opts ...clientv3.OpOption) error

func (*Discovery) UnRegisterConfigWatch

func (discovery *Discovery) UnRegisterConfigWatch(configKey string) error

func (*Discovery) UnRegisterNode

func (discovery *Discovery) UnRegisterNode(nodeKey string) error

func (*Discovery) UnRegisterNodeWatch

func (discovery *Discovery) UnRegisterNodeWatch(watchKey string) error

func (*Discovery) WatchData

func (discovery *Discovery) WatchData(ctx context.Context, key string, call func(e *clientv3.Event))

type DiscoveryConfig

type DiscoveryConfig struct {
	ConfigKey  string
	ConfigCall discoveryConfigCall
	// contains filtered or unexported fields
}

type DiscoveryInitConfig

type DiscoveryInitConfig struct {
	EtcdAddr       string
	ConnectTimeout int
	RequestTimeout int
}

type DiscoveryNode

type DiscoveryNode struct {
	NodeKey      string
	NodeData     []byte
	NodeKeepLive int64
}

type DiscoveryWatchNode

type DiscoveryWatchNode struct {
	NodeKey  string
	NodeData []byte
	NodeCall discoveryWatchNodeCall
	// contains filtered or unexported fields
}