Struct DistributedEncoder 

pub struct DistributedEncoder { /* private fields */ }

Main distributed encoder interface.

Maintains an in-process job store so that submit_job, job_status, and cancel_job operate on real state. In a production deployment the store would be backed by the gRPC coordinator; this implementation provides a fully functional local fallback that exercises the complete lifecycle.

Implementations

impl DistributedEncoder

pub fn new(config: DistributedConfig) -> Self

Create a new distributed encoder with the given configuration

pub fn with_defaults() -> Self

Create a new distributed encoder with default configuration

pub fn config(&self) -> &DistributedConfig

Get the current configuration

pub async fn job_count(&self) -> usize

Return the number of currently tracked jobs.

pub async fn active_job_count(&self) -> usize

Return the number of active (non-terminal) jobs.

pub async fn submit_job(&self, job: DistributedJob) -> Result<Uuid>

Submit a job for distributed encoding.

Validates the job, checks concurrency limits, registers it in the internal store, and returns the job ID on success.

Arguments

• job - The encoding job to submit

Returns

Returns the job ID on success

Errors

Returns DistributedError::InvalidConfig if the job definition is invalid, or DistributedError::ResourceExhausted if the maximum concurrent job limit has been reached.

pub async fn job_status(&self, job_id: Uuid) -> Result<JobStatus>

Query the status of a previously submitted job.

In addition to returning the stored status, this method performs timeout checking: if a job has been active longer than the configured job_timeout it is automatically marked as Failed.

Errors

Returns DistributedError::Job if the job ID is not found.

pub async fn cancel_job(&self, job_id: Uuid) -> Result<()>

Cancel a previously submitted job.

Only jobs that are not yet in a terminal state (Completed, Failed, Cancelled) can be cancelled.

Errors

Returns DistributedError::Job if the job ID is not found or the job is already in a terminal state.

pub async fn advance_job(&self, job_id: Uuid) -> Result<JobStatus>

Advance a job to the next logical status (for internal/testing use).

Transitions: Pending -> Assigned -> InProgress -> Completed

Errors

Returns error if the job is not found or is in a terminal state.

pub async fn fail_job(&self, job_id: Uuid) -> Result<()>

Mark a job as failed (for internal/testing use).

Errors

Returns error if the job is not found or already in a terminal state.

pub async fn job_retries(&self, job_id: Uuid) -> Result<u32>

Get the retry count for a job.

Errors

Returns error if the job is not found.

pub async fn list_jobs(&self) -> Vec<(Uuid, JobStatus)>

List all job IDs with their current statuses.