Onqueue is a lightweight, multithreaded task queue runner built in Rust. It features a socket-based client-server architecture for reliable task management, making it ideal for automating shell commands, deployment tasks, and lightweight job queues.

• ✅ Socket-based client-server architecture - Fast, reliable TCP communication
• ✅ Task queue management - Queue, execute, and monitor tasks with names and commands
• ✅ Full CLI client - Complete command-line interface for task management
• ✅ Multithreaded task runner - Concurrent task execution with configurable intervals
• ✅ Persistent queue state - Tasks saved to records.yml for reliability
• ✅ Task lifecycle management - Add, list, status, retry, delete, and run tasks
• ✅ Automatic retries - Built-in retry support for failed tasks
• ✅ Service installation - Easy setup as system service on Windows, Linux, and macOS
• ✅ Comprehensive testing - Full test suite with unit and integration tests
• ✅ Cross-platform - Supports Windows, Linux, and macOS

Onqueue uses a client-server architecture with TCP socket communication:

• Server (onqueued): Runs the task queue, executes tasks, and manages state
• Client (onqueue): CLI tool to interact with the server

The server listens on TCP sockets (default: 0.0.0.0:9876) and processes JSON-based commands from clients.

Windows:

# As Administrator
.\scripts\windows\install-service.ps1
Start-Service -Name OnqueueServer

Linux:

sudo ./scripts/linux/install-service.sh
sudo systemctl enable --now onqueued

macOS:

sudo ./scripts/macos/install-service.sh

See Installation Guide for detailed instructions.

1. Build from source:

   cargo build --release

2. Run the server:

   ./target/release/onqueued
   # Or on Windows: .\target\release\onqueued.exe

3. Use the client:

   ./target/release/onqueue list

# Using default config (0.0.0.0:9876)
./onqueued

# Or with cargo
cargo run --bin onqueued

The server will:

• Load configuration from config.yml (optional)
• Listen on the configured address (default: 0.0.0.0:9876)
• Process queued tasks at the configured interval (default: 10 seconds)
• Save queue state to records.yml

onqueue list

onqueue add --name "my-task" --cmd "echo hello world"

# Overall statistics
onqueue status

# Specific task status
onqueue status my-task

onqueue retry --name "my-task"

onqueue delete --name "my-task"

onqueue run --name "my-task"

onqueue --server 192.168.1.100:9876 list

# Start the server
./onqueued

# In another terminal, add a task
onqueue add --name "build" --cmd "cargo build --release"

# Check status
onqueue status build

# List all tasks
onqueue list

# Add multiple tasks
onqueue add --name "task1" --cmd "echo 'Task 1'"
onqueue add --name "task2" --cmd "echo 'Task 2'"
onqueue add --name "task3" --cmd "echo 'Task 3'"

# Check overall status
onqueue status
# Output: {"total": 3, "queued": 2, "running": 0, "completed": 1, "failed": 0}

# Retry a failed task
onqueue retry --name "task1"

# Delete a completed task
onqueue delete --name "task2"

Create config.yml:

host: "0.0.0.0"
port: 9876
task_interval: 10  # seconds between task checks
log_file: "logs/output.log"

onqueue/
├── src/
│   ├── server.rs          # Server binary (onqueued)
│   ├── client.rs          # Client binary (onqueue)
│   ├── server_types.rs    # Shared server types
│   └── client_types.rs    # Shared client types
├── scripts/
│   ├── windows/           # Windows service scripts
│   ├── linux/             # Linux systemd scripts
│   ├── macos/             # macOS launchd scripts
│   └── README.md          # Installation guide
├── tests/                 # Test suite
├── config.yml.example     # Configuration template
├── records.yml.example     # Queue records template
├── Cargo.toml
└── README.md

The server can be configured via config.yml:

Run the test suite:

# Run all unit tests
cargo test

# Run specific test suite
cargo test --test server_queue_tests
cargo test --test server_protocol_tests
cargo test --test client_tests

# Run integration tests (requires running server)
cargo test --test integration_tests -- --ignored

See Tests README for more details.

• USAGE.md - Complete usage guide
• Installation Guide - Service installation instructions
• Quick Start - Quick installation reference
• Feature TODO - Planned improvements

See FEATURE-TODO-LIST.md for upcoming improvements:

• Structured logging with tracing
• Web dashboard UI
• Docker support
• Task scheduling (cron-like)
• Authentication and security
• Task tagging and filtering

• Rust 1.70+ (stable)
• Cargo

# Build release binaries
cargo build --release

# Build specific binary
cargo build --release --bin onqueued
cargo build --release --bin onqueue

# Run server
cargo run --bin onqueued

# Run client
cargo run --bin onqueue -- list

# All tests
cargo test

# With output
cargo test -- --nocapture

Contributions are welcome! Please feel free to submit a Pull Request.

MIT © Mark Wayne Menorca

Built with:

• Tokio - Async runtime
• Serde - Serialization
• Clap - CLI parsing