Skip to content

Commit d6943fc

Browse files
committed
fte: refactor to reuse crd::s3 anc move resolved struct out of the crd module
1 parent 4d32b6f commit d6943fc

8 files changed

Lines changed: 599 additions & 656 deletions

File tree

deploy/helm/trino-operator/crds/crds.yaml

Lines changed: 0 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -251,16 +251,6 @@ spec:
251251
description: IAM role to assume for S3 access.
252252
nullable: true
253253
type: string
254-
maxErrorRetries:
255-
description: Maximum number of times the S3 client should retry a request.
256-
format: uint32
257-
minimum: 0.0
258-
nullable: true
259-
type: integer
260-
uploadPartSize:
261-
description: Part data size for S3 multi-part upload.
262-
nullable: true
263-
type: string
264254
required:
265255
- connection
266256
type: object

rust/operator-binary/src/command.rs

Lines changed: 3 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -9,23 +9,22 @@ use stackable_operator::{
99
use crate::{
1010
authentication::TrinoAuthenticationConfig,
1111
catalog::config::CatalogConfig,
12-
config::client_protocol,
12+
config::{client_protocol, fault_tolerant_execution},
1313
controller::{STACKABLE_LOG_CONFIG_DIR, STACKABLE_LOG_DIR},
1414
crd::{
1515
CONFIG_DIR_NAME, Container, EXCHANGE_MANAGER_PROPERTIES, LOG_PROPERTIES,
1616
RW_CONFIG_DIR_NAME, SPOOLING_MANAGER_PROPERTIES, STACKABLE_CLIENT_TLS_DIR,
1717
STACKABLE_INTERNAL_TLS_DIR, STACKABLE_MOUNT_INTERNAL_TLS_DIR,
1818
STACKABLE_MOUNT_SERVER_TLS_DIR, STACKABLE_SERVER_TLS_DIR, STACKABLE_TLS_STORE_PASSWORD,
19-
SYSTEM_TRUST_STORE, SYSTEM_TRUST_STORE_PASSWORD, TrinoRole,
20-
fault_tolerant_execution::ResolvedFaultTolerantExecutionConfig, v1alpha1,
19+
SYSTEM_TRUST_STORE, SYSTEM_TRUST_STORE_PASSWORD, TrinoRole, v1alpha1,
2120
},
2221
};
2322

2423
pub fn container_prepare_args(
2524
trino: &v1alpha1::TrinoCluster,
2625
catalogs: &[CatalogConfig],
2726
merged_config: &v1alpha1::TrinoConfig,
28-
resolved_fte_config: &Option<ResolvedFaultTolerantExecutionConfig>,
27+
resolved_fte_config: &Option<fault_tolerant_execution::ResolvedFaultTolerantExecutionConfig>,
2928
resolved_spooling_config: &Option<client_protocol::ResolvedClientProtocolConfig>,
3029
) -> Vec<String> {
3130
let mut args = vec![];

rust/operator-binary/src/config/client_protocol.rs

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -137,8 +137,6 @@ mod tests {
137137
),
138138
iam_role: None,
139139
external_id: None,
140-
max_error_retries: None,
141-
upload_part_size: None,
142140
}),
143141
});
144142

0 commit comments

Comments
 (0)