tasker-shared 0.1.1

Shared components for tasker orchestration and worker systems
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86

# tasker-shared

Shared foundation library for the [Tasker](https://github.com/tasker-systems/tasker-core) workflow orchestration system. Provides the core types, models, state machines, configuration, database operations, messaging abstractions, and infrastructure used by all other Tasker crates.

## Overview

`tasker-shared` is the foundational crate in the Tasker workspace. It contains everything that the orchestration server, workers, and client need to share: data models, state machine logic, configuration loading, database access, messaging protocols, and resilience patterns.

## Key Modules

| Module | Description |
|--------|-------------|
| `models` | Complete data model layer — tasks, steps, templates, namespaces, transitions, audit trails |
| `state_machine` | Dual state machines: 12 task states and 8 step states with guard-based transitions |
| `config` | TOML-based configuration with base/environment layering and runtime merge |
| `database` | Connection pooling, SQL function execution, migrations via SQLx |
| `messaging` | Provider-agnostic messaging — PGMQ (default) and RabbitMQ backends |
| `events` | Domain event system with typed publishers and subscriber registry |
| `resilience` | Circuit breaker patterns with configurable thresholds and recovery |
| `cache` | Multi-backend caching — Redis, Moka (in-process), Memcached, or noop |
| `metrics` | OpenTelemetry metrics for database, messaging, orchestration, and security |
| `web` | Shared web middleware — authentication, authorization, API key and JWT support |
| `proto` | gRPC/Protobuf type conversions (requires `grpc-api` feature) |
| `registry` | Step handler resolution with pluggable resolver chains |
| `scopes` | Database query scopes mirroring Rails-style named scopes |

## Features

| Feature | Description | Default |
|---------|-------------|---------|
| `web-api` | Axum web framework, JWT/API-key auth, OpenAPI docs | Yes |
| `grpc-api` | Tonic gRPC framework and Protobuf types | Yes |
| `cache-redis` | Redis caching backend | Yes |
| `cache-moka` | Moka in-process caching backend | Yes |
| `cache-memcached` | Memcached caching backend | No |
| `postgres` | PostgreSQL via SQLx | Yes |
| `test-utils` | Test factories and helpers | Yes |
| `tokio-console` | Runtime introspection via tokio-console | No |

## Usage

```rust,no_run
use tasker_shared::config::{ConfigLoader, tasker::TaskerConfig};

// Load configuration from TOML files based on TASKER_ENV
let config = ConfigLoader::load_from_env().expect("Failed to load config");

// Access configuration sections
assert!(config.common.database.pool.max_connections > 0);
```

State machine transitions:

```rust,ignore
use tasker_shared::state_machine::{TaskStateMachine, TaskState, TaskEvent};

// Task lifecycle: Pending → Initializing → EnqueuingSteps → StepsInProcess → Complete
let machine = TaskStateMachine::new();
let next = machine.transition(TaskState::Pending, TaskEvent::Initialize)?;
```

## Configuration

Configuration uses a layered TOML structure:

```
config/tasker/
├── base/                    # Defaults for all environments
│   ├── common.toml          # Shared: database, cache, circuit breakers
│   ├── orchestration.toml   # Orchestration-specific settings
│   └── worker.toml          # Worker-specific settings
└── environments/
    ├── development/         # Dev overrides
    ├── test/                # Test overrides
    └── production/          # Production overrides
```

Set `TASKER_ENV` to select the environment (defaults to `development`).

## License

MIT License — see [LICENSE](LICENSE) for details.

## Contributing

See the [Tasker Core contributing guide](https://github.com/tasker-systems/tasker-core) and [Code of Conduct](CODE_OF_CONDUCT.md).