esdiag 0.16.4

Elastic Stack diagnostic collector and processor
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

// Copyright Elasticsearch B.V. and/or licensed to Elasticsearch B.V. under one
// or more contributor license agreements. Licensed under the Elastic License 2.0;
// you may not use this file except in compliance with the Elastic License 2.0.

use super::super::DataSource;
use serde::{Deserialize, Serialize};
use serde_json::value::RawValue;
use serde_with::skip_serializing_none;
use std::collections::{HashMap, HashSet};

#[skip_serializing_none]
#[derive(Clone, Deserialize, Serialize)]
pub struct Node {
    aggregations: Option<Box<RawValue>>,
    pub attributes: Option<Box<RawValue>>,
    build_flavor: String,
    build_hash: String,
    build_type: String,
    component_version: Option<ComponentVersion>,
    pub host: Option<String>,
    http: Option<Box<RawValue>>,
    index_version: Option<i64>,
    //ingest: Box<RawValue>,
    pub ip: Option<String>,
    jvm: Box<RawValue>,
    //modules: Box<RawValue>,
    pub name: String,
    pub os: OsDetails,
    plugins: Option<Box<RawValue>>,
    process: Box<RawValue>,
    pub role: Option<String>,
    pub roles: HashSet<String>,
    settings: Option<Box<RawValue>>,
    thread_pool: Box<RawValue>,
    total_indexing_buffer: Option<Box<RawValue>>,
    total_indexing_buffer_in_bytes: Option<Box<RawValue>>,
    transport: Option<Box<RawValue>>,
    transport_address: Option<String>,
    transport_version: Option<i64>,
    pub version: Option<String>,
}

#[derive(Clone, Deserialize, Serialize)]
struct ComponentVersion {
    ml_config_version: i64,
    transform_config_version: i64,
}

#[skip_serializing_none]
#[derive(Clone, Deserialize, Serialize)]
pub struct OsDetails {
    pub refresh_interval_in_millis: usize,
    pub name: Option<String>,
    pub pretty_name: Option<String>,
    pub arch: Option<String>,
    pub version: Option<String>,
    pub available_processors: usize,
    pub allocated_processors: usize,
}

#[derive(Deserialize, Serialize)]
pub struct Nodes {
    _nodes: Box<RawValue>,
    //cluster_name: String,
    pub nodes: HashMap<String, Node>,
}

impl DataSource for Nodes {
    fn name() -> String {
        "nodes".to_string()
    }
}