This is an automated email from the ASF dual-hosted git repository. jiacai2050 pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/incubator-horaedb.git
commit f62a27d4e7b8008815fa415629bee123e488aa86 Merge: 87de3c38 b0409437 Author: Jiacai Liu <[email protected]> AuthorDate: Thu Jan 25 13:57:56 2024 +0800 Merge pull request #1460 from ZuLiangWang/merge_meta chore: merge HoraeMeta code into HoreaDB repository .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 ++ .github/workflows/dockerhub-publish.yml | 45 ++ .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 ++++ horaemeta/config/example-cluster0.toml | 34 + horaemeta/config/example-cluster1.toml | 34 + horaemeta/config/example-cluster2.toml | 34 + horaemeta/config/example-standalone.toml | 32 + horaemeta/docker/entrypoint.sh | 34 + horaemeta/docker/tini | Bin 0 -> 24064 bytes horaemeta/docs/style_guide.md | 111 +++ horaemeta/go.mod | 85 +++ horaemeta/go.sum | 613 ++++++++++++++++ horaemeta/licenserc.toml | 25 + horaemeta/pkg/assert/assert.go | 35 + 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 ++ horaemeta/scripts/run-integration-test.sh | 34 + 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 ++++++++++ horaemeta/server/config/error.go | 31 + horaemeta/server/config/util.go | 41 ++ horaemeta/server/coordinator/error.go | 27 + .../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 | 59 ++ .../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 ++ horaemeta/server/coordinator/procedure/manager.go | 37 + .../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 +++ horaemeta/server/coordinator/procedure/storage.go | 43 ++ .../server/coordinator/procedure/storage_impl.go | 198 +++++ .../server/coordinator/procedure/storage_test.go | 124 ++++ .../server/coordinator/procedure/test/common.go | 283 +++++++ horaemeta/server/coordinator/procedure/util.go | 51 ++ .../server/coordinator/scheduler/manager/error.go | 24 + .../scheduler/manager/scheduler_manager.go | 333 +++++++++ .../scheduler/manager/scheduler_manager_test.go | 74 ++ .../coordinator/scheduler/nodepicker/error.go | 24 + .../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 | 24 + .../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 +++ horaemeta/server/error.go | 30 + horaemeta/server/etcdutil/config.go | 85 +++ horaemeta/server/etcdutil/error.go | 28 + horaemeta/server/etcdutil/get_leader.go | 36 + horaemeta/server/etcdutil/util.go | 155 ++++ horaemeta/server/etcdutil/util_test.go | 146 ++++ horaemeta/server/id/error.go | 29 + horaemeta/server/id/id.go | 31 + 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 +++++++++++ horaemeta/server/service/grpc/error.go | 32 + 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 +++++ horaemeta/server/service/util.go | 55 ++ horaemeta/server/status/status.go | 52 ++ 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, 21253 insertions(+) --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
