Overview

A Go package designed to efficiently store real-time streaming websocket data in ClickHouse using queuing and bulk insert mechanisms. This project is optimized for high-throughput financial data ingestion.

Features

  • Real-time websocket data streaming
  • Efficient bulk insert operations
  • Queue-based data processing
  • ClickHouse optimization
  • High-performance data ingestion

Tech Stack

  • Language: Go
  • Database: ClickHouse
  • Protocol: WebSocket
  • Architecture: Queue-based processing

View on GitHub