This is an automated email from the ASF dual-hosted git repository. liujun pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/dubbo-kubernetes.git
commit 72347937608519763b7cd160e0599794249afa63 Merge: c88c47da 7bb50a6e Author: Ken Liu <[email protected]> AuthorDate: Mon Jun 3 16:50:36 2024 +0800 Merge pull request #295 from sjmshsh/feat_dds 调整dubbo目录模块以及测试client .github/workflows/ci.yml | 37 +- .licenserc.yaml | 6 + Makefile | 15 + api/mesh/v1alpha1/dds.pb.go | 102 +-- api/mesh/v1alpha1/dds.proto | 5 - api/mesh/v1alpha1/dds_grpc.pb.go | 118 --- api/mesh/v1alpha1/mapping.pb.go | 417 +--------- api/mesh/v1alpha1/mapping.proto | 41 - api/mesh/v1alpha1/mapping_grpc.pb.go | 192 ----- api/mesh/v1alpha1/mds.pb.go | 811 ++++++++++++++++++ api/mesh/v1alpha1/{mapping.proto => mds.proto} | 48 +- api/mesh/v1alpha1/mds_grpc.pb.go | 295 +++++++ api/mesh/v1alpha1/metadata.pb.go | 489 ++--------- api/mesh/v1alpha1/metadata.proto | 32 - api/mesh/v1alpha1/metadata_grpc.pb.go | 173 ---- app/dubbo-cp/cmd/run.go | 27 +- app/dubboctl/cmd/proxy.go | 1 - app/dubboctl/cmd/proxy_test.go | 271 ------ app/dubboctl/internal/kube/client_test.go | 256 ------ app/dubboctl/internal/kube/component_test.go | 154 ---- go.mod | 2 +- pkg/admin/handler/application.go | 7 +- pkg/admin/handler/instance.go | 11 +- pkg/admin/handler/overview.go | 7 +- pkg/admin/handler/search.go | 17 +- pkg/admin/handler/service.go | 19 +- pkg/admin/handler/service_testing.go | 2 + pkg/admin/handler/service_testing_impl.go | 5 +- pkg/admin/model/application.go | 32 +- pkg/admin/model/instance.go | 26 +- pkg/admin/model/testing.go | 17 + pkg/admin/server/router.go | 5 +- pkg/admin/server/server.go | 5 +- pkg/admin/service/application.go | 4 +- pkg/admin/service/instance.go | 12 +- pkg/admin/util/reflection/reflection.go | 5 + pkg/admin/util/reflection/reflection_test.go | 592 ------------- pkg/admin/util/reflection/testdata/api/server.go | 119 --- .../util/reflection/testdata/proto/greet.pb.go | 616 -------------- .../util/reflection/testdata/proto/greet.proto | 44 - .../testdata/proto/grpc_gen/greet_grpc.pb.go | 315 ------- .../proto/triple_gen/greettriple/greet.triple.go | 376 --------- pkg/config/plugins/runtime/k8s/config.go | 5 - .../xds/bootstrap/types/bootstrap_request.go | 17 + pkg/core/dns/lookup/cache.go | 17 + pkg/core/dns/lookup/cache_suite_test.go | 17 + pkg/core/dns/lookup/cache_test.go | 17 + pkg/core/dns/lookup/interface.go | 17 + pkg/core/logger/log.go | 2 + .../managers/apis/dataplane/dataplane_manager.go | 15 +- pkg/core/registry/mapping.go | 13 +- pkg/core/registry/metadata_instance.go | 3 + pkg/core/resources/manager/manager_test.go | 4 +- pkg/core/resources/model/resource.go | 7 - pkg/core/user/context.go | 17 + pkg/core/user/user.go | 17 + pkg/core/xds/sockets.go | 17 + pkg/dubbo/metadata/register_request.go | 55 -- pkg/dubbo/servicemapping/register_request.go | 58 -- pkg/dubbo/servicemapping/resource_meta.go | 65 -- pkg/dubbo/servicemapping/server.go | 432 ---------- pkg/{dubbo => mds}/client/stream.go | 4 +- pkg/{dubbo => mds}/client/sync_client.go | 0 pkg/{dubbo => mds}/components.go | 33 +- pkg/{dubbo => mds}/pusher/interface.go | 0 pkg/{dubbo => mds}/pusher/pushed_items.go | 0 pkg/{dubbo => mds}/pusher/pusher.go | 0 .../pusher/resource_changed_callbacks.go | 0 pkg/{dubbo => mds}/pusher/revision.go | 0 pkg/mds/server/debounce.go | 86 ++ pkg/mds/server/register_request.go | 205 +++++ .../metadata => mds/server}/resource_meta.go | 2 +- pkg/{dubbo/metadata => mds/server}/server.go | 400 ++++----- pkg/proxy/cgroups/cgroups.go | 17 + pkg/util/concurrent/debouncer.go | 96 +++ pkg/util/maps/sorted_keys_test.go | 17 + pkg/util/os/limits_test.go | 17 + pkg/util/protocol/protocol.go | 17 + pkg/util/sets/set.go | 297 +++++++ pkg/util/sets/set_test.go | 392 +++++++++ pkg/util/slices/slices.go | 315 +++++++ pkg/util/slices/slices_test.go | 916 +++++++++++++++++++++ pkg/xds/bootstrap/generator.go | 17 + pkg/xds/context/aggregate_mesh_context.go | 17 + pkg/xds/envoy/imports.go | 17 + pkg/xds/envoy/types.go | 2 - pkg/xds/generator/zoneproxy/destinations.go | 17 + pkg/xds/generator/zoneproxy/generator.go | 17 + pkg/xds/ingress/dataplane.go | 17 + pkg/xds/ingress/outbound.go | 17 + pkg/xds/ingress/router.go | 17 + templates/go/common/api/api.proto | 8 +- tools/dds-client/main.go | 180 ++++ tools/dds-client/stream/client.go | 181 ++++ 94 files changed, 4701 insertions(+), 5143 deletions(-)
