aion-proto 0.6.1

Shared gRPC and serde wire contracts for Aion servers, clients, and workers.
Documentation 
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

# aion-proto

Shared gRPC and serde wire contracts for Aion servers, clients, and workers. This crate mirrors core domain values into transport-safe types, provides conversion helpers, and optionally exposes generated tonic service definitions behind the `generated` feature.

## Install

```toml
[dependencies]
aion-proto = "0.4.0"
```

## Key public types

- `ProtoWorkflowId`, `ProtoRunId`, `ProtoPayload`, and related wrappers encode core identifiers and payloads.
- `ProtoStartWorkflowRequest`, `ProtoSignalRequest`, and response types model workflow RPCs.
- `SubscriptionRequest` and `StreamedEvent` model event streaming.
- `ProtoActivityTask`, `ProtoActivityResult`, and `ProtoRegisterWorker` model worker protocol messages.
- `WireError`, `ProtoWireError`, and conversion functions report invalid wire values.

## Minimal usage

```rust
use aion_core::WorkflowId;
use aion_proto::{decode_core_value, encode_core_value};

let id = WorkflowId::new_v4();
let envelope = encode_core_value("default", Some("request-1".to_owned()), &id)?;
let decoded: WorkflowId = decode_core_value(&envelope)?;
assert_eq!(decoded, id);
# Ok::<(), Box<dyn std::error::Error>>(())
```