ora 0.12.7

Part of the Ora scheduler framework.
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

//! Interface for querying executor information.

use std::time::SystemTime;

use eyre::{Context, OptionExt};
use tonic::Request;

use crate::{AdminClient, JobTypeId, executor::ExecutorId, proto::admin::v1::ListExecutorsRequest};

/// Information about a registered executor.
pub struct ExecutorInfo {
    /// The unique identifier of the executor.
    pub id: ExecutorId,
    /// The name of the executor.
    pub name: Option<String>,
    /// The time the executor was last seen.
    pub last_seen_at: SystemTime,
    /// Queues belonging to the executor.
    pub queues: Vec<ExecutorQueueInfo>,
}

/// A job queue belonging to an executor.
pub struct ExecutorQueueInfo {
    /// The job type ID of the queue.
    pub job_type_id: JobTypeId,
    /// The number of active executions.
    pub active_executions: u64,
    /// The maximum number of concurrent executions allowed.
    pub max_concurrent_executions: u64,
}

impl AdminClient {
    /// List connected executors.
    pub async fn list_executors(&self) -> crate::Result<Vec<ExecutorInfo>> {
        self.inner
            .list_executors(Request::new(ListExecutorsRequest {}))
            .await?
            .into_inner()
            .executors
            .into_iter()
            .map(|j| {
                Ok(ExecutorInfo {
                    id: ExecutorId(j.id.parse().wrap_err("invalid executor ID")?),
                    name: j.name,
                    last_seen_at: j
                        .last_seen_at
                        .map(TryInto::try_into)
                        .transpose()
                        .wrap_err("invalid last_seen_at")?
                        .ok_or_eyre("missing last_seen_at")?,
                    queues: j
                        .queues
                        .into_iter()
                        .map(|q| {
                            Ok(ExecutorQueueInfo {
                                job_type_id: JobTypeId::new(
                                    q.job_type.ok_or_eyre("missing job type")?.id,
                                )?,
                                active_executions: q.active_executions,
                                max_concurrent_executions: q.max_concurrent_executions,
                            })
                        })
                        .collect::<Result<Vec<_>, crate::Error>>()?,
                })
            })
            .collect::<Result<Vec<_>, crate::Error>>()
    }
}