mirror
/
etcd-cpp-apiv3
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Revert "Update Watcher re-connection sample." 

This reverts commit 23394ab9bb.
This commit is contained in:
Tao He 2022-04-08 16:41:58 +08:00
parent d4975f84b3
commit 9a2afd4e81
1 changed files with 4 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
README.md
View File

@ -586,14 +586,11 @@ void initialize_watcher(const std::string &endpoints,
wait_for_connection(client); wait_for_connection(client);
watcher->reset(new etcd::Watcher(client, prefix, callback)); watcher->reset(new etcd::Watcher(client, prefix, callback));
watcher->Wait([endpoints, prefix, callback, watcher->Wait([endpoints, prefix, callback,
/* watcher reference keep the shared_ptr alive */, &watcher](bool cancelled) -> bool { watcher_ref /* keep the shared_ptr alive */, &watcher](bool cancelled) {
if (cancelled) { if (cancelled) {
return false; // No reactivate watcher (default behaviour). return;
} }
initialize_watcher(endpoints, prefix, callback, watcher);
etcd::Client client(endpoints);
wait_for_connection(client);
return true; // Reactivate watcher.
}); });
} }
``` ```
@ -604,7 +601,7 @@ std::function<void(Response)> callback = printResponse;
const std::string prefix = "/test/key"; const std::string prefix = "/test/key";
// the watcher initialized in this way will auto re-connect to etcd // the watcher initialized in this way will auto re-connect to etcd
std::shared_ptr<etcd::Watcher> watcher; std::unique_ptr<etcd::Watcher> watcher;
initialize_watcher(endpoints, prefix, callback, watcher); initialize_watcher(endpoints, prefix, callback, watcher);
``` ```