chore(nats sink): Refactor to use StreamSink components (#18243)

* Move to stream based sink Signed-off-by: Stephen Wakely <fungus.humungus@gmail.com> * Add request settings Signed-off-by: Stephen Wakely <fungus.humungus@gmail.com> * Updated docs and comments Signed-off-by: Stephen Wakely <fungus.humungus@gmail.com> * Dont need to take metadata Signed-off-by: Stephen Wakely <fungus.humungus@gmail.com> * Clippy Signed-off-by: Stephen Wakely <fungus.humungus@gmail.com> * Made Subject a Template in config Signed-off-by: Stephen Wakely <fungus.humungus@gmail.com> --------- Signed-off-by: Stephen Wakely <fungus.humungus@gmail.com>
vectordotdev · Aug 17, 2023 · 294c1dd · 294c1dd
1 parent 7a1c49c
commit 294c1dd
Show file tree

Hide file tree

Showing 12 changed files with 1,098 additions and 756 deletions.
diff --git a/src/internal_events/mod.rs b/src/internal_events/mod.rs
@@ -86,8 +86,6 @@ mod lua;
 mod metric_to_log;
 #[cfg(feature = "sources-mongodb_metrics")]
 mod mongodb_metrics;
-#[cfg(feature = "sinks-nats")]
-mod nats;
 #[cfg(feature = "sources-nginx_metrics")]
 mod nginx_metrics;
 mod open;
@@ -224,8 +222,6 @@ pub(crate) use self::loki::*;
 pub(crate) use self::lua::*;
 #[cfg(feature = "transforms-metric_to_log")]
 pub(crate) use self::metric_to_log::*;
-#[cfg(feature = "sinks-nats")]
-pub(crate) use self::nats::*;
 #[cfg(feature = "sources-nginx_metrics")]
 pub(crate) use self::nginx_metrics::*;
 pub(crate) use self::parser::*;

diff --git a/src/internal_events/nats.rs b/src/internal_events/nats.rs