mirror of
https://github.com/zeromicro/go-zero.git
synced 2025-02-03 00:38:40 +08:00
36 lines
557 B
Go
36 lines
557 B
Go
package discov
|
|
|
|
import "zero/core/logx"
|
|
|
|
type (
|
|
Renewer interface {
|
|
Start()
|
|
Stop()
|
|
Pause()
|
|
Resume()
|
|
}
|
|
|
|
etcdRenewer struct {
|
|
*Publisher
|
|
}
|
|
)
|
|
|
|
func NewRenewer(endpoints []string, key, value string, renewId int64) Renewer {
|
|
var publisher *Publisher
|
|
if renewId > 0 {
|
|
publisher = NewPublisher(endpoints, key, value, WithId(renewId))
|
|
} else {
|
|
publisher = NewPublisher(endpoints, key, value)
|
|
}
|
|
|
|
return &etcdRenewer{
|
|
Publisher: publisher,
|
|
}
|
|
}
|
|
|
|
func (sr *etcdRenewer) Start() {
|
|
if err := sr.KeepAlive(); err != nil {
|
|
logx.Error(err)
|
|
}
|
|
}
|