Loading pkgs/tools/misc/vector/default.nix +5 −0 Original line number Diff line number Diff line Loading @@ -45,6 +45,11 @@ rustPlatform.buildRustPackage { sha256 = pinData.sha256; }; patches = [ # replace with https://github.com/vectordotdev/vector/pull/15093 when ready ./fix-for-rust-1.66.diff ]; cargoSha256 = pinData.cargoSha256; nativeBuildInputs = [ pkg-config cmake perl ]; buildInputs = [ oniguruma openssl protobuf rdkafka zstd ] Loading pkgs/tools/misc/vector/fix-for-rust-1.66.diff 0 → 100644 +13 −0 Original line number Diff line number Diff line diff --git a/src/sources/aws_kinesis_firehose/filters.rs b/src/sources/aws_kinesis_firehose/filters.rs index ac33682..fe65ed4 100644 --- a/src/sources/aws_kinesis_firehose/filters.rs +++ b/src/sources/aws_kinesis_firehose/filters.rs @@ -28,7 +28,7 @@ pub fn firehose( acknowledgements: bool, out: SourceSender, log_namespace: LogNamespace, -) -> impl Filter<Extract = impl warp::Reply, Error = Infallible> + Clone { +) -> impl Filter<Extract = (impl warp::Reply,), Error = Infallible> + Clone { let bytes_received = register!(BytesReceived::from(Protocol::HTTP)); let context = handlers::Context { compression: record_compression, Loading
pkgs/tools/misc/vector/default.nix +5 −0 Original line number Diff line number Diff line Loading @@ -45,6 +45,11 @@ rustPlatform.buildRustPackage { sha256 = pinData.sha256; }; patches = [ # replace with https://github.com/vectordotdev/vector/pull/15093 when ready ./fix-for-rust-1.66.diff ]; cargoSha256 = pinData.cargoSha256; nativeBuildInputs = [ pkg-config cmake perl ]; buildInputs = [ oniguruma openssl protobuf rdkafka zstd ] Loading
pkgs/tools/misc/vector/fix-for-rust-1.66.diff 0 → 100644 +13 −0 Original line number Diff line number Diff line diff --git a/src/sources/aws_kinesis_firehose/filters.rs b/src/sources/aws_kinesis_firehose/filters.rs index ac33682..fe65ed4 100644 --- a/src/sources/aws_kinesis_firehose/filters.rs +++ b/src/sources/aws_kinesis_firehose/filters.rs @@ -28,7 +28,7 @@ pub fn firehose( acknowledgements: bool, out: SourceSender, log_namespace: LogNamespace, -) -> impl Filter<Extract = impl warp::Reply, Error = Infallible> + Clone { +) -> impl Filter<Extract = (impl warp::Reply,), Error = Infallible> + Clone { let bytes_received = register!(BytesReceived::from(Protocol::HTTP)); let context = handlers::Context { compression: record_compression,