connect
connect copied to clipboard
Add `etcd` as input and cache.
This PR adds:
-
feat: add
etcdas cache resource. #1154 -
feat: add
etcdas input to watch a key. #1154
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