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
use std::collections::HashMap;
use crate::errors::Result;
use crate::request::{get, put};
use crate::{Client, QueryMeta, QueryOptions, WriteMeta, WriteOptions};
#[derive(Clone, Default, Eq, PartialEq, Serialize, Deserialize, Debug)]
#[serde(default)]
#[allow(clippy::upper_case_acronyms)]
pub struct SessionID {
pub ID: String,
}
#[derive(Clone, Default, Eq, PartialEq, Serialize, Deserialize, Debug)]
#[serde(default)]
pub struct SessionEntry {
pub CreateIndex: Option<u64>,
pub ID: Option<String>,
pub Name: Option<String>,
pub Node: Option<String>,
pub LockDelay: Option<u64>,
pub Behavior: Option<String>,
pub Checks: Option<Vec<String>>,
pub TTL: Option<String>,
}
pub trait Session {
fn create(
&self,
session: &SessionEntry,
options: Option<&WriteOptions>,
) -> Result<(SessionEntry, WriteMeta)>;
fn destroy(&self, id: &str, options: Option<&WriteOptions>) -> Result<(bool, WriteMeta)>;
fn info(
&self,
id: &str,
options: Option<&QueryOptions>,
) -> Result<(Vec<SessionEntry>, QueryMeta)>;
fn list(&self, options: Option<&QueryOptions>) -> Result<(Vec<SessionEntry>, QueryMeta)>;
fn node(
&self,
node: &str,
options: Option<&QueryOptions>,
) -> Result<(Vec<SessionEntry>, QueryMeta)>;
fn renew(
&self,
id: &str,
options: Option<&WriteOptions>,
) -> Result<(Vec<SessionEntry>, WriteMeta)>;
}
impl Session for Client {
fn create(
&self,
session: &SessionEntry,
options: Option<&WriteOptions>,
) -> Result<(SessionEntry, WriteMeta)> {
put(
"/v1/session/create",
Some(session),
&self.config,
HashMap::new(),
options,
)
}
fn destroy(&self, id: &str, options: Option<&WriteOptions>) -> Result<(bool, WriteMeta)> {
let path = format!("/v1/session/destroy/{}", id);
put(
&path,
None as Option<&()>,
&self.config,
HashMap::new(),
options,
)
}
fn info(
&self,
id: &str,
options: Option<&QueryOptions>,
) -> Result<(Vec<SessionEntry>, QueryMeta)> {
let path = format!("/v1/session/info/{}", id);
get(&path, &self.config, HashMap::new(), options)
}
fn list(&self, options: Option<&QueryOptions>) -> Result<(Vec<SessionEntry>, QueryMeta)> {
get("/v1/session/list", &self.config, HashMap::new(), options)
}
fn node(
&self,
node: &str,
options: Option<&QueryOptions>,
) -> Result<(Vec<SessionEntry>, QueryMeta)> {
let path = format!("/v1/session/node/{}", node);
get(&path, &self.config, HashMap::new(), options)
}
fn renew(
&self,
id: &str,
options: Option<&WriteOptions>,
) -> Result<(Vec<SessionEntry>, WriteMeta)> {
let path = format!("/v1/session/renew/{}", id);
put(
&path,
None as Option<&()>,
&self.config,
HashMap::new(),
options,
)
}
}