aboutsummaryrefslogtreecommitdiff
path: root/weed/mq/broker/broker_server.go
AgeCommit message (Expand)AuthorFilesLines
2025-05-22WIPorigin/changing-to-zapchrislu1-3/+3
2024-06-14sort importschrislu1-1/+1
2024-06-14Merge branch 'master' into mqchrislu1-2/+3
2024-06-14Added context for the MasterClient's methods to avoid endless loops (#5628)vadimartynov1-2/+3
2024-06-06refactor out FilerClientAccessorchrislu1-2/+3
2024-05-27balance subscriberschrislu1-3/+1
2024-05-23go fmtchrislu1-3/+3
2024-05-21renamechrislu1-12/+12
2024-05-21rename Coordinator to SubCoordinatorchrislu1-1/+1
2024-05-21rename Balancer to PubBalancerchrislu1-1/+1
2024-05-20go fmtchrislu1-3/+2
2024-05-14move initial assignment to rebalance logicchrislu1-2/+7
2024-05-14move read write topic config into filer client accessorchrislu1-0/+8
2024-03-09retry connecting to broker leaderchrislu1-11/+4
2024-03-07adjust errorchrislu1-1/+2
2024-02-05proxy requests to lock ownerChris Lu1-4/+2
2024-02-04fix lock TTLChris Lu1-4/+3
2024-02-04avoid too large expiration timeChris Lu1-1/+1
2024-02-02lock returns host and ownerchrislu1-4/+7
2024-02-01use a short-lived lockchrislu1-2/+2
2024-01-29re-lock if the lock owner is not foundchrislu1-4/+6
2024-01-20refactorchrislu1-2/+2
2024-01-20refactorchrislu1-0/+2
2024-01-17create local topic partition from config on filerchrislu1-4/+8
2024-01-15reuse local partitionchrislu1-0/+2
2024-01-08flush to diskchrislu1-0/+1
2024-01-03subscriber can be notified of the assignment change when topic is just config...chrislu1-1/+3
2023-12-11Merge accumulated changes related to message queue (#5098)Chris Lu1-23/+28
2023-10-12Revert "rename"chrislu1-2/+2
2023-10-11renamechrislu1-2/+2
2023-09-24add CreateTopic APIchrislu1-1/+1
2023-09-19fix compilation bugs during mergechrislu1-0/+1
2023-09-16balancer workschrislu1-0/+22
2023-09-14receive broker statschrislu1-1/+4
2023-09-13Merge branch 'master' into subchrislu1-1/+1
2023-08-27pub sub initial testschrislu1-1/+1
2023-08-24Implement SRV lookups for filer (#4767)Nico D'Cotta1-1/+1
2023-08-20Squashed commit of the following:chrislu1-9/+12
2023-01-20grpc connection to filer add sw-client-id headerchrislu1-1/+1
2022-08-26avoid race conditions for OnPeerUpdate (#3525)Konstantin Lebedev1-1/+1
2022-08-23remove old raft servers if they don't answer to pings for too long (#3398)askeipx1-2/+3
2022-08-04filer prefer volume server in same data center (#3405)Konstantin Lebedev1-1/+7
2022-07-29move to https://github.com/seaweedfs/seaweedfschrislu1-6/+6
2022-07-28segment serdechrislu1-2/+8
2022-07-28dynamically connect to a filerchrislu1-3/+37
2022-07-28allocate brokers to serve segmentschrislu1-0/+8
2022-07-28remove old codechrislu1-64/+0
2022-07-28display data center and rack in cluster.pschrislu1-1/+1
2022-07-28add dc and rackchrislu1-1/+3
2022-07-28cluster.ps can list brokerschrislu1-6/+13
generated by cgit v1.2.3 (git 2.25.1) at 2025-12-21 01:25:10 +0000