aboutsummaryrefslogtreecommitdiff
path: root/weed/replication/sub
AgeCommit message (Collapse)AuthorFilesLines
2025-07-16convert error fromating to %w everywhere (#6995)Chris Lu2-2/+2
2023-09-25weed/replication/sub: fix dropped error (#4865)Lars Lehtonen1-1/+4
2022-09-14refactor(notification_kafka): `parition` -> `partition` (#3663)Ryan Russell1-2/+2
2022-08-31Bump gocloud.dev/pubsub/rabbitpubsub from 0.25.0 to 0.26.0 (#3541)dependabot[bot]1-1/+1
* Bump gocloud.dev/pubsub/rabbitpubsub from 0.25.0 to 0.26.0 Bumps [gocloud.dev/pubsub/rabbitpubsub](https://github.com/google/go-cloud) from 0.25.0 to 0.26.0. - [Release notes](https://github.com/google/go-cloud/releases) - [Commits](https://github.com/google/go-cloud/compare/v0.25.0...v0.26.0) --- updated-dependencies: - dependency-name: gocloud.dev/pubsub/rabbitpubsub dependency-type: direct:production update-type: version-update:semver-minor ... Signed-off-by: dependabot[bot] <support@github.com> * update code * more code fix Signed-off-by: dependabot[bot] <support@github.com> Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com> Co-authored-by: chrislu <chris.lu@gmail.com>
2022-08-17also migrate jsonpbchrislu1-1/+1
2022-08-17move proto packagechrislu4-4/+4
2022-07-29move to https://github.com/seaweedfs/seaweedfschrislu5-14/+14
2022-07-06rabbitpubsub enable durableKonstantin Lebedev1-4/+4
2022-04-21conditionally build elastic, gocdk to reduce binary sizechrislu1-0/+3
2022-02-04change to util.WriteFilechrislu1-1/+1
2021-10-14refactor: move from io/ioutil to io and os packageEng Zer Jun1-3/+3
The io/ioutil package has been deprecated as of Go 1.16, see https://golang.org/doc/go1.16#ioutil. This commit replaces the existing io/ioutil functions with their new definitions in io and os packages. Signed-off-by: Eng Zer Jun <engzerjun@gmail.com>
2021-09-01go fmtChris Lu1-1/+1
2021-08-25cloud drive: add support for WasabiChris Lu1-0/+1
* disable md5, sha256 checking to avoid reading one chunk twice * single threaded upload to avoid chunk swapping (to be enhanced later)
2021-02-11Do reconnect to RabbitMQKonstantin Lebedev1-9/+24
https://github.com/google/go-cloud/issues/2958 https://github.com/chrislusf/seaweedfs/issues/1773
2021-02-10restart replication if RabbitMQ connection closedKonstantin Lebedev1-0/+4
https://github.com/google/go-cloud/issues/2958
2021-02-03fix log warnKonstantin Lebedev1-1/+1
2021-02-03RabbitMQ delay retry with Dead Letter ExchangeKonstantin Lebedev1-5/+89
https://github.com/chrislusf/seaweedfs/issues/1773 https://github.com/google/go-cloud/issues/2952
2021-01-26notification add ack and nackChris Lu5-8/+25
2020-04-10fix sqs message readingChris Lu1-1/+3
2020-01-29support env variables to overwrite toml fileChris Lu5-23/+23
2019-11-18WIPChris Lu1-3/+3
2019-07-17disable azure due to api changesChris Lu1-1/+1
2019-04-05fix typoJonathan Amsterdam1-1/+1
2019-04-04replication: add GoCDK PubSub supportJonathan Amsterdam1-0/+50
2018-11-01go fmtChris Lu2-6/+6
2018-11-01separate into notification.toml, add gcp pub/sub message queueChris Lu1-0/+109
2018-10-31support AWS SQS as file change notification message queueChris Lu3-0/+287