Merge pull request #25 from plivo/VT-5650

lua_script_added

CHANGELOG

@@ -1,3 +1,6 @@
+MINOR RELEASE v1.3.0
+	- Added function to get queue length
+
 MINOR RELEASE v1.2.0
 	- Allow interval to be 0.
 

setup.py

@@ -4,7 +4,7 @@
 
 setup(
     name='SharQ',
-    version='1.2.0',
+    version='1.3.0',
     url='https://github.com/plivo/sharq',
     author='Plivo Team',
     author_email='[email protected]',

sharq/queue.py

@@ -517,3 +517,21 @@ def clear_queue(self, queue_type=None, queue_id=None, purge_all=False):
             # always delete the job queue list
             self._r.delete(job_queue_list)
         return response
+
+    def get_queue_length(self, queue_type, queue_id):
+        """
+        Return the current length present in redis key of type list
+        Redis key structure : key_prefix : queue_type : queue_id
+        """
+
+        # validate all the input
+        if not is_valid_identifier(queue_type):
+            raise BadArgumentException('`queue_type` has an invalid value.')
+
+        if not is_valid_identifier(queue_id):
+            raise BadArgumentException('`queue_id` has an invalid value.')
+
+        redis_key = self._key_prefix + ':' + queue_type + ':' + queue_id
+        current_queue_length = self._r.llen(redis_key)
+        return current_queue_length
+