Index

A

activities_to_ids() (stream_framework.storage.base.BaseStorage method) Activity (class in stream_framework.activity) activity_class (stream_framework.aggregators.base.BaseAggregator attribute) (stream_framework.feeds.base.BaseFeed attribute) (stream_framework.storage.base.BaseStorage attribute) activity_count (stream_framework.activity.AggregatedActivity attribute) activity_ids (stream_framework.activity.AggregatedActivity attribute) activity_serializer (stream_framework.feeds.aggregated_feed.notification_feed.NotificationFeed attribute) (stream_framework.feeds.aggregated_feed.redis.RedisAggregatedFeed attribute) (stream_framework.feeds.base.BaseFeed attribute) (stream_framework.feeds.redis.RedisFeed attribute) activity_storage_class (stream_framework.feeds.aggregated_feed.notification_feed.NotificationFeed attribute) (stream_framework.feeds.aggregated_feed.redis.RedisAggregatedFeed attribute) (stream_framework.feeds.base.BaseFeed attribute) (stream_framework.feeds.memory.Feed attribute) (stream_framework.feeds.redis.RedisFeed attribute) activity_to_id() (stream_framework.storage.base.BaseStorage method) ActivityCache (class in stream_framework.storage.redis.activity_storage) ActivityNotFound actor_count (stream_framework.activity.AggregatedActivity attribute) actor_ids (stream_framework.activity.AggregatedActivity attribute)

Add (class in stream_framework.verbs.base) add() (stream_framework.feeds.base.BaseFeed method) (stream_framework.storage.base.BaseActivityStorage method) (stream_framework.storage.base.BaseTimelineStorage method) (stream_framework.storage.redis.structures.sorted_set.RedisSortedSetCache method) add_many() (stream_framework.feeds.aggregated_feed.base.AggregatedFeed method) (stream_framework.feeds.aggregated_feed.notification_feed.NotificationFeed method) (stream_framework.feeds.base.BaseFeed method) (stream_framework.storage.base.BaseActivityStorage method) (stream_framework.storage.base.BaseTimelineStorage method) (stream_framework.storage.redis.structures.sorted_set.RedisSortedSetCache method) add_many_aggregated() (stream_framework.feeds.aggregated_feed.base.AggregatedFeed method) add_to_storage() (stream_framework.storage.base.BaseActivityStorage method) (stream_framework.storage.memory.InMemoryActivityStorage method) (stream_framework.storage.memory.InMemoryTimelineStorage method) (stream_framework.storage.redis.activity_storage.RedisActivityStorage method) (stream_framework.storage.redis.timeline_storage.RedisTimelineStorage method) aggregate() (stream_framework.aggregators.base.BaseAggregator method) aggregated_activity_class (stream_framework.aggregators.base.BaseAggregator attribute) (stream_framework.feeds.aggregated_feed.base.AggregatedFeed attribute) (stream_framework.storage.base.BaseStorage attribute) AggregatedActivity (class in stream_framework.activity) AggregatedFeed (class in stream_framework.feeds.aggregated_feed.base) aggregator_class (stream_framework.feeds.aggregated_feed.base.AggregatedFeed attribute) append() (stream_framework.activity.AggregatedActivity method) (stream_framework.storage.redis.structures.list.RedisListCache method) append_many() (stream_framework.storage.redis.structures.list.RedisListCache method)

B

BaseActivity (class in stream_framework.activity) BaseActivityStorage (class in stream_framework.storage.base) BaseAggregator (class in stream_framework.aggregators.base) BaseFeed (class in stream_framework.feeds.base)

BaseRedisHashCache (class in stream_framework.storage.redis.structures.hash) BaseRedisListCache (class in stream_framework.storage.redis.structures.list) BaseStorage (class in stream_framework.storage.base) BaseTimelineStorage (class in stream_framework.storage.base)

C

cache() (stream_framework.storage.redis.structures.list.FallbackRedisListCache method) chunks() (in module stream_framework.utils) Comment (class in stream_framework.verbs.base) contains() (stream_framework.activity.AggregatedActivity method) (stream_framework.feeds.aggregated_feed.base.AggregatedFeed method) (stream_framework.storage.memory.InMemoryTimelineStorage method) (stream_framework.storage.redis.structures.hash.RedisHashCache method) (stream_framework.storage.redis.structures.hash.ShardedHashCache method) (stream_framework.storage.redis.structures.sorted_set.RedisSortedSetCache method) (stream_framework.storage.redis.timeline_storage.RedisTimelineStorage method)

count() (stream_framework.feeds.base.BaseFeed method) (stream_framework.storage.base.BaseTimelineStorage method) (stream_framework.storage.memory.InMemoryTimelineStorage method) (stream_framework.storage.redis.structures.hash.RedisHashCache method) (stream_framework.storage.redis.structures.hash.ShardedHashCache method) (stream_framework.storage.redis.structures.list.RedisListCache method) (stream_framework.storage.redis.structures.sorted_set.RedisSortedSetCache method) (stream_framework.storage.redis.timeline_storage.RedisTimelineStorage method) count_format (stream_framework.feeds.aggregated_feed.notification_feed.NotificationFeed attribute) count_unseen() (stream_framework.feeds.aggregated_feed.notification_feed.NotificationFeed method)

D

datetime_to_epoch() (in module stream_framework.utils) default_serializer_class (stream_framework.storage.base.BaseStorage attribute) (stream_framework.storage.base.BaseTimelineStorage attribute) (stream_framework.storage.redis.activity_storage.RedisActivityStorage attribute) DehydratedActivity (class in stream_framework.activity) delete() (stream_framework.feeds.base.BaseFeed method) (stream_framework.storage.base.BaseTimelineStorage method) (stream_framework.storage.memory.InMemoryTimelineStorage method) (stream_framework.storage.redis.structures.base.RedisCache method) (stream_framework.storage.redis.structures.hash.ShardedHashCache method) (stream_framework.storage.redis.timeline_storage.RedisTimelineStorage method)

delete_many() (stream_framework.storage.redis.structures.hash.RedisHashCache method) (stream_framework.storage.redis.structures.hash.ShardedHashCache method) denormalize_count() (stream_framework.feeds.aggregated_feed.notification_feed.NotificationFeed method) deserialize_activities() (stream_framework.storage.base.BaseStorage method) DuplicateActivityException

E

epoch_to_datetime() (in module stream_framework.utils)

F

FallbackHashCache (class in stream_framework.storage.redis.structures.hash) FallbackRedisListCache (class in stream_framework.storage.redis.structures.list) Feed (class in stream_framework.feeds.memory) filter() (stream_framework.feeds.base.BaseFeed method)

filtering_supported (stream_framework.feeds.base.BaseFeed attribute) (stream_framework.feeds.redis.RedisFeed attribute) flush() (stream_framework.feeds.base.BaseFeed class method) (stream_framework.storage.base.BaseStorage method) (stream_framework.storage.memory.InMemoryActivityStorage method) (stream_framework.storage.redis.activity_storage.RedisActivityStorage method) Follow (class in stream_framework.verbs.base)

G

get() (stream_framework.storage.base.BaseActivityStorage method) (stream_framework.storage.redis.structures.hash.RedisHashCache method) (stream_framework.utils.LRUCache method) get_activity_slice() (stream_framework.feeds.base.BaseFeed method) get_activity_storage() (stream_framework.feeds.base.BaseFeed class method) get_aggregator() (stream_framework.feeds.aggregated_feed.base.AggregatedFeed method) get_batch_interface() (stream_framework.storage.base.BaseTimelineStorage method) (stream_framework.storage.memory.InMemoryTimelineStorage class method) (stream_framework.storage.redis.timeline_storage.RedisTimelineStorage method) get_cache() (stream_framework.storage.redis.activity_storage.RedisActivityStorage method) (stream_framework.storage.redis.timeline_storage.RedisTimelineStorage method) get_class_from_string() (in module stream_framework.utils) get_dehydrated() (stream_framework.activity.Activity method) (stream_framework.activity.AggregatedActivity method) get_denormalized_count() (stream_framework.feeds.aggregated_feed.notification_feed.NotificationFeed method) get_fallback_results() (stream_framework.storage.redis.structures.list.FallbackRedisListCache method) get_from_storage() (stream_framework.storage.base.BaseActivityStorage method) (stream_framework.storage.memory.InMemoryActivityStorage method) (stream_framework.storage.redis.activity_storage.RedisActivityStorage method) get_group() (stream_framework.aggregators.base.BaseAggregator method) (stream_framework.aggregators.base.NotificationAggregator method) (stream_framework.aggregators.base.RecentVerbAggregator method) get_hydrated() (stream_framework.activity.AggregatedActivity method) (stream_framework.activity.DehydratedActivity method) get_index_of() (stream_framework.storage.base.BaseTimelineStorage method) (stream_framework.storage.memory.InMemoryTimelineStorage method) (stream_framework.storage.redis.timeline_storage.RedisTimelineStorage method) get_key() (stream_framework.storage.redis.activity_storage.RedisActivityStorage method) (stream_framework.storage.redis.structures.base.RedisCache method) (stream_framework.storage.redis.structures.hash.RedisHashCache method) (stream_framework.storage.redis.structures.hash.ShardedHashCache method) get_keys() (stream_framework.storage.redis.structures.hash.ShardedHashCache method)

get_many() (stream_framework.storage.base.BaseActivityStorage method) (stream_framework.storage.redis.structures.hash.FallbackHashCache method) (stream_framework.storage.redis.structures.hash.RedisHashCache method) (stream_framework.storage.redis.structures.hash.ShardedHashCache method) get_many_from_fallback() (stream_framework.storage.redis.structures.hash.FallbackHashCache method) get_metrics_instance() (in module stream_framework.utils) get_redis() (stream_framework.storage.redis.structures.base.RedisCache method) get_redis_connection() (in module stream_framework.storage.redis.connection) get_redis_results() (stream_framework.storage.redis.structures.list.FallbackRedisListCache method) get_results() (stream_framework.storage.redis.structures.list.BaseRedisListCache method) (stream_framework.storage.redis.structures.list.FallbackRedisListCache method) (stream_framework.storage.redis.structures.list.RedisListCache method) (stream_framework.storage.redis.structures.sorted_set.RedisSortedSetCache method) get_slice() (stream_framework.storage.base.BaseTimelineStorage method) get_slice_from_storage() (stream_framework.storage.base.BaseTimelineStorage method) (stream_framework.storage.memory.InMemoryTimelineStorage method) (stream_framework.storage.redis.timeline_storage.RedisTimelineStorage method) get_timeline_batch_interface() (stream_framework.feeds.base.BaseFeed class method) get_timeline_storage() (stream_framework.feeds.base.BaseFeed class method) get_timeline_storage_options() (stream_framework.feeds.aggregated_feed.base.AggregatedFeed class method) (stream_framework.feeds.base.BaseFeed class method) (stream_framework.feeds.redis.RedisFeed class method) get_verb_by_id() (in module stream_framework.verbs) get_verb_storage() (in module stream_framework.verbs) group_activities() (stream_framework.aggregators.base.BaseAggregator method)

H

hydrate_activities() (stream_framework.feeds.base.BaseFeed method)

I

id (stream_framework.verbs.base.Add attribute) (stream_framework.verbs.base.Comment attribute) (stream_framework.verbs.base.Follow attribute) (stream_framework.verbs.base.Love attribute) (stream_framework.verbs.base.Verb attribute) import_global_module() (in module stream_framework.settings) index_of() (stream_framework.feeds.base.BaseFeed method) (stream_framework.storage.base.BaseTimelineStorage method) (stream_framework.storage.redis.structures.sorted_set.RedisSortedSetCache method) infinitive (stream_framework.verbs.base.Add attribute) (stream_framework.verbs.base.Comment attribute) (stream_framework.verbs.base.Follow attribute) (stream_framework.verbs.base.Love attribute) InMemoryActivityStorage (class in stream_framework.storage.memory)

InMemoryTimelineStorage (class in stream_framework.storage.memory) insert_activities() (stream_framework.feeds.base.BaseFeed class method) insert_activity() (stream_framework.feeds.base.BaseFeed class method) is_read() (stream_framework.activity.AggregatedActivity method) is_seen() (stream_framework.activity.AggregatedActivity method)

K

key_format (stream_framework.feeds.aggregated_feed.notification_feed.NotificationFeed attribute) (stream_framework.feeds.base.BaseFeed attribute) (stream_framework.feeds.base.UserBaseFeed attribute) (stream_framework.storage.redis.activity_storage.ActivityCache attribute) (stream_framework.storage.redis.structures.base.RedisCache attribute) (stream_framework.storage.redis.structures.hash.BaseRedisHashCache attribute) (stream_framework.storage.redis.structures.hash.FallbackHashCache attribute) (stream_framework.storage.redis.structures.hash.RedisHashCache attribute) (stream_framework.storage.redis.structures.list.BaseRedisListCache attribute) (stream_framework.storage.redis.structures.list.FallbackRedisListCache attribute) (stream_framework.storage.redis.structures.list.RedisListCache attribute)

keys() (stream_framework.storage.redis.structures.hash.RedisHashCache method) (stream_framework.storage.redis.structures.hash.ShardedHashCache method)

L

last_activities (stream_framework.activity.AggregatedActivity attribute) last_activity (stream_framework.activity.AggregatedActivity attribute) lock_format (stream_framework.feeds.aggregated_feed.notification_feed.NotificationFeed attribute)

Love (class in stream_framework.verbs.base) LRUCache (class in stream_framework.utils)

M

make_list_unique() (in module stream_framework.utils) mark_all() (stream_framework.feeds.aggregated_feed.notification_feed.NotificationFeed method) max_aggregated_activities_length (stream_framework.activity.AggregatedActivity attribute) max_items (stream_framework.storage.redis.structures.list.RedisListCache attribute) max_length (stream_framework.feeds.aggregated_feed.notification_feed.NotificationFeed attribute) (stream_framework.feeds.base.BaseFeed attribute) (stream_framework.feeds.base.UserBaseFeed attribute) (stream_framework.storage.redis.structures.list.BaseRedisListCache attribute)

memoized (class in stream_framework.utils) merge() (stream_framework.aggregators.base.BaseAggregator method) merge_max_length (stream_framework.feeds.aggregated_feed.base.AggregatedFeed attribute) metrics (stream_framework.storage.base.BaseStorage attribute)

N

needs_hydration() (stream_framework.feeds.base.BaseFeed method) NotificationActivity (class in stream_framework.activity) NotificationAggregator (class in stream_framework.aggregators.base)

NotificationFeed (class in stream_framework.feeds.aggregated_feed.notification_feed) number_of_keys (stream_framework.storage.redis.structures.hash.ShardedHashCache attribute)

O

object_ids (stream_framework.activity.AggregatedActivity attribute) on_update_feed() (stream_framework.feeds.base.BaseFeed method) order_by() (stream_framework.feeds.base.BaseFeed method)

ordering_supported (stream_framework.feeds.base.BaseFeed attribute) (stream_framework.feeds.redis.RedisFeed attribute) other_actor_count (stream_framework.activity.AggregatedActivity attribute) overwrite() (stream_framework.storage.redis.structures.list.FallbackRedisListCache method)

P

past_tense (stream_framework.verbs.base.Add attribute) (stream_framework.verbs.base.Comment attribute) (stream_framework.verbs.base.Follow attribute) (stream_framework.verbs.base.Love attribute) publish_count() (stream_framework.feeds.aggregated_feed.notification_feed.NotificationFeed method)

pubsub_main_channel (stream_framework.feeds.aggregated_feed.notification_feed.NotificationFeed attribute)

R

rank() (stream_framework.aggregators.base.BaseAggregator method) (stream_framework.aggregators.base.RecentRankMixin method) RecentRankMixin (class in stream_framework.aggregators.base) RecentVerbAggregator (class in stream_framework.aggregators.base) redis (stream_framework.storage.redis.structures.base.RedisCache attribute) redis_server (stream_framework.feeds.redis.RedisFeed attribute) RedisActivityStorage (class in stream_framework.storage.redis.activity_storage) RedisAggregatedFeed (class in stream_framework.feeds.aggregated_feed.redis) RedisCache (class in stream_framework.storage.redis.structures.base) RedisFeed (class in stream_framework.feeds.redis) RedisHashCache (class in stream_framework.storage.redis.structures.hash) RedisListCache (class in stream_framework.storage.redis.structures.list)

RedisNotificationFeed (class in stream_framework.feeds.aggregated_feed.notification_feed) RedisSortedSetCache (class in stream_framework.storage.redis.structures.sorted_set) RedisTimelineStorage (class in stream_framework.storage.redis.timeline_storage) register() (in module stream_framework.verbs) remove() (stream_framework.activity.AggregatedActivity method) (stream_framework.feeds.base.BaseFeed method) (stream_framework.storage.base.BaseActivityStorage method) (stream_framework.storage.base.BaseTimelineStorage method) (stream_framework.storage.redis.structures.list.RedisListCache method) remove_activity() (stream_framework.feeds.base.BaseFeed class method) remove_by_scores() (stream_framework.storage.redis.structures.sorted_set.RedisSortedSetCache method) remove_from_storage() (stream_framework.storage.base.BaseActivityStorage method) (stream_framework.storage.base.BaseTimelineStorage method) (stream_framework.storage.memory.InMemoryActivityStorage method) (stream_framework.storage.memory.InMemoryTimelineStorage method) (stream_framework.storage.redis.activity_storage.RedisActivityStorage method) (stream_framework.storage.redis.timeline_storage.RedisTimelineStorage method) remove_many() (stream_framework.activity.AggregatedActivity method) (stream_framework.feeds.aggregated_feed.base.AggregatedFeed method) (stream_framework.feeds.base.BaseFeed method) (stream_framework.storage.base.BaseActivityStorage method) (stream_framework.storage.base.BaseTimelineStorage method) (stream_framework.storage.redis.structures.list.RedisListCache method) (stream_framework.storage.redis.structures.sorted_set.RedisSortedSetCache method) remove_many_aggregated() (stream_framework.feeds.aggregated_feed.base.AggregatedFeed method) reverse_bisect_left() (in module stream_framework.storage.memory)

S

serialization_id (stream_framework.activity.Activity attribute) (stream_framework.activity.AggregatedActivity attribute) SerializationException serialize() (stream_framework.verbs.base.Verb method) serialize_activities() (stream_framework.storage.base.BaseStorage method) serialize_activity() (stream_framework.storage.base.BaseStorage method) serializer (stream_framework.storage.base.BaseStorage attribute) set() (stream_framework.storage.redis.structures.hash.RedisHashCache method) (stream_framework.utils.LRUCache method) set_denormalized_count() (stream_framework.feeds.aggregated_feed.notification_feed.NotificationFeed method) set_many() (stream_framework.storage.redis.structures.hash.RedisHashCache method) set_redis() (stream_framework.storage.redis.structures.base.RedisCache method) setup_connection() (in module stream_framework.storage.cassandra.connection) setup_redis() (in module stream_framework.storage.redis.connection) ShardedDatabaseFallbackHashCache (class in stream_framework.storage.redis.structures.hash) ShardedHashCache (class in stream_framework.storage.redis.structures.hash) sort_asc (stream_framework.storage.redis.structures.sorted_set.RedisSortedSetCache attribute) (stream_framework.storage.redis.timeline_storage.TimelineCache attribute) stream_framework (module) stream_framework.activity (module) stream_framework.aggregators.base (module) stream_framework.default_settings (module) stream_framework.exceptions (module) stream_framework.feeds.aggregated_feed (module)

stream_framework.feeds.aggregated_feed.base (module) stream_framework.feeds.aggregated_feed.notification_feed (module) stream_framework.feeds.aggregated_feed.redis (module) stream_framework.feeds.base (module) stream_framework.feeds.memory (module) stream_framework.feeds.redis (module) stream_framework.settings (module) stream_framework.storage.base (module) stream_framework.storage.cassandra (module) stream_framework.storage.cassandra.connection (module) stream_framework.storage.memory (module) stream_framework.storage.redis.activity_storage (module) stream_framework.storage.redis.connection (module) stream_framework.storage.redis.structures.base (module) stream_framework.storage.redis.structures.hash (module) stream_framework.storage.redis.structures.list (module) stream_framework.storage.redis.structures.sorted_set (module) stream_framework.storage.redis.timeline_storage (module) stream_framework.utils (module) stream_framework.verbs (module) stream_framework.verbs.base (module)

T

timeline_serializer (stream_framework.feeds.aggregated_feed.base.AggregatedFeed attribute) (stream_framework.feeds.aggregated_feed.notification_feed.NotificationFeed attribute) (stream_framework.feeds.aggregated_feed.redis.RedisAggregatedFeed attribute) (stream_framework.feeds.base.BaseFeed attribute) timeline_storage_class (stream_framework.feeds.aggregated_feed.notification_feed.RedisNotificationFeed attribute) (stream_framework.feeds.aggregated_feed.redis.RedisAggregatedFeed attribute) (stream_framework.feeds.base.BaseFeed attribute) (stream_framework.feeds.memory.Feed attribute) (stream_framework.feeds.redis.RedisFeed attribute) TimelineCache (class in stream_framework.storage.redis.timeline_storage)

trim() (stream_framework.feeds.base.BaseFeed method) (stream_framework.storage.base.BaseTimelineStorage method) (stream_framework.storage.memory.InMemoryTimelineStorage method) (stream_framework.storage.redis.structures.list.RedisListCache method) (stream_framework.storage.redis.structures.sorted_set.RedisSortedSetCache method) (stream_framework.storage.redis.timeline_storage.RedisTimelineStorage method) trim_chance (stream_framework.feeds.base.BaseFeed attribute)

U

update_read_at() (stream_framework.activity.AggregatedActivity method) update_seen_at() (stream_framework.activity.AggregatedActivity method)

UserBaseFeed (class in stream_framework.feeds.base)

V

Verb (class in stream_framework.verbs.base) verb (stream_framework.activity.AggregatedActivity attribute)

verbs (stream_framework.activity.AggregatedActivity attribute)

W

warn_on_duplicate() (in module stream_framework.utils)

warn_on_error() (in module stream_framework.utils)