feat: grpc server with queue management rpcs

[vieiralucas]

Summary

• Implement fila-server binary with tonic gRPC server serving FilaAdmin service
• Add CreateQueue and DeleteQueue scheduler command variants with full queue lifecycle management
• CreateQueue RPC persists to storage, returns ALREADY_EXISTS on duplicate
• DeleteQueue RPC removes from storage, returns NOT_FOUND if missing
• Map FilaError variants to appropriate gRPC status codes (NOT_FOUND, ALREADY_EXISTS, INVALID_ARGUMENT, INTERNAL)
• Config file loading from fila.toml or /etc/fila/fila.toml with defaults
• Graceful shutdown on SIGINT/SIGTERM
• Remaining admin RPCs (SetConfig, GetConfig, GetStats, Redrive) stubbed as UNIMPLEMENTED

Test plan

• 4 new scheduler queue management tests (create, duplicate, delete, delete nonexistent)
• All 32 tests pass via cargo nextest run
• cargo clippy -- -D warnings passes
• cargo fmt --check passes

---

Summary by cubic

Adds a tonic gRPC server (fila-server) with CreateQueue and DeleteQueue RPCs for queue management. Validates queue config (including visibility_timeout_ms), routes commands through the scheduler, persists to storage, and shuts down cleanly on Ctrl+C or SIGTERM.

• New Features

  • FilaAdmin with CreateQueue/DeleteQueue; validates empty names, normalizes config (ignores empty scripts, defaults visibility_timeout_ms when unset, rejects <1000 ms), and maps ALREADY_EXISTS/NOT_FOUND/INVALID_ARGUMENT; broker backpressure/unavailability map to RESOURCE_EXHAUSTED/UNAVAILABLE.
  • SchedulerCommand variants with per-command errors; persist/remove queues via storage with oneshot replies; documented single-threaded check-then-put/delete safety for uniqueness and not-found behavior.
  • Server reads config from fila.toml or /etc/fila/fila.toml, uses FILA_DATA_DIR for RocksDB, initializes tracing, and listens on the configured address (default 0.0.0.0:5555); other admin RPCs stubbed as UNIMPLEMENTED.
  • Added unit tests for scheduler queue management and admin service visibility-timeout validation.

• Bug Fixes

  • Ensure CreateQueue sets config.name to the requested queue name.
  • Graceful shutdown signal handling (Ctrl+C, SIGTERM).

^{Written for commit 67eec3c. Summary will update on new commits.}

[cubic-dev-ai]

2 issues found across 8 files

Prompt for AI agents (all issues)

Check if these issues are valid — if so, understand the root cause of each and fix them.


<file name="crates/fila-server/src/main.rs">

<violation number="1" location="crates/fila-server/src/main.rs:72">
P2: shutdown_signal only listens for SIGINT (ctrl_c). SIGTERM won’t trigger graceful shutdown, so systemd/docker stops can hang. Add SIGTERM handling alongside ctrl_c.</violation>
</file>

<file name="crates/fila-core/src/broker/scheduler.rs">

<violation number="1" location="crates/fila-core/src/broker/scheduler.rs:142">
P2: Validate that `config.name` matches the requested queue name (or overwrite it) before persisting, otherwise mismatched configs can be stored under the wrong queue ID.</violation>
</file>

_{Reply with feedback, questions, or to request a fix. Tag @cubic-dev-ai to re-run a review.}