chore(deps): Bump tokio-util from 0.6.9 to 0.7.0 (#3743)

Bumps [tokio-util](https://github.com/tokio-rs/tokio) from 0.6.9 to 0.7.0.
- [Release notes](https://github.com/tokio-rs/tokio/releases)
- [Commits](https://github.com/tokio-rs/tokio/commits)

---
updated-dependencies:
- dependency-name: tokio-util
  dependency-type: direct:production
  update-type: version-update:semver-minor
...

Signed-off-by: dependabot[bot] <support@github.com>

Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>
pull/24376/head
dependabot[bot] 2022-02-15 11:33:41 +00:00 committed by GitHub
parent 4db27eec68
commit 89105ccfab
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
12 changed files with 43 additions and 27 deletions

47
Cargo.lock generated
View File

@ -1016,7 +1016,7 @@ dependencies = [
"test_helpers",
"time 0.1.0",
"tokio",
"tokio-util",
"tokio-util 0.7.0",
"trace",
"tracker",
"uuid",
@ -1532,7 +1532,7 @@ dependencies = [
"thiserror",
"tokio",
"tokio-stream",
"tokio-util",
"tokio-util 0.7.0",
"tonic",
"tonic-build",
"tonic-reflection",
@ -1564,7 +1564,7 @@ dependencies = [
"indexmap",
"slab",
"tokio",
"tokio-util",
"tokio-util 0.6.9",
"tracing",
]
@ -1929,7 +1929,7 @@ dependencies = [
"time 0.1.0",
"tokio",
"tokio-stream",
"tokio-util",
"tokio-util 0.7.0",
"tonic",
"tonic-health",
"tonic-reflection",
@ -2054,7 +2054,7 @@ dependencies = [
"thiserror",
"time 0.1.0",
"tokio",
"tokio-util",
"tokio-util 0.7.0",
"tonic",
"trace",
"uuid",
@ -2351,7 +2351,7 @@ dependencies = [
"thiserror",
"tokio",
"tokio-native-tls",
"tokio-util",
"tokio-util 0.6.9",
"tower",
"tower-http",
"tracing",
@ -2408,7 +2408,7 @@ dependencies = [
"smallvec",
"thiserror",
"tokio",
"tokio-util",
"tokio-util 0.6.9",
"tracing",
]
@ -3079,7 +3079,7 @@ dependencies = [
"snafu",
"tempfile",
"tokio",
"tokio-util",
"tokio-util 0.7.0",
"walkdir",
"workspace-hack",
]
@ -3813,7 +3813,7 @@ dependencies = [
"test_helpers",
"tokio",
"tokio-stream",
"tokio-util",
"tokio-util 0.7.0",
"trace",
"workspace-hack",
]
@ -4063,7 +4063,7 @@ dependencies = [
"tokio",
"tokio-native-tls",
"tokio-rustls",
"tokio-util",
"tokio-util 0.6.9",
"url",
"wasm-bindgen",
"wasm-bindgen-futures",
@ -4608,7 +4608,7 @@ dependencies = [
"test_helpers",
"time 0.1.0",
"tokio",
"tokio-util",
"tokio-util 0.7.0",
"trace",
"tracker",
"uuid",
@ -5275,6 +5275,20 @@ dependencies = [
"tokio",
]
[[package]]
name = "tokio-util"
version = "0.7.0"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "64910e1b9c1901aaf5375561e35b9c057d95ff41a44ede043a03e09279eabaf1"
dependencies = [
"bytes",
"futures-core",
"futures-sink",
"log",
"pin-project-lite",
"tokio",
]
[[package]]
name = "toml"
version = "0.5.8"
@ -5307,7 +5321,7 @@ dependencies = [
"prost-derive",
"tokio",
"tokio-stream",
"tokio-util",
"tokio-util 0.6.9",
"tower",
"tower-layer",
"tower-service",
@ -5372,7 +5386,7 @@ dependencies = [
"slab",
"tokio",
"tokio-stream",
"tokio-util",
"tokio-util 0.6.9",
"tower-layer",
"tower-service",
"tracing",
@ -5555,7 +5569,7 @@ dependencies = [
"pin-project",
"time 0.1.0",
"tokio",
"tokio-util",
"tokio-util 0.7.0",
"workspace-hack",
]
@ -6022,7 +6036,8 @@ dependencies = [
"syn",
"tokio",
"tokio-stream",
"tokio-util",
"tokio-util 0.6.9",
"tokio-util 0.7.0",
"tower",
"tracing",
"tracing-core",
@ -6059,7 +6074,7 @@ dependencies = [
"test_helpers",
"time 0.1.0",
"tokio",
"tokio-util",
"tokio-util 0.7.0",
"trace",
"trace_http",
"uuid",

View File

@ -38,7 +38,7 @@ schema = { path = "../schema" }
snafu = "0.7"
time = { path = "../time" }
tokio = { version = "1.13", features = ["macros", "parking_lot", "rt-multi-thread", "sync", "time"] }
tokio-util = { version = "0.6.9" }
tokio-util = { version = "0.7.0" }
trace = { path = "../trace" }
tracker = { path = "../tracker" }
uuid = { version = "0.8", features = ["v4"] }

View File

@ -15,7 +15,7 @@ prost-types = "0.9"
thiserror = "1.0.30"
tokio = { version = "1.13", features = ["macros", "parking_lot", "rt-multi-thread"] }
tokio-stream = { version = "0.1", features = ["net"] }
tokio-util = { version = "0.6.9" }
tokio-util = { version = "0.7.0" }
tonic = "0.6"
tonic-reflection = "0.3.0"

View File

@ -88,7 +88,7 @@ thiserror = "1.0.30"
tikv-jemalloc-ctl = { version = "0.4.0" }
tokio = { version = "1.13", features = ["macros", "net", "parking_lot", "rt-multi-thread", "signal", "sync", "time"] }
tokio-stream = { version = "0.1", features = ["net"] }
tokio-util = { version = "0.6.9" }
tokio-util = { version = "0.7.0" }
tonic = "0.6"
tonic-health = "0.5.0"
tonic-reflection = "0.3.0"

View File

@ -39,7 +39,7 @@ tonic = { version = "0.6" }
uuid = { version = "0.8", features = ["v4"] }
workspace-hack = { path = "../workspace-hack"}
write_buffer = { path = "../write_buffer" }
tokio-util = { version = "0.6.9" }
tokio-util = { version = "0.7.0" }
trace = { path = "../trace" }
[dev-dependencies]

View File

@ -30,7 +30,7 @@ rusoto_s3 = { version = "0.47.0", optional = true}
snafu = "0.7"
tokio = { version = "1.13", features = ["fs", "io-util", "macros", "parking_lot", "rt-multi-thread", "time"] }
# Filesystem integration
tokio-util = { version = "0.6.9", features = [ "codec", "io" ] }
tokio-util = { version = "0.7.0", features = [ "codec", "io" ] }
reqwest = { version = "0.11", optional = true }
# Filesystem integration
walkdir = "2"

View File

@ -32,7 +32,7 @@ schema = { path = "../schema" }
snafu = "0.7"
tokio = { version = "1.13", features = ["macros", "parking_lot"] }
tokio-stream = "0.1"
tokio-util = { version = "0.6.9" }
tokio-util = { version = "0.7.0" }
trace = { path = "../trace" }
predicate = { path = "../predicate" }
workspace-hack = { path = "../workspace-hack"}

View File

@ -36,7 +36,7 @@ snafu = "0.7"
time = { path = "../time" }
trace = { path = "../trace" }
tokio = { version = "1.13", features = ["macros", "parking_lot", "rt-multi-thread", "sync", "time"] }
tokio-util = { version = "0.6.9" }
tokio-util = { version = "0.7.0" }
tracker = { path = "../tracker" }
uuid = { version = "0.8", features = ["v4"] }
write_buffer = { path = "../write_buffer" }

View File

@ -16,7 +16,7 @@ parking_lot = "0.12"
pin-project = "1.0"
time = { path = "../time" }
tokio = { version = "1.13", features = ["macros", "parking_lot", "sync", "time"] }
tokio-util = { version = "0.6.9" }
tokio-util = { version = "0.7.0" }
workspace-hack = { path = "../workspace-hack"}
[dev-dependencies]

View File

@ -52,7 +52,8 @@ sha2 = { version = "0.9", features = ["std"] }
smallvec = { version = "1", default-features = false, features = ["union"] }
tokio = { version = "1", features = ["bytes", "fs", "io-std", "io-util", "libc", "macros", "memchr", "mio", "net", "num_cpus", "once_cell", "parking_lot", "rt", "rt-multi-thread", "signal", "signal-hook-registry", "sync", "time", "tokio-macros", "winapi"] }
tokio-stream = { version = "0.1", features = ["fs", "net", "time"] }
tokio-util = { version = "0.6", features = ["codec", "io", "slab", "time"] }
tokio-util-3b31131e45eafb45 = { package = "tokio-util", version = "0.6", features = ["codec", "io", "slab", "time"] }
tokio-util-ca01ad9e24f5d932 = { package = "tokio-util", version = "0.7", features = ["codec", "io"] }
tower = { version = "0.4", features = ["balance", "buffer", "discover", "filter", "futures-util", "indexmap", "limit", "load", "log", "make", "rand", "ready-cache", "slab", "timeout", "tokio", "tokio-stream", "tokio-util", "tracing", "util"] }
tracing = { version = "0.1", features = ["attributes", "log", "max_level_trace", "release_max_level_debug", "std", "tracing-attributes"] }
tracing-core = { version = "0.1", features = ["lazy_static", "std", "valuable"] }

View File

@ -25,7 +25,7 @@ rskafka = { git = "https://github.com/influxdata/rskafka.git", rev="7c74d43f50c5
schema = { path = "../schema" }
time = { path = "../time" }
tokio = { version = "1.13", features = ["fs", "macros", "parking_lot", "rt", "sync", "time"] }
tokio-util = "0.6.9"
tokio-util = "0.7.0"
trace = { path = "../trace" }
trace_http = { path = "../trace_http" }
uuid = { version = "0.8", features = ["v4"] }

View File

@ -366,7 +366,7 @@ impl WriteBufferReading for FileBufferConsumer {
#[pin_project]
struct ConsumerStream {
fut: ReusableBoxFuture<Option<Result<DmlOperation, WriteBufferError>>>,
fut: ReusableBoxFuture<'static, Option<Result<DmlOperation, WriteBufferError>>>,
sequencer_id: u32,
path: PathBuf,
next_sequence_number: Arc<AtomicU64>,