Skip to content

Commit 294c1dd

Browse files
chore(nats sink): Refactor to use StreamSink components (vectordotdev#18243)
* Move to stream based sink Signed-off-by: Stephen Wakely <[email protected]> * Add request settings Signed-off-by: Stephen Wakely <[email protected]> * Updated docs and comments Signed-off-by: Stephen Wakely <[email protected]> * Dont need to take metadata Signed-off-by: Stephen Wakely <[email protected]> * Clippy Signed-off-by: Stephen Wakely <[email protected]> * Made Subject a Template in config Signed-off-by: Stephen Wakely <[email protected]> --------- Signed-off-by: Stephen Wakely <[email protected]>
1 parent 7a1c49c commit 294c1dd

File tree

12 files changed

+1098
-756
lines changed

12 files changed

+1098
-756
lines changed

src/internal_events/mod.rs

-4
Original file line numberDiff line numberDiff line change
@@ -86,8 +86,6 @@ mod lua;
8686
mod metric_to_log;
8787
#[cfg(feature = "sources-mongodb_metrics")]
8888
mod mongodb_metrics;
89-
#[cfg(feature = "sinks-nats")]
90-
mod nats;
9189
#[cfg(feature = "sources-nginx_metrics")]
9290
mod nginx_metrics;
9391
mod open;
@@ -224,8 +222,6 @@ pub(crate) use self::loki::*;
224222
pub(crate) use self::lua::*;
225223
#[cfg(feature = "transforms-metric_to_log")]
226224
pub(crate) use self::metric_to_log::*;
227-
#[cfg(feature = "sinks-nats")]
228-
pub(crate) use self::nats::*;
229225
#[cfg(feature = "sources-nginx_metrics")]
230226
pub(crate) use self::nginx_metrics::*;
231227
pub(crate) use self::parser::*;

src/internal_events/nats.rs

-33
This file was deleted.

0 commit comments

Comments
 (0)