diff options
| author | Erik Johnston <erik@matrix.org> | 2016-08-15 11:45:57 +0100 |
|---|---|---|
| committer | Erik Johnston <erik@matrix.org> | 2016-08-15 11:45:57 +0100 |
| commit | d9664344ecf481a73b2189f5bc65f4f784222969 (patch) | |
| tree | 561371e33f98b5ef8b4c2e12bd504ebc4ad1857a /synapse/storage/schema/delta/34 | |
| parent | Remove broken cache stuff (diff) | |
| download | synapse-d9664344ecf481a73b2189f5bc65f4f784222969.tar.xz | |
Rename table. Add docs.
Diffstat (limited to 'synapse/storage/schema/delta/34')
| -rw-r--r-- | synapse/storage/schema/delta/34/cache_stream.py | 6 |
1 files changed, 4 insertions, 2 deletions
diff --git a/synapse/storage/schema/delta/34/cache_stream.py b/synapse/storage/schema/delta/34/cache_stream.py index 4c350bfb11..3b63a1562d 100644 --- a/synapse/storage/schema/delta/34/cache_stream.py +++ b/synapse/storage/schema/delta/34/cache_stream.py @@ -20,15 +20,17 @@ import logging logger = logging.getLogger(__name__) +# This stream is used to notify replication slaves that some caches have +# been invalidated that they cannot infer from the other streams. CREATE_TABLE = """ -CREATE TABLE cache_stream ( +CREATE TABLE cache_invalidation_stream ( stream_id BIGINT, cache_func TEXT, keys TEXT[], invalidation_ts BIGINT ); -CREATE INDEX cache_stream_id ON cache_stream(stream_id); +CREATE INDEX cache_invalidation_stream_id ON cache_invalidation_stream(stream_id); """ |