hatchet-sdk 0.2.8

This is an unofficial Rust SDK for Hatchet, a distributed, fault-tolerant task queue.
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

use std::collections::HashMap;

use crate::clients::rest::models::V1TaskEventList200ResponsePagination;

/// Converts an auto-generated `Option<HashMap<String, Value>>` to a flat `Value::Object`,
/// defaulting to `{}`. Used by feature client `From` impls.
pub(super) fn hash_map_to_value(
    value: Option<HashMap<String, serde_json::Value>>,
) -> serde_json::Value {
    value
        .and_then(|map| serde_json::to_value(map).ok())
        .unwrap_or_else(|| serde_json::json!({}))
}

/// Pagination metadata returned by list endpoints.
#[derive(Clone, Debug)]
pub struct PaginationResponse {
    pub current_page: Option<i64>,
    pub num_pages: Option<i64>,
    pub next_page: Option<i64>,
}

impl From<Box<V1TaskEventList200ResponsePagination>> for PaginationResponse {
    fn from(response: Box<V1TaskEventList200ResponsePagination>) -> Self {
        Self {
            current_page: response.current_page,
            num_pages: response.num_pages,
            next_page: response.next_page,
        }
    }
}