aion-proto 0.10.0

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
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

//! Shared gRPC and serde wire contracts for Aion servers, clients, and workers.
//!
//! This crate mirrors core domain values into transport-safe protobuf and JSON
//! shapes, provides conversion helpers, and optionally exposes generated tonic
//! service definitions behind the `generated` feature.
//!
//! # Example
//!
//! ```
//! 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>>(())
//! ```

/// Conversion helpers between wire structures and `aion-core` values.
pub mod convert;
/// Operator deploy API wire contracts.
pub mod deploy;
/// Wire-level error types and protobuf-friendly error payloads.
pub mod error;
/// Event-stream subscription and streamed-event contracts.
pub mod events;
/// Schedule management wire contracts.
pub mod schedule;
/// Remote-worker protocol wire contracts.
pub mod worker;
/// Workflow operation wire contracts.
pub mod workflow;

#[cfg(feature = "generated")]
/// Generated tonic service definitions, re-exported from the isolated
/// `aion-proto-generated` crate (kept separate so its relaxed lint posture
/// does not affect hand-written code here).
pub use aion_proto_generated as generated;

pub use convert::{
    ProtoActivityId, ProtoPayload, ProtoRunId, ProtoScheduleId, ProtoTimerId, ProtoWorkflowId,
    ProtoWorkflowStatus, WireEnvelope, decode_core_value, decode_event, decode_schedule_config,
    decode_schedule_state, decode_workflow_filter, decode_workflow_summary, encode_core_value,
    encode_event, encode_schedule_config, encode_schedule_state, encode_workflow_filter,
    encode_workflow_summary,
};
pub use deploy::{
    ProtoListVersionsRequest, ProtoListVersionsResponse, ProtoLoadPackageRequest,
    ProtoLoadPackageResponse, ProtoRouteVersionRequest, ProtoRouteVersionResponse,
    ProtoUnloadVersionRequest, ProtoUnloadVersionResponse, ProtoWorkflowVersion,
};
pub use error::{ProtoWireError, ProtoWireErrorCode, WireError, WireErrorCode};
pub use events::{
    ClusterSubscription, FilteredSubscription, FirehoseSubscription, PerWorkflowSubscription,
    StreamedActivityEvent, StreamedClusterEvent, StreamedClusterSnapshot, StreamedEvent,
    SubscriptionRequest, TranscriptSubscription, encode_streamed_event, subscription_request,
};
pub use schedule::{
    ProtoCreateScheduleRequest, ProtoCreateScheduleResponse, ProtoDeleteScheduleResponse,
    ProtoDescribeScheduleResponse, ProtoListSchedulesRequest, ProtoListSchedulesResponse,
    ProtoPauseScheduleResponse, ProtoResumeScheduleResponse, ProtoScheduleIdRequest,
    ProtoUpdateScheduleRequest, ProtoUpdateScheduleResponse,
};
pub use worker::{
    ProtoActivityError, ProtoActivityErrorKind, ProtoActivityResult, ProtoActivityTask,
    ProtoDrainRequest, ProtoHeartbeat, ProtoRegisterAck, ProtoRegisterWorker, ProtoResultAck,
    proto_activity_result,
};
pub use workflow::{
    ProtoCancelRequest, ProtoCancelResponse, ProtoCountWorkflowsRequest,
    ProtoCountWorkflowsResponse, ProtoDescribeWorkflowRequest, ProtoDescribeWorkflowResponse,
    ProtoListWorkflowsRequest, ProtoListWorkflowsResponse, ProtoPauseRequest, ProtoPauseResponse,
    ProtoQueryRequest, ProtoQueryResponse, ProtoReopenRequest, ProtoReopenResponse,
    ProtoResumeRequest, ProtoResumeResponse, ProtoSignalRequest, ProtoSignalResponse,
    ProtoStartWorkflowRequest, ProtoStartWorkflowResponse, proto_query_response,
};