Struct WorkerConfig 

pub struct WorkerConfig {

    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

impl WorkerConfig

pub fn new() -> WorkerConfig

Trait Implementations

impl Clone for WorkerConfig

fn clone(&self) -> WorkerConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for WorkerConfig

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

Formats the value using the given formatter.

impl Default for WorkerConfig

fn default() -> WorkerConfig

Returns the “default value” for a type.

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

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for WorkerConfig

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

Tests for self and other values to be equal, and is used by ==.

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

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Serialize for WorkerConfig

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for WorkerConfig