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

Update Watcher re-connection sample.

This commit is contained in:
David Pastor 2022-02-09 16:08:04 +01:00 committed by Tao He
parent 0467c0eef3
commit 23394ab9bb
1 changed files with 7 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
README.md
View File

@ -585,11 +585,14 @@ 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_ref /* keep the shared_ptr alive */, &watcher](bool cancelled) { /* watcher reference keep the shared_ptr alive */, &watcher](bool cancelled) -> bool {
if (cancelled) { if (cancelled) {
return; return false; // No reactivate watcher (default behaviour).
} }
initialize_watcher(endpoints, prefix, callback, watcher);
etcd::Client client(endpoints);
wait_for_connection(client);
return true; // Reactivate watcher.
}); });
} }
``` ```
@ -600,7 +603,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::unique_ptr<etcd::Watcher> watcher; std::shared_ptr<etcd::Watcher> watcher;
initialize_watcher(endpoints, prefix, callback, watcher); initialize_watcher(endpoints, prefix, callback, watcher);
``` ```