@@ -10,7 +10,7 @@ tokio = { version = "1.14.0", features = ["full"] } | |||||
anyhow = "1.0.51" | anyhow = "1.0.51" | ||||
tracing = "0.1" | tracing = "0.1" | ||||
tracing-subscriber = "0.2" | tracing-subscriber = "0.2" | ||||
clap = { version = "3.0.0-rc.0", features = ["derive"] } | |||||
clap = { version = "3.0.0-rc.0", features = ["derive", "env"] } | |||||
redis = { version = "0.21.4", features = ["tokio-comp"] } | redis = { version = "0.21.4", features = ["tokio-comp"] } | ||||
futures = "0.3" | futures = "0.3" | ||||
tokio-stream = { version = "0.1.8", features = ["io-util"] } | tokio-stream = { version = "0.1.8", features = ["io-util"] } | ||||
@@ -0,0 +1,29 @@ | |||||
# queuectl | |||||
Program to bulk-load items into redis queues. | |||||
Call it using `./queuectl -h` to see the instructions. | |||||
Note that the default redis url assumes the primary redis on blackbird is available on localhost using the default redis port. | |||||
Note that there is an environment variable set on blackbird that will make it just work ther eas well. | |||||
## Features | |||||
* Retrieve files from URLs | |||||
* ZSTD Decompression | |||||
* XZ Decompression | |||||
* GZIP Decompression | |||||
* Progress bar (can be disabled) | |||||
## Building | |||||
Install rust via rustup. | |||||
Enable the `x86_64-unknown-linux-musl` target architecture. | |||||
```sh | |||||
rustup target add x86_64-unknown-linux-musl | |||||
``` | |||||
Now build the binary using: | |||||
```sh | |||||
cargo build --release --target=x86_64-unknown-linux-musl | |||||
``` | |||||
The binary is now at `target/x86_64-unknown-linux-musl/release/queuectl`. | |||||
This is a static binary that can be copied around at will. |
@@ -17,7 +17,7 @@ pub struct Cli { | |||||
#[clap(long, default_value = "8192")] | #[clap(long, default_value = "8192")] | ||||
/// How many items to send per SADD command. | /// How many items to send per SADD command. | ||||
pub chunk_size: usize, | pub chunk_size: usize, | ||||
#[clap(long, default_value = "redis://127.0.0.1/")] | |||||
#[clap(short, long, default_value = "redis://127.0.0.1/", env = "TRACKER_REDIS_URL")] | |||||
/// URL of the redis to connect to. | /// URL of the redis to connect to. | ||||
pub redis: String, | pub redis: String, | ||||
#[clap(long, short, default_value = "auto", arg_enum)] | #[clap(long, short, default_value = "auto", arg_enum)] | ||||