benthosdev / benthos

Fancy stream processing made operationally mundane
https://www.benthos.dev
MIT License
7.68k stars 752 forks source link

Add `etcd` as input and cache. #2555

Open danriedl opened 2 weeks ago

danriedl commented 2 weeks ago

This PR adds:

Following configs can be used in parallel to test this PR:

watch-key.etcd.yaml:

input:
  etcd:
    endpoints:
      - localhost:2379
    key: "test" 
pipeline:
  processors: []
output:
  stdout:
    codec: lines

write-key.etcd.yaml:

input:
  generate:
    mapping: |
      root = {
        "id": nanoid(5, "ABCDEFGHIJKL")
      }
    interval: 1000ms
pipeline:
  processors: []
output:
  cache:
    target: etcd
    key: test
cache_resources:
  - label: etcd
    etcd:
      endpoints:
        - localhost:2379