Stream Framework
latest
Installation
Feed setup
Adding data
Verbs
Querying feeds
Settings
Metrics
Testing Stream Framework
Support
Activity class
Choosing a storage layer
Background Tasks with celery
Tutorial: building a notification feed
Stream Framework Design
Cassandra storage backend
Stream Framework API Docs
Stream Framework
Docs
»
Index
Edit on GitHub
Index
A
|
B
|
C
|
D
|
E
|
F
|
G
|
H
|
I
|
K
|
L
|
M
|
N
|
O
|
P
|
R
|
S
|
T
|
U
|
V
|
W
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.base.BaseFeed attribute)
activity_storage_class (stream_framework.feeds.base.BaseFeed attribute)
(stream_framework.feeds.memory.Feed attribute)
activity_to_id() (stream_framework.storage.base.BaseStorage method)
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)
add_many() (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)
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)
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)
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)
BaseStorage (class in stream_framework.storage.base)
BaseTimelineStorage (class in stream_framework.storage.base)
C
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)
count() (stream_framework.feeds.base.BaseFeed method)
(stream_framework.storage.base.BaseTimelineStorage method)
(stream_framework.storage.memory.InMemoryTimelineStorage 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)
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)
deserialize_activities() (stream_framework.storage.base.BaseStorage method)
DuplicateActivityException
E
epoch_to_datetime() (in module stream_framework.utils)
F
Feed (class in stream_framework.feeds.memory)
filter() (stream_framework.feeds.base.BaseFeed method)
filtering_supported (stream_framework.feeds.base.BaseFeed attribute)
flush() (stream_framework.feeds.base.BaseFeed class method)
(stream_framework.storage.base.BaseStorage method)
(stream_framework.storage.memory.InMemoryActivityStorage method)
Follow (class in stream_framework.verbs.base)
G
get() (stream_framework.storage.base.BaseActivityStorage 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)
get_class_from_string() (in module stream_framework.utils)
get_dehydrated() (stream_framework.activity.Activity method)
(stream_framework.activity.AggregatedActivity method)
get_from_storage() (stream_framework.storage.base.BaseActivityStorage method)
(stream_framework.storage.memory.InMemoryActivityStorage 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)
get_many() (stream_framework.storage.base.BaseActivityStorage method)
get_metrics_instance() (in module stream_framework.utils)
get_slice() (stream_framework.storage.base.BaseTimelineStorage method)
get_slice_from_storage() (stream_framework.storage.base.BaseTimelineStorage method)
(stream_framework.storage.memory.InMemoryTimelineStorage 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)
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)
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.base.BaseFeed attribute)
(stream_framework.feeds.base.UserBaseFeed attribute)
L
last_activities (stream_framework.activity.AggregatedActivity attribute)
last_activity (stream_framework.activity.AggregatedActivity attribute)
Love (class in stream_framework.verbs.base)
LRUCache (class in stream_framework.utils)
M
make_list_unique() (in module stream_framework.utils)
max_aggregated_activities_length (stream_framework.activity.AggregatedActivity attribute)
max_length (stream_framework.feeds.base.BaseFeed attribute)
(stream_framework.feeds.base.UserBaseFeed 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)
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)
other_actor_count (stream_framework.activity.AggregatedActivity attribute)
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)
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)
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)
remove_activity() (stream_framework.feeds.base.BaseFeed class 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)
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)
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.utils.LRUCache method)
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.base (module)
stream_framework.feeds.memory (module)
stream_framework.settings (module)
stream_framework.storage.base (module)
stream_framework.storage.cassandra (module)
stream_framework.storage.memory (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.base.BaseFeed attribute)
timeline_storage_class (stream_framework.feeds.base.BaseFeed attribute)
(stream_framework.feeds.memory.Feed attribute)
trim() (stream_framework.feeds.base.BaseFeed method)
(stream_framework.storage.base.BaseTimelineStorage method)
(stream_framework.storage.memory.InMemoryTimelineStorage 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)
Read the Docs
v: latest
Versions
latest
stable
Downloads
pdf
htmlzip
epub
On Read the Docs
Project Home
Builds
Free document hosting provided by
Read the Docs
.