Struct pulsar_admin_sdk::models::worker_config::WorkerConfig

source · 
pub struct WorkerConfig {
Show 121 fields
    pub additional_java_runtime_arguments: Option<Vec<String>>,
    pub assignment_write_max_retries: Option<i32>,
    pub authenticate_metrics_endpoint: Option<bool>,
    pub authentication_enabled: Option<bool>,
    pub authentication_providers: Option<Vec<String>>,
    pub authorization_enabled: Option<bool>,
    pub authorization_provider: Option<String>,
    pub bookkeeper_client_authentication_parameters: Option<String>,
    pub bookkeeper_client_authentication_parameters_name: Option<String>,
    pub bookkeeper_client_authentication_plugin: Option<String>,
    pub broker_client_authentication_enabled: Option<bool>,
    pub broker_client_authentication_parameters: Option<String>,
    pub broker_client_authentication_plugin: Option<String>,
    pub broker_client_trust_certs_file_path: Option<String>,
    pub client_authentication_parameters: Option<String>,
    pub client_authentication_plugin: Option<String>,
    pub cluster_coordination_topic: Option<String>,
    pub cluster_coordination_topic_name: Option<String>,
    pub configuration_metadata_store_url: Option<String>,
    pub configuration_store_servers: Option<String>,
    pub connectors_directory: Option<String>,
    pub download_directory: Option<String>,
    pub enable_classloading_of_builtin_files: Option<bool>,
    pub enable_classloading_of_external_files: Option<bool>,
    pub expose_admin_client_enabled: Option<bool>,
    pub failure_check_freq_ms: Option<i64>,
    pub forward_source_message_property: Option<bool>,
    pub function_assignment_topic: Option<String>,
    pub function_assignment_topic_name: Option<String>,
    pub function_auth_provider_class_name: Option<String>,
    pub function_instance_max_resources: Option<Box<Resources>>,
    pub function_instance_min_resources: Option<Box<Resources>>,
    pub function_instance_resource_change_in_lock_step: Option<bool>,
    pub function_instance_resource_granularities: Option<Box<Resources>>,
    pub function_metadata_topic: Option<String>,
    pub function_metadata_topic_name: Option<String>,
    pub function_runtime_factory_class_name: Option<String>,
    pub function_runtime_factory_configs: Option<HashMap<String, Value>>,
    pub function_web_service_url: Option<String>,
    pub functions_directory: Option<String>,
    pub functions_worker_enable_package_management: Option<bool>,
    pub functions_worker_service_custom_configs: Option<HashMap<String, Value>>,
    pub functions_worker_service_nar_package: Option<String>,
    pub http_requests_limit_enabled: Option<bool>,
    pub http_requests_max_per_second: Option<f64>,
    pub http_server_accept_queue_size: Option<i32>,
    pub http_server_thread_pool_queue_size: Option<i32>,
    pub ignore_unknown_config_fields: Option<bool>,
    pub include_standard_prometheus_metrics: Option<bool>,
    pub initial_broker_reconnect_max_retries: Option<i32>,
    pub initialized_dlog_metadata: Option<bool>,
    pub instance_liveness_check_freq_ms: Option<i64>,
    pub jvm_gc_metrics_logger_class_name: Option<String>,
    pub kinit_command: Option<String>,
    pub kubernetes_container_factory: Option<Box<KubernetesContainerFactory>>,
    pub max_concurrent_http_requests: Option<i32>,
    pub max_http_server_connections: Option<i32>,
    pub max_pending_async_requests: Option<i32>,
    pub metadata_store_allow_read_only_operations: Option<bool>,
    pub metadata_store_cache_expiry_seconds: Option<i32>,
    pub metadata_store_operation_timeout_seconds: Option<i32>,
    pub metadata_store_session_timeout_millis: Option<i64>,
    pub nar_extraction_directory: Option<String>,
    pub num_function_package_replicas: Option<i32>,
    pub num_http_server_threads: Option<i32>,
    pub process_container_factory: Option<Box<ProcessContainerFactory>>,
    pub properties: Option<HashMap<String, String>>,
    pub proxy_roles: Option<Vec<String>>,
    pub pulsar_functions_cluster: Option<String>,
    pub pulsar_functions_namespace: Option<String>,
    pub pulsar_service_url: Option<String>,
    pub pulsar_web_service_url: Option<String>,
    pub rebalance_check_freq_sec: Option<i64>,
    pub reschedule_timeout_ms: Option<i64>,
    pub runtime_customizer_class_name: Option<String>,
    pub runtime_customizer_config: Option<HashMap<String, Value>>,
    pub sasl_jaas_client_allowed_ids: Option<String>,
    pub sasl_jaas_server_role_token_signer_secret_path: Option<String>,
    pub sasl_jaas_server_section_name: Option<String>,
    pub scheduler_class_name: Option<String>,
    pub secrets_provider_configurator_class_name: Option<String>,
    pub secrets_provider_configurator_config: Option<HashMap<String, String>>,
    pub state_storage_provider_implementation: Option<String>,
    pub state_storage_service_url: Option<String>,
    pub super_user_roles: Option<Vec<String>>,
    pub thread_container_factory: Option<Box<ThreadContainerFactory>>,
    pub tls_allow_insecure_connection: Option<bool>,
    pub tls_cert_refresh_check_duration_sec: Option<i64>,
    pub tls_certificate_file_path: Option<String>,
    pub tls_enable_hostname_verification: Option<bool>,
    pub tls_enabled: Option<bool>,
    pub tls_enabled_with_key_store: Option<bool>,
    pub tls_key_file_path: Option<String>,
    pub tls_key_store: Option<String>,
    pub tls_key_store_password: Option<String>,
    pub tls_key_store_type: Option<String>,
    pub tls_provider: Option<String>,
    pub tls_require_trusted_client_cert_on_connect: Option<bool>,
    pub tls_trust_certs_file_path: Option<String>,
    pub tls_trust_chain_bytes: Option<Vec<String>>,
    pub tls_trust_store: Option<String>,
    pub tls_trust_store_password: Option<String>,
    pub tls_trust_store_type: Option<String>,
    pub topic_compaction_frequency_sec: Option<i64>,
    pub upload_builtin_sinks_sources: Option<bool>,
    pub use_compacted_metadata_topic: Option<bool>,
    pub use_tls: Option<bool>,
    pub validate_connector_config: Option<bool>,
    pub web_service_tls_ciphers: Option<Vec<String>>,
    pub web_service_tls_protocols: Option<Vec<String>>,
    pub worker_hostname: Option<String>,
    pub worker_id: Option<String>,
    pub worker_list_probe_interval_sec: Option<i32>,
    pub worker_port: Option<i32>,
    pub worker_port_tls: Option<i32>,
    pub worker_web_address: Option<String>,
    pub worker_web_address_tls: Option<String>,
    pub zoo_keeper_allow_read_only_operations: Option<bool>,
    pub zoo_keeper_cache_expiry_seconds: Option<i32>,
    pub zoo_keeper_operation_timeout_seconds: Option<i32>,
    pub zoo_keeper_session_timeout_millis: Option<i64>,

}

Fields§

§additional_java_runtime_arguments: Option<Vec<String>>§assignment_write_max_retries: Option<i32>§authenticate_metrics_endpoint: Option<bool>§authentication_enabled: Option<bool>§authentication_providers: Option<Vec<String>>§authorization_enabled: Option<bool>§authorization_provider: Option<String>§bookkeeper_client_authentication_parameters: Option<String>§bookkeeper_client_authentication_parameters_name: Option<String>§bookkeeper_client_authentication_plugin: Option<String>§broker_client_authentication_enabled: Option<bool>§broker_client_authentication_parameters: Option<String>§broker_client_authentication_plugin: Option<String>§broker_client_trust_certs_file_path: Option<String>§client_authentication_parameters: Option<String>§client_authentication_plugin: Option<String>§cluster_coordination_topic: Option<String>§cluster_coordination_topic_name: Option<String>§configuration_metadata_store_url: Option<String>§configuration_store_servers: Option<String>§connectors_directory: Option<String>§download_directory: Option<String>§enable_classloading_of_builtin_files: Option<bool>§enable_classloading_of_external_files: Option<bool>§expose_admin_client_enabled: Option<bool>§failure_check_freq_ms: Option<i64>§forward_source_message_property: Option<bool>§function_assignment_topic: Option<String>§function_assignment_topic_name: Option<String>§function_auth_provider_class_name: Option<String>§function_instance_max_resources: Option<Box<Resources>>§function_instance_min_resources: Option<Box<Resources>>§function_instance_resource_change_in_lock_step: Option<bool>§function_instance_resource_granularities: Option<Box<Resources>>§function_metadata_topic: Option<String>§function_metadata_topic_name: Option<String>§function_runtime_factory_class_name: Option<String>§function_runtime_factory_configs: Option<HashMap<String, Value>>§function_web_service_url: Option<String>§functions_directory: Option<String>§functions_worker_enable_package_management: Option<bool>§functions_worker_service_custom_configs: Option<HashMap<String, Value>>§functions_worker_service_nar_package: Option<String>§http_requests_limit_enabled: Option<bool>§http_requests_max_per_second: Option<f64>§http_server_accept_queue_size: Option<i32>§http_server_thread_pool_queue_size: Option<i32>§ignore_unknown_config_fields: Option<bool>§include_standard_prometheus_metrics: Option<bool>§initial_broker_reconnect_max_retries: Option<i32>§initialized_dlog_metadata: Option<bool>§instance_liveness_check_freq_ms: Option<i64>§jvm_gc_metrics_logger_class_name: Option<String>§kinit_command: Option<String>§kubernetes_container_factory: Option<Box<KubernetesContainerFactory>>§max_concurrent_http_requests: Option<i32>§max_http_server_connections: Option<i32>§max_pending_async_requests: Option<i32>§metadata_store_allow_read_only_operations: Option<bool>§metadata_store_cache_expiry_seconds: Option<i32>§metadata_store_operation_timeout_seconds: Option<i32>§metadata_store_session_timeout_millis: Option<i64>§nar_extraction_directory: Option<String>§num_function_package_replicas: Option<i32>§num_http_server_threads: Option<i32>§process_container_factory: Option<Box<ProcessContainerFactory>>§properties: Option<HashMap<String, String>>§proxy_roles: Option<Vec<String>>§pulsar_functions_cluster: Option<String>§pulsar_functions_namespace: Option<String>§pulsar_service_url: Option<String>§pulsar_web_service_url: Option<String>§rebalance_check_freq_sec: Option<i64>§reschedule_timeout_ms: Option<i64>§runtime_customizer_class_name: Option<String>§runtime_customizer_config: Option<HashMap<String, Value>>§sasl_jaas_client_allowed_ids: Option<String>§sasl_jaas_server_role_token_signer_secret_path: Option<String>§sasl_jaas_server_section_name: Option<String>§scheduler_class_name: Option<String>§secrets_provider_configurator_class_name: Option<String>§secrets_provider_configurator_config: Option<HashMap<String, String>>§state_storage_provider_implementation: Option<String>§state_storage_service_url: Option<String>§super_user_roles: Option<Vec<String>>§thread_container_factory: Option<Box<ThreadContainerFactory>>§tls_allow_insecure_connection: Option<bool>§tls_cert_refresh_check_duration_sec: Option<i64>§tls_certificate_file_path: Option<String>§tls_enable_hostname_verification: Option<bool>§tls_enabled: Option<bool>§tls_enabled_with_key_store: Option<bool>§tls_key_file_path: Option<String>§tls_key_store: Option<String>§tls_key_store_password: Option<String>§tls_key_store_type: Option<String>§tls_provider: Option<String>§tls_require_trusted_client_cert_on_connect: Option<bool>§tls_trust_certs_file_path: Option<String>§tls_trust_chain_bytes: Option<Vec<String>>§tls_trust_store: Option<String>§tls_trust_store_password: Option<String>§tls_trust_store_type: Option<String>§topic_compaction_frequency_sec: Option<i64>§upload_builtin_sinks_sources: Option<bool>§use_compacted_metadata_topic: Option<bool>§use_tls: Option<bool>§validate_connector_config: Option<bool>§web_service_tls_ciphers: Option<Vec<String>>§web_service_tls_protocols: Option<Vec<String>>§worker_hostname: Option<String>§worker_id: Option<String>§worker_list_probe_interval_sec: Option<i32>§worker_port: Option<i32>§worker_port_tls: Option<i32>§worker_web_address: Option<String>§worker_web_address_tls: Option<String>§zoo_keeper_allow_read_only_operations: Option<bool>§zoo_keeper_cache_expiry_seconds: Option<i32>§zoo_keeper_operation_timeout_seconds: Option<i32>§zoo_keeper_session_timeout_millis: Option<i64>

Implementations§

Trait Implementations§

source§

impl Clone for WorkerConfig

source§

fn clone(&self) -> WorkerConfig

Returns a copy of the value. Read more
1.0.0 · source§

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source. Read more
source§

impl Debug for WorkerConfig

source§

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter. Read more
source§

impl Default for WorkerConfig

source§

fn default() -> WorkerConfig

Returns the “default value” for a type. Read more
source§

impl<'de> Deserialize<'de> for WorkerConfig

source§

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>
where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer. Read more
source§

impl PartialEq for WorkerConfig

source§

fn eq(&self, other: &WorkerConfig) -> bool

This method tests for self and other values to be equal, and is used by ==.
1.0.0 · source§

fn ne(&self, other: &Rhs) -> bool

This method tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.
source§

impl Serialize for WorkerConfig

source§

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>
where __S: Serializer,

Serialize this value into the given Serde serializer. Read more
source§

impl StructuralPartialEq for WorkerConfig

Auto Trait Implementations§

Blanket Implementations§

source§

impl<T> Any for T
where T: 'static + ?Sized,

source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
source§

impl<T> Borrow<T> for T
where T: ?Sized,

source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
source§

impl<T> From<T> for T

source§

fn from(t: T) -> T

Returns the argument unchanged.

§

impl<T> Instrument for T

§

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided [Span], returning an Instrumented wrapper. Read more
§

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
source§

impl<T, U> Into<U> for T
where U: From<T>,

source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

source§

impl<T> ToOwned for T
where T: Clone,

§

type Owned = T

The resulting type after obtaining ownership.
source§

fn to_owned(&self) -> T

Creates owned data from borrowed data, usually by cloning. Read more
source§

fn clone_into(&self, target: &mut T)

Uses borrowed data to replace owned data, usually by cloning. Read more
source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

§

type Error = Infallible

The type returned in the event of a conversion error.
source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
§

impl<T> WithSubscriber for T

§

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a [WithDispatch] wrapper. Read more
§

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a [WithDispatch] wrapper. Read more
source§

impl<T> DeserializeOwned for T
where T: for<'de> Deserialize<'de>,