Crate aion_proto_generated

Expand description

Machine-generated tonic/prost gRPC stubs compiled from the Aion proto contract.

This crate exists solely to isolate the generated code from the hand-written aion-proto crate. Because the stubs are produced by tonic/prost and not maintained by hand, their relaxed lint posture is expressed in this crate’s Cargo.toml [lints] section instead of an in-source lint-suppression attribute. Consumers should depend on aion-proto with the generated feature, which re-exports this crate as aion_proto::generated.

Modules§

activity_result: Nested message and enum types in ActivityResult.
deploy_service_client: Generated client implementations.
deploy_service_server: Generated server implementations.
query_response: Nested message and enum types in QueryResponse.
server_to_worker: Nested message and enum types in ServerToWorker.
subscription_request: Nested message and enum types in SubscriptionRequest.
timer_id: Nested message and enum types in TimerId.
worker_protocol_client: Generated client implementations.
worker_protocol_server: Generated server implementations.
worker_to_server: Nested message and enum types in WorkerToServer.
workflow_service_client: Generated client implementations.
workflow_service_server: Generated server implementations.

Structs§

ActivityDescriptor: Initial worker advertisement. A registration scopes this stream and worker to a SET of (namespace) correctness boundaries, one task_queue pool/flavour lane within each, and an optional node locality; server-side partitioning and authorization are handled by the server worker endpoint.
ActivityError: Failure shape mirroring aion-core ActivityError without inferring retryability from the message string.
ActivityId: Sequence-position-backed activity identifier.
ActivityResult: Activity completion or failure reported by a worker.
ActivityTask: Activity invocation pushed by the server to a registered worker.
AutoWorker: One task queue’s auto-provision outcome.
CancelActivity: Server-initiated cancellation of ONE in-flight activity (#233).
CancelRequest
CancelResponse
CreateScheduleRequest
CreateScheduleResponse
DeleteScheduleResponse
DescribeScheduleResponse
DescribeWorkflowRequest
DescribeWorkflowResponse
DrainRequest: Server-initiated drain: this server is going away (restart, deploy, rebalance). The worker finishes already-assigned work, reports what it can, stops expecting new tasks, and reconnects — to this address after the schedule’s initial backoff. Receiving DrainRequest re-classifies this session’s eventual stream end (clean or abrupt) as a DRAIN drop: the reconnect consumes NO drop budget. Distinct from denial (gRPC error status, terminal) and from an unannounced close (budgeted retryable drop).
FilteredSubscription: Subscribe to events matching optional selectors. The namespace field is the caller’s namespace; namespace_selector narrows the selection and must be authorised by the server before any engine call.
FirehoseSubscription: Subscribe to every event visible in the caller’s namespace.
Heartbeat: Worker liveness for an in-flight activity. Progress is opaque and optional.
LeaseRecording: Leases recorded and attempts dispatched over a run’s WHOLE history.
ListManagedWorkersRequest
ListManagedWorkersResponse
ListSchedulesRequest
ListSchedulesResponse
ListVersionsRequest: Engine-global listing; no namespace (the catalog is namespace-blind).
ListVersionsResponse
ListWorkflowsRequest
ListWorkflowsResponse
LivenessAnswer: The worker runtime’s answer to a LivenessPing, echoing its sequence.
LivenessPing: Transport-level liveness ping, pushed by the server down the SAME stream a dispatch travels. It is answered by the worker SDK RUNTIME, never by action code: the fact it establishes is “the server can reach this worker’s dispatch path”, and only a frame that rides that exact path can establish it. An open stream sender is not an answering worker — the server can hold a perfectly healthy-looking channel to a wedged process indefinitely, which is the failure class this ping exists to detect.
LoadPackageRequest: A complete .aion archive, uploaded in one unary message. The server enforces the operator-configured \[deploy\].max_archive_bytes ceiling.
LoadPackageResponse: Outcome of a package load. Idempotency is specified behavior: re-sending the same archive succeeds with freshly_loaded = false, and route_changed reports whether the call re-pointed routing.
ManagedWorker: One managed worker: durable intent joined with live supervision state.
ManagedWorkerRequest: Every lifecycle mutation addresses one deployment by its primary key.
ManagedWorkerResponse
MintNamespaceRequest
MintNamespaceResponse: An empty ack: the mint is idempotent, so “created” and “already existed” are the same success to the caller.
PauseRequest: Pause holds new activity dispatch for a live Running run (#204).
PauseResponse: Pause returns the run id and its projected status (Paused).
PauseScheduleResponse
Payload: Opaque serialized payload with an explicit content-type tag.
PerWorkflowSubscription: Subscribe to events for a single workflow in the caller’s namespace.
QueryRequest
QueryResponse
ReadHistoryRequest
ReadHistoryResponse
ReadProvenance: The serving install’s own state at read time. A list page carries the same object INSIDE its serde-encoded page (WorkflowListPage.provenance).
RegisterAck: Positive registration acknowledgement. Always the first frame on the response stream. There is no negative counterpart: a denied or invalid registration fails the RPC with a gRPC error status exactly as before (PermissionDenied = ungranted namespace, Unauthenticated = rejected credentials, InvalidArgument = malformed first frame).
RegisterWorker
RenameRequest: Rename records a new operator-facing display name for a run (#211). The name is a label over the UUID identity, never an address; every rename is a RECORDED SearchAttributesUpdated event, so history keeps every name the run has worn.
RenameResponse: Rename returns the run id and the display name as recorded (trimmed).
ReopenRequest
ReopenResponse: Reopen returns the reopened run id and its projected status (Running) so the caller learns the run is live again — distinct from CancelResponse which is an empty ack.
ResultAck: Per-result acknowledgement: the server has consumed the identified ActivityResult frame and the worker may stop re-reporting it. Sent for every well-formed result frame, including duplicates the engine could no longer apply (their obligation is equally discharged). NOT a durability receipt — the durable truth is the workflow’s event history; an ack lost in transit merely costs one redundant re-report on the next session.
ResumeRequest: Resume releases the dispatch hold on a Paused run (#204).
ResumeResponse: Resume returns the run id and its projected status (Running).
ResumeScheduleResponse
RetireWorkloopRequest
RetireWorkloopResponse: Retirement answers with the reason it recorded, so a caller that supplied none learns what the loop’s history now says.
RouteVersionRequest: Atomic, idempotent route re-point (rollback / roll-forward).
RouteVersionResponse
RunId: UUID-backed concrete workflow run identifier.
ScheduleId: UUID-backed schedule resource identifier.
ScheduleIdRequest
ServerToWorker: Messages sent by the server to a worker over the bidirectional stream.
SignalRequest
SignalResponse
StartWorkflowRequest
StartWorkflowResponse
StreamedEvent: Streamed event frame. The event payload is a serde-encoded aion-core Event in the shared WireEnvelope, not a field-by-field wire clone.
SubscriptionRequest: Request to subscribe to workflow events. Every variant carries the caller’s namespace so the server can authorise and scope before mapping to an engine event filter.
TaskRefused: A worker declining ONE pushed task because it has no free execution slot.
TimerId: Timer identifier assigned either by workflow code or by the engine.
UnloadVersionRequest: Unload of a non-routed, unpinned version; refusals are typed (version_pinned) and name what pins the version.
UnloadVersionResponse
UpdateScheduleRequest
UpdateScheduleResponse
WireEnvelope: Thin envelope for serde-encoded aion-core values such as Event, WorkflowFilter, and WorkflowSummary. The payload is the core type’s own JSON representation; no field-by-field wire clone is introduced.
WireError: Wire-safe error value returned by server, client, and worker APIs.
WorkerInstanceIdentity: Stable identity of one worker process within an operator deployment.
WorkerToServer: Messages sent by a worker to the server over the bidirectional stream. RegisterWorker MUST be the first frame; the server answers it with RegisterAck as the first frame on the response stream before any other server-to-worker message.
WorkflowId: UUID-backed logical workflow identifier.
WorkflowVersion: One loaded version of one workflow type, mirroring the engine’s WorkflowVersionInfo listing record.

Enums§

ActivityErrorKind: Explicit retryability classification for an activity failure.
NamespaceMintOrigin: How a namespace came to be minted, carried so the owner records the same provenance the initiating node would have recorded.
WireErrorCode: Stable client-branchable wire error codes. Messages are informational only.
WorkflowStatus: Transport representation for aion-core WorkflowStatus.