Chris Lu
f5684839a2
add DeleteTopic
5 years ago
Chris Lu
3a57aef7a9
sync subscribe()
5 years ago
Chris Lu
95ca9dd8a2
subscribe support cancel
5 years ago
Chris Lu
f11233cd49
simplify disconnected stream detection
5 years ago
Chris Lu
1ea9bc66d9
avoid leaking grpc.NewClientStream
5 years ago
Chris Lu
85b53ac510
detect disconnected subscribers
5 years ago
Chris Lu
759cda0fe2
log
5 years ago
Chris Lu
b0de01ff3b
able to detect disconnected subscribers
5 years ago
Chris Lu
e02a8c67da
revert to one subscriber one thread
5 years ago
Chris Lu
b4e02ec525
fix prometheus problem
metrics.go:123] could not push metrics to prometheus push gateway 192.168.xx:9091: unexpected status code 200 while pushing to http://192.168.xx:9091/metrics/job/filer/instance/m111p112%3A8888 :
5 years ago
Chris Lu
3a5e4769cf
prevent empty locations returned
fix https://github.com/chrislusf/seaweedfs/issues/1313
5 years ago
Chris Lu
ca4017dd87
rename
5 years ago
Chris Lu
25257acd51
rename
5 years ago
Chris Lu
a7959c1c48
multiple subscriber with same subscriberId shares the topic manager
rename topicControl to topicCursor
5 years ago
Chris Lu
2f243f5b0b
refactor
5 years ago
Chris Lu
4b7fa31468
ensure montonically increasing tsNs
5 years ago
Chris Lu
d5a8297a1c
able to connect publisher
5 years ago
Chris Lu
015dd3a147
batch file id deletion
5 years ago
Chris Lu
39e72fb23c
go fmt
5 years ago
Chris Lu
6bf3eb69cb
async chan write read, no write for closed chan
5 years ago
Chris Lu
d693e77418
add pub sub md5
5 years ago
Chris Lu
07d7abe428
add deleteTopic, refactoring
5 years ago
Chris Lu
dfccc3c263
able to read chan and write chan
5 years ago
zhangsong
b161baa3f0
fix volume vacuum test unit
5 years ago
Chris Lu
73087f59b1
filer store: mongodb deleting children
fix https://github.com/chrislusf/seaweedfs/issues/1303
5 years ago
Chris Lu
5568395edd
Revert "Revert "Merge pull request #1299 from song-zhang/master""
This reverts commit afb6a1dbb4
.
5 years ago
zhangsong
3703c7e176
write request keep compatible with before
5 years ago
Chris Lu
1e3e4b3072
add broker connects to filer
5 years ago
Chris Lu
afb6a1dbb4
Revert "Merge pull request #1299 from song-zhang/master"
This reverts commit 9016fa19ba
, reversing
changes made to 47234760f4
.
5 years ago
zhangsong
f9e8702bb4
use async write to persistent file to disk - part1
5 years ago
Chris Lu
47234760f4
log adjust format
5 years ago
Chris Lu
97a504b0bb
fix possible directory deletion error
5 years ago
Chris Lu
871efa4fc1
refactoring
some previous chunk etag was using md5, which should be wrong.
5 years ago
zhangsong
d819865fe7
add fsync option for benchmark
5 years ago
Chris Lu
ea809a45ab
add cipher key
5 years ago
Chris Lu
f9b6178b8f
log messages
5 years ago
Chris Lu
8c73410a51
subscribe from a timestamp
5 years ago
Chris Lu
4e16a90454
for debugging
5 years ago
Chris Lu
a25a8d8822
s3: print out time in UTC format
fix https://github.com/chrislusf/seaweedfs/issues/1297
5 years ago
Chris Lu
e93588ec78
FUSE mount: atomic local cache updates
5 years ago
Chris Lu
9e72e9e4b8
able to subscribe any topic from any point of time
5 years ago
Chris Lu
ed3cf811f5
refactoring
5 years ago
Chris Lu
7c10602b49
read in case cross chunks
5 years ago
Chris Lu
f9da859720
better error message
5 years ago
Chris Lu
d57559d3f7
chunk rememober encryption or not
5 years ago
Chris Lu
5a0986dca0
reset on getting the buffer
5 years ago
Chris Lu
8d42a1263b
meta subscription: update the last read time
5 years ago
Chris Lu
31583b5d6c
master and volume server: avoid race condition
The volume server may disconnect and reconnect to the same master.
The master's unregistration may happen after the reconnection. Thus the volume server will disappear.
5 years ago
Chris Lu
98edec7c3e
remove printouts
5 years ago
Chris Lu
8ed490164e
refactoring
5 years ago