module

Logarithm::Distributed

Distributed processing module for large-scale deployments.

This module provides basic infrastructure for distributing log processing across multiple nodes. It includes a simple master-worker architecture using TCP sockets for communication.

Features:

  • Master node coordinates workers
  • Worker nodes process logs in parallel
  • Basic load balancing
  • Fault tolerance (worker reconnection)

Example usage:

master = Distributed::Master.new(port: 9000)
master.start

worker = Distributed::Worker.new(master_host: "localhost", master_port: 9000)
worker.start

Nested types