Extra library of actors for the Ergo Framework 3.0 (and above)

leader

Distributed leader election actor implementing Raft-inspired consensus algorithm. Provides coordination primitives for building systems that require single leader selection across a cluster - task schedulers, resource managers, single-writer databases, distributed locks.

Features:

• Raft-style leader election with term-based disambiguation
• Automatic failover on leader failure
• Network partition safety (split-brain prevention through majority quorum)
• Dynamic peer discovery
• No external dependencies

See documentation for details.

health

Kubernetes health probe actor that serves /health/live, /health/ready, and /health/startup endpoints. Actors register named signals with probe type and optional heartbeat timeout. When a signal goes down (missed heartbeat, process termination, or explicit notification), the corresponding probe endpoint returns 503.

Features:

• Kubernetes liveness, readiness, and startup probe endpoints
• Signal registration with bitmask probe selection and heartbeat timeout
• Automatic failure detection on heartbeat timeout or process termination
• Thread-safe HTTP responses via atomic operations
• External mux support for sharing a port with other HTTP handlers
• Package-level helper functions for convenient signal management

See documentation for details.

metrics

Prometheus metrics exporter actor that automatically collects and exposes Ergo node and network telemetry via HTTP endpoint. Provides observability for monitoring cluster health, resource usage, and inter-node communication patterns.

Features:

• Automatic collection of node metrics (uptime, processes, memory, CPU)
• Network metrics per remote node (messages, bytes transferred, connection uptime)
• HTTP endpoint exposing metrics in Prometheus format
• Extensible - embed metrics.Actor to add custom application metrics
• Configurable collection interval
• External mux support for sharing a port with other HTTP handlers
• Observer UI integration for real-time inspection

See documentation for details.