enhancement(websocket sink): Allow any data type depending on configu…

…red codec (vectordotdev#18295) * enhancement(websocket sink): Allow any data type depending on configured codec I had mistakenly thought this was done in vectordotdev#18060 but it was not. Signed-off-by: Jesse Szwedko <jesse.szwedko@datadoghq.com> * Fix input type determination Signed-off-by: Jesse Szwedko <jesse.szwedko@datadoghq.com> --------- Signed-off-by: Jesse Szwedko <jesse.szwedko@datadoghq.com>
aholmberg · Aug 23, 2023 · 1c303e8 · 1c303e8
1 parent e15aec7
commit 1c303e8
Show file tree

Hide file tree

Showing 2 changed files with 11 additions and 4 deletions.
diff --git a/src/sinks/websocket/config.rs b/src/sinks/websocket/config.rs
@@ -94,7 +94,7 @@ impl SinkConfig for WebSocketSinkConfig {
     }
 
     fn input(&self) -> Input {
-        Input::log()
+        Input::new(self.encoding.config().input_type())
     }
 
     fn acknowledgements(&self) -> &AcknowledgementsConfig {

diff --git a/website/cue/reference/components/sinks/websocket.cue b/website/cue/reference/components/sinks/websocket.cue
@@ -67,9 +67,16 @@ components: sinks: websocket: {
 	}
 
 	input: {
-		logs:    true
-		metrics: null
-		traces:  false
+		logs: true
+		metrics: {
+			counter:      true
+			distribution: true
+			gauge:        true
+			histogram:    true
+			summary:      true
+			set:          true
+		}
+		traces: true
 	}
 
 	telemetry: metrics: {