Documentation ¶
Index ¶
- type ServiceRegisterDiscovery
- type XETCD
- func (object *XETCD) Close()
- func (object *XETCD) GetClient() *clientv3.Client
- func (object *XETCD) GetWithPrefix(key string, timeout time.Duration) (values map[string][]byte, err error)
- func (object *XETCD) IsClosed() bool
- func (object *XETCD) KeepAlive(key, value string, ttl int64, timeout time.Duration) (err error)
- func (object *XETCD) PutWithTTL(key, value string, ttl int64, timeout time.Duration) (err error)
- func (object *XETCD) Watch(ctx context.Context, key string, callback func(event *clientv3.Event))
- func (object *XETCD) WatchPrefix(ctx context.Context, key string, callback func(event *clientv3.Event))
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ServiceRegisterDiscovery ¶
type ServiceRegisterDiscovery struct {
// contains filtered or unexported fields
}
ServiceRegisterDiscovery 服务注册发现
func NewServiceRegisterDiscovery ¶
func NewServiceRegisterDiscovery(xetcd *XETCD, servicePrefix string) *ServiceRegisterDiscovery
NewServiceRegisterDiscovery 工厂方法
func (*ServiceRegisterDiscovery) Register ¶
func (object *ServiceRegisterDiscovery) Register(name, config string) (err error)
Register 注册
func (*ServiceRegisterDiscovery) RunAsServer ¶
func (object *ServiceRegisterDiscovery) RunAsServer(onlineHook func(key, value []byte), offlineHook func(key []byte))
RunAsServer 运行于服务状态
Click to show internal directories.
Click to hide internal directories.