mirror of https://github.com/milvus-io/milvus.git
parent
1341dcd3f8
commit
cdab13668a
|
@ -346,7 +346,7 @@ func (w *sessionWatcher) start() {
|
||||||
// typeutil.type.go.
|
// typeutil.type.go.
|
||||||
// revision is a etcd reversion to prevent missing key events and can be obtained
|
// revision is a etcd reversion to prevent missing key events and can be obtained
|
||||||
// in GetSessions.
|
// in GetSessions.
|
||||||
// If a server up, a event will be add to channel with eventType SessionAddType.
|
// If a server up, an event will be add to channel with eventType SessionAddType.
|
||||||
// If a server down, a event will be add to channel with eventType SessionDelType.
|
// If a server down, a event will be add to channel with eventType SessionDelType.
|
||||||
func (s *Session) WatchServices(prefix string, revision int64, rewatch Rewatch) (eventChannel <-chan *SessionEvent) {
|
func (s *Session) WatchServices(prefix string, revision int64, rewatch Rewatch) (eventChannel <-chan *SessionEvent) {
|
||||||
w := &sessionWatcher{
|
w := &sessionWatcher{
|
||||||
|
|
Loading…
Reference in New Issue