diff options
| author | Baitinq <manuelpalenzuelamerino@gmail.com> | 2022-10-23 12:05:16 +0200 |
|---|---|---|
| committer | Baitinq <manuelpalenzuelamerino@gmail.com> | 2022-10-23 12:05:19 +0200 |
| commit | 37414fda51b18096a1834edf2ea0fe53191325e3 (patch) | |
| tree | f3628e87d22115f68f7ce7ee5f499244a29c5203 /Cargo.lock | |
| parent | Indexer: Listen on 0.0.0.0 (diff) | |
| download | OSSE-37414fda51b18096a1834edf2ea0fe53191325e3.tar.gz OSSE-37414fda51b18096a1834edf2ea0fe53191325e3.tar.bz2 OSSE-37414fda51b18096a1834edf2ea0fe53191325e3.zip | |
Crawler: Change blockingqueue to channels
We now use the async-channel channels implementation. This allows us to have bounded async channels.
Diffstat (limited to 'Cargo.lock')
| -rw-r--r-- | Cargo.lock | 40 |
1 files changed, 33 insertions, 7 deletions
diff --git a/Cargo.lock b/Cargo.lock index 6ed1be4..8a36c19 100644 --- a/Cargo.lock +++ b/Cargo.lock @@ -223,6 +223,17 @@ dependencies = [ ] [[package]] +name = "async-channel" +version = "1.7.1" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "e14485364214912d3b19cc3435dde4df66065127f05fa0d75c712f36f12c2f28" +dependencies = [ + "concurrent-queue", + "event-listener", + "futures-core", +] + +[[package]] name = "autocfg" version = "1.1.0" source = "registry+https://github.com/rust-lang/crates.io-index" @@ -250,12 +261,6 @@ dependencies = [ ] [[package]] -name = "blockingqueue" -version = "0.1.1" -source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "763bb38f196c65b369c68796e6d15b83d7eb63c354f2ab7c03c13edd13f2c4ff" - -[[package]] name = "brotli" version = "3.3.4" source = "registry+https://github.com/rust-lang/crates.io-index" @@ -310,6 +315,12 @@ dependencies = [ ] [[package]] +name = "cache-padded" +version = "1.2.0" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "c1db59621ec70f09c5e9b597b220c7a2b43611f4710dc03ceb8748637775692c" + +[[package]] name = "cc" version = "1.0.73" source = "registry+https://github.com/rust-lang/crates.io-index" @@ -335,6 +346,15 @@ name = "client" version = "0.1.0" [[package]] +name = "concurrent-queue" +version = "1.2.4" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "af4780a44ab5696ea9e28294517f1fffb421a83a25af521333c838635509db9c" +dependencies = [ + "cache-padded", +] + +[[package]] name = "convert_case" version = "0.4.0" source = "registry+https://github.com/rust-lang/crates.io-index" @@ -380,7 +400,7 @@ dependencies = [ name = "crawler" version = "0.1.0" dependencies = [ - "blockingqueue", + "async-channel", "itertools", "reqwest", "scraper", @@ -494,6 +514,12 @@ dependencies = [ ] [[package]] +name = "event-listener" +version = "2.5.3" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "0206175f82b8d6bf6652ff7d71a1e27fd2e4efde587fd368662814d6ec1d9ce0" + +[[package]] name = "fastrand" version = "1.8.0" source = "registry+https://github.com/rust-lang/crates.io-index" |