fix: peer keepalive with manager (#1940)
Signed-off-by: Gaius <gaius.qi@gmail.com>
This commit is contained in:
parent
e588fb8bcf
commit
c3882ccfc6
|
|
@ -309,17 +309,17 @@ func (a *announcer) announceToManager() error {
|
||||||
}); err != nil {
|
}); err != nil {
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
}
|
|
||||||
|
|
||||||
// Start keepalive to manager.
|
// Start keepalive to manager.
|
||||||
go func() {
|
go func() {
|
||||||
a.managerClient.KeepAlive(a.config.Scheduler.Manager.SeedPeer.KeepAlive.Interval, &managerv1.KeepAliveRequest{
|
a.managerClient.KeepAlive(a.config.Scheduler.Manager.SeedPeer.KeepAlive.Interval, &managerv1.KeepAliveRequest{
|
||||||
SourceType: managerv1.SourceType_SEED_PEER_SOURCE,
|
SourceType: managerv1.SourceType_SEED_PEER_SOURCE,
|
||||||
HostName: a.config.Host.Hostname,
|
HostName: a.config.Host.Hostname,
|
||||||
Ip: a.config.Host.AdvertiseIP.String(),
|
Ip: a.config.Host.AdvertiseIP.String(),
|
||||||
ClusterId: uint64(a.config.Scheduler.Manager.SeedPeer.ClusterID),
|
ClusterId: uint64(a.config.Scheduler.Manager.SeedPeer.ClusterID),
|
||||||
}, a.done)
|
}, a.done)
|
||||||
}()
|
}()
|
||||||
|
}
|
||||||
|
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue