Source code for stream_framework.feeds.redis

from stream_framework.feeds.base import BaseFeed
from stream_framework.storage.redis.activity_storage import RedisActivityStorage
from stream_framework.storage.redis.timeline_storage import RedisTimelineStorage
from stream_framework.serializers.activity_serializer import ActivitySerializer


[docs]class RedisFeed(BaseFeed): timeline_storage_class = RedisTimelineStorage activity_storage_class = RedisActivityStorage activity_serializer = ActivitySerializer # : allow you point to a different redis server as specified in # : settings.STREAM_REDIS_CONFIG redis_server = 'default' @classmethod
[docs] def get_timeline_storage_options(cls): ''' Returns the options for the timeline storage ''' options = super(RedisFeed, cls).get_timeline_storage_options() options['redis_server'] = cls.redis_server return options # : clarify that this feed supports filtering and ordering
filtering_supported = True ordering_supported = True