AndreaBozzo

AndreaBozzo/Nephtys

Lightweight real-time stream connector for NATS JetStream — WebSocket, SSE, REST polling, webhooks & gRPC in, durable normalized events out. ~19 MB RSS, runtime-reconfigurable pipelines. IEEE UIC 2026 paper.

1 stars 0 forks 1 watchers Go Apache License 2.0
connector connectors data-engineering data-ingestion docker edge-computing event-driven golang grafana grpc iot jetstream nats prometheus-metrics real-time sse streaming webhooks websocket
View on GitHub
2 Open Issues Need Help Last updated: Jul 18, 2026

Open Issues Need Help

View All on GitHub
fix(store,server): persist pipeline updates across restart 1 day ago
bug good first issue roadmap ops-surface
AndreaBozzo/Nephtys
1

Lightweight real-time stream connector for NATS JetStream — WebSocket, SSE, REST polling, webhooks & gRPC in, durable normalized events out. ~19 MB RSS, runtime-reconfigurable pipelines. IEEE UIC 2026 paper.

Go
#connector#connectors#data-engineering#data-ingestion#docker#edge-computing#event-driven#golang#grafana#grpc#iot#jetstream#nats#prometheus-metrics#real-time#sse#streaming#webhooks#websocket
docs: JetStream replay recipe + example consumer + integration test (A4) 17 days ago
documentation good first issue roadmap
AndreaBozzo/Nephtys
1

Lightweight real-time stream connector for NATS JetStream — WebSocket, SSE, REST polling, webhooks & gRPC in, durable normalized events out. ~19 MB RSS, runtime-reconfigurable pipelines. IEEE UIC 2026 paper.

Go
#connector#connectors#data-engineering#data-ingestion#docker#edge-computing#event-driven#golang#grafana#grpc#iot#jetstream#nats#prometheus-metrics#real-time#sse#streaming#webhooks#websocket