Struct faktory::ConsumerBuilder

pub struct ConsumerBuilder<F> { /* fields omitted */ }

Convenience wrapper for building a Faktory worker.

See the Consumer documentation for details.

Methods

impl<F> ConsumerBuilder<F>

fn hostname(&mut self, hn: String) -> &mut Self

Set the hostname to use for this worker.

Defaults to the machine's hostname as reported by the operating system.

fn wid(&mut self, wid: String) -> &mut Self

Set a unique identifier for this worker.

Defaults to a randomly generated ASCII string.

fn labels(&mut self, labels: Vec<String>) -> &mut Self

Set the labels to use for this worker.

Defaults to ["rust"].

fn workers(&mut self, w: usize) -> &mut Self

Set the number of workers to use for run and run_to_completion_*.

Defaults to 1.

impl<F, E> ConsumerBuilder<F> where
    F: Fn(Job) -> Result<(), E> + Send + Sync + 'static, 

fn register<K>(&mut self, kind: K, handler: F) -> &mut Self where
    K: ToString, 

Register a handler function for the given job type (kind).

Whenever a job whose type matches kind is fetched from the Faktory, the given handler function is called with that job as its argument.

fn connect(self, url: Option<&str>) -> Result<Consumer<TcpStream, F>>

Connect to a Faktory server.

If url is not given, will use the standard Faktory environment variables. Specifically, FAKTORY_PROVIDER is read to get the name of the environment variable to get the address from (defaults to FAKTORY_URL), and then that environment variable is read to get the server address. If the latter environment variable is not defined, the connection will be made to

tcp://localhost:7419

If url is given, but does not specify a port, it defaults to 7419.

fn connect_with<S: Read + Write>(
    self,
    stream: S,
    pwd: Option<String>
) -> Result<Consumer<S, F>>

Connect to a Faktory server with a non-standard stream.

Trait Implementations

impl<F: Clone> Clone for ConsumerBuilder<F>

fn clone(&self) -> ConsumerBuilder<F>

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<F> Default for ConsumerBuilder<F>

fn default() -> Self

Construct a new worker with default worker options and the url fetched from environment variables.

This will construct a worker where:

• hostname is this machine's hostname.
• wid is a randomly generated string.
• pid is the OS PID of this process.
• labels is ["rust"].