Skip to content

Commit 1c303e8

Browse files
authored
enhancement(websocket sink): Allow any data type depending on configured codec (#18295)
* enhancement(websocket sink): Allow any data type depending on configured codec I had mistakenly thought this was done in #18060 but it was not. Signed-off-by: Jesse Szwedko <[email protected]> * Fix input type determination Signed-off-by: Jesse Szwedko <[email protected]> --------- Signed-off-by: Jesse Szwedko <[email protected]>
1 parent e15aec7 commit 1c303e8

File tree

2 files changed

+11
-4
lines changed

2 files changed

+11
-4
lines changed

src/sinks/websocket/config.rs

+1-1
Original file line numberDiff line numberDiff line change
@@ -94,7 +94,7 @@ impl SinkConfig for WebSocketSinkConfig {
9494
}
9595

9696
fn input(&self) -> Input {
97-
Input::log()
97+
Input::new(self.encoding.config().input_type())
9898
}
9999

100100
fn acknowledgements(&self) -> &AcknowledgementsConfig {

website/cue/reference/components/sinks/websocket.cue

+10-3
Original file line numberDiff line numberDiff line change
@@ -67,9 +67,16 @@ components: sinks: websocket: {
6767
}
6868

6969
input: {
70-
logs: true
71-
metrics: null
72-
traces: false
70+
logs: true
71+
metrics: {
72+
counter: true
73+
distribution: true
74+
gauge: true
75+
histogram: true
76+
summary: true
77+
set: true
78+
}
79+
traces: true
7380
}
7481

7582
telemetry: metrics: {

0 commit comments

Comments
 (0)