mosuka · mosuka · Mar 19, 2020 · Mar 19, 2020
diff --git a/README.md b/README.md
@@ -223,6 +223,36 @@ You can see the result in JSON format. The result of the above command is:
 
 Recommend 3 or more odd number of nodes in the cluster. In failure scenarios, data loss is inevitable, so avoid deploying single nodes.
 
+The above example, the node joins to the cluster at startup, but you can also join the node that already started on standalone mode to the cluster later, as follows:
+
+```bash
+$ ./bin/cete join --grpc-addr=:9000 node2 127.0.0.1:9001
+```
+
+or, you can use the RESTful API as follows:
+
+```bash
+$ curl -X PUT 'http://127.0.0.1:8000/v1/cluster/node2' --data-binary '
+{
+  "bind_addr": ":7001",
+  "grpc_addr": ":9001",
+  "http_addr": ":8001"
+}
+'
+```
+
+To remove a node from the cluster, execute the following command:
+
+```bash
+$ ./bin/cete leave --grpc-addr=:9000 node2
+```
+
+or, you can use the RESTful API as follows:
+
+```bash
+$ curl -X DELETE 'http://127.0.0.1:8000/v1/cluster/node2'
+```
+
 The following command indexes documents to any node in the cluster:
 
 ```bash

diff --git a/kvs/marshaler.go b/kvs/marshaler.go
@@ -62,6 +62,21 @@ func (j *CeteMarshaler) NewDecoder(r io.Reader) runtime.Decoder {
 			case *pbkvs.PutRequest:
 				v.(*pbkvs.PutRequest).Value = buffer
 				return nil
+			case *pbkvs.JoinRequest:
+				var tmpValue map[string]interface{}
+				if err = json.Unmarshal(buffer, &tmpValue); err != nil {
+					return err
+				}
+				if bindAddr, ok := tmpValue["bind_addr"].(string); ok {
+					v.(*pbkvs.JoinRequest).BindAddr = bindAddr
+				}
+				if grpcAddr, ok := tmpValue["grpc_addr"].(string); ok {
+					v.(*pbkvs.JoinRequest).GrpcAddr = grpcAddr
+				}
+				if httpAddr, ok := tmpValue["http_addr"].(string); ok {
+					v.(*pbkvs.JoinRequest).HttpAddr = httpAddr
+				}
+				return nil
 			default:
 				return json.Unmarshal(buffer, v)
 			}