Module wire 

Generated protobuf types for the current Task API.

This module includes messages, enums, crate::grpc::wire::TaskServiceClient, and crate::grpc::wire::TaskServiceServer.

Example

use solti_api::grpc::wire::TaskServiceClient;

async fn connect() -> Result<(), solti_api::tonic::transport::Error> {
    let client = TaskServiceClient::connect("http://127.0.0.1:50052").await?;
    let _ = client;
    Ok(())
}

Modules

stream_task_logs_response

Nested message and enum types in StreamTaskLogsResponse.

subprocess_mode

Nested message and enum types in SubprocessMode.

task_service_client

Generated client implementations.

task_service_server

Generated server implementations.

task_workload

Nested message and enum types in TaskWorkload.

Structs

ApplyTaskRequest

ApplyTask desired-state input.

ApplyTaskResponse

ApplyTask output.

BackoffPolicy

Exponential backoff between restart attempts.

CommandMode

Run a command directly (resolved via PATH).

ContainerCommand

Explicit OCI container entrypoint override.

ContainerTask

Run an OCI container.

CreateTaskRequest

CreateTask desired-state input.

CreateTaskResponse

CreateTask output.

DeleteTaskRequest

DeleteTask input.

DeleteTaskResponse

DeleteTask output. Empty on success.

ExtensionTask

Application-provided workload configuration.

GetTaskRequest

GetTask input.

GetTaskResponse

GetTask output.

KeyValue

One environment variable.

LabelSelector

Kubernetes-style selector for any labeled object.

Lagged

The subscriber fell behind and the server dropped events.

ListTaskRunsRequest

ListTaskRuns input.

ListTaskRunsResponse

ListTaskRuns output.

ListTasksRequest

ListTasks input. Filters are ANDed; omitted filters match all. A non-empty continue token resumes the previous snapshot. Filters must be repeated unchanged.

ListTasksResponse

ListTasks output.

ObjectMeta

Identity, versioning and timestamps of a stored object.

OutputChunk

One captured line of process output.

RawExtension

Workload implemented by an application-provided runner. Mirrors Kubernetes RawExtension: raw is one UTF-8 JSON value.

RunFinished

The current attempt ended. Stop accumulating its chunks.

RunStarted

A new attempt started.

ScriptMode

Run a script through an interpreter.

SelectorRequirement

One set-based selector requirement.

StatusCause

One readable cause attached to an API error.

StreamTaskLogsRequest

StreamTaskLogs input.

StreamTaskLogsResponse

One StreamTaskLogs event: exactly one field is set.

SubprocessMode

Typed subprocess execution strategy.

SubprocessTask

Run an external OS process.

Task

Full Kubernetes-shaped Task resource.

TaskCondition

One observed condition for a Task resource.

TaskManifest

Desired Task resource. Server-owned identity and status are deliberately absent.

TaskManifestMeta

User-owned metadata accepted on create and apply.

TaskRunInfo

History record for one finished or running attempt.

TaskServiceClient

Task management API exposed by the agent.

TaskServiceServer

Task management API exposed by the agent.

TaskSpec

Desired state of a Task resource.

TaskStatus

Observed controller and execution status of a Task.

TaskWorkload

Versioned desired workload handled by a registered runner. Embedded workloads intentionally have no public representation.

WasmTask

Run a WebAssembly module.

WatchTasksRequest

WatchTasks input. Filters are ANDed; omitted filters match all.

WatchTasksResponse

One Task collection change.

WriteConflictDetails

Structured details carried by an Aborted gRPC status for a write conflict.

WritePreconditions

Optional identity and version checks for apply and delete.

Enums

AdmissionPolicy

What to do when the target slot is already busy.

ConditionStatus

Kubernetes-compatible three-valued condition status.

JitterPolicy

Randomness added to each backoff delay to avoid retry storms. “base” is the delay computed by BackoffPolicy before jitter.

OutputStreamKind

Source stream of a captured output line.

RestartPolicy

When to restart a task after an attempt ends.

SelectorOperator

Comparison operator for one selector requirement.

TaskPhase

Phase of a task’s current attempt.

TaskWatchEventType

Task collection watch event type.