redis Package¶
activity_storage
Module¶
-
class
stream_framework.storage.redis.activity_storage.
ActivityCache
(key, redis=None)[source]¶ Bases:
stream_framework.storage.redis.structures.hash.ShardedHashCache
-
key_format
= 'activity:cache:%s'¶
-
-
class
stream_framework.storage.redis.activity_storage.
RedisActivityStorage
(serializer_class=None, activity_class=None, **options)[source]¶ Bases:
stream_framework.storage.base.BaseActivityStorage
-
default_serializer_class
¶ alias of
ActivitySerializer
-
connection
Module¶
timeline_storage
Module¶
-
class
stream_framework.storage.redis.timeline_storage.
RedisTimelineStorage
(serializer_class=None, activity_class=None, **options)[source]¶ Bases:
stream_framework.storage.base.BaseTimelineStorage
-
get_slice_from_storage
(key, start, stop, filter_kwargs=None, ordering_args=None)[source]¶ Returns a slice from the storage :param key: the redis key at which the sorted set is located :param start: the start :param stop: the stop :param filter_kwargs: a dict of filter kwargs :param ordering_args: a list of fields used for sorting
- Example::
- get_slice_from_storage(‘feed:13‘, 0, 10, {activity_id__lte=10})
-
-
class
stream_framework.storage.redis.timeline_storage.
TimelineCache
(key, redis=None)[source]¶ Bases:
stream_framework.storage.redis.structures.sorted_set.RedisSortedSetCache
-
sort_asc
= False¶
-