rustfs_config/constants/
targets.rs

1//  Copyright 2024 RustFS Team
2//
3//  Licensed under the Apache License, Version 2.0 (the "License");
4//  you may not use this file except in compliance with the License.
5//  You may obtain a copy of the License at
6//
7//      http://www.apache.org/licenses/LICENSE-2.0
8//
9//  Unless required by applicable law or agreed to in writing, software
10//  distributed under the License is distributed on an "AS IS" BASIS,
11//  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
12//  See the License for the specific language governing permissions and
13//  limitations under the License.
14
15pub const WEBHOOK_ENDPOINT: &str = "endpoint";
16pub const WEBHOOK_AUTH_TOKEN: &str = "auth_token";
17pub const WEBHOOK_CLIENT_CERT: &str = "client_cert";
18pub const WEBHOOK_CLIENT_KEY: &str = "client_key";
19pub const WEBHOOK_CLIENT_CA: &str = "client_ca";
20pub const WEBHOOK_SKIP_TLS_VERIFY: &str = "skip_tls_verify";
21pub const WEBHOOK_BATCH_SIZE: &str = "batch_size";
22pub const WEBHOOK_QUEUE_LIMIT: &str = "queue_limit";
23pub const WEBHOOK_QUEUE_DIR: &str = "queue_dir";
24pub const WEBHOOK_MAX_RETRY: &str = "max_retry";
25pub const WEBHOOK_RETRY_INTERVAL: &str = "retry_interval";
26pub const WEBHOOK_HTTP_TIMEOUT: &str = "http_timeout";
27
28pub const MQTT_BROKER: &str = "broker";
29pub const MQTT_TOPIC: &str = "topic";
30pub const MQTT_QOS: &str = "qos";
31pub const MQTT_USERNAME: &str = "username";
32pub const MQTT_PASSWORD: &str = "password";
33pub const MQTT_RECONNECT_INTERVAL: &str = "reconnect_interval";
34pub const MQTT_KEEP_ALIVE_INTERVAL: &str = "keep_alive_interval";
35pub const MQTT_QUEUE_DIR: &str = "queue_dir";
36pub const MQTT_QUEUE_LIMIT: &str = "queue_limit";
37pub const MQTT_TLS_POLICY: &str = "tls_policy";
38pub const MQTT_TLS_CA: &str = "tls_ca";
39pub const MQTT_TLS_CLIENT_CERT: &str = "tls_client_cert";
40pub const MQTT_TLS_CLIENT_KEY: &str = "tls_client_key";
41pub const MQTT_TLS_TRUST_LEAF_AS_CA: &str = "tls_trust_leaf_as_ca";
42pub const MQTT_WS_PATH_ALLOWLIST: &str = "ws_path_allowlist";
43pub const KAFKA_BROKERS: &str = "brokers";
44pub const KAFKA_TOPIC: &str = "topic";
45pub const KAFKA_ACKS: &str = "acks";
46pub const KAFKA_QUEUE_DIR: &str = "queue_dir";
47pub const KAFKA_QUEUE_LIMIT: &str = "queue_limit";
48pub const KAFKA_TLS_ENABLE: &str = "tls_enable";
49pub const KAFKA_TLS_CA: &str = "tls_ca";
50pub const KAFKA_TLS_CLIENT_CERT: &str = "tls_client_cert";
51pub const KAFKA_TLS_CLIENT_KEY: &str = "tls_client_key";
52pub const KAFKA_SASL_ENABLE: &str = "sasl_enable";
53pub const KAFKA_SASL_MECHANISM: &str = "sasl_mechanism";
54pub const KAFKA_SASL_USERNAME: &str = "sasl_username";
55pub const KAFKA_SASL_PASSWORD: &str = "sasl_password";
56
57pub const AMQP_URL: &str = "url";
58pub const AMQP_EXCHANGE: &str = "exchange";
59pub const AMQP_ROUTING_KEY: &str = "routing_key";
60pub const AMQP_MANDATORY: &str = "mandatory";
61pub const AMQP_PERSISTENT: &str = "persistent";
62pub const AMQP_USERNAME: &str = "username";
63pub const AMQP_PASSWORD: &str = "password";
64pub const AMQP_TLS_CA: &str = "tls_ca";
65pub const AMQP_TLS_CLIENT_CERT: &str = "tls_client_cert";
66pub const AMQP_TLS_CLIENT_KEY: &str = "tls_client_key";
67pub const AMQP_QUEUE_DIR: &str = "queue_dir";
68pub const AMQP_QUEUE_LIMIT: &str = "queue_limit";
69
70pub const NATS_ADDRESS: &str = "address";
71pub const NATS_SUBJECT: &str = "subject";
72pub const NATS_USERNAME: &str = "username";
73pub const NATS_PASSWORD: &str = "password";
74pub const NATS_TOKEN: &str = "token";
75pub const NATS_CREDENTIALS_FILE: &str = "credentials_file";
76pub const NATS_TLS_CA: &str = "tls_ca";
77pub const NATS_TLS_CLIENT_CERT: &str = "tls_client_cert";
78pub const NATS_TLS_CLIENT_KEY: &str = "tls_client_key";
79pub const NATS_TLS_REQUIRED: &str = "tls_required";
80pub const NATS_QUEUE_DIR: &str = "queue_dir";
81pub const NATS_QUEUE_LIMIT: &str = "queue_limit";
82pub const NATS_JETSTREAM_ENABLE: &str = "jetstream_enable";
83pub const NATS_JETSTREAM_STREAM_NAME: &str = "jetstream_stream_name";
84pub const NATS_JETSTREAM_ACK_TIMEOUT_SECS: &str = "jetstream_ack_timeout_secs";
85
86pub const NATS_JETSTREAM_ACK_TIMEOUT_DEFAULT_SECS: u64 = 30;
87pub const NATS_JETSTREAM_ACK_TIMEOUT_MIN_SECS: u64 = 10;
88pub const NATS_JETSTREAM_ACK_TIMEOUT_MAX_SECS: u64 = 120;
89
90pub const PULSAR_BROKER: &str = "broker";
91pub const PULSAR_TOPIC: &str = "topic";
92pub const PULSAR_AUTH_TOKEN: &str = "auth_token";
93pub const PULSAR_USERNAME: &str = "username";
94pub const PULSAR_PASSWORD: &str = "password";
95pub const PULSAR_TLS_CA: &str = "tls_ca";
96pub const PULSAR_TLS_ALLOW_INSECURE: &str = "tls_allow_insecure";
97pub const PULSAR_TLS_HOSTNAME_VERIFICATION: &str = "tls_hostname_verification";
98pub const PULSAR_QUEUE_DIR: &str = "queue_dir";
99pub const PULSAR_QUEUE_LIMIT: &str = "queue_limit";
100
101pub const BASE_DSN_STRING: &str = "dsn_string";
102
103pub const MYSQL_DSN_STRING: &str = BASE_DSN_STRING;
104pub const MYSQL_TABLE: &str = "table";
105pub const MYSQL_FORMAT: &str = "format";
106pub const MYSQL_TLS_CA: &str = "tls_ca";
107pub const MYSQL_TLS_CLIENT_CERT: &str = "tls_client_cert";
108pub const MYSQL_TLS_CLIENT_KEY: &str = "tls_client_key";
109pub const MYSQL_QUEUE_DIR: &str = "queue_dir";
110pub const MYSQL_QUEUE_LIMIT: &str = "queue_limit";
111pub const MYSQL_MAX_OPEN_CONNECTIONS: &str = "max_open_connections";
112
113pub const REDIS_URL: &str = "url";
114pub const REDIS_CHANNEL: &str = "channel";
115pub const REDIS_USERNAME: &str = "username";
116pub const REDIS_PASSWORD: &str = "password";
117pub const REDIS_KEEP_ALIVE_INTERVAL: &str = "keep_alive_interval";
118pub const REDIS_QUEUE_DIR: &str = "queue_dir";
119pub const REDIS_QUEUE_LIMIT: &str = "queue_limit";
120pub const REDIS_MAX_RETRY_ATTEMPTS: &str = "max_retry_attempts";
121pub const REDIS_RECONNECT_RETRY_ATTEMPTS: &str = "reconnect_retry_attempts";
122pub const REDIS_MIN_RETRY_DELAY: &str = "min_retry_delay";
123pub const REDIS_MAX_RETRY_DELAY: &str = "max_retry_delay";
124pub const REDIS_CONNECTION_TIMEOUT: &str = "connection_timeout";
125pub const REDIS_RESPONSE_TIMEOUT: &str = "response_timeout";
126pub const REDIS_PIPELINE_BUFFER_SIZE: &str = "pipeline_buffer_size";
127pub const REDIS_TLS_POLICY: &str = "tls_policy";
128pub const REDIS_TLS_CA: &str = "tls_ca";
129pub const REDIS_TLS_CLIENT_CERT: &str = "tls_client_cert";
130pub const REDIS_TLS_CLIENT_KEY: &str = "tls_client_key";
131pub const REDIS_TLS_ALLOW_INSECURE: &str = "tls_allow_insecure";
132
133pub const POSTGRES_DSN_STRING: &str = BASE_DSN_STRING;
134pub const POSTGRES_TABLE: &str = "table";
135pub const POSTGRES_FORMAT: &str = "format";
136pub const POSTGRES_TLS_REQUIRED: &str = "tls_required";
137pub const POSTGRES_TLS_CA: &str = "tls_ca";
138pub const POSTGRES_TLS_CLIENT_CERT: &str = "tls_client_cert";
139pub const POSTGRES_TLS_CLIENT_KEY: &str = "tls_client_key";
140pub const POSTGRES_QUEUE_DIR: &str = "queue_dir";
141pub const POSTGRES_QUEUE_LIMIT: &str = "queue_limit";
142
143/// Environment variable controlling whether target queue files are Snappy-compressed.
144/// Applies to both notify and audit target queue stores.
145pub const ENV_TARGET_STORE_COMPRESS: &str = "RUSTFS_TARGET_STORE_COMPRESS";
146
147/// Queue-store compression is enabled by default to reduce disk footprint.
148pub const DEFAULT_TARGET_STORE_COMPRESS: bool = true;
rustfs_config/constants/targets.rs

rustfs_config/constants/
targets.rs
