Merge pull request #6 from 007hacky007/etcd-node-failover

Etcd node failover

README.md

@@ -69,3 +69,24 @@ $shardedClient = new Aternos\Etcd\ShardedClient($clients);
 $shardedClient->put("key", "value");
 $shardedClient->get("key");
 ```
+
+### Failover client
+
+- automatically and transparently fails-over in case etcd host fails 
+```php
+<?php
+
+$clients = [
+    new Aternos\Etcd\Client("hostA:2379"),
+    new Aternos\Etcd\Client("hostB:2379"),
+    new Aternos\Etcd\Client("hostC:2379")
+];
+$failoverClient = new Aternos\Etcd\FailoverClient($clients);
+
+// set 60 seconds as a hold-off period between another connection attempt to the failing host 
+// default is 120 seconds
+// failing host is being remembered within FailoverClient object instance 
+$failoverClient->setHoldoffTime(60);
+$failoverClient->put("key", "value");
+$failoverClient->get("key");
+```

src/Client.php

@@ -2,6 +2,8 @@
 
 namespace Aternos\Etcd;
 
+use Aternos\Etcd\Exception\InvalidLeaseException;
+use Aternos\Etcd\Exception\NoResponseException;
 use Aternos\Etcd\Exception\Status\InvalidResponseStatusCodeException;
 use Aternos\Etcd\Exception\Status\ResponseStatusCodeExceptionFactory;
 use Etcdserverpb\AuthClient;
@@ -27,7 +29,6 @@
 use Etcdserverpb\ResponseOp;
 use Etcdserverpb\TxnRequest;
 use Etcdserverpb\TxnResponse;
-use Exception;
 use Grpc\ChannelCredentials;
 use Mvccpb\KeyValue;
 
@@ -197,7 +198,6 @@ public function delete(string $key)
      * @param bool $returnNewValueOnFail
      * @return bool|string
      * @throws InvalidResponseStatusCodeException
-     * @throws \Exception
      */
     public function putIf(string $key, string $value, $compareValue, bool $returnNewValueOnFail = false)
     {
@@ -217,7 +217,6 @@ public function putIf(string $key, string $value, $compareValue, bool $returnNew
      * @param bool $returnNewValueOnFail
      * @return bool|string
      * @throws InvalidResponseStatusCodeException
-     * @throws \Exception
      */
     public function deleteIf(string $key, $compareValue, bool $returnNewValueOnFail = false)
     {
@@ -270,8 +269,7 @@ public function revokeLeaseID(int $leaseID)
      *
      * @param int $leaseID
      * @return int lease TTL
-     * @throws InvalidResponseStatusCodeException
-     * @throws Exception
+     * @throws InvalidResponseStatusCodeException|NoResponseException|InvalidLeaseException
      */
     public function refreshLease(int $leaseID)
     {
@@ -285,18 +283,21 @@ public function refreshLease(int $leaseID)
         /** @var LeaseKeepAliveResponse $response */
         $response = $leaseBidi->read();
         $leaseBidi->cancel();
-        if(empty($response->getID()) || (int)$response->getID() !== $leaseID)
-            throw new Exception('Could not refresh lease ID: ' . $leaseID);
+        if($response === null || empty($response->getID()) || (int)$response->getID() !== $leaseID)
+            throw new NoResponseException('Could not refresh lease ID: ' . $leaseID);
+
+        if((int)$response->getTTL() === 0)
+            throw new InvalidLeaseException('Invalid lease ID or expired lease');
 
         return (int)$response->getTTL();
     }
 
     /**
      * Execute $requestOperations if Compare succeeds, execute $failureOperations otherwise if defined
      *
-     * @param array $requestOperations operations to perform on success, array of RequestOp objects
-     * @param array|null $failureOperations operations to perform on failure, array of RequestOp objects
-     * @param array $compare array of Compare objects
+     * @param RequestOp[] $requestOperations operations to perform on success, array of RequestOp objects
+     * @param RequestOp[]|null $failureOperations operations to perform on failure, array of RequestOp objects
+     * @param Compare[] $compare array of Compare objects
      * @return TxnResponse
      * @throws InvalidResponseStatusCodeException
      */

src/Exception/InvalidLeaseException.php

@@ -0,0 +1,13 @@
+<?php
+
+namespace Aternos\Etcd\Exception;
+
+/**
+ * Class InvalidLeaseException
+ *
+ * @package Aternos\Etcd\Exception
+ */
+class InvalidLeaseException extends \Exception
+{
+
+}

src/Exception/NoClientAvailableException.php

@@ -0,0 +1,13 @@
+<?php
+
+namespace Aternos\Etcd\Exception;
+
+/**
+ * Class NoClientAvailableException
+ *
+ * @package Aternos\Etcd\Exception
+ */
+class NoClientAvailableException extends \Exception
+{
+
+}

src/Exception/NoResponseException.php

@@ -0,0 +1,13 @@
+<?php
+
+namespace Aternos\Etcd\Exception;
+
+/**
+ * Class NoResponseException
+ *
+ * @package Aternos\Etcd\Exception
+ */
+class NoResponseException extends \Exception
+{
+
+}