Files

livestream

Name		Name	Last commit message	Last commit date
parent directory ..
configs		configs
mocks		mocks
.gitignore		.gitignore
.mockery.yaml		.mockery.yaml
Dockerfile		Dockerfile
README.md		README.md
configs.go		configs.go
db.go		db.go
deploy.sh		deploy.sh
docker-compose.yml		docker-compose.yml
event.go		event.go
event_test.go		event_test.go
filter.go		filter.go
filter_test.go		filter_test.go
geoip.go		geoip.go
geoip_test.go		geoip_test.go
go.mod		go.mod
go.sum		go.sum
handlers.go		handlers.go
index.html		index.html
jwt.go		jwt.go
jwt_test.go		jwt_test.go
kafka.go		kafka.go
kafka_test.go		kafka_test.go
live_stats.go		live_stats.go
main.go		main.go
main_test.go		main_test.go
metrics.go		metrics.go
posthog.go		posthog.go
served.go		served.go
start.sh		start.sh
ttl_counter.go		ttl_counter.go
ttl_counter_test.go		ttl_counter_test.go

README.md

RealTime Hog 3000

The start of something fresh.

Hog 3000 powers live event stream on PostHog: https://us.posthog.com/project/0/activity/live

Endpoints

/ - dummy placeholder
/served - total number of events and users recorded
/stats - number of unique users (distinct id) on a page
/events - stream consumed events to the requester, it's a done through Server Side Event, it supports extra query params adding filters:
- eventType - event type name,
- distinctId - only events with a given distinctId,
- geo - return only coordinates guessed based on IP,
/debug - dummy html for SSE testing,
/debug/sse/ - backend for /debug generating a server side events,
/metrics - exposes metrics in Prometheus format

Installing

One needs a IP -> (lat,lng) database:

curl https://mmdbcdn.posthog.net/ | brotli -d > mmdb.db

Config the configs in configs/config.yml. You can take a peak at the examples in configs/configs.example.yml

Run it!

go run .