Tree: 38e81632e0

add-message-queue-agent

add_fasthttp_client

add_remote_storage

avoid_releasing_temp_file_on_write

create-table-snapshot-api-design

data_query_pushdown

dependabot/maven/other/java/client/com.google.protobuf-protobuf-java-3.25.5

dependabot/maven/other/java/examples/org.apache.hadoop-hadoop-common-3.4.0

fasthttp

filer1_maintenance_branch

ftp

gh-pages

logrus

master

message_send

mount2

mq-subscribe

mq2

original_weed_mount

random_access_file

remote_overlay

revert-5134-patch-1

revert-5819-patch-1

s3-select

sub

tcp_read

test-reverting-lock-table

test_udp

testing

tikv

track-mount-e2e

volume_buffered_writes

0.72

0.72.release

0.73

0.74

0.75

0.76

0.77

0.90

0.91

0.92

0.93

0.94

0.95

0.96

0.97

0.98

0.99

1.00

1.01

1.02

1.03

1.04

1.05

1.06

1.07

1.08

1.09

1.10

1.11

1.12

1.14

1.15

1.16

1.17

1.18

1.19

1.20

1.21

1.22

1.23

1.24

1.25

1.26

1.27

1.28

1.29

1.30

1.31

1.32

1.33

1.34

1.35

1.36

1.37

1.38

1.40

1.41

1.42

1.43

1.44

1.45

1.46

1.47

1.48

1.49

1.50

1.51

1.52

1.53

1.54

1.55

1.56

1.57

1.58

1.59

1.60

1.61

1.61RC

1.62

1.63

1.64

1.65

1.66

1.67

1.68

1.69

1.70

1.71

1.72

1.73

1.74

1.75

1.76

1.77

1.78

1.79

1.80

1.81

1.82

1.83

1.84

1.85

1.86

1.87

1.88

1.90

1.91

1.92

1.93

1.94

1.95

1.96

1.97

1.98

1.99

1;70

2.00

2.01

2.02

2.03

2.04

2.05

2.06

2.07

2.08

2.09

2.10

2.11

2.12

2.13

2.14

2.15

2.16

2.17

2.18

2.19

2.20

2.21

2.22

2.23

2.24

2.25

2.26

2.27

2.28

2.29

2.30

2.31

2.32

2.33

2.34

2.35

2.36

2.37

2.38

2.39

2.40

2.41

2.42

2.43

2.47

2.48

2.49

2.50

2.51

2.52

2.53

2.54

2.55

2.56

2.57

2.58

2.59

2.60

2.61

2.62

2.63

2.64

2.65

2.66

2.67

2.68

2.69

2.70

2.71

2.72

2.73

2.74

2.75

2.76

2.77

2.78

2.79

2.80

2.81

2.82

2.83

2.84

2.85

2.86

2.87

2.88

2.89

2.90

2.91

2.92

2.93

2.94

2.95

2.96

2.97

2.98

2.99

3.00

3.01

3.02

3.03

3.04

3.05

3.06

3.07

3.08

3.09

3.10

3.11

3.12

3.13

3.14

3.15

3.16

3.18

3.19

3.20

3.21

3.22

3.23

3.24

3.25

3.26

3.27

3.28

3.29

3.30

3.31

3.32

3.33

3.34

3.35

3.36

3.37

3.38

3.39

3.40

3.41

3.42

3.43

3.44

3.45

3.46

3.47

3.48

3.50

3.51

3.52

3.53

3.54

3.55

3.56

3.57

3.58

3.59

3.60

3.61

3.62

3.63

3.64

3.65

3.66

3.67

3.68

3.69

3.71

3.72

3.73

3.74

3.75

3.76

3.77

3.78

3.79

3.80

3.81

dev

helm-3.65.1

v0.69

v0.70beta

v3.33

Branches Tags

${ item.name }

Create tag ${ searchTerm }

Create branch ${ searchTerm }

from '38e81632e0'

${ noResults }

Commit Graph

158 Commits (38e81632e04ebe8cc1dec974a1a75b62b7f019f9)

Author	SHA1	Message	Date
chrislu	a507069d19	lock for creating local partition	12 months ago
chrislu	9e6ea80dff	read existing topic conf	12 months ago
chrislu	d40225ecd2	return the lookup results	12 months ago
chrislu	841fafd0a8	publish to input buffer currently, the input buffer may not exist when start to publish	12 months ago
chrislu	d268fbe18a	when configure, cancel existing assignments	12 months ago
chrislu	3ff6b31d94	sub broker wait for partition	12 months ago
chrislu	2beaa2d0b3	pub/sub brokers check filer for assigned partitions	12 months ago
chrislu	c3f8530f97	refactor	12 months ago
chrislu	5f35857cd0	no need to assign partitions explicitly	12 months ago
chrislu	428fea45f3	updated and added assignments	12 months ago
chrislu	e8b05ecc91	add/remove assigned partitions	12 months ago
chrislu	861ad732ca	refactor	12 months ago
chrislu	47924afa1c	refactor	12 months ago
chrislu	581cf6644c	lookup reads from filer instead of local memory	12 months ago
chrislu	7121ae9617	separate out read topic conf and ensure topic active assignments	12 months ago
chrislu	c77d35313e	pub/sub broker only check local assigned partitions	12 months ago
chrislu	b0a2e9aea3	fix assignments if brokers changed	12 months ago
chrislu	a5b906c0dd	refactor	12 months ago
chrislu	34839237ab	refactor	12 months ago
chrislu	2828ccbb30	refactor	12 months ago
chrislu	541140f735	rename	12 months ago
chrislu	c8090b1f99	send assignments to newly connected subscribers	12 months ago
chrislu	c616081ab9	refactor	12 months ago
chrislu	bc8d2a01cc	create local topic partition from config on filer	12 months ago
chrislu	be0c426dc7	simplify to LookupTopicPartitions(topic)	12 months ago
chrislu	db3670a3a5	simplify api	12 months ago
chrislu	34a78ffad0	remove isForPublish from LookupTopicBrokers also adds a return parameter: whether the topic exists or not	12 months ago
chrislu	3795d8dca8	release local topic partition if no publisher and subscribers	12 months ago
chrislu	ba73199174	reuse local partition	12 months ago
chrislu	fa59a5d67e	read from disk if not in memory	12 months ago
chrislu	7afaad31a4	wait on local topic partition creation	1 year ago
chrislu	61dbdd0ff6	log ctrl messages	1 year ago
chrislu	6a7a679137	passing partition generation timestamp	1 year ago
chrislu	8af61dec91	avoid empty spaces in file name	1 year ago
chrislu	aed54eda61	refactor	1 year ago
chrislu	d51efddf5c	flush to disk Need to do: read from disk	1 year ago
chrislu	49428a303b	add batch index for each memory buffer	1 year ago
chrislu	e8611ed85d	subscribe with partition offset	1 year ago
chrislu	ee41dbb7fc	rename functions	1 year ago
chrislu	47a4963d7a	subscription start from specified timestamp	1 year ago
chrislu	35869b5c80	subscriber can be notified of the assignment change when topic is just configured Next: Subscriber needs to read by the timestamp offset.	1 year ago
chrislu	efb695fd93	lookup existing topic partitions	1 year ago
chrislu	093fdc1621	subscriber can get assignments	1 year ago
chrislu	c950a40aad	subscriber keep connected to the balancer	1 year ago
chrislu	e0727071c8	go fmt	1 year ago
chrislu	034db049a0	comment fix	1 year ago
Chris Lu	580940bf82	Merge accumulated changes related to message queue (#5098) * balance partitions on brokers * prepare topic partition first and then publish, move partition * purge unused APIs * clean up * adjust logs * add BalanceTopics() grpc API * configure topic * configure topic command * refactor * repair missing partitions * sequence of operations to ensure ordering * proto to close publishers and consumers * rename file * topic partition versioned by unixTimeNs * create local topic partition * close publishers * randomize the client name * wait until no publishers * logs * close stop publisher channel * send last ack * comments * comment * comments * support list of brokers * add cli options * Update .gitignore * logs * return io.eof directly * refactor * optionally create topic * refactoring * detect consumer disconnection * sub client wait for more messages * subscribe by time stamp * rename * rename to sub_balancer * rename * adjust comments * rename * fix compilation * rename * rename * SubscriberToSubCoordinator * sticky rebalance * go fmt * add tests * balance partitions on brokers * prepare topic partition first and then publish, move partition * purge unused APIs * clean up * adjust logs * add BalanceTopics() grpc API * configure topic * configure topic command * refactor * repair missing partitions * sequence of operations to ensure ordering * proto to close publishers and consumers * rename file * topic partition versioned by unixTimeNs * create local topic partition * close publishers * randomize the client name * wait until no publishers * logs * close stop publisher channel * send last ack * comments * comment * comments * support list of brokers * add cli options * Update .gitignore * logs * return io.eof directly * refactor * optionally create topic * refactoring * detect consumer disconnection * sub client wait for more messages * subscribe by time stamp * rename * rename to sub_balancer * rename * adjust comments * rename * fix compilation * rename * rename * SubscriberToSubCoordinator * sticky rebalance * go fmt * add tests * tracking topic=>broker * merge * comment	1 year ago
chrislu	17710e1ecb	adjust logs	1 year ago
chrislu	de0b969b36	Revert "rename" This reverts commit 35b5264ab7.	1 year ago
chrislu	35b5264ab7	rename	1 year ago