another attempt for windows

Author: pront

src/lib.rs

@@ -21,7 +21,7 @@
 
 //! The main library to support building Vector.
 
-#[cfg(feature = "sinks-socket")]
+#[cfg(all(unix, feature = "sinks-socket"))]
 #[macro_use]
 extern crate cfg_if;
 #[macro_use]

src/sinks/socket.rs

@@ -1,11 +1,10 @@
+use std::path::PathBuf;
 use vector_lib::codecs::{
     encoding::{Framer, FramingConfig},
     TextSerializerConfig,
 };
 use vector_lib::configurable::configurable_component;
 
-#[cfg(unix)]
-use crate::sinks::util::unix::UnixSinkConfig;
 use crate::{
     codecs::{Encoder, EncodingConfig, EncodingConfigWithFraming, SinkType},
     config::{AcknowledgementsConfig, GenerateConfig, Input, SinkConfig, SinkContext},
@@ -83,6 +82,17 @@ pub struct UnixMode {
     encoding: EncodingConfigWithFraming,
 }
 
+/// A Unix Domain Socket sink.
+#[configurable_component]
+#[derive(Clone, Debug)]
+pub struct UnixSinkConfig {
+    /// The Unix socket path.
+    ///
+    /// This should be an absolute path.
+    #[configurable(metadata(docs::examples = "/path/to/socket"))]
+    pub path: PathBuf,
+}
+
 impl GenerateConfig for SocketSinkConfig {
     fn generate_config() -> toml::Value {
         toml::from_str(

src/sinks/util/unix.rs

@@ -16,13 +16,12 @@ use tokio::{
     time::sleep,
 };
 use tokio_util::codec::Encoder;
+use vector_lib::internal_event::{BytesSent, Protocol};
 use vector_lib::json_size::JsonSize;
-use vector_lib::{
-    configurable::configurable_component,
-    internal_event::{BytesSent, Protocol},
-};
 use vector_lib::{ByteSizeOf, EstimatedJsonEncodedSizeOf};
 
+use super::datagram::{send_datagrams, DatagramSocket};
+use crate::sinks::socket::UnixSinkConfig;
 use crate::{
     codecs::Transformer,
     event::{Event, Finalizable},
@@ -42,8 +41,6 @@ use crate::{
     },
 };
 
-use super::datagram::{send_datagrams, DatagramSocket};
-
 #[derive(Debug, Snafu)]
 pub enum UnixError {
     #[snafu(display("Failed connecting to socket at path {}: {}", path.display(), source))]
@@ -56,17 +53,6 @@ pub enum UnixError {
     FailedToBind { source: std::io::Error },
 }
 
-/// A Unix Domain Socket sink.
-#[configurable_component]
-#[derive(Clone, Debug)]
-pub struct UnixSinkConfig {
-    /// The Unix socket path.
-    ///
-    /// This should be an absolute path.
-    #[configurable(metadata(docs::examples = "/path/to/socket"))]
-    pub path: PathBuf,
-}
-
 impl UnixSinkConfig {
     pub const fn new(path: PathBuf) -> Self {
         Self { path }