This is an automated email from the ASF dual-hosted git repository.
liujun pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/dubbo-kubernetes.git
from c88c47da Merge pull request #286 from SHA-4096/cp
add c13d4201 fix fmt
add d13e7a31 redine
add 2947cb0c refactor register
add df2be8fb fix ci
add d63db18a types
add 69065458 mds
add fdcae435 dds_client
add 772449bf dds_client
add 60279678 dds_client
add bd9e4529 dds_client
add 17d1a5d7 fix ci
add 1b3c19ea fix ci
add 7bb50a6e go lint
new 72347937 Merge pull request #295 from sjmshsh/feat_dds
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/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(-)
delete mode 100644 api/mesh/v1alpha1/mapping_grpc.pb.go
create mode 100644 api/mesh/v1alpha1/mds.pb.go
copy api/mesh/v1alpha1/{mapping.proto => mds.proto} (58%)
create mode 100644 api/mesh/v1alpha1/mds_grpc.pb.go
delete mode 100644 api/mesh/v1alpha1/metadata_grpc.pb.go
delete mode 100644 app/dubboctl/cmd/proxy_test.go
delete mode 100644 app/dubboctl/internal/kube/client_test.go
delete mode 100644 app/dubboctl/internal/kube/component_test.go
delete mode 100644 pkg/admin/util/reflection/reflection_test.go
delete mode 100644 pkg/admin/util/reflection/testdata/api/server.go
delete mode 100644 pkg/admin/util/reflection/testdata/proto/greet.pb.go
delete mode 100644 pkg/admin/util/reflection/testdata/proto/greet.proto
delete mode 100644
pkg/admin/util/reflection/testdata/proto/grpc_gen/greet_grpc.pb.go
delete mode 100644
pkg/admin/util/reflection/testdata/proto/triple_gen/greettriple/greet.triple.go
delete mode 100644 pkg/dubbo/metadata/register_request.go
delete mode 100644 pkg/dubbo/servicemapping/register_request.go
delete mode 100644 pkg/dubbo/servicemapping/resource_meta.go
delete mode 100644 pkg/dubbo/servicemapping/server.go
rename pkg/{dubbo => mds}/client/stream.go (97%)
rename pkg/{dubbo => mds}/client/sync_client.go (100%)
rename pkg/{dubbo => mds}/components.go (71%)
rename pkg/{dubbo => mds}/pusher/interface.go (100%)
rename pkg/{dubbo => mds}/pusher/pushed_items.go (100%)
rename pkg/{dubbo => mds}/pusher/pusher.go (100%)
rename pkg/{dubbo => mds}/pusher/resource_changed_callbacks.go (100%)
rename pkg/{dubbo => mds}/pusher/revision.go (100%)
create mode 100644 pkg/mds/server/debounce.go
create mode 100644 pkg/mds/server/register_request.go
rename pkg/{dubbo/metadata => mds/server}/resource_meta.go (99%)
rename pkg/{dubbo/metadata => mds/server}/server.go (52%)
create mode 100644 pkg/util/concurrent/debouncer.go
create mode 100644 pkg/util/sets/set.go
create mode 100644 pkg/util/sets/set_test.go
create mode 100644 pkg/util/slices/slices.go
create mode 100644 pkg/util/slices/slices_test.go
create mode 100644 tools/dds-client/main.go
create mode 100644 tools/dds-client/stream/client.go
