chrislu
d45a372615
add schema.proto
1 year ago
chrislu
ccdd9cd8de
refactor
1 year ago
chrislu
f37c0d0d7a
comment out println
1 year ago
chrislu
d935f70e3c
shutdown follower when leader stops
1 year ago
chrislu
f07875e8e1
send flush message to follower before shutting down logBuffer
1 year ago
chrislu
e568e742c9
renaming
1 year ago
chrislu
47975e75bf
purge old code
1 year ago
chrislu
237e68059d
shutdown follower if no clients, not only publishers
to avoid overhead when a publisher repeatedly send one message and close
1 year ago
chrislu
66a878af39
add control message to data message
1 year ago
chrislu
546ae87c39
send is_close message to broker
1 year ago
chrislu
c9df613b6b
add publisher name for debugging
1 year ago
chrislu
ca4f89a6f6
simplify
1 year ago
chrislu
0d55bddc75
logs
1 year ago
chrislu
e3c8be7f89
LocalPartition shutdown
1 year ago
chrislu
ab9fc0ad70
simplify
1 year ago
chrislu
7463058299
change visibility
1 year ago
chrislu
dab5454332
publish and send to follower
1 year ago
chrislu
f249f831b1
MaybeShutdownLocalPartition refactor
1 year ago
chrislu
2a0ab7e90d
fix
1 year ago
chrislu
059a120708
refactor
1 year ago
chrislu
7d87c1d2bb
refactor
1 year ago
chrislu
5cc94a05b9
separate goroutine to send ack to publisher
1 year ago
chrislu
17806cde2a
separate context
If using the same context, the downstream grpc would be cancelled when the parent grpc is cancelled.
1 year ago
chrislu
f67c8309d8
rename
1 year ago
chrislu
d6a066495b
adjust logs
1 year ago
chrislu
1b1b96ea1e
close local partition if no more publishers and subscribers
1 year ago
chrislu
4f5c4c3388
refactor
1 year ago
chrislu
d558a58946
refactor
1 year ago
chrislu
205d2285f3
setup follower by publisher
* the subscriber would getOrGen a local partition and wait
* the publisher would getOrGen a local partition. If localPartition follower is not setup, and init message has follower info, it would create followers based on init.Messages.
1 year ago
chrislu
da31e9b939
correctly wait for the publisher to finish
1 year ago
chrislu
7003ce7425
publisher is able to fully send data and receive acks
still needs to close the pipes cleanly
1 year ago
chrislu
516cba7053
remove FollowInMemoryMessages
1 year ago
chrislu
6ef3e6bcad
logging
1 year ago
chrislu
a8b73296d7
fix test3
1 year ago
chrislu
ea2601799c
fix test
1 year ago
chrislu
8e5068fd2f
notify
1 year ago
chrislu
44ab42d03c
unnecessary
1 year ago
chrislu
3f2dd8cc3e
add follower id info
1 year ago
chrislu
529fa8c4c8
go fmt
1 year ago
chrislu
1b5c547cfe
logs
1 year ago
chrislu
55714f54ab
local partition is generated or not
1 year ago
chrislu
549455c30d
streaming mode
1 year ago
chrislu
f653838f34
follower receive a hello message before actual data
the leader can ensure the follower has connected
1 year ago
chrislu
64a32730a2
add size()
1 year ago
chrislu
6f75a0af55
ask follower to follow
1 year ago
chrislu
e7823ee967
retry connecting to broker leader
1 year ago
chrislu
3b28433cb1
change LogBuffer visibility in LocalPartition
1 year ago
chrislu
28f8f33d6a
include key in LogEntry
1 year ago
chrislu
34f2b600ac
each log function adds a "done" return parameter
1 year ago
chrislu
62397f2371
adjust error
1 year ago