NATS Put

NATS Put
Certified
Put values into NATS Key/Value bucket

Writes one or more Key/Value entries to an existing NATS bucket. Values are rendered, serialized to JSON, and the resulting revisions are returned.

yaml
type: io.kestra.plugin.nats.kv.Put

Examples

yaml
id: nats_kv_put
namespace: company.team

tasks:
  - id: put
    type: io.kestra.plugin.nats.kv.Put
    url: nats://localhost:4222
    username: nats_user
    password: "{{ secret('NATS_PASSWORD') }}"
    bucketName: my_bucket
    values:
      key1: value1
      key2: value2
      key3:
        subKey1: some other value

Properties

bucketName *string

Min length1

Bucket name

Rendered bucket identifier that must already exist.

url *string

Min length1

URL to connect to NATS server

The format is (nats://)server_url: port. You can also provide a connection token like so: nats://token@server_url: port

values *object

Values to write

Map of keys to values rendered then serialized to JSON before being stored.

creds string

Credentials files authentification

password string

Plaintext authentication password

pluginDefaultsRef string

Reference (ref) of the pluginDefaults to apply to this task.

token string

Token authentification

username string

Plaintext authentication username

Outputs

revisions object

SubTypeinteger

Revision numbers

Revision returned by NATS for each written key.

Liquibase

Tasks that run Liquibase change management commands.

Data

PostgreSQL

Tasks that connect to PostgreSQL via JDBC to run queries and loads.

Data

NATS PutCertifiedPut values into NATS Key/Value bucket

More Plugins in this Category

Liquibase

PostgreSQL

NATS Put
Certified
Put values into NATS Key/Value bucket