pulsar_admin_sdk/models/
worker_service.rs

1/*
2 * Pulsar Admin REST API
3 *
4 * This provides the REST API for admin operations
5 *
6 * The version of the OpenAPI document: v2
7 * 
8 * Generated by: https://openapi-generator.tech
9 */
10
11use crate::models;
12
13#[derive(Clone, Default, Debug, PartialEq, Serialize, Deserialize)]
14pub struct WorkerService {
15    #[serde(rename = "functions", skip_serializing_if = "Option::is_none")]
16    pub functions: Option<Box<models::FunctionsWorkerService>>,
17    #[serde(rename = "functionsV2", skip_serializing_if = "Option::is_none")]
18    pub functions_v2: Option<Box<models::FunctionsV2WorkerService>>,
19    #[serde(rename = "initialized", skip_serializing_if = "Option::is_none")]
20    pub initialized: Option<bool>,
21    #[serde(rename = "sinks", skip_serializing_if = "Option::is_none")]
22    pub sinks: Option<Box<models::SinksWorkerService>>,
23    #[serde(rename = "sources", skip_serializing_if = "Option::is_none")]
24    pub sources: Option<Box<models::SourcesWorkerService>>,
25    #[serde(rename = "workerConfig", skip_serializing_if = "Option::is_none")]
26    pub worker_config: Option<Box<models::WorkerConfig>>,
27    #[serde(rename = "workers", skip_serializing_if = "Option::is_none")]
28    pub workers: Option<serde_json::Value>,
29}
30
31impl WorkerService {
32    pub fn new() -> WorkerService {
33        WorkerService {
34            functions: None,
35            functions_v2: None,
36            initialized: None,
37            sinks: None,
38            sources: None,
39            worker_config: None,
40            workers: None,
41        }
42    }
43}
44
pulsar_admin_sdk/models/worker_service.rs

pulsar_admin_sdk/models/
worker_service.rs
