We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 4bad5b4 commit e44dd5bCopy full SHA for e44dd5b
2 files changed
trino-lb-core/src/trino_api/stats.rs
@@ -1,7 +1,7 @@
1
use serde::{Deserialize, Serialize};
2
3
/// Copied from [`prusto::Stat`], but with `root_stage`
4
-#[derive(Deserialize, Debug, Serialize)]
+#[derive(Clone, Debug, Deserialize, Serialize)]
5
#[serde(rename_all = "camelCase")]
6
pub struct Stat {
7
pub completed_splits: u32,
trino-lb-core/src/trino_api/trino_events.rs
@@ -1,11 +1,11 @@
use std::fmt::Display;
-use serde::Deserialize;
+use serde::{Deserialize, Serialize};
use url::Url;
use crate::TrinoQueryId;
8
-#[derive(Clone, Debug, PartialEq, Eq, Deserialize)]
+#[derive(Clone, Debug, PartialEq, Eq, Deserialize, Serialize)]
9
10
pub struct TrinoEvent {
11
pub metadata: TrinoEventMetadata,
@@ -21,15 +21,15 @@ impl TrinoEvent {
21
}
22
23
24
25
26
pub struct TrinoEventMetadata {
27
pub uri: Url,
28
pub query_id: TrinoQueryId,
29
pub query_state: TrinoQueryState,
30
31
32
33
#[serde(rename_all = "SCREAMING_SNAKE_CASE")]
34
pub enum TrinoQueryState {
35
Queued,
0 commit comments