Over the past weekend, I decided to come out of a rut and do some recreational programming. For this time, I decided to dig deeper into Go and build a distributed log ingestion system.

In just 2-3 days, I was able to build the following:

  • Built ingest nodes that accepts logs from producer applications
  • Used FNV-1a hashing for deterministic partition routing to distribute logs across multiple storage nodes by service name
  • Implemented append-only log-structured storage with JSON line format
  • Created HTTP APIs for batch log ingestion with automatic metadata enrichment (timestamps, client IP, node ID)
  • Implemented fan-out Fan-in writes to storage nodes via goroutines, which reduced latency from sequential (O(N)) to concurrent execution (bounded by the slowest node).
  • Added …

Similar Posts

Loading similar posts...

Keyboard Shortcuts

Navigation
Next / previous item
j/k
Open post
oorEnter
Preview post
v
Post Actions
Love post
a
Like post
l
Dislike post
d
Undo reaction
u
Recommendations
Add interest / feed
Enter
Not interested
x
Go to
Home
gh
Interests
gi
Feeds
gf
Likes
gl
History
gy
Changelog
gc
Settings
gs
Browse
gb
Search
/
General
Show this help
?
Submit feedback
!
Close modal / unfocus
Esc

Press ? anytime to show this help