smithyq 0.1.1

A high-performance async task worker library for Rust - forge your tasks with type safety
docs.rs failed to build smithyq-0.1.1
Please check the build logs for more information.
See Builds for ideas on how to fix a failed build, or Metadata for how to configure docs.rs builds.
If you believe this is docs.rs' fault, open an issue.
Visit the last successful build: smithyq-0.1.0

🔨 SmithyQ

Forge your tasks with type safety

SmithyQ is a high-performance async task worker library for Rust that brings the power of compile-time type safety to distributed task processing.

Crates.io Documentation License Build Status

🚀 Features

  • 🔒 Type-Safe: Compile-time verification of task payloads and return types
  • ⚡ High Performance: Built on Tokio for maximum async performance
  • 🎯 Auto-Registration: Automatic task registration with macros
  • 🔄 Multiple Backends: In-memory, Redis, and PostgreSQL queue support
  • 📊 Observability: Built-in metrics, tracing, and monitoring
  • 🛡️ Fault Tolerant: Graceful shutdown, retry logic, and error handling
  • 📅 Scheduling: Support for delayed and recurring tasks

📦 Installation

Add SmithyQ to your Cargo.toml:

[dependencies]
smithyq = "0.1"

# For Redis queue backend
smithyq = { version = "0.1", features = ["redis-queue"] }

# For PostgreSQL queue backend  
smithyq = { version = "0.1", features = ["postgres-queue"] }

# For all features
smithyq = { version = "0.1", features = ["full"] }


// ...existing code...

## 🛣️ Roadmap - Upcoming Features

### 📋 Queue Backends
- [ ] **Redis Queue**: Complete Redis backend implementation for distributed queue management
- [ ] **RabbitMQ Queue**: Support for RabbitMQ as backend for robust and scalable messaging
- [ ] **AWS SQS**: Integration with Amazon Simple Queue Service for cloud-native deployments

### 🔧 Middleware & Extensibility
- [ ] **Tower Integration**: Integration with Tower framework for composable middleware
  - Logging middleware
  - Rate limiting
  - Authentication/Authorization
  - Request/Response transformation
  - Circuit breaker pattern

### 🎯 Advanced Features
- [ ] **Dead Letter Queue**: Automatic handling of failed tasks
- [ ] **Task Prioritization**: Priority system for task execution
- [ ] **Batch Processing**: Process tasks in batches for improved efficiency
- [ ] **Health Checks**: Endpoints for worker status monitoring

### 📊 Monitoring & Observability
- [ ] **Prometheus Metrics**: Export metrics in Prometheus format
- [ ] **OpenTelemetry**: Full support for distributed tracing
- [ ] **Dashboard**: Web interface for real-time monitoring