taskvisor 0.9.0

In-process Tokio task supervisor: one job per key with queue/replace/reject admission, retries, graceful shutdown, and reliable final outcomes
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

//! Converts public task selectors into one management-operation target.

use std::sync::Arc;

use crate::TaskId;

/// Task selected by controller-aware identity or registered name.
///
/// Identity operations can address controller work that has not reached the registry yet.
/// Name operations resolve only current registry membership because queued controller work does not own a registered name.
#[derive(Clone, Debug, PartialEq, Eq, Hash)]
#[non_exhaustive]
pub enum TaskTarget {
    /// One task or controller submission by its process-local identity.
    Id(TaskId),
    /// Current registered owner of a task name.
    Name(Arc<str>),
}

impl From<TaskId> for TaskTarget {
    fn from(id: TaskId) -> Self {
        Self::Id(id)
    }
}

impl From<Arc<str>> for TaskTarget {
    fn from(name: Arc<str>) -> Self {
        Self::Name(name)
    }
}

impl From<&Arc<str>> for TaskTarget {
    fn from(name: &Arc<str>) -> Self {
        Self::Name(Arc::clone(name))
    }
}

impl From<Box<str>> for TaskTarget {
    fn from(name: Box<str>) -> Self {
        Self::Name(Arc::from(name))
    }
}

impl From<String> for TaskTarget {
    fn from(name: String) -> Self {
        Self::Name(Arc::from(name))
    }
}

impl From<&String> for TaskTarget {
    fn from(name: &String) -> Self {
        Self::Name(Arc::from(name.as_str()))
    }
}

impl From<&str> for TaskTarget {
    fn from(name: &str) -> Self {
        Self::Name(Arc::from(name))
    }
}