Index

A

admin (slipstream.core.Topic property) (slipstream.Topic property)

apublish() (slipstream.utils.PubSub method) asend() (slipstream.core.Topic method) (slipstream.Topic method)

C

Cache (class in slipstream) (class in slipstream.caching) check_pulse() (slipstream.checkpointing.Checkpoint method) Checkpoint (class in slipstream.checkpointing) close() (slipstream.Cache method) (slipstream.caching.Cache method)

compact_range() (slipstream.Cache method) (slipstream.caching.Cache method) Conf (class in slipstream) (class in slipstream.core) conf (slipstream.core.Conf attribute) create_column_family() (slipstream.Cache method) (slipstream.caching.Cache method)

D

decode() (slipstream.codecs.JsonCodec method) (slipstream.interfaces.ICodec method) delete() (slipstream.Cache method) (slipstream.caching.Cache method) delete_range() (slipstream.Cache method) (slipstream.caching.Cache method)

Dependency (class in slipstream.checkpointing) destroy() (slipstream.Cache method) (slipstream.caching.Cache method) drop_column_family() (slipstream.Cache method) (slipstream.caching.Cache method)

E

encode() (slipstream.codecs.JsonCodec method) (slipstream.interfaces.ICodec method) exit_hook() (slipstream.core.Topic method) (slipstream.Topic method)

exit_hooks (slipstream.Conf attribute) (slipstream.core.Conf attribute)

F

flush() (slipstream.Cache method) (slipstream.caching.Cache method)

flush_wal() (slipstream.Cache method) (slipstream.caching.Cache method)

G

get() (slipstream.Cache method) (slipstream.caching.Cache method) get_column_family() (slipstream.Cache method) (slipstream.caching.Cache method) get_column_family_handle() (slipstream.Cache method) (slipstream.caching.Cache method)

get_consumer() (slipstream.core.Topic method) (slipstream.Topic method) get_params_names() (in module slipstream.utils) get_producer() (slipstream.core.Topic method) (slipstream.Topic method)

H

handle() (in module slipstream) (in module slipstream.core)

heartbeat() (slipstream.checkpointing.Checkpoint method)

I

ICache (class in slipstream.interfaces) ICodec (class in slipstream.interfaces) ingest_external_file() (slipstream.Cache method) (slipstream.caching.Cache method) init_generator() (slipstream.core.Topic method) (slipstream.Topic method) iscoroutinecallable() (in module slipstream.utils)

items() (slipstream.Cache method) (slipstream.caching.Cache method) iter() (slipstream.Cache method) (slipstream.caching.Cache method) iter_topic() (slipstream.utils.PubSub method) iterables (slipstream.Conf attribute) (slipstream.core.Conf attribute)

J

JsonCodec (class in slipstream.codecs)

K

key_may_exist() (slipstream.Cache method) (slipstream.caching.Cache method)

keys() (slipstream.Cache method) (slipstream.caching.Cache method)

L

latest_sequence_number() (slipstream.Cache method) (slipstream.caching.Cache method)

live_files() (slipstream.Cache method) (slipstream.caching.Cache method) load() (slipstream.checkpointing.Dependency method)

M

module slipstream slipstream.caching slipstream.checkpointing slipstream.codecs slipstream.core slipstream.interfaces slipstream.utils

P

path() (slipstream.Cache method) (slipstream.caching.Cache method) PausableStream (class in slipstream.core) PAUSE (slipstream.core.Signal attribute) property_int_value() (slipstream.Cache method) (slipstream.caching.Cache method) property_value() (slipstream.Cache method) (slipstream.caching.Cache method)

publish() (slipstream.utils.PubSub method) PubSub (class in slipstream.utils) pubsub (slipstream.Conf attribute) (slipstream.core.Conf attribute) put() (slipstream.Cache method) (slipstream.caching.Cache method)

R

register_exit_hook() (slipstream.Conf method) (slipstream.core.Conf method) register_handler() (slipstream.Conf method) (slipstream.core.Conf method)

register_iterable() (slipstream.Conf method) (slipstream.core.Conf method) RESUME (slipstream.core.Signal attribute)

S

save() (slipstream.checkpointing.Dependency method) seek() (slipstream.core.Topic method) (slipstream.Topic method) send_signal() (slipstream.core.PausableStream method) SENTINEL (slipstream.core.Signal attribute) set_dumps() (slipstream.Cache method) (slipstream.caching.Cache method) set_loads() (slipstream.Cache method) (slipstream.caching.Cache method) set_options() (slipstream.Cache method) (slipstream.caching.Cache method) set_read_options() (slipstream.Cache method) (slipstream.caching.Cache method) set_write_options() (slipstream.Cache method) (slipstream.caching.Cache method) Signal (class in slipstream.core) Singleton (class in slipstream.utils) slipstream module

slipstream.caching module slipstream.checkpointing module slipstream.codecs module slipstream.core module slipstream.interfaces module slipstream.utils module snapshot() (slipstream.Cache method) (slipstream.caching.Cache method) start() (slipstream.Conf method) (slipstream.core.Conf method) stream() (in module slipstream) (in module slipstream.core) subscribe() (slipstream.utils.PubSub method)

T

Topic (class in slipstream) (class in slipstream.core)

transaction() (slipstream.Cache method) (slipstream.caching.Cache method)

U

unsubscribe() (slipstream.utils.PubSub method)

V

values() (slipstream.Cache method) (slipstream.caching.Cache method)