Skip to content

Commit 610d8dd

Browse files
test: Fix the integration tests
1 parent 45dfd7c commit 610d8dd

10 files changed

Lines changed: 270 additions & 931 deletions

File tree

rust/operator-binary/src/controller/build/role_group_builder.rs

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -234,7 +234,7 @@ impl<'a> RoleGroupBuilder<'a> {
234234
&self.resource_names.role_name,
235235
&self.resource_names.role_group_name,
236236
&self.cluster.image,
237-
&LOG_CONFIG_VOLUME_NAME,
237+
&CONFIG_VOLUME_NAME,
238238
&LOG_VOLUME_NAME,
239239
)
240240
});
@@ -433,10 +433,6 @@ impl<'a> RoleGroupBuilder<'a> {
433433

434434
new_container_builder(&v1alpha1::Container::OpenSearch.to_container_name())
435435
.image_from_product_image(&self.cluster.image)
436-
.command(vec![format!(
437-
"{opensearch_home}/opensearch-docker-entrypoint.sh"
438-
)])
439-
.args(self.role_group_config.cli_overrides_to_vec())
440436
.command(vec![
441437
"/bin/bash".to_string(),
442438
"-x".to_string(),
@@ -448,8 +444,12 @@ impl<'a> RoleGroupBuilder<'a> {
448444
"{COMMON_BASH_TRAP_FUNCTIONS}\n\
449445
{remove_vector_shutdown_file_command}\n\
450446
prepare_signal_handlers\n\
447+
if command --search containerdebug >/dev/null 2>&1; then\n\
451448
containerdebug --output={STACKABLE_LOG_DIR}/containerdebug-state.json --loop &\n\
452-
{opensearch_home}/opensearch-docker-entrypoint.sh {extra_args} &\n\
449+
else\n\
450+
echo >&2 \"containerdebug not installed; Proceed without it.\"\n\
451+
fi\n\
452+
./opensearch-docker-entrypoint.sh {extra_args} &\n\
453453
wait_for_termination $!\n\
454454
{create_vector_shutdown_file_command}",
455455
extra_args = self.role_group_config.cli_overrides_to_vec().join(" "),

tests/templates/kuttl/logging/10_opensearch-vector-aggregator-values.yaml.j2

Lines changed: 24 additions & 64 deletions
Original file line numberDiff line numberDiff line change
@@ -22,91 +22,50 @@ customConfig:
2222
transforms:
2323
validEvents:
2424
type: filter
25-
inputs: [vector]
25+
inputs:
26+
- vector
2627
condition: is_null(.errors)
27-
filteredAutomaticLogConfigMasterHbase:
28-
type: filter
29-
inputs: [validEvents]
30-
condition: >-
31-
.pod == "test-opensearch-master-automatic-log-config-0" &&
32-
.container == "opensearch"
33-
filteredAutomaticLogConfigMasterVector:
34-
type: filter
35-
inputs: [validEvents]
36-
condition: >-
37-
.pod == "test-opensearch-master-automatic-log-config-0" &&
38-
.container == "vector"
39-
filteredCustomLogConfigMasterHbase:
40-
type: filter
41-
inputs: [validEvents]
42-
condition: >-
43-
.pod == "test-opensearch-master-custom-log-config-0" &&
44-
.container == "opensearch"
45-
filteredCustomLogConfigMasterVector:
46-
type: filter
47-
inputs: [validEvents]
48-
condition: >-
49-
.pod == "test-opensearch-master-custom-log-config-0" &&
50-
.container == "vector"
51-
filteredAutomaticLogConfigRegionserverHbase:
28+
filteredAutomaticLogConfigOpenSearch:
5229
type: filter
53-
inputs: [validEvents]
54-
condition: >-
55-
.pod == "test-opensearch-regionserver-automatic-log-config-0" &&
56-
.container == "opensearch"
57-
filteredAutomaticLogConfigRegionserverVector:
58-
type: filter
59-
inputs: [validEvents]
60-
condition: >-
61-
.pod == "test-opensearch-regionserver-automatic-log-config-0" &&
62-
.container == "vector"
63-
filteredCustomLogConfigRegionserverHbase:
64-
type: filter
65-
inputs: [validEvents]
66-
condition: >-
67-
.pod == "test-opensearch-regionserver-custom-log-config-0" &&
68-
.container == "opensearch"
69-
filteredCustomLogConfigRegionserverVector:
70-
type: filter
71-
inputs: [validEvents]
72-
condition: >-
73-
.pod == "test-opensearch-regionserver-custom-log-config-0" &&
74-
.container == "vector"
75-
filteredAutomaticLogConfigRestserverHbase:
76-
type: filter
77-
inputs: [validEvents]
30+
inputs:
31+
- validEvents
7832
condition: >-
79-
.pod == "test-opensearch-restserver-automatic-log-config-0" &&
33+
.pod == "opensearch-nodes-automatic-0" &&
8034
.container == "opensearch"
81-
filteredAutomaticLogConfigRestserverVector:
35+
filteredAutomaticLogConfigVector:
8236
type: filter
83-
inputs: [validEvents]
37+
inputs:
38+
- validEvents
8439
condition: >-
85-
.pod == "test-opensearch-restserver-automatic-log-config-0" &&
40+
.pod == "opensearch-nodes-automatic-0" &&
8641
.container == "vector"
87-
filteredCustomLogConfigRestserverHbase:
42+
filteredCustomLogConfigOpenSearch:
8843
type: filter
89-
inputs: [validEvents]
44+
inputs:
45+
- validEvents
9046
condition: >-
91-
.pod == "test-opensearch-restserver-custom-log-config-0" &&
47+
.pod == "opensearch-nodes-custom-0" &&
9248
.container == "opensearch"
93-
filteredCustomLogConfigRestserverVector:
49+
filteredCustomLogConfigVector:
9450
type: filter
95-
inputs: [validEvents]
51+
inputs:
52+
- validEvents
9653
condition: >-
97-
.pod == "test-opensearch-restserver-custom-log-config-0" &&
54+
.pod == "opensearch-nodes-custom-0" &&
9855
.container == "vector"
9956
filteredInvalidEvents:
10057
type: filter
101-
inputs: [vector]
58+
inputs:
59+
- vector
10260
condition: |-
10361
.timestamp == from_unix_timestamp!(0) ||
10462
is_null(.level) ||
10563
is_null(.logger) ||
10664
is_null(.message)
10765
sinks:
10866
test:
109-
inputs: [filtered*]
67+
inputs:
68+
- filtered*
11069
type: blackhole
11170
stdout:
11271
inputs:
@@ -116,7 +75,8 @@ customConfig:
11675
codec: json
11776
{% if lookup('env', 'VECTOR_AGGREGATOR') %}
11877
aggregator:
119-
inputs: [vector]
78+
inputs:
79+
- vector
12080
type: vector
12181
address: {{ lookup('env', 'VECTOR_AGGREGATOR') }}
12282
buffer:

0 commit comments

Comments
 (0)