FlowDSL Node Catalog

Idempotency Key

Ensure a request is processed at most once. Routes new/duplicate.

Overview

PropertyValue
Node IDcore/idempotency-key
Kindrouter
Modulecore-flowdsl
Repogo-flowdsl
Handlergithub.com/redelay/go-flowdsl/nodes/core.IdempotencyKey
Iconlucide:fingerprint
Color#84cc16
Tagsidempotency, redis, safety

Description

Stores the request's idempotency key in the app-supplied KVStore (ctx value core.KVStoreKey). If SETNX succeeds → emits on new. If the key already exists → emits on duplicate (the prior result is copied back if available).

Outputs

  • new — (no description)
  • duplicate — (no description)

Settings

PropertyTypeRequiredDefaultUI GroupDescription
keyPathstringyes—Key
namespacestring—idemKey
ttlstring—24hTTL

Example

yaml
# Use this node in a flow:
nodes:
  - id: my_step
    name: My Step
    kind: router
    action_ref: core/idempotency-key
    config:
      keyPath: some.packet.path
      namespace: idem
      ttl: 24h

ForEach

Emit one output packet per element of an array field.

If

Route the packet down the true or false branch based on a boolean expression.