feat(peerdb): management via api

snippets/peerdb.fish

@@ -0,0 +1,68 @@
+#!/usr/bin/env fish
+
+# List peers
+curl -fsS --url 'http://localhost:3000/api/v1/peers/list' \
+	-H "Authorization: Basic $(gopass show -o 'peerdb/instance' | xargs printf '%s' ':' | base64)"
+
+# Create peers
+# postgres: peer.type=3|'POSTGRES' + postgres_config={…}
+# clickhouse: peer.type=8 + clickhouse_config={…}
+# kafka: peer.type=9 + kafka_config={…}
+curl -fsS --url 'http://localhost:3000/api/v1/peers/create' -X 'POST' \
+	-H 'Content-Type: application/json' \
+	-H "Authorization: Basic $(gopass show -o 'peerdb/instance' | xargs printf '%s' ':' | base64)" \
+	-d "{
+		\"peer\": {
+			\"name\": \"some_pg_peer\",
+			\"type\": \"POSTGRES\",
+			\"postgres_config\": {
+				\"host\": \"localhost\",
+				\"port\": 5432,
+				\"user\": \"peerdb\",
+				\"password\": \"$(gopass show -o 'peerdb/db-user')\",
+				\"database\": \"sales\"
+			}
+		}
+	}"
+
+# Update peers
+# Reuse the command for creation but add 'allow_update: true' to the data
+curl -fsS --url 'http://localhost:3000/api/v1/peers/create' -X 'POST' … \
+	-d "{
+		\"peer\": { … },
+		allow_update: true
+	}"
+
+# List mirrors
+curl -fsS --url 'http://localhost:3000/api/v1/mirrors/list' \
+	-H "Authorization: Basic $(gopass show -o 'peerdb/instance' | xargs printf '%s' ':' | base64)" \
+| jq '.mirrors[]' -
+
+# Get mirrors' status
+curl -fsS 'http://localhost:3000/api/v1/mirrors/status' -X 'POST' \
+	-H 'Content-Type: application/json' \
+	-H "Authorization: Basic $(gopass show -o 'peerdb/instance' | xargs printf '%s' ':' | base64)" \
+	-d '{ "flowJobName": "testing_bq_2" }'
+
+# Get mirrors' configuration
+curl -fsS 'http://localhost:3000/api/v1/mirrors/status' -X 'POST' \
+	-H 'Content-Type: application/json' \
+	-H "Authorization: Basic $(gopass show -o 'peerdb/instance' | xargs printf '%s' ':' | base64)" \
+	-d '{
+		"flowJobName": "testing_bq_2",
+		"includeFlowInfo": true
+	}' \
+| jq '.cdcStatus.config' -
+
+# Show alerts' configuration
+curl -fsS --url 'http://localhost:3000/api/v1/alerts/config' \
+	-H "Authorization: Basic $(gopass show -o 'peerdb/instance' | xargs printf '%s' ':' | base64)" \
+| jq '.configs[]' -
+
+# Others
+curl -fsS 'http://localhost:3000/api/v1/dynamic_settings' \
+	-H "Authorization: Basic $(gopass show -o 'peerdb/instance' | xargs printf '%s' ':' | base64)" \
+| jq '.settings[]' -
+curl -fsS --url 'http://localhost:3000/api/v1/scripts/-1' \
+	-H "Authorization: Basic $(gopass show -o 'peerdb/instance' | xargs printf '%s' ':' | base64)" \
+| jq '.scripts[]' -