Skip to content

Commit

Permalink
enhancement(websocket sink): Allow any data type depending on configu…
Browse files Browse the repository at this point in the history
…red codec

I had mistakenly thought this was done in #18060 but it
was not.

Signed-off-by: Jesse Szwedko <[email protected]>
  • Loading branch information
jszwedko committed Aug 17, 2023
1 parent 378926d commit b9e45f8
Show file tree
Hide file tree
Showing 2 changed files with 11 additions and 4 deletions.
2 changes: 1 addition & 1 deletion src/sinks/websocket/config.rs
Original file line number Diff line number Diff line change
Expand Up @@ -94,7 +94,7 @@ impl SinkConfig for WebSocketSinkConfig {
}

fn input(&self) -> Input {
Input::log()
Input::new(self.encoding.config().1.input_type())
}

fn acknowledgements(&self) -> &AcknowledgementsConfig {
Expand Down
13 changes: 10 additions & 3 deletions website/cue/reference/components/sinks/websocket.cue
Original file line number Diff line number Diff line change
Expand Up @@ -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: {
Expand Down

0 comments on commit b9e45f8

Please sign in to comment.