Tree: dbdb7c8abe

add_fasthttp_client

add_remote_storage

avoid_releasing_temp_file_on_write

collect-public-metrics

create-table-snapshot-api-design

data_query_pushdown

dependabot/go_modules/github.com/parquet-go/parquet-go-0.25.0

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

more-efficient-copy-object

mount2

mq-subscribe

mq2

original_weed_mount

random_access_file

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

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

3.82

3.83

3.84

3.85

dev

helm-3.65.1

v0.69

v0.70beta

v3.33

Branches Tags

${ item.name }

Create tag ${ searchTerm }

Create branch ${ searchTerm }

from 'dbdb7c8abe'

${ noResults }

Commit Graph

62 Commits (dbdb7c8abe9e041c16a7842680c63af8fb1fc4e1)

Author	SHA1	Message	Date
yudrywet	8833745fbc	chore: fix some typos in comments (#5497)	1 year ago
chrislu	68ade92d4f	publisher send schema	1 year ago
chrislu	5324e4288a	rename parameter	1 year ago
chrislu	66a878af39	add control message to data message	1 year ago
chrislu	546ae87c39	send is_close message to broker	1 year ago
chrislu	c9df613b6b	add publisher name for debugging	1 year ago
chrislu	205d2285f3	setup follower by publisher * the subscriber would getOrGen a local partition and wait * the publisher would getOrGen a local partition. If localPartition follower is not setup, and init message has follower info, it would create followers based on init.Messages.	1 year ago
chrislu	da31e9b939	correctly wait for the publisher to finish	1 year ago
chrislu	7003ce7425	publisher is able to fully send data and receive acks still needs to close the pipes cleanly	1 year ago
chrislu	33ab6cfcf7	adjust error	1 year ago
chrislu	ead27a4f59	publish init add followers	1 year ago
chrislu	1b4484bf0a	go fmt	1 year ago
Chris Lu	16b4f9d9ab	subscriber find broker leader first	1 year ago
Chris Lu	90fcde0e26	report EOF error	1 year ago
Chris Lu	07028a4864	minor	1 year ago
Chris Lu	4dc6681833	proxy requests to lock owner	1 year ago
chrislu	0b2e5ddc7c	wait 3 seconds before shutting down publish client, to wait for all messages to be received	1 year ago
chrislu	545d5fbdf6	unused code	1 year ago
chrislu	a297247137	wait for each publish clients	1 year ago
chrislu	b6c5e57c30	read will block if no items	1 year ago
chrislu	0bf5424a2e	adjust visibility	1 year ago
chrislu	dedfd31dfb	refactor	1 year ago
chrislu	cbf750a31f	refactor	1 year ago
chrislu	b51dfe2bff	wait for publishing clients	1 year ago
chrislu	f8c55f101e	clean up	1 year ago
chrislu	841fafd0a8	publish to input buffer currently, the input buffer may not exist when start to publish	1 year ago
chrislu	91af1f3069	schedule jobs	1 year ago
chrislu	34a78ffad0	remove isForPublish from LookupTopicBrokers also adds a return parameter: whether the topic exists or not	1 year ago
chrislu	7e6497cc1c	adjust publisher subscriber	1 year ago
chrislu	026c54a9bb	fix publisher	1 year ago
chrislu	3aa3991f0f	adjust client side logs	1 year ago
chrislu	6a7a679137	passing partition generation timestamp	1 year ago
chrislu	49428a303b	add batch index for each memory buffer	1 year ago
chrislu	d0d24f1e40	rename functions	1 year ago
chrislu	aa5b6a8187	adjust logs	1 year ago
chrislu	496fc8fbbf	refactor	1 year ago
chrislu	531f854af2	rename functions	1 year ago
chrislu	f8787a9761	rename functions	1 year ago
chrislu	ddd0fde094	rename functions	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	8b4cd50aac	log errors	1 year ago
chrislu	32bc8d6a38	adjust wait time	1 year ago
chrislu	458ddbf919	clean up dead code	1 year ago
chrislu	2845230329	passing broker into the assignments	1 year ago
chrislu	093fdc1621	subscriber can get assignments	1 year ago
chrislu	c950a40aad	subscriber keep connected to the balancer	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	bf13f3ced7	add subscriber coordinator	2 years ago