Skip to content

Commit 8397acc

Browse files
Add support for DEPRECATION log level
1 parent 7e987a3 commit 8397acc

2 files changed

Lines changed: 36 additions & 3 deletions

File tree

rust/operator-binary/src/controller/build/product_logging/vector-test.yaml

Lines changed: 31 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -297,6 +297,37 @@ tests:
297297
"timestamp": t'2025-10-01T10:47:28.582Z'
298298
}
299299
300+
assert_eq!(expected_log_event, .)
301+
- name: Test opensearch_server log entry with DEPRECATION level
302+
inputs:
303+
- type: log
304+
insert_at: processed_files_opensearch_server
305+
log_fields:
306+
file: /stackable/log/opensearch/opensearch_server.json
307+
message: |
308+
{"type": "server", "timestamp": "2025-10-01T12:47:28,582Z", "level": "DEPRECATION", "component": "o.o.d.t.TransportInfo", "cluster.name": "opensearch", "node.name": "opensearch-nodes-cluster-manager-0", "message": "transport.publish_address was printed as [ip:port] instead of [hostname/ip:port]. This format is deprecated and will change to [hostname/ip:port] in a future version. Use -Dopensearch.transport.cname_in_publish_address=true to enforce non-deprecated formatting.", "cluster.uuid": "Jh1D6YAhTmyzkHI7vM1WWw", "node.id": "sk-r0P_TTYuPqaamTFbjKg" }
309+
pod: opensearch-nodes-cluster-manager-0
310+
source_type: file
311+
timestamp: 2025-10-01T12:47:29.473487331Z
312+
outputs:
313+
- extract_from: extended_logs
314+
conditions:
315+
- type: vrl
316+
source: |
317+
expected_log_event = {
318+
"cluster": "opensearch",
319+
"container": "opensearch",
320+
"file": "opensearch_server.json",
321+
"level": "WARN",
322+
"logger": "o.o.d.t.TransportInfo",
323+
"message": "transport.publish_address was printed as [ip:port] instead of [hostname/ip:port]. This format is deprecated and will change to [hostname/ip:port] in a future version. Use -Dopensearch.transport.cname_in_publish_address=true to enforce non-deprecated formatting.",
324+
"namespace": "default",
325+
"pod": "opensearch-nodes-cluster-manager-0",
326+
"role": "nodes",
327+
"roleGroup": "cluster-manager",
328+
"timestamp": t'2025-10-01T10:47:28.582Z'
329+
}
330+
300331
assert_eq!(expected_log_event, .)
301332
- name: Test opensearch_server log entry with unknown level
302333
inputs:

rust/operator-binary/src/controller/build/product_logging/vector.yaml

Lines changed: 5 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -68,10 +68,12 @@ transforms:
6868
level, err = string(event.level)
6969
if err != null {
7070
.errors = push(.errors, "Level not found, using \"" + .level + "\" instead.")
71-
} else if !includes(["TRACE", "DEBUG", "INFO", "WARN", "ERROR", "FATAL"], level) {
72-
.errors = push(.errors, "Level \"" + level + "\" unknown, using \"" + .level + "\" instead.")
73-
} else {
71+
} else if level == "DEPRECATION" {
72+
.level = "WARN"
73+
} else if includes(["TRACE", "DEBUG", "INFO", "WARN", "ERROR", "FATAL"], level) {
7474
.level = level
75+
} else {
76+
.errors = push(.errors, "Level \"" + level + "\" unknown, using \"" + .level + "\" instead.")
7577
}
7678
7779
.message, err = string(event.message)

0 commit comments

Comments
 (0)