redis3m/docs/scheduler_8h_source.html

 // Copyright (c) 2014 Luca Marturana. All rights reserved.

 // Licensed under Apache 2.0, see LICENSE for details


 #pragma once


 #include <string>

 #include <redis3m/patterns/script_exec.h>

 #include <redis3m/connection.h>

 #include <boost/date_time/posix_time/ptime.hpp>

 #include <boost/date_time/posix_time/posix_time_duration.hpp>


 namespace redis3m

 {

 namespace patterns

 {


 class scheduler

 {

 public:

     scheduler(const std::string& queue_name);


     void append_enqueue(connection::ptr_t connection, const std::string& object_id, const boost::posix_time::ptime& time);


     void append_enqueue(connection::ptr_t connection, const std::string& object_id, const boost::posix_time::time_duration& delay);


     void enqueue(connection::ptr_t connection, const std::string& object_id, const boost::posix_time::ptime& time);


     void enqueue(connection::ptr_t connection, const std::string& object_id, const boost::posix_time::time_duration& delay);


     void append_dequeue(connection::ptr_t connection, const std::string& object_id);


     void dequeue(connection::ptr_t connection, const std::string& object_id);


     std::string find_expired(connection::ptr_t connection, const boost::posix_time::time_duration& lock_for=boost::posix_time::seconds(60));


 private:

     std::string _queue;

     static script_exec find_expired_script;

 };

 }

 }

redis3m::patterns::scheduler::append_dequeue
void append_dequeue(connection::ptr_t connection, const std::string &object_id)
Append Redis commands to remove a job from queue, use it when worker ends a job. Otherwise it will fi...
Definition: scheduler.cpp:48

redis3m::patterns::scheduler::scheduler
scheduler(const std::string &queue_name)
Scheduler constructor.
Definition: scheduler.cpp:14

redis3m::connection
The connection class, represent a connection to a Redis server.
Definition: connection.h:27

redis3m::patterns::scheduler::find_expired
std::string find_expired(connection::ptr_t connection, const boost::posix_time::time_duration &lock_for=boost::posix_time::seconds(60))
Return a fired job, it will be locked for an amount of time. During this time the worker will run the...
Definition: scheduler.cpp:59

redis3m::patterns::scheduler::dequeue
void dequeue(connection::ptr_t connection, const std::string &object_id)
Remove a job from queue, use it when worker ends a job. Otherwise it will fire on another worker...
Definition: scheduler.cpp:53

redis3m::patterns::script_exec
Helps to run Lua scripts on a Redis instance. It will take care to use EVALSHA to optimize performanc...
Definition: script_exec.h:21

redis3m::patterns::scheduler
A scheduler pattern, can be useful to manage "jobs" that needs to be run at a given time...
Definition: scheduler.h:23

redis3m::patterns::scheduler::append_enqueue
void append_enqueue(connection::ptr_t connection, const std::string &object_id, const boost::posix_time::ptime &time)
Append Redis commands needed to enqueue a job, useful to use inside transactions. ...
Definition: scheduler.cpp:20

redis3m::patterns::scheduler::enqueue
void enqueue(connection::ptr_t connection, const std::string &object_id, const boost::posix_time::ptime &time)
Put a job in schedule.
Definition: scheduler.cpp:34