Kubemq Rethinkdb target connector allows services using kubemq server to access Rethinkdb database services.
Prerequisites
The following are required to run the Rethinkdb target connector:
kubemq-targets deployment
Configuration
Rethinkdb target connector configuration properties:
Example:
bindings:
- name: kubemq-query-Rethinkdb
source:
kind: kubemq.query
name: kubemq-query
properties:
address: "kubemq-cluster:50000"
client_id: "kubemq-query-Rethinkdb-connector"
auth_token: ""
channel: "query.Rethinkdb"
group: ""
concurrency: "1"
auto_reconnect: "true"
reconnect_interval_seconds: "1"
max_reconnects: "0"
target:
kind: stores.Rethinkdb
name: target-Rethinkdb
properties:
host: "localhost:27017"
username: "admin"
password: "password"
database: "admin"
collection: "test"
write_concurrency: "majority"
read_concurrency: ""
params: ""
operation_timeout_seconds: "2"
Usage
Get Request
Get request metadata setting:
Example:
{
"metadata": {
"key": "your-Rethinkdb-key",
"db_name": "test",
"table": "users",
"method": "get"
},
"data": null
}
Update Request
Update request metadata setting:
Update request data setting:
Example:
{
"metadata": {
"key": "your-Rethinkdb-key",
"db_name": "test",
"table": "users",
"method": "update"
},
"data": "ICAibWV0YWRhdGEiOiB7CiAgICAia2V5IjogInlvdXItUmV0aGlua2RiLWtleSIsCiAgICAiZGJfbmFtZSI6ICJ0ZXN0IiwKICAgICJ0YWJsZSI6ICJ1c2VycyIsCiAgICAibWV0aG9kIjogImdldCIKICB9LA=="
}
Delete Request
Delete request metadata setting:
Example:
{
"metadata": {
"key": "your-Rethinkdb-key",
"db_name": "test",
"table": "users",
"method": "delete"
},
"data": null
}
Insert Request
insert request metadata setting:
Insert request data setting:
Example:
{
"metadata": {
"key": "your-Rethinkdb-key",
"db_name": "test",
"table": "users",
"method": "insert"
},
"data": "ICAibWV0YWRhdGEiOiB7CiAgICAia2V5IjogInlvdXItUmV0aGlua2RiLWtleSIsCiAgICAiZGJfbmFtZSI6ICJ0ZXN0IiwKICAgICJ0YWJsZSI6ICJ1c2VycyIsCiAgICAibWV0aG9kIjogImdldCIKICB9LA=="
}