Did I find the right examples for you? yes no

All Samples(30)  |  Call(0)  |  Derive(15)  |  Import(15)

src/o/h/oh-mainline-HEAD/vendor/packages/ghettoq/ghettoq/backends/pyredis.py   oh-mainline(Download)
from Queue import Empty
 
from redis import Redis
from ghettoq.backends.base import BaseBackend
 
DEFAULT_PORT = 6379
DEFAULT_DB = 0
 
 
class RedisBackend(BaseBackend):

src/o/h/oh-mainline-HEAD/vendor/packages/ghettoq/ghettoq/backends/mongodb.py   oh-mainline(Download)
from pymongo.connection import Connection
from pymongo.errors import OperationFailure
 
from ghettoq.backends.base import BaseBackend
from ghettoq.messaging import Empty
class MongodbBackend(BaseBackend):
 
    def establish_connection(self):
        self.port = self.port or DEFAULT_PORT
        self.host = self.host or DEFAULT_HOST

src/o/h/oh-mainline-HEAD/vendor/packages/ghettoq/ghettoq/backends/database.py   oh-mainline(Download)
from ghettoq.models import Queue
from ghettoq.backends.base import BaseBackend
 
 
class DatabaseBackend(BaseBackend):

src/o/h/oh-mainline-HEAD/vendor/packages/ghettoq/ghettoq/backends/couch_db.py   oh-mainline(Download)
from Queue import Empty
 
import couchdb
import uuid
from ghettoq.backends.base import BaseBackend
class CouchdbBackend(BaseBackend):
 
    def __init__(self, host=None, port=None, user=None, password=None,
                 database=None, timeout=None, ssl=False):
 

src/o/h/oh-mainline-HEAD/vendor/packages/ghettoq/ghettoq/backends/beanstalk.py   oh-mainline(Download)
from itertools import ifilter
from Queue import Empty
 
from beanstalkc import Connection
from ghettoq.backends.base import BaseBackend
class BeanstalkBackend(BaseBackend):
 
    def _parse_job(self, job):
        item, dest = None, None
        if job:

src/g/h/ghettoq-0.4.5/ghettoq/backends/pyredis.py   ghettoq(Download)
from Queue import Empty
 
from redis import Redis
from ghettoq.backends.base import BaseBackend
 
DEFAULT_PORT = 6379
DEFAULT_DB = 0
 
 
class RedisBackend(BaseBackend):

src/g/h/ghettoq-0.4.5/ghettoq/backends/mongodb.py   ghettoq(Download)
from pymongo.connection import Connection
from pymongo.errors import OperationFailure
 
from ghettoq.backends.base import BaseBackend
from ghettoq.messaging import Empty
class MongodbBackend(BaseBackend):
 
    def establish_connection(self):
        self.port = self.port or DEFAULT_PORT
        self.host = self.host or DEFAULT_HOST

src/g/h/ghettoq-0.4.5/ghettoq/backends/database.py   ghettoq(Download)
from ghettoq.models import Queue
from ghettoq.backends.base import BaseBackend
 
 
class DatabaseBackend(BaseBackend):

src/g/h/ghettoq-0.4.5/ghettoq/backends/couch_db.py   ghettoq(Download)
from Queue import Empty
 
import couchdb
import uuid
from ghettoq.backends.base import BaseBackend
class CouchdbBackend(BaseBackend):
 
    def __init__(self, host=None, port=None, user=None, password=None,
                 database=None, timeout=None, ssl=False):
 

src/g/h/ghettoq-0.4.5/ghettoq/backends/beanstalk.py   ghettoq(Download)
from itertools import ifilter
from Queue import Empty
 
from beanstalkc import Connection
from ghettoq.backends.base import BaseBackend
class BeanstalkBackend(BaseBackend):
 
    def _parse_job(self, job):
        item, dest = None, None
        if job:

  1 | 2  Next