backends.riak

Riak result store backend.

Module Contents

Classes

RiakBackend(self,host=None,port=None,bucket_name=None,protocol=None,url=None,*args,**kwargs) Riak result backend.

Functions

to_bytes(s)
str_decode(s,encoding)
str_decode(s,encoding)
is_ascii(s)
to_bytes(s)
str_decode(s, encoding)
str_decode(s, encoding)
is_ascii(s)
class RiakBackend(host=None, port=None, bucket_name=None, protocol=None, url=None, *args, **kwargs)

Riak result backend.

Raises:
celery.exceptions.ImproperlyConfigured:
if module :pypi:`riak` is not available.
__init__(host=None, port=None, bucket_name=None, protocol=None, url=None, *args, **kwargs)
_get_client()

Get client connection.

_get_bucket()

Connect to our bucket.

client()
bucket()
get(key)
set(key, value)
mget(keys)
delete(key)