var searchIndex = {};
searchIndex["disqrust"] = {"doc":"A high-level library to implement Disque workers.","items":[[3,"EventLoop","disqrust","Workers manager.",null,null],[4,"JobStatus","","Once a job execution finishes, change its status by performing one of this\nactions.",null,null],[13,"FastAck","","Performs a best effort cluster wide deletion of the job.",0,null],[13,"AckJob","","Acknowledges the execution of the jobs.",0,null],[13,"NAck","","Puts back the job in the queue ASAP.",0,null],[8,"Handler","","Handles a job task.",null,null],[10,"process_job","","Process a job.",1,null],[11,"process_error","","Decides if a job that failed in the past should be re-executed.\n`nack` is the count of negatives acknowledges.\n`additional_deliveries` is the number of times the job was processed\nbut it was not acknowledged.",1,null],[11,"clone","","",0,null],[11,"new","","",2,{"inputs":[{"name":"disque"},{"name":"usize"},{"name":"h"}],"output":{"name":"self"}}],[11,"watch_queue","","Adds a queue to process its jobs.",2,null],[11,"unwatch_queue","","Removes a queue from job processing.",2,null],[11,"choose_favorite_node","","Connects to the server that is issuing most of the jobs.",2,null],[11,"jobcount_current_node","","Number of jobs produced by the current server.",2,null],[11,"current_node_id","","Identifier of the current server.",2,null],[11,"do_cycle","","Connects to the server doing most jobs.",2,null],[11,"run","","Runs for ever. Every `cycle` jobs reevaluates which server to use.",2,null],[11,"run_times","","Runs until `times` jobs are received.",2,null],[11,"run_times_cycle","","Runs `times` jobs and changes server every `cycle`.",2,null],[11,"stop","","Sends a kill signal to all workers and waits for them to finish their\ncurrent job.",2,null]],"paths":[[4,"JobStatus"],[8,"Handler"],[3,"EventLoop"]]};
initSearch(searchIndex);