brokerapi 0.1.0

V2.16 Open Service Broker API-compliant brokers in Rust
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
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154

use std::collections::HashMap;

use actix_web::{web, HttpResponse, Responder};
use serde::{Deserialize, Serialize};
use serde_json::json;

#[allow(unused)]
pub enum BindingType {
    Credentials,
    LogDrain,
    RouteServices,
    VolumeServices,
}

/// <https://github.com/openservicebrokerapi/servicebroker/blob/v2.16/spec.md#parameters-5>
#[derive(Deserialize, Debug)]
#[allow(unused)]
pub struct ProvisionParams {
    pub accepts_incomplete: Option<bool>,
}

/// <https://github.com/openservicebrokerapi/servicebroker/blob/v2.16/spec.md#body-8>
#[derive(Deserialize, Debug)]
#[allow(unused)]
pub struct BindingRequestBody {
    pub service_id: String,
    pub plan_id: String,
    pub context: Option<HashMap<String, String>>,
    pub bind_resource: Option<BindResource>,
    pub parameters: Option<HashMap<String, String>>,
}

/// <https://github.com/openservicebrokerapi/servicebroker/blob/v2.16/spec.md#bind-resource-object>
#[derive(Deserialize, Debug)]
#[allow(unused)]
pub struct BindResource {
    pub app_guid: Option<String>,
    pub route: Option<String>,
}

/// <https://github.com/openservicebrokerapi/servicebroker/blob/v2.16/spec.md#body-9>
#[derive(Serialize, Default, Debug)]
#[allow(unused)]
pub struct Binding {
    #[serde(skip_serializing_if = "Option::is_none")]
    pub metadata: Option<BindingMetadata>,
    #[serde(skip_serializing_if = "Option::is_none")]
    pub credentials: Option<HashMap<String, String>>,
    #[serde(skip_serializing_if = "Option::is_none")]
    pub syslog_drain_url: Option<String>,
    #[serde(skip_serializing_if = "Option::is_none")]
    pub route_service_url: Option<String>,
    #[serde(skip_serializing_if = "Option::is_none")]
    pub volume_mounts: Option<VolumeMount>,
    #[serde(skip_serializing_if = "Option::is_none")]
    pub endpoints: Option<Vec<Endpoint>>,
}

#[derive(Serialize, Default, Debug)]
#[allow(unused)]
pub struct BindingMetadata {
    pub expires_at: String,
}

#[derive(Serialize, Debug)]
#[allow(unused)]
pub struct VolumeMount {
    pub driver: String,
    pub container_dir: String,
    pub mode: VolumeMode,
    pub device_type: DeviceType,
    pub device: Device,
}

#[derive(Serialize, Debug)]
#[serde(rename_all = "lowercase")]
#[allow(unused)]
pub enum VolumeMode {
    R,
    RW,
}

#[derive(Serialize, Debug)]
#[serde(rename_all = "snake_case")]
#[allow(unused)]
pub enum DeviceType {
    Shared,
}

#[derive(Serialize, Default, Debug)]
#[allow(unused)]
pub struct Device {
    pub volume_id: String,
    pub mount_config: Option<HashMap<String, String>>,
}

#[derive(Serialize, Default, Debug)]
#[allow(unused)]
pub struct Endpoint {
    pub host: String,
    pub ports: Vec<String>,
    pub protocol: Option<Protocol>,
}

#[derive(Serialize, Debug)]
#[serde(rename_all = "lowercase")]
#[allow(unused)]
pub enum Protocol {
    TCP,
    UDP,
    All,
}

impl Default for Protocol {
    fn default() -> Self {
        Protocol::TCP
    }
}

pub async fn put_binding(
    web::Path((_instance_id, _binding_id)): web::Path<(String, String)>,
    web::Query(params): web::Query<ProvisionParams>,
    web::Json(body): web::Json<BindingRequestBody>,
) -> impl Responder {
    log::info!("params {:?}, body:\n{:#?}", params, body);

    HttpResponse::Created().json(Binding::default())
}

/// <https://github.com/openservicebrokerapi/servicebroker/blob/v2.16/spec.md#parameters-6>
#[derive(Deserialize, Debug)]
#[allow(unused)]
pub struct BindingFetchParams {
    pub service: Option<String>,
    pub plan_id: Option<String>,
}

pub async fn get_binding(
    web::Path((_instance_id, _binding_id)): web::Path<(String, String)>,
    web::Query(params): web::Query<BindingFetchParams>,
) -> impl Responder {
    log::info!("params {:?}", params);

    HttpResponse::Ok().json(Binding::default())
}

pub async fn delete_binding(
    web::Path((_instance_id, _binding_id)): web::Path<(String, String)>,
    web::Query(params): web::Query<BindingFetchParams>,
) -> impl Responder {
    log::info!("params {:?}", params);

    HttpResponse::Ok().json(json!({}))
}