Redis
Kubemq redis target connector allows services using kubemq server to access redis server functions such set, get and delete.
Prerequisites
The following are required to run the redis target connector:
kubemq cluster
redis v5.0.0 (or later)
access to gcp redis server
kubemq-targets deployment
Configuration
Redis target connector configuration properties:
Properties Key
Required
Description
Example
url
yes
redis connection string
"redis://localhost:6379"
Example:
bindings:
- name: kubemq-query-redis
source:
kind: kubemq.kubemq.query
name: kubemq-query
properties:
host: "localhost"
port: "50000"
client_id: "kubemq-query-redis-connector"
auth_token: ""
channel: "query.redis"
group: ""
concurrency: "1"
auto_reconnect: "true"
reconnect_interval_seconds: "1"
max_reconnects: "0"
target:
kind: gcp.cache.redis
name: target-redis
properties:
url: "redis://localhost:6379"Usage
Get Request
Get request metadata setting:
Metadata Key
Required
Description
Possible values
key
yes
redis key string
any string
method
yes
get
"get"
Example:
{
"metadata": {
"key": "your-redis-key",
"method": "get"
},
"data": null
}Set Request
Set request metadata setting:
Metadata Key
Required
Description
Possible values
key
yes
redis key string
any string
method
yes
set
"set"
etag
no
set etag version
"0"
concurrency
no
set concurrency
""
"first-write"
"last-write"
consistency
no
set consistency
""
"strong"
"eventual"
Set request data setting:
Data Key
Required
Description
Possible values
data
yes
data to set for the redis key
base64 bytes array
Example:
{
"metadata": {
"key": "your-redis-key",
"method": "set",
"etag": "0",
"concurrency": "",
"consistency": ""
},
"data": "c29tZS1kYXRh"
}Delete Request
Delete request metadata setting:
Metadata Key
Required
Description
Possible values
key
yes
redis key string
any string
method
yes
delete
"delete"
Example:
{
"metadata": {
"key": "your-redis-key",
"method": "delete"
},
"data": null
}Last updated
Was this helpful?