pulsar_admin_sdk/models/
worker_config.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 WorkerConfig {
15    #[serde(rename = "additionalJavaRuntimeArguments", skip_serializing_if = "Option::is_none")]
16    pub additional_java_runtime_arguments: Option<Vec<String>>,
17    #[serde(rename = "assignmentWriteMaxRetries", skip_serializing_if = "Option::is_none")]
18    pub assignment_write_max_retries: Option<i32>,
19    #[serde(rename = "authenticateMetricsEndpoint", skip_serializing_if = "Option::is_none")]
20    pub authenticate_metrics_endpoint: Option<bool>,
21    #[serde(rename = "authenticationEnabled", skip_serializing_if = "Option::is_none")]
22    pub authentication_enabled: Option<bool>,
23    #[serde(rename = "authenticationProviders", skip_serializing_if = "Option::is_none")]
24    pub authentication_providers: Option<Vec<String>>,
25    #[serde(rename = "authorizationEnabled", skip_serializing_if = "Option::is_none")]
26    pub authorization_enabled: Option<bool>,
27    #[serde(rename = "authorizationProvider", skip_serializing_if = "Option::is_none")]
28    pub authorization_provider: Option<String>,
29    #[serde(rename = "bookkeeperClientAuthenticationParameters", skip_serializing_if = "Option::is_none")]
30    pub bookkeeper_client_authentication_parameters: Option<String>,
31    #[serde(rename = "bookkeeperClientAuthenticationParametersName", skip_serializing_if = "Option::is_none")]
32    pub bookkeeper_client_authentication_parameters_name: Option<String>,
33    #[serde(rename = "bookkeeperClientAuthenticationPlugin", skip_serializing_if = "Option::is_none")]
34    pub bookkeeper_client_authentication_plugin: Option<String>,
35    #[serde(rename = "brokerClientAuthenticationEnabled", skip_serializing_if = "Option::is_none")]
36    pub broker_client_authentication_enabled: Option<bool>,
37    #[serde(rename = "brokerClientAuthenticationParameters", skip_serializing_if = "Option::is_none")]
38    pub broker_client_authentication_parameters: Option<String>,
39    #[serde(rename = "brokerClientAuthenticationPlugin", skip_serializing_if = "Option::is_none")]
40    pub broker_client_authentication_plugin: Option<String>,
41    #[serde(rename = "brokerClientTrustCertsFilePath", skip_serializing_if = "Option::is_none")]
42    pub broker_client_trust_certs_file_path: Option<String>,
43    #[serde(rename = "clientAuthenticationParameters", skip_serializing_if = "Option::is_none")]
44    pub client_authentication_parameters: Option<String>,
45    #[serde(rename = "clientAuthenticationPlugin", skip_serializing_if = "Option::is_none")]
46    pub client_authentication_plugin: Option<String>,
47    #[serde(rename = "clusterCoordinationTopic", skip_serializing_if = "Option::is_none")]
48    pub cluster_coordination_topic: Option<String>,
49    #[serde(rename = "clusterCoordinationTopicName", skip_serializing_if = "Option::is_none")]
50    pub cluster_coordination_topic_name: Option<String>,
51    #[serde(rename = "configurationMetadataStoreUrl", skip_serializing_if = "Option::is_none")]
52    pub configuration_metadata_store_url: Option<String>,
53    #[serde(rename = "configurationStoreServers", skip_serializing_if = "Option::is_none")]
54    pub configuration_store_servers: Option<String>,
55    #[serde(rename = "connectorsDirectory", skip_serializing_if = "Option::is_none")]
56    pub connectors_directory: Option<String>,
57    #[serde(rename = "downloadDirectory", skip_serializing_if = "Option::is_none")]
58    pub download_directory: Option<String>,
59    #[serde(rename = "enableClassloadingOfBuiltinFiles", skip_serializing_if = "Option::is_none")]
60    pub enable_classloading_of_builtin_files: Option<bool>,
61    #[serde(rename = "enableClassloadingOfExternalFiles", skip_serializing_if = "Option::is_none")]
62    pub enable_classloading_of_external_files: Option<bool>,
63    #[serde(rename = "exposeAdminClientEnabled", skip_serializing_if = "Option::is_none")]
64    pub expose_admin_client_enabled: Option<bool>,
65    #[serde(rename = "failureCheckFreqMs", skip_serializing_if = "Option::is_none")]
66    pub failure_check_freq_ms: Option<i64>,
67    #[serde(rename = "forwardSourceMessageProperty", skip_serializing_if = "Option::is_none")]
68    pub forward_source_message_property: Option<bool>,
69    #[serde(rename = "functionAssignmentTopic", skip_serializing_if = "Option::is_none")]
70    pub function_assignment_topic: Option<String>,
71    #[serde(rename = "functionAssignmentTopicName", skip_serializing_if = "Option::is_none")]
72    pub function_assignment_topic_name: Option<String>,
73    #[serde(rename = "functionAuthProviderClassName", skip_serializing_if = "Option::is_none")]
74    pub function_auth_provider_class_name: Option<String>,
75    #[serde(rename = "functionInstanceMaxResources", skip_serializing_if = "Option::is_none")]
76    pub function_instance_max_resources: Option<Box<models::Resources>>,
77    #[serde(rename = "functionInstanceMinResources", skip_serializing_if = "Option::is_none")]
78    pub function_instance_min_resources: Option<Box<models::Resources>>,
79    #[serde(rename = "functionInstanceResourceChangeInLockStep", skip_serializing_if = "Option::is_none")]
80    pub function_instance_resource_change_in_lock_step: Option<bool>,
81    #[serde(rename = "functionInstanceResourceGranularities", skip_serializing_if = "Option::is_none")]
82    pub function_instance_resource_granularities: Option<Box<models::Resources>>,
83    #[serde(rename = "functionMetadataTopic", skip_serializing_if = "Option::is_none")]
84    pub function_metadata_topic: Option<String>,
85    #[serde(rename = "functionMetadataTopicName", skip_serializing_if = "Option::is_none")]
86    pub function_metadata_topic_name: Option<String>,
87    #[serde(rename = "functionRuntimeFactoryClassName", skip_serializing_if = "Option::is_none")]
88    pub function_runtime_factory_class_name: Option<String>,
89    #[serde(rename = "functionRuntimeFactoryConfigs", skip_serializing_if = "Option::is_none")]
90    pub function_runtime_factory_configs: Option<std::collections::HashMap<String, serde_json::Value>>,
91    #[serde(rename = "functionWebServiceUrl", skip_serializing_if = "Option::is_none")]
92    pub function_web_service_url: Option<String>,
93    #[serde(rename = "functionsDirectory", skip_serializing_if = "Option::is_none")]
94    pub functions_directory: Option<String>,
95    #[serde(rename = "functionsWorkerEnablePackageManagement", skip_serializing_if = "Option::is_none")]
96    pub functions_worker_enable_package_management: Option<bool>,
97    #[serde(rename = "functionsWorkerServiceCustomConfigs", skip_serializing_if = "Option::is_none")]
98    pub functions_worker_service_custom_configs: Option<std::collections::HashMap<String, serde_json::Value>>,
99    #[serde(rename = "functionsWorkerServiceNarPackage", skip_serializing_if = "Option::is_none")]
100    pub functions_worker_service_nar_package: Option<String>,
101    #[serde(rename = "httpRequestsLimitEnabled", skip_serializing_if = "Option::is_none")]
102    pub http_requests_limit_enabled: Option<bool>,
103    #[serde(rename = "httpRequestsMaxPerSecond", skip_serializing_if = "Option::is_none")]
104    pub http_requests_max_per_second: Option<f64>,
105    #[serde(rename = "httpServerAcceptQueueSize", skip_serializing_if = "Option::is_none")]
106    pub http_server_accept_queue_size: Option<i32>,
107    #[serde(rename = "httpServerThreadPoolQueueSize", skip_serializing_if = "Option::is_none")]
108    pub http_server_thread_pool_queue_size: Option<i32>,
109    #[serde(rename = "ignoreUnknownConfigFields", skip_serializing_if = "Option::is_none")]
110    pub ignore_unknown_config_fields: Option<bool>,
111    #[serde(rename = "includeStandardPrometheusMetrics", skip_serializing_if = "Option::is_none")]
112    pub include_standard_prometheus_metrics: Option<bool>,
113    #[serde(rename = "initialBrokerReconnectMaxRetries", skip_serializing_if = "Option::is_none")]
114    pub initial_broker_reconnect_max_retries: Option<i32>,
115    #[serde(rename = "initializedDlogMetadata", skip_serializing_if = "Option::is_none")]
116    pub initialized_dlog_metadata: Option<bool>,
117    #[serde(rename = "instanceLivenessCheckFreqMs", skip_serializing_if = "Option::is_none")]
118    pub instance_liveness_check_freq_ms: Option<i64>,
119    #[serde(rename = "jvmGCMetricsLoggerClassName", skip_serializing_if = "Option::is_none")]
120    pub jvm_gc_metrics_logger_class_name: Option<String>,
121    #[serde(rename = "kinitCommand", skip_serializing_if = "Option::is_none")]
122    pub kinit_command: Option<String>,
123    #[serde(rename = "kubernetesContainerFactory", skip_serializing_if = "Option::is_none")]
124    pub kubernetes_container_factory: Option<Box<models::KubernetesContainerFactory>>,
125    #[serde(rename = "maxConcurrentHttpRequests", skip_serializing_if = "Option::is_none")]
126    pub max_concurrent_http_requests: Option<i32>,
127    #[serde(rename = "maxHttpServerConnections", skip_serializing_if = "Option::is_none")]
128    pub max_http_server_connections: Option<i32>,
129    #[serde(rename = "maxPendingAsyncRequests", skip_serializing_if = "Option::is_none")]
130    pub max_pending_async_requests: Option<i32>,
131    #[serde(rename = "metadataStoreAllowReadOnlyOperations", skip_serializing_if = "Option::is_none")]
132    pub metadata_store_allow_read_only_operations: Option<bool>,
133    #[serde(rename = "metadataStoreCacheExpirySeconds", skip_serializing_if = "Option::is_none")]
134    pub metadata_store_cache_expiry_seconds: Option<i32>,
135    #[serde(rename = "metadataStoreOperationTimeoutSeconds", skip_serializing_if = "Option::is_none")]
136    pub metadata_store_operation_timeout_seconds: Option<i32>,
137    #[serde(rename = "metadataStoreSessionTimeoutMillis", skip_serializing_if = "Option::is_none")]
138    pub metadata_store_session_timeout_millis: Option<i64>,
139    #[serde(rename = "narExtractionDirectory", skip_serializing_if = "Option::is_none")]
140    pub nar_extraction_directory: Option<String>,
141    #[serde(rename = "numFunctionPackageReplicas", skip_serializing_if = "Option::is_none")]
142    pub num_function_package_replicas: Option<i32>,
143    #[serde(rename = "numHttpServerThreads", skip_serializing_if = "Option::is_none")]
144    pub num_http_server_threads: Option<i32>,
145    #[serde(rename = "processContainerFactory", skip_serializing_if = "Option::is_none")]
146    pub process_container_factory: Option<Box<models::ProcessContainerFactory>>,
147    #[serde(rename = "properties", skip_serializing_if = "Option::is_none")]
148    pub properties: Option<std::collections::HashMap<String, String>>,
149    #[serde(rename = "proxyRoles", skip_serializing_if = "Option::is_none")]
150    pub proxy_roles: Option<Vec<String>>,
151    #[serde(rename = "pulsarFunctionsCluster", skip_serializing_if = "Option::is_none")]
152    pub pulsar_functions_cluster: Option<String>,
153    #[serde(rename = "pulsarFunctionsNamespace", skip_serializing_if = "Option::is_none")]
154    pub pulsar_functions_namespace: Option<String>,
155    #[serde(rename = "pulsarServiceUrl", skip_serializing_if = "Option::is_none")]
156    pub pulsar_service_url: Option<String>,
157    #[serde(rename = "pulsarWebServiceUrl", skip_serializing_if = "Option::is_none")]
158    pub pulsar_web_service_url: Option<String>,
159    #[serde(rename = "rebalanceCheckFreqSec", skip_serializing_if = "Option::is_none")]
160    pub rebalance_check_freq_sec: Option<i64>,
161    #[serde(rename = "rescheduleTimeoutMs", skip_serializing_if = "Option::is_none")]
162    pub reschedule_timeout_ms: Option<i64>,
163    #[serde(rename = "runtimeCustomizerClassName", skip_serializing_if = "Option::is_none")]
164    pub runtime_customizer_class_name: Option<String>,
165    #[serde(rename = "runtimeCustomizerConfig", skip_serializing_if = "Option::is_none")]
166    pub runtime_customizer_config: Option<std::collections::HashMap<String, serde_json::Value>>,
167    #[serde(rename = "saslJaasClientAllowedIds", skip_serializing_if = "Option::is_none")]
168    pub sasl_jaas_client_allowed_ids: Option<String>,
169    #[serde(rename = "saslJaasServerRoleTokenSignerSecretPath", skip_serializing_if = "Option::is_none")]
170    pub sasl_jaas_server_role_token_signer_secret_path: Option<String>,
171    #[serde(rename = "saslJaasServerSectionName", skip_serializing_if = "Option::is_none")]
172    pub sasl_jaas_server_section_name: Option<String>,
173    #[serde(rename = "schedulerClassName", skip_serializing_if = "Option::is_none")]
174    pub scheduler_class_name: Option<String>,
175    #[serde(rename = "secretsProviderConfiguratorClassName", skip_serializing_if = "Option::is_none")]
176    pub secrets_provider_configurator_class_name: Option<String>,
177    #[serde(rename = "secretsProviderConfiguratorConfig", skip_serializing_if = "Option::is_none")]
178    pub secrets_provider_configurator_config: Option<std::collections::HashMap<String, String>>,
179    #[serde(rename = "stateStorageProviderImplementation", skip_serializing_if = "Option::is_none")]
180    pub state_storage_provider_implementation: Option<String>,
181    #[serde(rename = "stateStorageServiceUrl", skip_serializing_if = "Option::is_none")]
182    pub state_storage_service_url: Option<String>,
183    #[serde(rename = "superUserRoles", skip_serializing_if = "Option::is_none")]
184    pub super_user_roles: Option<Vec<String>>,
185    #[serde(rename = "threadContainerFactory", skip_serializing_if = "Option::is_none")]
186    pub thread_container_factory: Option<Box<models::ThreadContainerFactory>>,
187    #[serde(rename = "tlsAllowInsecureConnection", skip_serializing_if = "Option::is_none")]
188    pub tls_allow_insecure_connection: Option<bool>,
189    #[serde(rename = "tlsCertRefreshCheckDurationSec", skip_serializing_if = "Option::is_none")]
190    pub tls_cert_refresh_check_duration_sec: Option<i64>,
191    #[serde(rename = "tlsCertificateFilePath", skip_serializing_if = "Option::is_none")]
192    pub tls_certificate_file_path: Option<String>,
193    #[serde(rename = "tlsEnableHostnameVerification", skip_serializing_if = "Option::is_none")]
194    pub tls_enable_hostname_verification: Option<bool>,
195    #[serde(rename = "tlsEnabled", skip_serializing_if = "Option::is_none")]
196    pub tls_enabled: Option<bool>,
197    #[serde(rename = "tlsEnabledWithKeyStore", skip_serializing_if = "Option::is_none")]
198    pub tls_enabled_with_key_store: Option<bool>,
199    #[serde(rename = "tlsKeyFilePath", skip_serializing_if = "Option::is_none")]
200    pub tls_key_file_path: Option<String>,
201    #[serde(rename = "tlsKeyStore", skip_serializing_if = "Option::is_none")]
202    pub tls_key_store: Option<String>,
203    #[serde(rename = "tlsKeyStorePassword", skip_serializing_if = "Option::is_none")]
204    pub tls_key_store_password: Option<String>,
205    #[serde(rename = "tlsKeyStoreType", skip_serializing_if = "Option::is_none")]
206    pub tls_key_store_type: Option<String>,
207    #[serde(rename = "tlsProvider", skip_serializing_if = "Option::is_none")]
208    pub tls_provider: Option<String>,
209    #[serde(rename = "tlsRequireTrustedClientCertOnConnect", skip_serializing_if = "Option::is_none")]
210    pub tls_require_trusted_client_cert_on_connect: Option<bool>,
211    #[serde(rename = "tlsTrustCertsFilePath", skip_serializing_if = "Option::is_none")]
212    pub tls_trust_certs_file_path: Option<String>,
213    #[serde(rename = "tlsTrustChainBytes", skip_serializing_if = "Option::is_none")]
214    pub tls_trust_chain_bytes: Option<Vec<String>>,
215    #[serde(rename = "tlsTrustStore", skip_serializing_if = "Option::is_none")]
216    pub tls_trust_store: Option<String>,
217    #[serde(rename = "tlsTrustStorePassword", skip_serializing_if = "Option::is_none")]
218    pub tls_trust_store_password: Option<String>,
219    #[serde(rename = "tlsTrustStoreType", skip_serializing_if = "Option::is_none")]
220    pub tls_trust_store_type: Option<String>,
221    #[serde(rename = "topicCompactionFrequencySec", skip_serializing_if = "Option::is_none")]
222    pub topic_compaction_frequency_sec: Option<i64>,
223    #[serde(rename = "uploadBuiltinSinksSources", skip_serializing_if = "Option::is_none")]
224    pub upload_builtin_sinks_sources: Option<bool>,
225    #[serde(rename = "useCompactedMetadataTopic", skip_serializing_if = "Option::is_none")]
226    pub use_compacted_metadata_topic: Option<bool>,
227    #[serde(rename = "useTls", skip_serializing_if = "Option::is_none")]
228    pub use_tls: Option<bool>,
229    #[serde(rename = "validateConnectorConfig", skip_serializing_if = "Option::is_none")]
230    pub validate_connector_config: Option<bool>,
231    #[serde(rename = "webServiceTlsCiphers", skip_serializing_if = "Option::is_none")]
232    pub web_service_tls_ciphers: Option<Vec<String>>,
233    #[serde(rename = "webServiceTlsProtocols", skip_serializing_if = "Option::is_none")]
234    pub web_service_tls_protocols: Option<Vec<String>>,
235    #[serde(rename = "workerHostname", skip_serializing_if = "Option::is_none")]
236    pub worker_hostname: Option<String>,
237    #[serde(rename = "workerId", skip_serializing_if = "Option::is_none")]
238    pub worker_id: Option<String>,
239    #[serde(rename = "workerListProbeIntervalSec", skip_serializing_if = "Option::is_none")]
240    pub worker_list_probe_interval_sec: Option<i32>,
241    #[serde(rename = "workerPort", skip_serializing_if = "Option::is_none")]
242    pub worker_port: Option<i32>,
243    #[serde(rename = "workerPortTls", skip_serializing_if = "Option::is_none")]
244    pub worker_port_tls: Option<i32>,
245    #[serde(rename = "workerWebAddress", skip_serializing_if = "Option::is_none")]
246    pub worker_web_address: Option<String>,
247    #[serde(rename = "workerWebAddressTls", skip_serializing_if = "Option::is_none")]
248    pub worker_web_address_tls: Option<String>,
249    #[serde(rename = "zooKeeperAllowReadOnlyOperations", skip_serializing_if = "Option::is_none")]
250    pub zoo_keeper_allow_read_only_operations: Option<bool>,
251    #[serde(rename = "zooKeeperCacheExpirySeconds", skip_serializing_if = "Option::is_none")]
252    pub zoo_keeper_cache_expiry_seconds: Option<i32>,
253    #[serde(rename = "zooKeeperOperationTimeoutSeconds", skip_serializing_if = "Option::is_none")]
254    pub zoo_keeper_operation_timeout_seconds: Option<i32>,
255    #[serde(rename = "zooKeeperSessionTimeoutMillis", skip_serializing_if = "Option::is_none")]
256    pub zoo_keeper_session_timeout_millis: Option<i64>,
257}
258
259impl WorkerConfig {
260    pub fn new() -> WorkerConfig {
261        WorkerConfig {
262            additional_java_runtime_arguments: None,
263            assignment_write_max_retries: None,
264            authenticate_metrics_endpoint: None,
265            authentication_enabled: None,
266            authentication_providers: None,
267            authorization_enabled: None,
268            authorization_provider: None,
269            bookkeeper_client_authentication_parameters: None,
270            bookkeeper_client_authentication_parameters_name: None,
271            bookkeeper_client_authentication_plugin: None,
272            broker_client_authentication_enabled: None,
273            broker_client_authentication_parameters: None,
274            broker_client_authentication_plugin: None,
275            broker_client_trust_certs_file_path: None,
276            client_authentication_parameters: None,
277            client_authentication_plugin: None,
278            cluster_coordination_topic: None,
279            cluster_coordination_topic_name: None,
280            configuration_metadata_store_url: None,
281            configuration_store_servers: None,
282            connectors_directory: None,
283            download_directory: None,
284            enable_classloading_of_builtin_files: None,
285            enable_classloading_of_external_files: None,
286            expose_admin_client_enabled: None,
287            failure_check_freq_ms: None,
288            forward_source_message_property: None,
289            function_assignment_topic: None,
290            function_assignment_topic_name: None,
291            function_auth_provider_class_name: None,
292            function_instance_max_resources: None,
293            function_instance_min_resources: None,
294            function_instance_resource_change_in_lock_step: None,
295            function_instance_resource_granularities: None,
296            function_metadata_topic: None,
297            function_metadata_topic_name: None,
298            function_runtime_factory_class_name: None,
299            function_runtime_factory_configs: None,
300            function_web_service_url: None,
301            functions_directory: None,
302            functions_worker_enable_package_management: None,
303            functions_worker_service_custom_configs: None,
304            functions_worker_service_nar_package: None,
305            http_requests_limit_enabled: None,
306            http_requests_max_per_second: None,
307            http_server_accept_queue_size: None,
308            http_server_thread_pool_queue_size: None,
309            ignore_unknown_config_fields: None,
310            include_standard_prometheus_metrics: None,
311            initial_broker_reconnect_max_retries: None,
312            initialized_dlog_metadata: None,
313            instance_liveness_check_freq_ms: None,
314            jvm_gc_metrics_logger_class_name: None,
315            kinit_command: None,
316            kubernetes_container_factory: None,
317            max_concurrent_http_requests: None,
318            max_http_server_connections: None,
319            max_pending_async_requests: None,
320            metadata_store_allow_read_only_operations: None,
321            metadata_store_cache_expiry_seconds: None,
322            metadata_store_operation_timeout_seconds: None,
323            metadata_store_session_timeout_millis: None,
324            nar_extraction_directory: None,
325            num_function_package_replicas: None,
326            num_http_server_threads: None,
327            process_container_factory: None,
328            properties: None,
329            proxy_roles: None,
330            pulsar_functions_cluster: None,
331            pulsar_functions_namespace: None,
332            pulsar_service_url: None,
333            pulsar_web_service_url: None,
334            rebalance_check_freq_sec: None,
335            reschedule_timeout_ms: None,
336            runtime_customizer_class_name: None,
337            runtime_customizer_config: None,
338            sasl_jaas_client_allowed_ids: None,
339            sasl_jaas_server_role_token_signer_secret_path: None,
340            sasl_jaas_server_section_name: None,
341            scheduler_class_name: None,
342            secrets_provider_configurator_class_name: None,
343            secrets_provider_configurator_config: None,
344            state_storage_provider_implementation: None,
345            state_storage_service_url: None,
346            super_user_roles: None,
347            thread_container_factory: None,
348            tls_allow_insecure_connection: None,
349            tls_cert_refresh_check_duration_sec: None,
350            tls_certificate_file_path: None,
351            tls_enable_hostname_verification: None,
352            tls_enabled: None,
353            tls_enabled_with_key_store: None,
354            tls_key_file_path: None,
355            tls_key_store: None,
356            tls_key_store_password: None,
357            tls_key_store_type: None,
358            tls_provider: None,
359            tls_require_trusted_client_cert_on_connect: None,
360            tls_trust_certs_file_path: None,
361            tls_trust_chain_bytes: None,
362            tls_trust_store: None,
363            tls_trust_store_password: None,
364            tls_trust_store_type: None,
365            topic_compaction_frequency_sec: None,
366            upload_builtin_sinks_sources: None,
367            use_compacted_metadata_topic: None,
368            use_tls: None,
369            validate_connector_config: None,
370            web_service_tls_ciphers: None,
371            web_service_tls_protocols: None,
372            worker_hostname: None,
373            worker_id: None,
374            worker_list_probe_interval_sec: None,
375            worker_port: None,
376            worker_port_tls: None,
377            worker_web_address: None,
378            worker_web_address_tls: None,
379            zoo_keeper_allow_read_only_operations: None,
380            zoo_keeper_cache_expiry_seconds: None,
381            zoo_keeper_operation_timeout_seconds: None,
382            zoo_keeper_session_timeout_millis: None,
383        }
384    }
385}
386
pulsar_admin_sdk/models/worker_config.rs

pulsar_admin_sdk/models/
worker_config.rs
