{"repo":"geniusrabbit/eventstream","free":true,"listed":false,"github":"https://github.com/geniusrabbit/eventstream","clone":"git clone https://github.com/geniusrabbit/eventstream.git","description":"🚀 Eventstream pipeline to preprocess and resend from some source to some storage","language":"Go","stars":16,"topics":["go","golang","kafka","nats","clickhouse","vertica","postgresql","eventstream","prometheus","redis"],"license":"Apache-2.0","category":"databases-storage","readme_excerpt":"Eventstream message pipeline Eventstream is a Go framework for building event pipelines (source → map → storage), plus an optional service binary that loads file-based scenarios. Use as a library The library API is code-first: pipeline.New(ctx, ...Option) with private registries (no global connection registry required). Imperative style is equivalent: Open drivers directly with typed options (no Config bags / global connector registry): File scenarios map YAML/HCL fields onto these same typed APIs inside cmd/eventstream via tag-selected driver catalogs in cmd/eventstream/{source,storage} ( -tags all / nats / clickhouse / …). Library drivers under source/ and storage/ have no build tags — include them by importing the package. Run the service binary File scenarios (YAML / TOML / HCL) are a service-only feature under cmd/eventstream . They are not part of the importable framework API. Docker: See deploy/develop/config.hcl (also .yml / .toml ). Sources - kafka - NATS & NATS stream - Redis stream Storages - Clickhouse - Vertica - kafka / NATS / Redis stream - ping (HTTP) Metrics & health (service) - Prometheus: /metrics - Health: /healthcheck Package layout Package Role --------- ------ eventstream Core interfaces ( Sourcer , Storager ; Streamer alias) eventstream/pkg/message Message types eventstream/source Shared source subscriber + options eventstream/source/{nats,kafka,…} Source drivers ( source.go ) eventstream/storage Shared publish storage + stream options eventstream/stor","default_branch":null,"files":null,"tree":[],"storefront":"/r/geniusrabbit","claimed":false,"request_supported":{"post":"https://gitbuyer.com/r/geniusrabbit/eventstream/request-supported","requests":0},"note":"indexed from public GitHub; nothing is for sale on this page. Clone it from GitHub. Paid listings live at /search."}