opensearch_client/ml/
source.rs

1/*
2 * opensearch-client
3 *
4 * Rust Client for OpenSearch
5 *
6 * The version of the OpenAPI document: 3.1.0
7 * Contact: alberto.paro@gmail.com
8 * Generated by Paro OpenAPI Generator
9 */
10
11use crate::ml;
12use crate::common;
13use serde::{Deserialize, Serialize};
14
15
16
17
18#[derive(Clone, Default, Debug, PartialEq, Serialize, Deserialize)]
19pub struct Source {
20    #[serde(rename = "actions", default, skip_serializing_if = "Option::is_none")]
21    pub actions: Option<Vec<ml::Action>>,  /// The current worker node count.
22    #[serde(rename = "current_worker_node_count", default, skip_serializing_if = "Option::is_none")]
23    pub current_worker_node_count: Option<f64>,  /// The chunk number.
24    #[serde(rename = "chunk_number", default, skip_serializing_if = "Option::is_none")]
25    pub chunk_number: Option<u32>,  /// The model content hash value.
26    #[serde(rename = "model_content_hash_value", default, skip_serializing_if = "Option::is_none")]
27    pub model_content_hash_value: Option<String>,  /// The model version.
28    #[serde(rename = "model_version", default, skip_serializing_if = "Option::is_none")]
29    pub model_version: Option<String>,  /// The model task type.
30    #[serde(rename = "model_task_type", default, skip_serializing_if = "Option::is_none")]
31    pub model_task_type: Option<String>,  /// The status.
32    #[serde(rename = "state", default, skip_serializing_if = "Option::is_none")]
33    pub state: Option<String>,
34    #[serde(rename = "worker_node", default, skip_serializing_if = "Option::is_none")]
35    pub worker_node: Option<Vec<common::NodeIds>>,  /// The function name.
36    #[serde(rename = "function_name", default, skip_serializing_if = "Option::is_none")]
37    pub function_name: Option<String>,  /// The latest version.
38    #[serde(rename = "latest_version", default, skip_serializing_if = "Option::is_none")]
39    pub latest_version: Option<u32>,  /// The total chunks.
40    #[serde(rename = "total_chunks", default, skip_serializing_if = "Option::is_none")]
41    pub total_chunks: Option<u32>,
42    #[serde(rename = "model_config", default, skip_serializing_if = "Option::is_none")]
43    pub model_config: Option<ml::ModelConfig>,  /// The model content size in bytes.
44    #[serde(rename = "model_content_size_in_bytes", default, skip_serializing_if = "Option::is_none")]
45    pub model_content_size_in_bytes: Option<u32>,  /// The updated time.
46    #[serde(rename = "updated_time", default, skip_serializing_if = "Option::is_none")]
47    pub updated_time: Option<String>,  /// The agent type
48    #[serde(rename = "type", default, skip_serializing_if = "Option::is_none")]
49    pub r#type: Option<String>,
50    #[serde(rename = "version", default, skip_serializing_if = "Option::is_none")]
51    pub version: Option<String>,  /// The algorithm.
52    #[serde(rename = "algorithm", default, skip_serializing_if = "Option::is_none")]
53    pub algorithm: Option<String>,  /// The input type.
54    #[serde(rename = "input_type", default, skip_serializing_if = "Option::is_none")]
55    pub input_type: Option<String>,  /// Whether the model is hidden.
56    #[serde(rename = "is_hidden", default, skip_serializing_if = "Option::is_none")]
57    pub is_hidden: Option<bool>,
58    #[serde(rename = "memory_id", default, skip_serializing_if = "Option::is_none")]
59    pub memory_id: Option<String>,  /// The last deployed time.
60    #[serde(rename = "last_deployed_time", default, skip_serializing_if = "Option::is_none")]
61    pub last_deployed_time: Option<u32>,  /// The connector ID.
62    #[serde(rename = "connector_id", default, skip_serializing_if = "Option::is_none")]
63    pub connector_id: Option<String>,  /// The planning worker node count.
64    #[serde(rename = "planning_worker_node_count", default, skip_serializing_if = "Option::is_none")]
65    pub planning_worker_node_count: Option<f64>,  /// The connector protocol.
66    #[serde(rename = "protocol", default, skip_serializing_if = "Option::is_none")]
67    pub protocol: Option<String>,  /// The username of the user.
68    #[serde(rename = "user", default, skip_serializing_if = "Option::is_none")]
69    pub user: Option<String>,
70    #[serde(rename = "model_format", default, skip_serializing_if = "Option::is_none")]
71    pub model_format: Option<String>,  /// Task type.
72    #[serde(rename = "task_type", default, skip_serializing_if = "Option::is_none")]
73    pub task_type: Option<String>,  /// The model group access.
74    #[serde(rename = "access", default, skip_serializing_if = "Option::is_none")]
75    pub access: Option<String>,  /// The created time.
76    #[serde(rename = "created_time", default, skip_serializing_if = "Option::is_none")]
77    pub created_time: Option<u32>,  /// The model group ID.
78    #[serde(rename = "model_group_id", default, skip_serializing_if = "Option::is_none")]
79    pub model_group_id: Option<String>,
80    #[serde(rename = "parameters", default, skip_serializing_if = "Option::is_none")]
81    pub parameters: Option<ml::Parameters>,  /// The last registered time.
82    #[serde(rename = "last_registered_time", default, skip_serializing_if = "Option::is_none")]
83    pub last_registered_time: Option<u32>,  /// The auto redeploy retry times.
84    #[serde(rename = "auto_redeploy_retry_times", default, skip_serializing_if = "Option::is_none")]
85    pub auto_redeploy_retry_times: Option<u32>,  /// Whether to deploy to all nodes.
86    #[serde(rename = "deploy_to_all_nodes", default, skip_serializing_if = "Option::is_none")]
87    pub deploy_to_all_nodes: Option<bool>,
88    #[serde(rename = "name", default, skip_serializing_if = "Option::is_none")]
89    pub name: Option<String>,
90    #[serde(rename = "owner", default, skip_serializing_if = "Option::is_none")]
91    pub owner: Option<ml::Owner>,  /// Additional information query.
92    #[serde(rename = "additional_info", default, skip_serializing_if = "Option::is_none")]
93    pub additional_info: Option<ml::AdditionalInfo>,
94    #[serde(rename = "tools", default, skip_serializing_if = "Option::is_none")]
95    pub tools: Option<Vec<ml::ToolItems>>,  /// The model URL.
96    #[serde(rename = "url", default, skip_serializing_if = "Option::is_none")]
97    pub url: Option<String>,  /// The backend roles.
98    #[serde(rename = "backend_roles", default, skip_serializing_if = "Option::is_none")]
99    pub backend_roles: Option<Vec<String>>,  /// The last update time.
100    #[serde(rename = "last_update_time", default, skip_serializing_if = "Option::is_none")]
101    pub last_update_time: Option<u32>,  /// The app type.
102    #[serde(rename = "app_type", default, skip_serializing_if = "Option::is_none")]
103    pub app_type: Option<String>,
104    #[serde(rename = "planning_worker_nodes", default, skip_serializing_if = "Option::is_none")]
105    pub planning_worker_nodes: Option<Vec<common::NodeIds>>,  /// The model state.
106    #[serde(rename = "model_state", default, skip_serializing_if = "Option::is_none")]
107    pub model_state: Option<String>,  /// The error message.
108    #[serde(rename = "error", default, skip_serializing_if = "Option::is_none")]
109    pub error: Option<String>,  /// Whether the task is asynchronous.
110    #[serde(rename = "is_async", default, skip_serializing_if = "Option::is_none")]
111    pub is_async: Option<bool>,  /// The model description.
112    #[serde(rename = "description", default, skip_serializing_if = "Option::is_none")]
113    pub description: Option<String>,  /// The last updated time.
114    #[serde(rename = "last_updated_time", default, skip_serializing_if = "Option::is_none")]
115    pub last_updated_time: Option<u32>,
116    #[serde(rename = "memory", default, skip_serializing_if = "Option::is_none")]
117    pub memory: Option<ml::Memory>,
118    #[serde(rename = "model_id", default, skip_serializing_if = "Option::is_none")]
119    pub model_id: Option<String>,
120}
121
122impl Source {
123    
124    pub fn new() -> Source {
125        Source {
126            actions: None,
127            current_worker_node_count: None,
128            chunk_number: None,
129            model_content_hash_value: None,
130            model_version: None,
131            model_task_type: None,
132            state: None,
133            worker_node: None,
134            function_name: None,
135            latest_version: None,
136            total_chunks: None,
137            model_config: None,
138            model_content_size_in_bytes: None,
139            updated_time: None,
140            r#type: None,
141            version: None,
142            algorithm: None,
143            input_type: None,
144            is_hidden: None,
145            memory_id: None,
146            last_deployed_time: None,
147            connector_id: None,
148            planning_worker_node_count: None,
149            protocol: None,
150            user: None,
151            model_format: None,
152            task_type: None,
153            access: None,
154            created_time: None,
155            model_group_id: None,
156            parameters: None,
157            last_registered_time: None,
158            auto_redeploy_retry_times: None,
159            deploy_to_all_nodes: None,
160            name: None,
161            owner: None,
162            additional_info: None,
163            tools: None,
164            url: None,
165            backend_roles: None,
166            last_update_time: None,
167            app_type: None,
168            planning_worker_nodes: None,
169            model_state: None,
170            error: None,
171            is_async: None,
172            description: None,
173            last_updated_time: None,
174            memory: None,
175            model_id: None,
176        }
177    }
178}
opensearch_client/ml/source.rs

opensearch_client/ml/
source.rs
