Rust Sidekiq Client

Sidekiq job format

Dependencies

Installation

ini [dependencies] sidekiq = "0.3"

Usage

Job

``` rust extern crate sidekiq;

use std::default::Default;

use sidekiq::{Job, JobOpts};

use serdejson::value::Value; use serdejson::builder::{ArrayBuilder, ObjectBuilder};

fn args() -> Vec { let argstr: Value = Value::String("arg".tostring()); let argint: Value = Value::I64(42); let argbool: Value = Value::Bool(true); let argobject = ObjectBuilder::new() .insert("class".tostring(), "Ruby") .build(); let argarray = ArrayBuilder::new() .push(1.2) .build(); let args: Vec = vec![argstr, argint, argbool, argobject, argarray]; args }

let class = "MyClass".tostring(); let jobopts = JobOpts { queue: "test".to_string(), ..Default::default() }; let job = Job::new(class, args(), Default::default()); ```

Client

``` rust extern crate sidekiq; use std::default::Default;

use sidekiq::{Client, ClientOpts, createredispool};

let ns = "test"; let clientopts = ClientOpts { namespace: Some(ns.tostring()), ..Default::default() }; let pool = createredispool().unwrap(); let client = Client::new(pool, clientopts); match client.push(job) { Ok() => {}, Err(err) => { println!("Sidekiq push failed: {}", err); }, } ```

Default environment variables

REFERENCES

LICENSE

The MIT License

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


Build Version Documentation License Project status