diff --git a/EtcdConnector/src/main/java/eu/mikroskeem/utils/etcdconnector/EtcdConnector.java b/EtcdConnector/src/main/java/eu/mikroskeem/utils/etcdconnector/EtcdConnector.java index 56d2750..0594c23 100644 --- a/EtcdConnector/src/main/java/eu/mikroskeem/utils/etcdconnector/EtcdConnector.java +++ b/EtcdConnector/src/main/java/eu/mikroskeem/utils/etcdconnector/EtcdConnector.java @@ -1,5 +1,6 @@ package eu.mikroskeem.utils.etcdconnector; +import mousio.etcd4j.EtcdClient; import org.jetbrains.annotations.NotNull; import org.jetbrains.annotations.Nullable; @@ -73,8 +74,18 @@ public interface EtcdConnector { /** * Waits for key change * + * Deprecated: it is broken, literally + * * @param path Key path * @param callback Callback to run */ + @Deprecated void waitKey(@NotNull String path, @NotNull Function callback); + + /** + * Get client instance + * + * @return Etcd client instance + */ + EtcdClient getClient(); } diff --git a/EtcdConnector/src/main/java/eu/mikroskeem/utils/etcdconnector/EtcdConnectorBase.java b/EtcdConnector/src/main/java/eu/mikroskeem/utils/etcdconnector/EtcdConnectorBase.java index d1ca204..20e77ad 100644 --- a/EtcdConnector/src/main/java/eu/mikroskeem/utils/etcdconnector/EtcdConnectorBase.java +++ b/EtcdConnector/src/main/java/eu/mikroskeem/utils/etcdconnector/EtcdConnectorBase.java @@ -166,4 +166,8 @@ abstract class EtcdConnectorBase implements EtcdConnector { e.printStackTrace(); } } + + public EtcdClient getClient() { + return etcdClient; + } }