Tree: 55501bb51c

add-admin-and-worker-to-helm-charts

add-ec-vacuum

add-foundation-db

add_fasthttp_client

add_remote_storage

adding-message-queue-integration-tests

avoid_releasing_temp_file_on_write

changing-to-zap

collect-public-metrics

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

detect-and-plan-ec-tasks

do-not-retry-if-error-is-NotFound

enhance-erasure-coding

fallback-on-volume-id-lookup

fasthttp

filer1_maintenance_branch

fix-GetObjectLockConfigurationHandler

fix-versioning-listing-only

ftp

gh-pages

improve-fuse-mount

improve-fuse-mount2

logrus

master

message_send

mount2

mq-subscribe

mq2

original_weed_mount

random_access_file

refactor-needle-read-operations

refactor-volume-write

remote_overlay

revert-5134-patch-1

revert-5819-patch-1

revert-6434-bugfix-missing-s3-audit

s3-select

sub

tcp_read

test-reverting-lock-table

test_udp

testing

testing-sdx-generation

tikv

track-mount-e2e

volume_buffered_writes

worker-execute-ec-tasks

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

3.82

3.83

3.84

3.85

3.86

3.87

3.88

3.89

3.90

3.91

3.92

3.93

3.94

3.95

3.96

3.97

3.98

3.99

dev

helm-3.65.1

v0.69

v0.70beta

v3.33

Branches Tags

${ item.name }

Create tag ${ searchTerm }

Create branch ${ searchTerm }

from '55501bb51c'

${ noResults }

Commit Graph

195 Commits (55501bb51cc34b9cdb4455f455238e18130c5d09)

Author	SHA1	Message	Date
chrislu	b0a2e9aea3	fix assignments if brokers changed	2 years ago
chrislu	a5b906c0dd	refactor	2 years ago
chrislu	34839237ab	refactor	2 years ago
chrislu	2828ccbb30	refactor	2 years ago
chrislu	541140f735	rename	2 years ago
chrislu	c8090b1f99	send assignments to newly connected subscribers	2 years ago
chrislu	c616081ab9	refactor	2 years ago
chrislu	bc8d2a01cc	create local topic partition from config on filer	2 years ago
chrislu	be0c426dc7	simplify to LookupTopicPartitions(topic)	2 years ago
chrislu	db3670a3a5	simplify api	2 years ago
chrislu	34a78ffad0	remove isForPublish from LookupTopicBrokers also adds a return parameter: whether the topic exists or not	2 years ago
chrislu	3795d8dca8	release local topic partition if no publisher and subscribers	2 years ago
chrislu	ba73199174	reuse local partition	2 years ago
chrislu	fa59a5d67e	read from disk if not in memory	2 years ago
chrislu	7afaad31a4	wait on local topic partition creation	2 years ago
chrislu	61dbdd0ff6	log ctrl messages	2 years ago
chrislu	6a7a679137	passing partition generation timestamp	2 years ago
chrislu	8af61dec91	avoid empty spaces in file name	2 years ago
chrislu	aed54eda61	refactor	2 years ago
chrislu	d51efddf5c	flush to disk Need to do: read from disk	2 years ago
chrislu	49428a303b	add batch index for each memory buffer	2 years ago
chrislu	e8611ed85d	subscribe with partition offset	2 years ago
chrislu	ee41dbb7fc	rename functions	2 years ago
chrislu	47a4963d7a	subscription start from specified timestamp	2 years 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.	2 years ago
chrislu	efb695fd93	lookup existing topic partitions	2 years ago
chrislu	093fdc1621	subscriber can get assignments	2 years ago
chrislu	c950a40aad	subscriber keep connected to the balancer	2 years ago
chrislu	e0727071c8	go fmt	2 years ago
chrislu	034db049a0	comment fix	2 years 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	2 years ago
chrislu	17710e1ecb	adjust logs	2 years ago
chrislu	de0b969b36	Revert "rename" This reverts commit 35b5264ab7.	2 years ago
chrislu	35b5264ab7	rename	2 years ago
chrislu	734178093e	refactor TopicPartition struct	2 years ago
chrislu	ebd6f96d35	adjust mq.proto	2 years ago
chrislu	02cb799481	add a test framework for grpc	2 years ago
chrislu	c4e6545197	fix compilation	2 years ago
chrislu	9d589b48e6	rename function	2 years ago
chrislu	23f334dd13	comment	2 years ago
chrislu	c7e05e4e71	ensure latest stats are reported	2 years ago
chrislu	dff2ce5d2f	read existing broker stats	2 years ago
chrislu	1492bf7552	fix listing topics	2 years ago
chrislu	3cf9b8d621	create topic and report topic	2 years ago
chrislu	b3f94feede	do create topic	2 years ago
chrislu	d74348048a	implement create topic	2 years ago
chrislu	0361c321b4	add CreateTopic API	2 years ago
chrislu	b18112ae10	fix compilation bugs during merge	2 years ago
chrislu	6c6655de9d	wip	2 years ago
chrislu	27af11f1e8	Revert "Revert "Merge branch 'master' into sub"" This reverts commit 0bb97709d4.	2 years ago