This is an automated email from the ASF dual-hosted git repository.
jiacai2050 pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/incubator-horaedb.git
from 87de3c38 fix: random failure of test_collect_system_stats (#1459)
add 9be64c6e initial commit
add 36f3d6bc chore: add issue/pr template
add 940a66ff feat: init the skeleton code (#1)
add 1ce48f78 build: add github workflow for ci (#2)
add a6985e66 docs: add CONTRIBUTING section in README (#3)
add 7bc5a40d feat: provide logging and error handling style (#4)
add 447dccea feat: HA of ceresmeta (#6)
add fbf5882e docs: improvement logging style_guide (#7)
add 955b9c5c feat: impl etcd kv storage (#8)
add 9e50259c feat: support grpc service (#11)
add ff07d619 feat: support managing heartbeat (#12)
add 615113cf feat: impl cluster meta storage (#9)
add 1986ab3f feat: make ceresmeta runnable in cluster mode (#17)
add b2edc770 feat: impl ID Allocator (#22)
add b8790e82 feat: impl MetaStorage interface (#19)
add a236bc31 feat: impl cluster supports static cluster topology (#21)
add 1b71e857 feat: impl ceresmeta grpc service & redirect request to
leader (#26)
add b9d6fb44 feat(schedule): impl event_handler (#28)
add c39462c8 feat: Support static cluster topology (#29)
add 3cb99f34 refactor: id allocator (#31)
add 463fca7b feat(cluster): impl start&stop of cluster manager (#35)
add e8c27f66 feat(server): add createDefaultCluster of Server (#36)
add 73bbf6e4 feat: support leadership event callback mechanism (#41)
add 10f84403 feat: impl RouteTable of grpc server (#39)
add 82e32ec7 feat: support scatterShard when clusterState is stable (#40)
add 9cb3cc20 feat: impl `LeadershipEventCallbacks` interface of Server
(#42)
add b0d01ded fix(grpcservice): fix forward request bug (#43)
add e2502394 feat:impl GetNodes of grpc server (#45)
add 7b78a18b docs: add `Quick Start` in README (#47)
add 641d2f50 chore: update README (#48)
add 420f01aa chore: Refactor readme (#50)
add 6d5129b0 fix: fix manager_test & manager (#37)
add 73b5970f chore: update golang to 1.19.1 (#53)
add c51272a0 refactor: refactor meta storage (#51)
add 149d1f3e refactor: `Scan` method for etcdclient (#54)
add c921eb35 refactor: attach call stack to coderr (#55)
add da8ebac5 feat: add shard fsm definition (#52)
add 5eb01527 run go mod tidy (#59)
add fe0f52ff feat: define procedure interface (#58)
add 2effb77d feat: add check-license script (#60)
add 0627a185 feat: set warningCode = 1 in revive config (#65)
add 331cd395 feat: add shard fsm implementation (#61)
add 0b857bcd feat: add procedure storage implementation (#68)
add a35d6be9 feat: add shardID allocator (#56)
add 0ca35420 feat: update ceresdbproto and impl EventDispatch (#71)
add ed69aad5 feat: add scatter procedure (#69)
add 1564d8af feat: add transfer leader procedure (#67)
add fb4fe0df feat: upgrade ceresdbproto to latest version (#77)
add 5c954064 feat: add CreateTableProcedure (#73)
add 5ec91ae6 feat: add DropTableProcedure (#78)
add 0fe490db feat: add procedure manager (#72)
add e6ffa2a9 chore: upgrade ceresdbproto to latest version (#79)
add 4a78bbf6 ci: run UT in ci (#81)
add 177f7b97 feat: impl create and drop table service (#84)
add 0c14f33e fix: fix some scatter error (#83)
add a1340b74 feat: add rebuild topology (#75)
add eaa4d58b fix: address some bugs by testing with ceresdb (#85)
add 35652535 feat: support manage registered nodes (#86)
add e6a3e474 feat: add procedure scheduler (#80)
add 28129278 fix: update the cache when create shard topology (#87)
add dbe6022f fix: fix input address format mistake (#89)
add 944e7eb3 feat: add data package in cluster (#90)
add 4940d46c refactor: refactor storage of cluster meta data (#93)
add 5ab36890 fix: fix create/drop table request forward (#96)
add e0002ffe refactor: refactor cluster package (#98)
add b4046bee feat: add http server (#97)
add 2f8e93d7 feat: add transfer leader procedure (#99)
add 7c39563f chore: bump ceresdbproto to the latest version (#100)
add 7631ccf8 chore: add toml config parser (#101)
add 79486183 fix: fix http server start (#102)
add 7ad99081 chore: add route http interface & fix some bugs (#104)
add 9b06e325 chore: add env variable config parser (#103)
add da50fa9d fix: fix shard view copy table (#108)
add a3f9ca3e fix: fix load schema table mapping (#106)
add d6a50097 chore: add some debug info when cluster load metadata (#113)
add 061a6b68 chore: modify TestCreateAndDropTable test (#109)
add a18992af feat: parse config from env (#112)
add 2c72c8e0 fix: remove dropTable rollback when createTable failed (#105)
add 97b71000 feat: expose some operation http api (#107)
add 51c36f64 chore: update pb definition (#114)
add 89e4f333 feat: add split procedure (#111)
add 655821ae chore: add example config file (#117)
add a66e0673 chore: add codecov (#118)
add 423ca15a chore: workflows/check run on the workflow_dispatch event
(#119)
add 225891bd feat: add create partition table procedure (#123)
add d66bc427 chore: update ceresdbproto & adapter to partition info (#124)
add a8d90e30 feat: support alloc shard on same node (#125)
add 22a67910 docs: update example config (#128)
add dfa7b521 refactor: refactor create partition table procedure (#127)
add 0b532410 chore: add etcd max txn ops config (#120)
add 7555c193 feat: support drop partition table (#126)
add 3e3acfc1 feat: support forwarding http requests (#116)
add 494e15e1 refactor: replace reopen shard with open table (#129)
add 76b429e5 chore: beautify the http response (#133)
add f56930ac feat: store partition info in ceresmeta (#131)
add 44a70432 chore: add code of conduct (#135)
add a1ddc32a add some monitoring logs (#121)
add ee563471 chore: add dockerhub publish & adjust data directory (#137)
add d4087072 refactor: refactor the directory organization of procedure
(#138)
add 8caee7f6 fix: add node state check in transfer leader procedure &
support multi-node concurrent shard opening. (#134)
add c0872b8c chore: update CI branch config (#151)
add 9ee58dc2 refactor: implement entry lock (#149)
add 19f90f5f refactor: implement delay queue (#150)
add f8d24fdf refactor: implement failover based distributed etcd lock
(#146)
add 54fc18eb refactor: refactor scheduler module (#147)
add 4231566e refactor: procedure module (#148)
add a80e37ea refactor: refactor cluster operation procedures (#153)
add 1bb4c5ab refactor: refactor shard picker (#154)
add e9a1ded2 refactor: refactor ddl procedures (#155)
add 2dc99a6f refactor: fix bugs detected by added unit tests (#156)
add 9189a149 chore: bump ceresproto version
add d1b74362 test: fix drop partition table
add 82009f5f feat: do shard version check (#158)
add 9d49b87d feat/health_check (#159)
add e84961d5 fix: update cluster view when shardinfos is empty (#160)
add 0e2b4505 feat: add rebalanced shard scheduler (#162)
add 9608d4c8 feat: add deploy mode (#163)
add ff52175f fix: empty results of get table of shards (#164)
add e084d80c refactor: avoid frequent update of clusterVersion (#166)
add 3f9d2471 fix: fix drop partition table (#167)
add 77bd5215 refactor: support topology type (#168)
add 541b7bf6 fix: register node (#169)
add 7f1354e5 fix: touch time not updated when register node (#170)
add a90ce9bd chore: add codecov.yml (#175)
add 45c4f10c feat: support multiple cluster (#172)
add dedea8ce test: add integration test (#177)
add 82ca6a34 fix: mod zero (#171)
add 713a18af refactor: add pprof debug API (#184)
add 4ab299b4 fix: add leader cache (#183)
add bf3e2f99 refactor: error message in http api (#180)
add 37ff902d fix: optimize sub table creation (#182)
add ea31bd7c refactor: refactor cluster interface (#185)
add 8d98f165 test: add unit tests (#178)
add 2553e087 feat: add gRPC flow limiter (#176)
add 6ebfc475 refactor: error message (#189)
add 111e9ba4 fix: remove test code (#190)
add 4864e9eb chore: rename limiter api (#192)
add 5726523d refactor: compatible with topology persistence (#191)
add 741535c6 chore: update golangci-lint version (#196)
add d7ae6ee7 test: fix test update cluster view (#204)
add 0f526064 fix: fix panic when shard is not assigned (#202)
add 71712bc8 feat: add flow limiter read interface (#197)
add 433cc8e2 refactor: refactor http api module (#198)
add 95b39107 chore: add nighty builder (#210)
add 22007610 refactor: support open shard concurrently (#205)
add 16f8ff40 feat: add reopen shard scheduler (#218)
add f33dc1bc fix: remove codecov config (#212)
add dc084d62 feat: add list procedure api (#214)
add 2eeb7b0a feat: add ETCD member API (#207)
add bfb62e61 refactor: refactor api module (#220)
add ca094dc6 refactor: optimize hash node select algo (#215)
add 22ed580e fix: remove gprc header error stack (#222)
add b14d5e7f refactor: avoid routing tables returning errors due to
incorrect metadata (#225)
add 7624f6fc chore: add version print (#227)
add bb34836c fix: add cluster state check (#203)
add c47a5253 chore: ugprade the ceresdbproto (#229)
add 07a50fc9 fix: wrong shard id when drop non-exist table (#230)
add b397c748 fix: drop partition table (#231)
add fde3dd99 chore: remove coverage (#234)
add ba4c8e29 feat: add diagnose/shards api (#235)
add e097efee chore: remove useless code (#239)
add b24f7eb4 feat: support drop partition table parallelly (#240)
add ab7fb2d2 chore: add some operation apis (#241)
add 40d30633 refactor: http mod (#242)
add a12b7fc5 improve: generate a more uniform distribution (#236)
add 30751977 fix: allow rebalance scheduler to run on the unstable cluster
(#243)
add bdd40e66 feat: support external etcd (#238)
add 7095a6a5 chore: refactor some code (#244)
add 8e38f4bc feat: add deploy mode (#247)
add 8da409a2 feat: add least table shard picker (#248)
add e35dcb38 feat: support shard affinity (#245)
add 27fad2f8 refactor: diagnose shards api (#246)
add 70e316e3 chore: use clusters in api endpoint (#249)
add 3f810567 feat: support access etcd with tls (#250)
add afc07f51 fix: TLS config (#251)
add 98ef8144 fix: logger panic (#252)
add 89dbb61c feat: support MaxOpsPerTxn for operate etcd (#254)
add 0ffbf5c6 fix: unset the MaxOpsPerTxn (#255)
add a3baa122 fix: return error when single node is not found in static
topology (#226)
add bf4c026d chore: add debug prefix (#258)
add f561cd63 fix: modify the logic of pick shards (#259)
add 78483af3 refactor: remove useless topology data (#237)
add d65de0ac chore: upgrade golang to v1.21 and tool chains (#260)
add 40ccbe8f fix: nil resp if no need to forward (#261)
add 15b5ef7d chore: fix golang version pattern in go.mod (#262)
add 58617800 refactor!: rename binary to ceresmeta-server (#265)
add e621b9f7 ci: catchup and simplify integrate test runner (#267)
add b502492d ci: check license header tool (#269)
add b4402f77 refactor: correct shard version (#268)
add 7afb2952 refactor!: refactor shard version logic (#264)
add 81b8d688 fix: fix update shard view (#270)
add da81e536 ci: fix integration-test (#275)
add 8a070adc refactor: rename deployMode to enableSchedule (#273)
add 849c5853 chore: Ratelimiter is enabled by default (#271)
add 70d49deb chore: rename ceresmeta to horaemeta (#280)
add 312a8601 fix: wrong env variable in integration test (#281)
add 472b91c0 fix: wrong procedure id allocator (#282)
add 08d66c42 refactor: procedure storage (#279)
add 2bce1d11 chore: rename ceresdb to horaedb (#283)
add 1285ef89 chore: rename comment's ceresdb to horaedb (#285)
add a937ab15 chore: update license header and do the rename (#290)
add 393774aa chore: add asf yaml (#292)
add ab067bf0 chore: fix publish nightly image (#293)
add 24322bc7 feat!: upgrade horaedbproto (#297)
add 5b5eb124 chore: update website url (#294)
add 52ee69c1 fix: fix integration tests on dev branch (#287)
add 475647fc refactor: refactor create table procedure (#288)
add 7e5268a3 feat: add drop shard node api (#295)
add b3d62d9c fix ut
add 51536a12 refactor: remove useless procedure persist (#300)
add 7d901908 chore!: replace ceresdb with test (#298)
add 1da3a208 chore: fix broken link (#301)
add d880dd24 refactor: make create table idempotent (#286)
add 0d3cb7f9 merge horeaMeta
add fd7d9f77 chore(horaemeta): fix conflicts
add b0409437 chore(horaemeta): remove useless files
new f62a27d4 Merge pull request #1460 from ZuLiangWang/merge_meta
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.github/ISSUE_TEMPLATE/bug_report.md | 30 +
.github/ISSUE_TEMPLATE/feature_request.md | 25 +
.github/ISSUE_TEMPLATE/question.md | 24 +
.github/workflows/check.yml | 67 ++
...ish-nightly-image.yml => dockerhub-publish.yml} | 32 +-
.gitignore | 3 +
horaemeta/.golangci.yml | 62 ++
horaemeta/CONTRIBUTING.md | 69 ++
horaemeta/Dockerfile | 52 ++
horaemeta/Makefile | 33 +
horaemeta/README.md | 51 ++
horaemeta/cmd/horaemeta-server/main.go | 132 ++++
.../config/example-cluster0.toml | 6 +-
.../config/example-cluster1.toml | 16 +-
.../config/example-cluster2.toml | 16 +-
.../config/example-standalone.toml | 4 +-
.../Cargo.toml => horaemeta/docker/entrypoint.sh | 25 +-
{docker => horaemeta/docker}/tini | Bin
horaemeta/docs/style_guide.md | 111 +++
horaemeta/go.mod | 85 +++
horaemeta/go.sum | 613 ++++++++++++++++
{ctl => horaemeta}/licenserc.toml | 3 +
.../diagnose.go => horaemeta/pkg/assert/assert.go | 25 +-
horaemeta/pkg/coderr/code.go | 52 ++
horaemeta/pkg/coderr/error.go | 106 +++
horaemeta/pkg/log/config.go | 61 ++
horaemeta/pkg/log/global.go | 66 ++
horaemeta/pkg/log/log.go | 76 ++
.../scripts/run-integration-test.sh | 25 +-
horaemeta/server/cluster/cluster.go | 116 +++
horaemeta/server/cluster/manager.go | 517 +++++++++++++
horaemeta/server/cluster/manager_test.go | 221 ++++++
.../server/cluster/metadata/cluster_metadata.go | 815 +++++++++++++++++++++
.../cluster/metadata/cluster_metadata_test.go | 235 ++++++
.../cluster/metadata/compare_benchmark_test.go | 95 +++
horaemeta/server/cluster/metadata/error.go | 39 +
horaemeta/server/cluster/metadata/table_manager.go | 375 ++++++++++
.../server/cluster/metadata/table_manager_test.go | 94 +++
.../server/cluster/metadata/topology_manager.go | 691 +++++++++++++++++
.../cluster/metadata/topology_manager_test.go | 151 ++++
horaemeta/server/cluster/metadata/types.go | 215 ++++++
horaemeta/server/config/config.go | 402 ++++++++++
.../quit.go => horaemeta/server/config/error.go | 25 +-
ctl/cmd/quit.go => horaemeta/server/config/util.go | 31 +-
.../server/coordinator/error.go | 11 +-
.../server/coordinator/eventdispatch/dispatch.go | 71 ++
.../coordinator/eventdispatch/dispatch_impl.go | 199 +++++
horaemeta/server/coordinator/factory.go | 302 ++++++++
horaemeta/server/coordinator/factory_test.go | 171 +++++
horaemeta/server/coordinator/lock/entry_lock.go | 71 ++
.../server/coordinator/lock/entry_lock_test.go | 63 +-
.../server/coordinator/persist_shard_picker.go | 80 ++
.../coordinator/persist_shard_picker_test.go | 87 +++
.../coordinator/procedure/ddl/common_util.go | 173 +++++
.../createpartitiontable/create_partition_table.go | 387 ++++++++++
.../create_partition_table_test.go | 94 +++
.../procedure/ddl/createtable/create_table.go | 329 +++++++++
.../procedure/ddl/createtable/create_table_test.go | 69 ++
.../create_drop_partition_table_test.go | 193 +++++
.../ddl/droppartitiontable/drop_partition_table.go | 424 +++++++++++
.../ddl/droptable/create_drop_table_test.go | 154 ++++
.../procedure/ddl/droptable/drop_table.go | 297 ++++++++
.../server/coordinator/procedure/delay_queue.go | 146 ++++
.../coordinator/procedure/delay_queue_test.go | 110 +++
horaemeta/server/coordinator/procedure/error.go | 46 ++
.../server/coordinator/procedure/manager.go | 25 +-
.../server/coordinator/procedure/manager_impl.go | 259 +++++++
.../server/coordinator/procedure/manager_test.go | 177 +++++
.../coordinator/procedure/operation/split/split.go | 370 ++++++++++
.../procedure/operation/split/split_test.go | 100 +++
.../transferleader/batch_transfer_leader.go | 154 ++++
.../transferleader/batch_transfer_leader_test.go | 123 ++++
.../operation/transferleader/transfer_leader.go | 295 ++++++++
.../transferleader/trasnfer_leader_test.go | 61 ++
.../server/coordinator/procedure/procedure.go | 104 +++
.../server/coordinator/procedure/storage.go | 31 +-
.../server/coordinator/procedure/storage_impl.go | 198 +++++
.../server/coordinator/procedure/storage_test.go | 124 ++++
.../server/coordinator/procedure/test/common.go | 283 +++++++
.../server/coordinator/procedure}/util.go | 51 +-
.../server/coordinator/scheduler/manager/error.go | 8 +-
.../scheduler/manager/scheduler_manager.go | 333 +++++++++
.../scheduler/manager/scheduler_manager_test.go | 74 ++
.../coordinator/scheduler/nodepicker/error.go | 8 +-
.../nodepicker/hash/consistent_uniform.go | 380 ++++++++++
.../nodepicker/hash/consistent_uniform_test.go | 311 ++++++++
.../scheduler/nodepicker/node_picker.go | 131 ++++
.../scheduler/nodepicker/node_picker_test.go | 215 ++++++
.../coordinator/scheduler/rebalanced/scheduler.go | 230 ++++++
.../scheduler/rebalanced/scheduler_test.go | 59 ++
.../coordinator/scheduler/reopen/scheduler.go | 127 ++++
.../coordinator/scheduler/reopen/scheduler_test.go | 72 ++
.../server/coordinator/scheduler/scheduler.go | 55 ++
.../server/coordinator/scheduler/static/error.go | 8 +-
.../coordinator/scheduler/static/scheduler.go | 188 +++++
.../coordinator/scheduler/static/scheduler_test.go | 61 ++
horaemeta/server/coordinator/shard_picker.go | 82 +++
horaemeta/server/coordinator/shard_picker_test.go | 125 ++++
horaemeta/server/coordinator/watch/watch.go | 224 ++++++
horaemeta/server/coordinator/watch/watch_test.go | 93 +++
ctl/cmd/quit.go => horaemeta/server/error.go | 26 +-
horaemeta/server/etcdutil/config.go | 85 +++
.../quit.go => horaemeta/server/etcdutil/error.go | 24 +-
.../server/etcdutil/get_leader.go | 24 +-
horaemeta/server/etcdutil/util.go | 155 ++++
horaemeta/server/etcdutil/util_test.go | 146 ++++
ctl/cmd/quit.go => horaemeta/server/id/error.go | 25 +-
ctl/cmd/quit.go => horaemeta/server/id/id.go | 25 +-
horaemeta/server/id/id_impl.go | 179 +++++
horaemeta/server/id/id_test.go | 61 ++
horaemeta/server/id/reusable_id_impl.go | 111 +++
horaemeta/server/id/reusable_id_test.go | 90 +++
horaemeta/server/limiter/limiter.go | 78 ++
horaemeta/server/limiter/limiter_test.go | 74 ++
horaemeta/server/member/error.go | 34 +
horaemeta/server/member/lease.go | 233 ++++++
horaemeta/server/member/member.go | 286 ++++++++
horaemeta/server/member/watch_leader.go | 199 +++++
horaemeta/server/member/watch_leader_test.go | 92 +++
horaemeta/server/server.go | 416 +++++++++++
.../server/service/grpc/error.go | 26 +-
horaemeta/server/service/grpc/forward.go | 81 ++
horaemeta/server/service/grpc/service.go | 458 ++++++++++++
horaemeta/server/service/http/api.go | 777 ++++++++++++++++++++
horaemeta/server/service/http/error.go | 49 ++
horaemeta/server/service/http/etcd_api.go | 204 ++++++
horaemeta/server/service/http/forward.go | 133 ++++
horaemeta/server/service/http/route.go | 131 ++++
horaemeta/server/service/http/service.go | 63 ++
horaemeta/server/service/http/types.go | 170 +++++
.../operation => horaemeta/server/service}/util.go | 55 +-
.../const.go => horaemeta/server/status/status.go | 38 +-
horaemeta/server/storage/error.go | 37 +
horaemeta/server/storage/key_path.go | 147 ++++
horaemeta/server/storage/meta.go | 83 +++
horaemeta/server/storage/storage_impl.go | 661 +++++++++++++++++
horaemeta/server/storage/storage_test.go | 359 +++++++++
horaemeta/server/storage/types.go | 605 +++++++++++++++
138 files changed, 20586 insertions(+), 362 deletions(-)
create mode 100644 .github/ISSUE_TEMPLATE/bug_report.md
create mode 100644 .github/ISSUE_TEMPLATE/feature_request.md
create mode 100644 .github/ISSUE_TEMPLATE/question.md
create mode 100644 .github/workflows/check.yml
copy .github/workflows/{publish-nightly-image.yml => dockerhub-publish.yml}
(59%)
create mode 100644 horaemeta/.golangci.yml
create mode 100644 horaemeta/CONTRIBUTING.md
create mode 100644 horaemeta/Dockerfile
create mode 100644 horaemeta/Makefile
create mode 100644 horaemeta/README.md
create mode 100644 horaemeta/cmd/horaemeta-server/main.go
copy integration_tests/config/horaemeta.toml =>
horaemeta/config/example-cluster0.toml (86%)
copy integration_tests/config/horaemeta.toml =>
horaemeta/config/example-cluster1.toml (71%)
copy integration_tests/config/horaemeta.toml =>
horaemeta/config/example-cluster2.toml (71%)
copy integration_tests/config/horaemeta.toml =>
horaemeta/config/example-standalone.toml (94%)
copy src/components/partitioned_lock/Cargo.toml =>
horaemeta/docker/entrypoint.sh (73%)
mode change 100644 => 100755
copy {docker => horaemeta/docker}/tini (100%)
create mode 100644 horaemeta/docs/style_guide.md
create mode 100644 horaemeta/go.mod
create mode 100644 horaemeta/go.sum
copy {ctl => horaemeta}/licenserc.toml (81%)
copy ctl/cmd/diagnose.go => horaemeta/pkg/assert/assert.go (70%)
create mode 100644 horaemeta/pkg/coderr/code.go
create mode 100644 horaemeta/pkg/coderr/error.go
create mode 100644 horaemeta/pkg/log/config.go
create mode 100644 horaemeta/pkg/log/global.go
create mode 100644 horaemeta/pkg/log/log.go
copy src/components/partitioned_lock/Cargo.toml =>
horaemeta/scripts/run-integration-test.sh (69%)
create mode 100644 horaemeta/server/cluster/cluster.go
create mode 100644 horaemeta/server/cluster/manager.go
create mode 100644 horaemeta/server/cluster/manager_test.go
create mode 100644 horaemeta/server/cluster/metadata/cluster_metadata.go
create mode 100644 horaemeta/server/cluster/metadata/cluster_metadata_test.go
create mode 100644 horaemeta/server/cluster/metadata/compare_benchmark_test.go
create mode 100644 horaemeta/server/cluster/metadata/error.go
create mode 100644 horaemeta/server/cluster/metadata/table_manager.go
create mode 100644 horaemeta/server/cluster/metadata/table_manager_test.go
create mode 100644 horaemeta/server/cluster/metadata/topology_manager.go
create mode 100644 horaemeta/server/cluster/metadata/topology_manager_test.go
create mode 100644 horaemeta/server/cluster/metadata/types.go
create mode 100644 horaemeta/server/config/config.go
copy ctl/cmd/quit.go => horaemeta/server/config/error.go (65%)
copy ctl/cmd/quit.go => horaemeta/server/config/util.go (65%)
copy ctl/main.go => horaemeta/server/coordinator/error.go (75%)
create mode 100644 horaemeta/server/coordinator/eventdispatch/dispatch.go
create mode 100644 horaemeta/server/coordinator/eventdispatch/dispatch_impl.go
create mode 100644 horaemeta/server/coordinator/factory.go
create mode 100644 horaemeta/server/coordinator/factory_test.go
create mode 100644 horaemeta/server/coordinator/lock/entry_lock.go
copy ctl/operation/util.go =>
horaemeta/server/coordinator/lock/entry_lock_test.go (52%)
create mode 100644 horaemeta/server/coordinator/persist_shard_picker.go
create mode 100644 horaemeta/server/coordinator/persist_shard_picker_test.go
create mode 100644 horaemeta/server/coordinator/procedure/ddl/common_util.go
create mode 100644
horaemeta/server/coordinator/procedure/ddl/createpartitiontable/create_partition_table.go
create mode 100644
horaemeta/server/coordinator/procedure/ddl/createpartitiontable/create_partition_table_test.go
create mode 100644
horaemeta/server/coordinator/procedure/ddl/createtable/create_table.go
create mode 100644
horaemeta/server/coordinator/procedure/ddl/createtable/create_table_test.go
create mode 100644
horaemeta/server/coordinator/procedure/ddl/droppartitiontable/create_drop_partition_table_test.go
create mode 100644
horaemeta/server/coordinator/procedure/ddl/droppartitiontable/drop_partition_table.go
create mode 100644
horaemeta/server/coordinator/procedure/ddl/droptable/create_drop_table_test.go
create mode 100644
horaemeta/server/coordinator/procedure/ddl/droptable/drop_table.go
create mode 100644 horaemeta/server/coordinator/procedure/delay_queue.go
create mode 100644 horaemeta/server/coordinator/procedure/delay_queue_test.go
create mode 100644 horaemeta/server/coordinator/procedure/error.go
copy ctl/cmd/diagnose.go => horaemeta/server/coordinator/procedure/manager.go
(60%)
create mode 100644 horaemeta/server/coordinator/procedure/manager_impl.go
create mode 100644 horaemeta/server/coordinator/procedure/manager_test.go
create mode 100644
horaemeta/server/coordinator/procedure/operation/split/split.go
create mode 100644
horaemeta/server/coordinator/procedure/operation/split/split_test.go
create mode 100644
horaemeta/server/coordinator/procedure/operation/transferleader/batch_transfer_leader.go
create mode 100644
horaemeta/server/coordinator/procedure/operation/transferleader/batch_transfer_leader_test.go
create mode 100644
horaemeta/server/coordinator/procedure/operation/transferleader/transfer_leader.go
create mode 100644
horaemeta/server/coordinator/procedure/operation/transferleader/trasnfer_leader_test.go
create mode 100644 horaemeta/server/coordinator/procedure/procedure.go
copy ctl/cmd/quit.go => horaemeta/server/coordinator/procedure/storage.go (61%)
create mode 100644 horaemeta/server/coordinator/procedure/storage_impl.go
create mode 100644 horaemeta/server/coordinator/procedure/storage_test.go
create mode 100644 horaemeta/server/coordinator/procedure/test/common.go
copy {ctl/operation => horaemeta/server/coordinator/procedure}/util.go (50%)
copy ctl/main.go => horaemeta/server/coordinator/scheduler/manager/error.go
(82%)
create mode 100644
horaemeta/server/coordinator/scheduler/manager/scheduler_manager.go
create mode 100644
horaemeta/server/coordinator/scheduler/manager/scheduler_manager_test.go
copy ctl/main.go => horaemeta/server/coordinator/scheduler/nodepicker/error.go
(82%)
create mode 100644
horaemeta/server/coordinator/scheduler/nodepicker/hash/consistent_uniform.go
create mode 100644
horaemeta/server/coordinator/scheduler/nodepicker/hash/consistent_uniform_test.go
create mode 100644
horaemeta/server/coordinator/scheduler/nodepicker/node_picker.go
create mode 100644
horaemeta/server/coordinator/scheduler/nodepicker/node_picker_test.go
create mode 100644
horaemeta/server/coordinator/scheduler/rebalanced/scheduler.go
create mode 100644
horaemeta/server/coordinator/scheduler/rebalanced/scheduler_test.go
create mode 100644 horaemeta/server/coordinator/scheduler/reopen/scheduler.go
create mode 100644
horaemeta/server/coordinator/scheduler/reopen/scheduler_test.go
create mode 100644 horaemeta/server/coordinator/scheduler/scheduler.go
copy ctl/main.go => horaemeta/server/coordinator/scheduler/static/error.go
(84%)
create mode 100644 horaemeta/server/coordinator/scheduler/static/scheduler.go
create mode 100644
horaemeta/server/coordinator/scheduler/static/scheduler_test.go
create mode 100644 horaemeta/server/coordinator/shard_picker.go
create mode 100644 horaemeta/server/coordinator/shard_picker_test.go
create mode 100644 horaemeta/server/coordinator/watch/watch.go
create mode 100644 horaemeta/server/coordinator/watch/watch_test.go
copy ctl/cmd/quit.go => horaemeta/server/error.go (61%)
create mode 100644 horaemeta/server/etcdutil/config.go
copy ctl/cmd/quit.go => horaemeta/server/etcdutil/error.go (68%)
copy ctl/cmd/quit.go => horaemeta/server/etcdutil/get_leader.go (74%)
create mode 100644 horaemeta/server/etcdutil/util.go
create mode 100644 horaemeta/server/etcdutil/util_test.go
copy ctl/cmd/quit.go => horaemeta/server/id/error.go (66%)
copy ctl/cmd/quit.go => horaemeta/server/id/id.go (73%)
create mode 100644 horaemeta/server/id/id_impl.go
create mode 100644 horaemeta/server/id/id_test.go
create mode 100644 horaemeta/server/id/reusable_id_impl.go
create mode 100644 horaemeta/server/id/reusable_id_test.go
create mode 100644 horaemeta/server/limiter/limiter.go
create mode 100644 horaemeta/server/limiter/limiter_test.go
create mode 100644 horaemeta/server/member/error.go
create mode 100644 horaemeta/server/member/lease.go
create mode 100644 horaemeta/server/member/member.go
create mode 100644 horaemeta/server/member/watch_leader.go
create mode 100644 horaemeta/server/member/watch_leader_test.go
create mode 100644 horaemeta/server/server.go
copy ctl/cmd/quit.go => horaemeta/server/service/grpc/error.go (61%)
create mode 100644 horaemeta/server/service/grpc/forward.go
create mode 100644 horaemeta/server/service/grpc/service.go
create mode 100644 horaemeta/server/service/http/api.go
create mode 100644 horaemeta/server/service/http/error.go
create mode 100644 horaemeta/server/service/http/etcd_api.go
create mode 100644 horaemeta/server/service/http/forward.go
create mode 100644 horaemeta/server/service/http/route.go
create mode 100644 horaemeta/server/service/http/service.go
create mode 100644 horaemeta/server/service/http/types.go
copy {ctl/operation => horaemeta/server/service}/util.go (52%)
copy ctl/operation/const.go => horaemeta/server/status/status.go (61%)
create mode 100644 horaemeta/server/storage/error.go
create mode 100644 horaemeta/server/storage/key_path.go
create mode 100644 horaemeta/server/storage/meta.go
create mode 100644 horaemeta/server/storage/storage_impl.go
create mode 100644 horaemeta/server/storage/storage_test.go
create mode 100644 horaemeta/server/storage/types.go
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
