aboutsummaryrefslogtreecommitdiff
path: root/weed/messaging
AgeCommit message (Collapse)AuthorFilesLines
2022-07-28renamingchrislu16-1411/+0
2022-05-30stop when in memory log is donechrislu1-1/+1
2022-05-30subscribe metadata between a rangechrislu1-1/+1
2022-05-24reduce busy waiting when reading metadata logschrislu1-1/+0
2021-12-26use streaming mode for long poll grpc callschrislu3-12/+12
streaming mode would create separate grpc connections for each call. this is to ensure the long poll connections are properly closed.
2021-12-05upgrade protoc to 3.17.3chrislu1-0/+2
$brew install protobuf $ protoc --version libprotoc 3.17.3 $ go install google.golang.org/protobuf/cmd/protoc-gen-go@v1.26 $ go install google.golang.org/grpc/cmd/protoc-gen-go-grpc@v1.1
2021-11-08use constantsChris Lu1-1/+2
2021-11-05Revert "master: rename grpc function KeepConnected() to ↵Chris Lu1-4/+4
SubscribeVolumeLocationUpdates()" This reverts commit af71ae11aa29350a60ed7d3b9a16276a06ba9dcc.
2021-11-03master: rename grpc function KeepConnected() to SubscribeVolumeLocationUpdates()Chris Lu1-4/+4
2021-11-02shell: optionally read filer address from masterChris Lu1-2/+4
2021-09-25avoid possible metadata subscription data lossChris Lu1-2/+4
Previous implementation append filer logs into one file. So one file is not always sorted, which can lead to miss reading some entries, especially when different filers have different write throughput.
2021-09-12change server address from string to a typeChris Lu3-9/+13
2021-09-06refactoringChris Lu1-1/+10
2021-06-27logging changes to debugChris Lu2-2/+2
2021-05-07add retry to assign volumeChris Lu1-19/+26
fix https://github.com/chrislusf/seaweedfs/issues/2056
2021-01-28add back AdjustedUrl() related codeChris Lu1-0/+4
2021-01-24mount: outsideContainerClusterMode proxy through filerChris Lu1-4/+0
Running mount outside of the cluster would not need to expose all the volume servers to outside of the cluster. The chunk read and write will go through the filer.
2021-01-24Revert "mount: when outside cluster network, use filer as proxy to access ↵Chris Lu1-0/+4
volume servers" This reverts commit 096e088d7bb2a5dce7573b24c2d3006d1cb6f9ec.
2021-01-24mount: when outside cluster network, use filer as proxy to access volume serversChris Lu1-4/+0
2021-01-11filer: ensure seamless meta data updatesChris Lu1-11/+15
2020-10-11refactoring in order to adjust volume server url laterChris Lu1-2/+2
2020-09-09properly cancel context for streaming grpcChris Lu1-1/+3
2020-09-09filer: cross cluster synchronizationChris Lu2-7/+17
2020-09-01rename filer2 to filerChris Lu4-10/+10
2020-08-29use UTC for all time related foldersChris Lu2-0/+2
2020-08-29read meta logs by timestampChris Lu1-1/+1
pass in event ts when moving logs meta aggregator reads in memory logs only
2020-08-28add signatures to messages to avoid double processingChris Lu1-1/+1
2020-07-05refactoringChris Lu1-2/+2
2020-06-30filer: support active<=>active filer replicationChris Lu1-1/+1
2020-06-05go fmtChris Lu2-4/+4
2020-05-17add delete channelChris Lu3-0/+5
2020-05-17reduc logsChris Lu1-1/+1
2020-05-17fix loopingChris Lu1-3/+3
2020-05-17add DeleteTopicChris Lu1-0/+63
2020-05-17sync subscribe()Chris Lu1-1/+8
2020-05-17subscribe support cancelChris Lu2-4/+26
2020-05-17simplify disconnected stream detectionChris Lu1-15/+2
2020-05-16detect disconnected subscribersChris Lu2-20/+32
2020-05-16able to detect disconnected subscribersChris Lu3-25/+40
2020-05-15revert to one subscriber one threadChris Lu3-97/+15
2020-05-12renameChris Lu1-14/+14
2020-05-12renameChris Lu1-9/+9
2020-05-12multiple subscriber with same subscriberId shares the topic managerChris Lu4-13/+95
rename topicControl to topicCursor
2020-05-12refactorChris Lu4-33/+33
2020-05-10able to connect publisherChris Lu1-10/+7
2020-05-10go fmtChris Lu7-8/+9
2020-05-10async chan write read, no write for closed chanChris Lu4-2/+26
2020-05-09add pub sub md5Chris Lu3-6/+27
2020-05-09add deleteTopic, refactoringChris Lu4-56/+83
2020-05-08able to read chan and write chanChris Lu12-41/+216
generated by cgit v1.2.3 (git 2.25.1) at 2025-12-22 00:03:47 +0000