Rust Sidekiq Client

Sidekiq client allowing to push jobs. Using the Sidekiq job format as reference.

Dependencies

• rand
• redis
• r2d2-redis
• serde_json

Installation

toml [dependencies] sidekiq = "0.12"

Default environment variables

• REDIS_URL="redis://127.0.0.1/"

Used by

• https://github.com/jkcclemens/paste
• https://github.com/spk/maman

Examples

```rust use sidekiq::{Job, Value}; use sidekiq::{Client, ClientOpts, createredispool}; use time::{OffsetDateTime, Duration};

let ns = "test"; let clientopts = ClientOpts { namespace: Some(ns.tostring()), ..Default::default() }; let pool = createredispool().unwrap(); let client = Client::new(pool, clientopts); let class = "MyClass".tostring();

// basic job let job = Job::new(class, vec![sidekiq::Value::Null], Default::default()); match client.push(job) { Ok(_) => {}, Err(err) => { println!("Sidekiq push failed: {}", err); }, }

// scheduled-jobs (performin) let job = Job::new(class, vec![sidekiq::Value::Null], Default::default()); let interval = Duration::hours(1); match client.performin(interval, job) { Ok(_) => {}, Err(err) => { println!("Sidekiq push failed: {}", err); }, }

// scheduled-jobs (performat) let job = Job::new(class, vec![sidekiq::Value::Null], Default::default()); let startat = OffsetDateTime::nowutc().checkedadd(Duration::HOUR).unwrap(); match client.performat(startat, job) { Ok(_) => {}, Err(err) => { println!("Sidekiq push failed: {}", err); }, } ```

REFERENCES

• http://julienblanchard.com/2015/using-resque-with-rust/
• https://github.com/d-unseductable/rust_sidekiq

LICENSE

The MIT License

Copyright (c) 2016-2021 Laurent Arnoud laurent@spkdev.net