Synadia Connect
Redis PubSub
NAME | RUNTIME | TYPE | VERSION |
---|---|---|---|
redis_pubsub | wombat | source | latest |
Consume from a Redis publish/subscribe channel using either the SUBSCRIBE or PSUBSCRIBE commands.
In order to subscribe to channels using the PSUBSCRIBE
command set the field use_patterns
to true
, then you can include glob-style patterns in your channel names. For example:
h?llo
subscribes to hello, hallo and hxlloh*llo
subscribes to hllo and heeeelloh[ae]llo
subscribes to hello and hallo, but not hillo
Use \
to escape special characters if you want to match them verbatim.
Configuration
Name | Type | Optional | Secret | Description |
---|---|---|---|---|
url | string | no | no | The URL of the target Redis server. Database is optional and is supplied as the URL path. |
kind | string | yes | no | Specifies a simple, cluster-aware, or failover-aware redis client. The value should be one of simple , cluster or failover . The value defaults to "simple" . |
master | string | yes | no | Name of the redis master when kind is failover . The value defaults to "" . |
tls | tls | no | no | Custom TLS settings can be used to override system defaults. |
channels | []string | no | no | A list of channels to consume from. |
use_patterns | bool | yes | no | Whether to use the PSUBSCRIBE command, allowing for glob-style patterns within target channel names. The value defaults to false . |
auto_replay_nacks | bool | yes | no | Whether messages that are rejected (nacked) at the output level should be automatically replayed indefinitely, eventually resulting in back pressure if the cause of the rejections is persistent. If set to false these messages will instead be deleted. Disabling auto replays can greatly improve memory efficiency of high throughput streams as the original shape of the data can be discarded immediately upon consumption and mutation. The value defaults to true . |
TLS Configuration
Name | Type | Optional | Secret | Description |
---|---|---|---|---|
enabled | bool | yes | no | Whether custom TLS settings are enabled. The value defaults to false . |
skip_cert_verify | bool | yes | no | Whether to skip server side certificate verification. The value defaults to false . |
enable_renegotiation | bool | yes | no | Whether to allow the remote server to repeatedly request renegotiation. |
Enable this option if you're seeing the error message local error: tls: no renegotiation . The value defaults to false . | ||||
root_cas | string | yes | yes | An optional root certificate authority to use. |
This is a string, representing a certificate chain from the parent trusted root certificate, | ||||
to possible intermediate signing certificates, to the host certificate. The value defaults to "" . | ||||
client_certs | []client_certs | yes | no | A list of client certificates to use. . The value defaults to [] . |