Bartosz Sypytkowski
|
9c428f1d89
|
chore: add stream key info to stream length exceeded check
|
2024-11-06 07:49:25 +01:00 |
|
Bartosz Sypytkowski
|
f328e96763
|
chore: reduce log visibility level
|
2024-11-06 07:31:32 +01:00 |
|
Bartosz Sypytkowski
|
5388d419e6
|
chore: remove unused import
|
2024-11-05 07:48:14 +01:00 |
|
Bartosz Sypytkowski
|
183e915f5e
|
chore: lease drop log message - use tracing crate
|
2024-11-05 07:48:14 +01:00 |
|
Bartosz Sypytkowski
|
25f0461389
|
chore: added metrics for new stateless operations
|
2024-11-05 07:48:14 +01:00 |
|
Bartosz Sypytkowski
|
e86c9de316
|
chore: when saving collab snapshot, do not load it unless there are pending updates in redis
|
2024-11-05 07:48:14 +01:00 |
|
Bartosz Sypytkowski
|
b6ba52672a
|
chore: add exponential backoff to collab update stream
|
2024-11-05 07:48:14 +01:00 |
|
Bartosz Sypytkowski
|
961c482995
|
chore: prevent hot loops in collab updates stream
|
2024-11-05 07:48:14 +01:00 |
|
Bartosz Sypytkowski
|
923fe7ffde
|
chore: fix errors in lease code
|
2024-11-05 07:48:14 +01:00 |
|
Bartosz Sypytkowski
|
e9a7d42b2e
|
chore: fix issues mentioned in nathan review
|
2024-11-05 07:48:14 +01:00 |
|
Bartosz Sypytkowski
|
7dc90904cb
|
chore: fix clippy warnings
|
2024-11-05 07:47:17 +01:00 |
|
Bartosz Sypytkowski
|
279a599b66
|
chore: fix early return from redis collab update stream reader
|
2024-11-05 07:47:17 +01:00 |
|
Bartosz Sypytkowski
|
85e25f887c
|
chore: don't try to prune empty redis stream
|
2024-11-05 07:47:17 +01:00 |
|
Bartosz Sypytkowski
|
d0b7c7d8e3
|
chore: update stream - live and current queries
|
2024-11-05 07:47:17 +01:00 |
|
Bartosz Sypytkowski
|
00f5a5bb7e
|
chore: code cleanup
|
2024-11-05 07:47:17 +01:00 |
|
Bartosz Sypytkowski
|
97335a94ec
|
chore: basics of snapshots (unoptimized)
|
2024-11-05 07:47:17 +01:00 |
|
Bartosz Sypytkowski
|
253bb97825
|
chore: a dirty draft of snapshot saving
|
2024-11-05 07:47:17 +01:00 |
|
Bartosz Sypytkowski
|
9164c494b1
|
chore: redis stream for awareness
|
2024-11-05 07:47:17 +01:00 |
|
Bartosz Sypytkowski
|
d26d0ff1a7
|
chore: collab streams
|
2024-11-05 07:47:17 +01:00 |
|
Bartosz Sypytkowski
|
0d6b595ee8
|
chore: create collab update sink and stream
|
2024-11-05 07:47:17 +01:00 |
|
Bartosz Sypytkowski
|
fe3611cc88
|
chore: remove broadcast and introduce lease
|
2024-11-05 07:47:17 +01:00 |
Nathan.fooo
|
054fd2e7d8
|
chore: ignore create redis stream error when create a new group (#826)
|
2024-09-16 15:31:05 +08:00 |
|
Nathan.fooo
|
54b811125e
|
chore: wrap spawn blocking when decoding collab (#767)
|
2024-08-29 22:53:33 +08:00 |
|
Bartosz Sypytkowski
|
f2fa4d7c22
|
chore: post rebase fixes
|
2024-08-14 05:26:38 +02:00 |
|
Nathan.fooo
|
73127fb886
|
chore: shorten group lifetime (#726)
|
2024-08-13 16:20:06 +08:00 |
Khor Shu Heng
|
bb1c93b98a
|
chore: replace bincode serialization with protobuf for collab stream (#715)
|
2024-08-05 23:44:34 +08:00 |
|
Khor Shu Heng
|
ca6490c1ac
|
feat: deserialization for entities used in collab stream (#682)
|
2024-07-30 17:08:48 +08:00 |
|
Nathan.fooo
|
1a22813113
|
chore: stop indexing when stream is not exist (#652)
|
2024-06-26 14:24:23 +08:00 |
|
Bartosz Sypytkowski
|
7ad105ee34
|
fix: index all of the document blocks
|
2024-06-14 11:23:19 +02:00 |
|
Nathan.fooo
|
115d046094
|
chore: periodicall check redis stream capacity (#580)
|
2024-05-27 14:09:57 +08:00 |
|
Nathan.fooo
|
3f2d5f0785
|
chore: optimize redis stream space usage (#579)
* chore: set maxlen for redis stream
* chore: update log
* chore: set expiration time
|
2024-05-27 13:22:14 +08:00 |
|
Nathan.fooo
|
4eb1e6bceb
|
chore: generate history using redis steam (#570)
* chore: combine test
* chore: add snapshot test
* chore: add test
|
2024-05-23 07:57:20 +08:00 |
|
Khor Shu Heng
|
67d9fad7d7
|
chore: migrate collab storage to appflowy-collaborate (#566)
* chore: migrate collab storage to appflowy-collaborate
* fix: clippy error
* chore: remove handler
---------
Co-authored-by: nathan <nathan@appflowy.io>
|
2024-05-21 10:06:26 +08:00 |
|
Nathan.fooo
|
2736fa60a7
|
chore: integrate redis stream (#559)
* chore: integrate redis stream
* chore: make CollabUpdateStreaming::send_update synchronous
---------
Co-authored-by: Bartosz Sypytkowski <b.sypytkowski@gmail.com>
|
2024-05-18 08:28:57 +08:00 |
|
Nathan.fooo
|
5f970a625a
|
chore: use rust 1.77 (#493)
|
2024-04-24 10:47:18 +08:00 |
|
Nathan.fooo
|
0be4d2d5b5
|
ci: try to fix flaky test (#473)
* chore: update ping config
* chore: fix test
* chore: fix test
|
2024-04-16 18:20:36 +08:00 |
|
Nathan.fooo
|
f3279e9b4e
|
feat: implement grpc for history server (#470)
* ci: docker compose for ci
* chore: add test
* chore: imple grpc
* chore: fix test
* chore: fix ci
|
2024-04-16 14:10:56 +08:00 |
|
Nathan.fooo
|
28e0e74fd1
|
feat: Implement history(1) (#466)
* chore: update collab commit
* chore: collab history test
* chore: collab history test
* chore: impl redis stream
* chore: impl redis stream test
* chore: impl migration
* chore: implement history sql
* chore: add test
* chore: add test
* chore: fix test
* chore: update log and test
* chore: add xtask
* chore: clippy
* chore: impl api
* chore: add missing sqlx files
* chore: fix test
* chore: fix test
|
2024-04-15 09:18:19 +08:00 |
|
Nathan.fooo
|
0df98e3f04
|
feat: ack group message (#405)
|
2024-03-21 07:35:34 +08:00 |
|
Nathan.fooo
|
15a07a61e7
|
feat: implement redis pubsub (#403)
* chore: implement redis pubsub
* chore: fix warns
* chore: use bincode to do serdde
|
2024-03-20 17:46:01 +08:00 |
|
Nathan.fooo
|
d4845a6784
|
feat: group stream (#399)
* feat: group stream
* chore: update
|
2024-03-20 11:24:31 +08:00 |
Zack
|
de92490e26
|
feat: collab-stream redis poc (#83)
* feat: collab-stream redis poc
* fix: remove unneeded print statements
* feat: implementing listening
* chore: fix conflict
* chore: add test
* chore: add test
---------
Co-authored-by: nathan <nathan@appflowy.io>
|
2024-03-20 10:00:25 +08:00 |