Struct ScheduleRequest

pub struct ScheduleRequest {
    pub cluster: ClusterName,
    pub backend_id: Option<BackendId>,
    pub max_idle_secs: Duration,
    pub metadata: HashMap<String, String>,
    pub executable: DockerExecutableConfig,
}

Fields

cluster: ClusterName

backend_id: Option<BackendId>

The name of the backend. This forms part of the hostname used to connect to the drone.

max_idle_secs: Duration

The timeout after which the drone is shut down if no connections are made.

metadata: HashMap<String, String>

Metadata for the spawn. Typically added to log messages for debugging and observability.

executable: DockerExecutableConfig

Configuration for docker run (image, creds, env vars etc.)

Implementations

impl ScheduleRequest

pub fn schedule(&self, drone_id: &DroneId) -> SpawnRequest

impl ScheduleRequest

pub fn subscribe_subject() -> SubscribeSubject<Self>

Trait Implementations

impl Clone for ScheduleRequest

fn clone(&self) -> ScheduleRequest

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for ScheduleRequest

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for ScheduleRequest

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for ScheduleRequest

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl TypedMessage for ScheduleRequest

type Response = ScheduleResponse

fn subject(&self) -> String

Returns the subject associated with this message. Subjects must be deterministically generated from the message body.