alien-core 1.4.0

Deploy software into your customers' cloud accounts and keep it fully managed
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
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100

use super::BindingValue;
use serde::{Deserialize, Serialize};

/// Binding parameters for Queue at runtime or in templates.
#[derive(Debug, Clone, PartialEq, Eq, Serialize, Deserialize)]
#[cfg_attr(feature = "openapi", derive(utoipa::ToSchema))]
#[cfg_attr(feature = "jsonschema", derive(schemars::JsonSchema))]
#[serde(tag = "service", rename_all = "lowercase")]
pub enum QueueBinding {
    /// AWS SQS binding
    #[serde(rename_all = "camelCase")]
    Sqs(SqsQueueBinding),
    /// GCP Pub/Sub binding
    #[serde(rename_all = "camelCase")]
    Pubsub(PubSubQueueBinding),
    /// Azure Service Bus binding
    #[serde(rename_all = "camelCase")]
    Servicebus(ServiceBusQueueBinding),
    /// Local development queue binding
    #[serde(rename = "local-queue", rename_all = "camelCase")]
    Local(LocalQueueBinding),
}

impl QueueBinding {
    pub fn sqs(queue_url: impl Into<BindingValue<String>>) -> Self {
        Self::Sqs(SqsQueueBinding {
            queue_url: queue_url.into(),
        })
    }

    pub fn pubsub(
        topic: impl Into<BindingValue<String>>,
        subscription: impl Into<BindingValue<String>>,
    ) -> Self {
        Self::Pubsub(PubSubQueueBinding {
            topic: topic.into(),
            subscription: subscription.into(),
        })
    }

    pub fn service_bus(
        namespace: impl Into<BindingValue<String>>,
        queue_name: impl Into<BindingValue<String>>,
    ) -> Self {
        Self::Servicebus(ServiceBusQueueBinding {
            namespace: namespace.into(),
            queue_name: queue_name.into(),
        })
    }

    pub fn local(queue_path: impl Into<BindingValue<String>>) -> Self {
        Self::Local(LocalQueueBinding {
            queue_path: queue_path.into(),
        })
    }
}

/// AWS SQS queue parameters
#[derive(Debug, Clone, PartialEq, Eq, Serialize, Deserialize)]
#[cfg_attr(feature = "openapi", derive(utoipa::ToSchema))]
#[cfg_attr(feature = "jsonschema", derive(schemars::JsonSchema))]
#[serde(rename_all = "camelCase")]
pub struct SqsQueueBinding {
    /// Full SQS queue URL
    pub queue_url: BindingValue<String>,
}

/// GCP Pub/Sub parameters
#[derive(Debug, Clone, PartialEq, Eq, Serialize, Deserialize)]
#[cfg_attr(feature = "openapi", derive(utoipa::ToSchema))]
#[cfg_attr(feature = "jsonschema", derive(schemars::JsonSchema))]
#[serde(rename_all = "camelCase")]
pub struct PubSubQueueBinding {
    /// Full topic name: projects/{project}/topics/{topic}
    pub topic: BindingValue<String>,
    /// Full subscription name: projects/{project}/subscriptions/{subscription}
    pub subscription: BindingValue<String>,
}

/// Azure Service Bus parameters
#[derive(Debug, Clone, PartialEq, Eq, Serialize, Deserialize)]
#[cfg_attr(feature = "openapi", derive(utoipa::ToSchema))]
#[cfg_attr(feature = "jsonschema", derive(schemars::JsonSchema))]
#[serde(rename_all = "camelCase")]
pub struct ServiceBusQueueBinding {
    /// Namespace name
    pub namespace: BindingValue<String>,
    /// Queue name
    pub queue_name: BindingValue<String>,
}

/// Local queue parameters
#[derive(Debug, Clone, PartialEq, Eq, Serialize, Deserialize)]
#[cfg_attr(feature = "openapi", derive(utoipa::ToSchema))]
#[cfg_attr(feature = "jsonschema", derive(schemars::JsonSchema))]
#[serde(rename_all = "camelCase")]
pub struct LocalQueueBinding {
    /// Path to the sled database directory for the queue
    pub queue_path: BindingValue<String>,
}