You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@dubbo.apache.org by li...@apache.org on 2024/02/18 02:29:49 UTC
(dubbo-kubernetes) branch control-plane updated (4813d538 -> d02648d1)
This is an automated email from the ASF dual-hosted git repository.
liujun pushed a change to branch control-plane
in repository https://gitbox.apache.org/repos/asf/dubbo-kubernetes.git
from 4813d538 Merge pull request #190 from sjmshsh/control-plane
add d8d64faa feat: ca
add 199e7489 feat: ca
add cc51cfdd controller
add 2ebd340e ingress
add c3ed00e4 ingress
add b8b71805 dds
add ae3aeeb7 dds
add ba68e656 feat: store
add 7f8ddf34 feat: store
add 7d17c4c2 feat: add mysql
add 8fff66da feat: add mysql
add f8436bc9 feat: leader
add 33c293bc 删除admin目录, 将逻辑下沉到control-plane
add 8ab7c883 event
add e62c74b2 add mapping resource
new d02648d1 Merge pull request #204 from sjmshsh/control-plane
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:
api/mesh/options.pb.go | 9 +-
api/mesh/v1alpha1/dataplane.pb.go | 15 +-
api/mesh/v1alpha1/dataplane_insight.pb.go | 15 +-
api/mesh/v1alpha1/dds.pb.go | 1125 ++++++++++++++++++++
api/mesh/v1alpha1/dds.proto | 162 +++
api/mesh/v1alpha1/dds_grpc.pb.go | 651 +++++++++++
api/mesh/v1alpha1/envoy_admin.pb.go | 8 +-
api/mesh/v1alpha1/mapping.pb.go | 176 +++
api/mesh/v1alpha1/mapping.proto | 21 +
api/mesh/v1alpha1/mesh.pb.go | 14 +-
api/mesh/v1alpha1/mesh_insight.pb.go | 13 +-
api/mesh/v1alpha1/metrics.pb.go | 9 +-
api/mesh/v1alpha1/mux.pb.go | 9 +-
api/mesh/v1alpha1/mux_grpc.pb.go | 3 -
api/mesh/v1alpha1/zone_ingress.pb.go | 138 +--
api/mesh/v1alpha1/zone_ingress.proto | 3 +
api/mesh/v1alpha1/zone_ingress_insight.pb.go | 13 +-
api/mesh/v1alpha1/zoneegress.pb.go | 264 +++++
api/mesh/v1alpha1/zoneegress.proto | 37 +
api/system/v1alpha1/config.pb.go | 13 +-
api/system/v1alpha1/datasource.pb.go | 14 +-
api/system/v1alpha1/inter_cp_ping.pb.go | 8 +-
api/system/v1alpha1/inter_cp_ping_grpc.pb.go | 3 -
api/system/v1alpha1/secret.pb.go | 14 +-
api/system/v1alpha1/zone.pb.go | 14 +-
app/dubbo-cp/cmd/run.go | 11 +-
build/tools-darwin-arm64/resource-gen | Bin 0 -> 27647874 bytes
...{dubbo.io_zones.yaml => dubbo.io_mappings.yaml} | 12 +-
...datasources.yaml => dubbo.io_zoneegresses.yaml} | 12 +-
go.mod | 11 +-
go.sum | 22 +-
pkg/admin/bootstrap.go | 189 ----
pkg/admin/cache/README.md | 48 -
pkg/admin/cache/cache.go | 71 --
pkg/admin/cache/interface_registry_cache.go | 24 -
pkg/admin/cache/registry/extension.go | 53 -
pkg/admin/cache/registry/kube/cache.go | 453 --------
pkg/admin/cache/registry/kube/registry.go | 80 --
pkg/admin/cache/registry/universal/cache.go | 527 ---------
pkg/admin/cache/registry/universal/mapping.go | 96 --
pkg/admin/cache/registry/universal/registry.go | 180 ----
.../service_instances_changed_listener_impl.go | 229 ----
pkg/admin/cache/selector/application_selector.go | 59 -
pkg/admin/cache/selector/multi_selector.go | 127 ---
pkg/admin/cache/selector/selector.go | 58 -
pkg/admin/cache/selector/service_selector.go | 69 --
pkg/admin/config/config.go | 49 -
pkg/admin/config/governance_config.go | 218 ----
.../config/mock_config/governance_config_mock.go | 167 ---
pkg/admin/constant/const.go | 90 --
pkg/admin/constant/kubenetes.go | 42 -
pkg/admin/handlers/condition_route.go | 248 -----
pkg/admin/handlers/mock_rule.go | 139 ---
pkg/admin/handlers/overrides.go | 262 -----
pkg/admin/handlers/service.go | 411 -------
pkg/admin/handlers/tag_route.go | 236 ----
pkg/admin/handlers/traffic/accesslog.go | 130 ---
pkg/admin/handlers/traffic/argument.go | 138 ---
pkg/admin/handlers/traffic/gray.go | 130 ---
pkg/admin/handlers/traffic/mock.go | 139 ---
pkg/admin/handlers/traffic/region.go | 139 ---
pkg/admin/handlers/traffic/retry.go | 138 ---
pkg/admin/handlers/traffic/timeout.go | 138 ---
pkg/admin/handlers/traffic/weight.go | 138 ---
pkg/admin/imports/imports.go | 27 -
pkg/admin/mapper/mock_rule_mapper.go | 63 --
pkg/admin/mapper/mock_rule_mapper_mock.go | 131 ---
pkg/admin/model/base.go | 24 -
pkg/admin/model/common.go | 26 -
pkg/admin/model/condition_route.go | 41 -
pkg/admin/model/consumer.go | 56 -
pkg/admin/model/dynamic_config.go | 78 --
pkg/admin/model/entity.go | 50 -
pkg/admin/model/match.go | 113 --
pkg/admin/model/mock_rule.go | 69 --
pkg/admin/model/monitor.go | 40 -
pkg/admin/model/override.go | 100 --
pkg/admin/model/provider.go | 79 --
pkg/admin/model/service_detail_dto.go | 24 -
pkg/admin/model/service_dto.go | 49 -
pkg/admin/model/tag_route.go | 46 -
pkg/admin/model/traffic.go | 240 -----
pkg/admin/model/util/override_utils.go | 65 --
pkg/admin/model/util/override_utils_test.go | 79 --
pkg/admin/model/util/sync_utils.go | 214 ----
pkg/admin/model/util/sync_utils_test.go | 126 ---
pkg/admin/monitor/prometheus/metrics.go | 65 --
pkg/admin/monitor/prometheus/types.go | 25 -
pkg/admin/providers/mock/api/mock.pb.go | 252 -----
pkg/admin/providers/mock/api/mock.proto | 35 -
pkg/admin/providers/mock/api/mock_triple.pb.go | 169 ---
pkg/admin/providers/mock/mock_provider.go | 80 --
pkg/admin/router/router.go | 217 ----
pkg/admin/services/consumer_service.go | 25 -
pkg/admin/services/consumer_service_impl.go | 50 -
pkg/admin/services/generic_service_Impl.go | 65 --
pkg/admin/services/mock_rule_service.go | 40 -
pkg/admin/services/mock_rule_service_impl.go | 100 --
pkg/admin/services/mock_rule_service_impl_test.go | 178 ----
pkg/admin/services/monitor_service.go | 31 -
pkg/admin/services/override_service.go | 29 -
pkg/admin/services/override_service_impl.go | 364 -------
pkg/admin/services/override_service_impl_test.go | 332 ------
pkg/admin/services/prometheus_service_impl.go | 252 -----
pkg/admin/services/prometheus_service_impl_test.go | 180 ----
pkg/admin/services/provider_service.go | 33 -
pkg/admin/services/provider_service_impl.go | 374 -------
pkg/admin/services/provider_service_impl_test.go | 283 -----
pkg/admin/services/route_service.go | 39 -
pkg/admin/services/route_service_impl.go | 299 ------
pkg/admin/services/route_service_impl_test.go | 592 ----------
pkg/admin/services/service_testing_v3.go | 231 ----
pkg/admin/services/traffic/accesslog.go | 94 --
pkg/admin/services/traffic/argument.go | 93 --
.../services/traffic/generic_rule_operation.go | 320 ------
pkg/admin/services/traffic/gray.go | 75 --
pkg/admin/services/traffic/mock.go | 86 --
pkg/admin/services/traffic/region.go | 108 --
pkg/admin/services/traffic/retry.go | 100 --
pkg/admin/services/traffic/timeout.go | 101 --
pkg/admin/services/traffic/timeout_test.go | 319 ------
pkg/admin/services/traffic/weight.go | 101 --
pkg/admin/util/base_service_metadata.go | 72 --
pkg/admin/util/monitor_utils.go | 32 -
pkg/admin/util/monitor_utils_test.go | 59 -
pkg/admin/util/yaml_parser.go | 34 -
pkg/admin/util/yaml_parser_test.go | 61 --
pkg/config/core/resources/store/config.go | 2 +
pkg/config/plugins/runtime/k8s/config.go | 44 +
pkg/core/ca/issuer/issuer.go | 161 +++
pkg/core/kubeclient/client/kube.go | 149 ---
.../managers/dataplane/dataplane_manager.go} | 18 +-
pkg/core/plugins/interfaces.go | 5 +
pkg/core/plugins/registry.go | 6 +
.../resources/apis/mesh/zone_ingress_helpers.go | 72 ++
.../resources/apis/mesh/zz_generated.resources.go | 220 +++-
.../apis/system/zz_generated.resources.go | 2 -
pkg/core/resources/model/resource.go | 21 +
pkg/dds/cache/builder.go | 66 ++
pkg/{hds => dds}/cache/cache_suite_test.go | 9 +-
pkg/dds/cache/snapshot.go | 140 +++
pkg/dds/cache/snapshot_test.go | 223 ++++
pkg/dds/client/dds_client.go | 130 +++
.../client/remote_suite_test.go} | 11 +-
pkg/dds/client/stream.go | 167 +++
pkg/dds/features.go | 53 +
pkg/{admin/util => dds/hash}/hash.go | 33 +-
.../datasource/loader.go => dds/mux/zone_watch.go} | 19 +-
.../reconcile/interfaces.go} | 41 +-
pkg/dds/reconcile/reconciler.go | 178 ++++
pkg/dds/reconcile/snapshot_generator.go | 132 +++
pkg/dds/store/sync.go | 382 +++++++
pkg/{xds/envoy/api_version.go => dds/types.go} | 16 +-
pkg/{admin/setup.go => dds/util/client_id.go} | 32 +-
pkg/dds/util/meta.go | 105 ++
pkg/dds/util/resource_test.go | 60 ++
pkg/dds/util/resources.go | 172 +++
.../util/util_suite_test.go} | 11 +-
.../leader/{memory => nacos}/leader_elector.go | 28 +-
pkg/plugins/leader/plugin.go | 6 +
.../leader/zookeeper/leader_elector.go} | 49 +-
pkg/plugins/policies/core/ordered/ordered.go | 5 +-
pkg/plugins/policies/imports.go | 5 -
.../servicenamemapping/api/v1alpha1/rest.yaml | 122 ---
.../servicenamemapping/api/v1alpha1/schema.yaml | 30 -
.../api/v1alpha1/servicenamemapping.go | 10 -
.../servicenamemapping/api/v1alpha1/validator.go | 11 -
.../api/v1alpha1/zz_generated.deepcopy.go | 25 -
.../api/v1alpha1/zz_generated.resource.go | 144 ---
.../k8s/crd/dubbo.io_servicenamemappings.yaml | 59 -
.../k8s/v1alpha1/groupversion_info.go | 20 -
.../k8s/v1alpha1/zz_generated.deepcopy.go | 75 --
.../k8s/v1alpha1/zz_generated.types.go | 108 --
.../servicenamemapping/plugin/v1alpha1/plugin.go | 30 -
.../servicenamemapping/zz_generated.plugin.go | 16 -
.../native/api/v1alpha1/zz_generated.deepcopy.go | 125 ++-
.../k8s/native/api/v1alpha1/zz_generated.mesh.go | 199 +++-
.../k8s/native/api/v1alpha1/zz_generated.system.go | 5 -
.../resources/mysql/events/listener.go} | 21 +-
pkg/plugins/resources/{memory => mysql}/plugin.go | 15 +-
.../resources/mysql/store.go} | 46 +-
.../resources/nacos/events/listener.go} | 21 +-
pkg/plugins/resources/{memory => nacos}/plugin.go | 15 +-
.../resources/nacos/store.go} | 46 +-
.../resources/zookeeper/events/listener.go} | 21 +-
.../resources/{memory => zookeeper}/plugin.go | 15 +-
pkg/plugins/resources/zookeeper/store.go | 55 +
pkg/plugins/runtime/k8s/containers/factory.go | 216 ++++
.../runtime/k8s/controllers/egress_converter.go | 69 ++
pkg/plugins/runtime/k8s/controllers/endpoints.go | 70 ++
.../runtime/k8s/controllers/inbound_converter.go | 223 ++++
.../runtime/k8s/controllers/ingress_converter.go | 168 +++
.../runtime/k8s/controllers/outbound_converter.go | 176 +++
.../runtime/k8s/controllers/pod_controller.go | 301 +++++-
.../runtime/k8s/controllers/pod_converter.go | 105 ++
.../runtime/k8s/controllers/probes.go} | 10 +-
.../runtime/k8s/controllers/service_controller.go | 65 ++
.../k8s/controllers/serviceless_name_extractor.go | 79 ++
pkg/plugins/runtime/k8s/metadata/annotations.go | 210 ++++
pkg/plugins/runtime/k8s/util/util.go | 200 ++++
.../dubbo_test.go => pkg/registry/components.go | 17 +-
.../os/limits_windows.go => registry/registry.go} | 17 +-
.../dubbo/validate.go => pkg/snp/components.go | 6 +-
pkg/tls/cert.go | 145 ++-
pkg/tls/keypair.go | 12 +-
.../envoy/endpoints/endpoints.go => tls/parse.go} | 37 +-
206 files changed, 7589 insertions(+), 14313 deletions(-)
create mode 100644 api/mesh/v1alpha1/dds.pb.go
create mode 100644 api/mesh/v1alpha1/dds.proto
create mode 100644 api/mesh/v1alpha1/dds_grpc.pb.go
create mode 100644 api/mesh/v1alpha1/mapping.pb.go
create mode 100644 api/mesh/v1alpha1/mapping.proto
create mode 100644 api/mesh/v1alpha1/zoneegress.pb.go
create mode 100644 api/mesh/v1alpha1/zoneegress.proto
create mode 100755 build/tools-darwin-arm64/resource-gen
copy deploy/charts/admin/crds/{dubbo.io_zones.yaml => dubbo.io_mappings.yaml} (92%)
copy deploy/charts/admin/crds/{dubbo.io_datasources.yaml => dubbo.io_zoneegresses.yaml} (91%)
delete mode 100644 pkg/admin/bootstrap.go
delete mode 100644 pkg/admin/cache/README.md
delete mode 100644 pkg/admin/cache/cache.go
delete mode 100644 pkg/admin/cache/interface_registry_cache.go
delete mode 100644 pkg/admin/cache/registry/extension.go
delete mode 100644 pkg/admin/cache/registry/kube/cache.go
delete mode 100644 pkg/admin/cache/registry/kube/registry.go
delete mode 100644 pkg/admin/cache/registry/universal/cache.go
delete mode 100644 pkg/admin/cache/registry/universal/mapping.go
delete mode 100644 pkg/admin/cache/registry/universal/registry.go
delete mode 100644 pkg/admin/cache/registry/universal/service_instances_changed_listener_impl.go
delete mode 100644 pkg/admin/cache/selector/application_selector.go
delete mode 100644 pkg/admin/cache/selector/multi_selector.go
delete mode 100644 pkg/admin/cache/selector/selector.go
delete mode 100644 pkg/admin/cache/selector/service_selector.go
delete mode 100644 pkg/admin/config/config.go
delete mode 100644 pkg/admin/config/governance_config.go
delete mode 100644 pkg/admin/config/mock_config/governance_config_mock.go
delete mode 100644 pkg/admin/constant/const.go
delete mode 100644 pkg/admin/constant/kubenetes.go
delete mode 100644 pkg/admin/handlers/condition_route.go
delete mode 100644 pkg/admin/handlers/mock_rule.go
delete mode 100644 pkg/admin/handlers/overrides.go
delete mode 100644 pkg/admin/handlers/service.go
delete mode 100644 pkg/admin/handlers/tag_route.go
delete mode 100644 pkg/admin/handlers/traffic/accesslog.go
delete mode 100644 pkg/admin/handlers/traffic/argument.go
delete mode 100644 pkg/admin/handlers/traffic/gray.go
delete mode 100644 pkg/admin/handlers/traffic/mock.go
delete mode 100644 pkg/admin/handlers/traffic/region.go
delete mode 100644 pkg/admin/handlers/traffic/retry.go
delete mode 100644 pkg/admin/handlers/traffic/timeout.go
delete mode 100644 pkg/admin/handlers/traffic/weight.go
delete mode 100644 pkg/admin/imports/imports.go
delete mode 100644 pkg/admin/mapper/mock_rule_mapper.go
delete mode 100644 pkg/admin/mapper/mock_rule_mapper_mock.go
delete mode 100644 pkg/admin/model/base.go
delete mode 100644 pkg/admin/model/common.go
delete mode 100644 pkg/admin/model/condition_route.go
delete mode 100644 pkg/admin/model/consumer.go
delete mode 100644 pkg/admin/model/dynamic_config.go
delete mode 100644 pkg/admin/model/entity.go
delete mode 100644 pkg/admin/model/match.go
delete mode 100644 pkg/admin/model/mock_rule.go
delete mode 100644 pkg/admin/model/monitor.go
delete mode 100644 pkg/admin/model/override.go
delete mode 100644 pkg/admin/model/provider.go
delete mode 100644 pkg/admin/model/service_detail_dto.go
delete mode 100644 pkg/admin/model/service_dto.go
delete mode 100644 pkg/admin/model/tag_route.go
delete mode 100644 pkg/admin/model/traffic.go
delete mode 100644 pkg/admin/model/util/override_utils.go
delete mode 100644 pkg/admin/model/util/override_utils_test.go
delete mode 100644 pkg/admin/model/util/sync_utils.go
delete mode 100644 pkg/admin/model/util/sync_utils_test.go
delete mode 100644 pkg/admin/monitor/prometheus/metrics.go
delete mode 100644 pkg/admin/monitor/prometheus/types.go
delete mode 100644 pkg/admin/providers/mock/api/mock.pb.go
delete mode 100644 pkg/admin/providers/mock/api/mock.proto
delete mode 100644 pkg/admin/providers/mock/api/mock_triple.pb.go
delete mode 100644 pkg/admin/providers/mock/mock_provider.go
delete mode 100644 pkg/admin/router/router.go
delete mode 100644 pkg/admin/services/consumer_service.go
delete mode 100644 pkg/admin/services/consumer_service_impl.go
delete mode 100644 pkg/admin/services/generic_service_Impl.go
delete mode 100644 pkg/admin/services/mock_rule_service.go
delete mode 100644 pkg/admin/services/mock_rule_service_impl.go
delete mode 100644 pkg/admin/services/mock_rule_service_impl_test.go
delete mode 100644 pkg/admin/services/monitor_service.go
delete mode 100644 pkg/admin/services/override_service.go
delete mode 100644 pkg/admin/services/override_service_impl.go
delete mode 100644 pkg/admin/services/override_service_impl_test.go
delete mode 100644 pkg/admin/services/prometheus_service_impl.go
delete mode 100644 pkg/admin/services/prometheus_service_impl_test.go
delete mode 100644 pkg/admin/services/provider_service.go
delete mode 100644 pkg/admin/services/provider_service_impl.go
delete mode 100644 pkg/admin/services/provider_service_impl_test.go
delete mode 100644 pkg/admin/services/route_service.go
delete mode 100644 pkg/admin/services/route_service_impl.go
delete mode 100644 pkg/admin/services/route_service_impl_test.go
delete mode 100644 pkg/admin/services/service_testing_v3.go
delete mode 100644 pkg/admin/services/traffic/accesslog.go
delete mode 100644 pkg/admin/services/traffic/argument.go
delete mode 100644 pkg/admin/services/traffic/generic_rule_operation.go
delete mode 100644 pkg/admin/services/traffic/gray.go
delete mode 100644 pkg/admin/services/traffic/mock.go
delete mode 100644 pkg/admin/services/traffic/region.go
delete mode 100644 pkg/admin/services/traffic/retry.go
delete mode 100644 pkg/admin/services/traffic/timeout.go
delete mode 100644 pkg/admin/services/traffic/timeout_test.go
delete mode 100644 pkg/admin/services/traffic/weight.go
delete mode 100644 pkg/admin/util/base_service_metadata.go
delete mode 100644 pkg/admin/util/monitor_utils.go
delete mode 100644 pkg/admin/util/monitor_utils_test.go
delete mode 100644 pkg/admin/util/yaml_parser.go
delete mode 100644 pkg/admin/util/yaml_parser_test.go
create mode 100644 pkg/core/ca/issuer/issuer.go
delete mode 100644 pkg/core/kubeclient/client/kube.go
copy pkg/{admin/util/hash.go => core/managers/dataplane/dataplane_manager.go} (70%)
create mode 100644 pkg/core/resources/apis/mesh/zone_ingress_helpers.go
create mode 100644 pkg/dds/cache/builder.go
copy pkg/{hds => dds}/cache/cache_suite_test.go (91%)
create mode 100644 pkg/dds/cache/snapshot.go
create mode 100644 pkg/dds/cache/snapshot_test.go
create mode 100644 pkg/dds/client/dds_client.go
copy pkg/{gc/gc_suite_test.go => dds/client/remote_suite_test.go} (90%)
create mode 100644 pkg/dds/client/stream.go
create mode 100644 pkg/dds/features.go
rename pkg/{admin/util => dds/hash}/hash.go (52%)
copy pkg/{core/datasource/loader.go => dds/mux/zone_watch.go} (69%)
copy pkg/{xds/envoy/listeners/v3/outbound_listener_configurer.go => dds/reconcile/interfaces.go} (50%)
create mode 100644 pkg/dds/reconcile/reconciler.go
create mode 100644 pkg/dds/reconcile/snapshot_generator.go
create mode 100644 pkg/dds/store/sync.go
copy pkg/{xds/envoy/api_version.go => dds/types.go} (70%)
rename pkg/{admin/setup.go => dds/util/client_id.go} (55%)
create mode 100644 pkg/dds/util/meta.go
create mode 100644 pkg/dds/util/resource_test.go
create mode 100644 pkg/dds/util/resources.go
copy pkg/{util/os/os_suite_test.go => dds/util/util_suite_test.go} (91%)
copy pkg/plugins/leader/{memory => nacos}/leader_elector.go (64%)
rename pkg/{admin/util/Tool.go => plugins/leader/zookeeper/leader_elector.go} (55%)
delete mode 100644 pkg/plugins/policies/imports.go
delete mode 100644 pkg/plugins/policies/servicenamemapping/api/v1alpha1/rest.yaml
delete mode 100644 pkg/plugins/policies/servicenamemapping/api/v1alpha1/schema.yaml
delete mode 100644 pkg/plugins/policies/servicenamemapping/api/v1alpha1/servicenamemapping.go
delete mode 100644 pkg/plugins/policies/servicenamemapping/api/v1alpha1/validator.go
delete mode 100644 pkg/plugins/policies/servicenamemapping/api/v1alpha1/zz_generated.deepcopy.go
delete mode 100644 pkg/plugins/policies/servicenamemapping/api/v1alpha1/zz_generated.resource.go
delete mode 100644 pkg/plugins/policies/servicenamemapping/k8s/crd/dubbo.io_servicenamemappings.yaml
delete mode 100644 pkg/plugins/policies/servicenamemapping/k8s/v1alpha1/groupversion_info.go
delete mode 100644 pkg/plugins/policies/servicenamemapping/k8s/v1alpha1/zz_generated.deepcopy.go
delete mode 100644 pkg/plugins/policies/servicenamemapping/k8s/v1alpha1/zz_generated.types.go
delete mode 100644 pkg/plugins/policies/servicenamemapping/plugin/v1alpha1/plugin.go
delete mode 100644 pkg/plugins/policies/servicenamemapping/zz_generated.plugin.go
copy pkg/{intercp/components.go => plugins/resources/mysql/events/listener.go} (66%)
copy pkg/plugins/resources/{memory => mysql}/plugin.go (79%)
copy pkg/{xds/sync/ingress_proxy_builder.go => plugins/resources/mysql/store.go} (50%)
copy pkg/{intercp/components.go => plugins/resources/nacos/events/listener.go} (66%)
copy pkg/plugins/resources/{memory => nacos}/plugin.go (79%)
copy pkg/{xds/sync/ingress_proxy_builder.go => plugins/resources/nacos/store.go} (50%)
copy pkg/{intercp/components.go => plugins/resources/zookeeper/events/listener.go} (66%)
copy pkg/plugins/resources/{memory => zookeeper}/plugin.go (80%)
create mode 100644 pkg/plugins/resources/zookeeper/store.go
create mode 100644 pkg/plugins/runtime/k8s/containers/factory.go
create mode 100644 pkg/plugins/runtime/k8s/controllers/egress_converter.go
create mode 100644 pkg/plugins/runtime/k8s/controllers/endpoints.go
create mode 100644 pkg/plugins/runtime/k8s/controllers/inbound_converter.go
create mode 100644 pkg/plugins/runtime/k8s/controllers/ingress_converter.go
create mode 100644 pkg/plugins/runtime/k8s/controllers/outbound_converter.go
copy pkg/{core/resources/manager/manager_suite_test.go => plugins/runtime/k8s/controllers/probes.go} (77%)
create mode 100644 pkg/plugins/runtime/k8s/controllers/service_controller.go
create mode 100644 pkg/plugins/runtime/k8s/controllers/serviceless_name_extractor.go
create mode 100644 pkg/plugins/runtime/k8s/metadata/annotations.go
create mode 100644 pkg/plugins/runtime/k8s/util/util.go
copy app/dubboctl/internal/dubbo/dubbo_test.go => pkg/registry/components.go (79%)
copy pkg/{util/os/limits_windows.go => registry/registry.go} (78%)
copy app/dubboctl/internal/dubbo/validate.go => pkg/snp/components.go (86%)
copy pkg/{xds/envoy/endpoints/endpoints.go => tls/parse.go} (55%)
(dubbo-kubernetes) 01/01: Merge pull request #204 from sjmshsh/control-plane
Posted by li...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
liujun pushed a commit to branch control-plane
in repository https://gitbox.apache.org/repos/asf/dubbo-kubernetes.git
commit d02648d1b44129ab0e9f8b179f78f5c54abb7e18
Merge: 4813d538 e62c74b2
Author: Ken Liu <ke...@gmail.com>
AuthorDate: Sun Feb 18 10:29:43 2024 +0800
Merge pull request #204 from sjmshsh/control-plane
control-plane build:v1
api/mesh/options.pb.go | 9 +-
api/mesh/v1alpha1/dataplane.pb.go | 15 +-
api/mesh/v1alpha1/dataplane_insight.pb.go | 15 +-
api/mesh/v1alpha1/dds.pb.go | 1125 ++++++++++++++++++++
api/mesh/v1alpha1/dds.proto | 162 +++
api/mesh/v1alpha1/dds_grpc.pb.go | 651 +++++++++++
api/mesh/v1alpha1/envoy_admin.pb.go | 8 +-
api/mesh/v1alpha1/mapping.pb.go | 176 +++
api/mesh/v1alpha1/mapping.proto | 21 +
api/mesh/v1alpha1/mesh.pb.go | 14 +-
api/mesh/v1alpha1/mesh_insight.pb.go | 13 +-
api/mesh/v1alpha1/metrics.pb.go | 9 +-
api/mesh/v1alpha1/mux.pb.go | 9 +-
api/mesh/v1alpha1/mux_grpc.pb.go | 3 -
api/mesh/v1alpha1/zone_ingress.pb.go | 138 +--
api/mesh/v1alpha1/zone_ingress.proto | 3 +
api/mesh/v1alpha1/zone_ingress_insight.pb.go | 13 +-
api/mesh/v1alpha1/zoneegress.pb.go | 264 +++++
api/mesh/v1alpha1/zoneegress.proto | 37 +
api/system/v1alpha1/config.pb.go | 13 +-
api/system/v1alpha1/datasource.pb.go | 14 +-
api/system/v1alpha1/inter_cp_ping.pb.go | 8 +-
api/system/v1alpha1/inter_cp_ping_grpc.pb.go | 3 -
api/system/v1alpha1/secret.pb.go | 14 +-
api/system/v1alpha1/zone.pb.go | 14 +-
app/dubbo-cp/cmd/run.go | 11 +-
build/tools-darwin-arm64/resource-gen | Bin 0 -> 27647874 bytes
.../charts/admin/crds/dubbo.io_mappings.yaml | 35 +-
.../charts/admin/crds/dubbo.io_zoneegresses.yaml | 35 +-
go.mod | 11 +-
go.sum | 22 +-
pkg/admin/bootstrap.go | 189 ----
pkg/admin/cache/README.md | 48 -
pkg/admin/cache/cache.go | 71 --
pkg/admin/cache/registry/extension.go | 53 -
pkg/admin/cache/registry/kube/cache.go | 453 --------
pkg/admin/cache/registry/kube/registry.go | 80 --
pkg/admin/cache/registry/universal/cache.go | 527 ---------
pkg/admin/cache/registry/universal/mapping.go | 96 --
pkg/admin/cache/registry/universal/registry.go | 180 ----
.../service_instances_changed_listener_impl.go | 229 ----
pkg/admin/cache/selector/application_selector.go | 59 -
pkg/admin/cache/selector/multi_selector.go | 127 ---
pkg/admin/cache/selector/selector.go | 58 -
pkg/admin/cache/selector/service_selector.go | 69 --
pkg/admin/config/config.go | 49 -
pkg/admin/config/governance_config.go | 218 ----
.../config/mock_config/governance_config_mock.go | 167 ---
pkg/admin/constant/const.go | 90 --
pkg/admin/constant/kubenetes.go | 42 -
pkg/admin/handlers/condition_route.go | 248 -----
pkg/admin/handlers/mock_rule.go | 139 ---
pkg/admin/handlers/overrides.go | 262 -----
pkg/admin/handlers/service.go | 411 -------
pkg/admin/handlers/tag_route.go | 236 ----
pkg/admin/handlers/traffic/accesslog.go | 130 ---
pkg/admin/handlers/traffic/argument.go | 138 ---
pkg/admin/handlers/traffic/gray.go | 130 ---
pkg/admin/handlers/traffic/mock.go | 139 ---
pkg/admin/handlers/traffic/region.go | 139 ---
pkg/admin/handlers/traffic/retry.go | 138 ---
pkg/admin/handlers/traffic/timeout.go | 138 ---
pkg/admin/handlers/traffic/weight.go | 138 ---
pkg/admin/imports/imports.go | 27 -
pkg/admin/mapper/mock_rule_mapper.go | 63 --
pkg/admin/mapper/mock_rule_mapper_mock.go | 131 ---
pkg/admin/model/base.go | 24 -
pkg/admin/model/common.go | 26 -
pkg/admin/model/condition_route.go | 41 -
pkg/admin/model/consumer.go | 56 -
pkg/admin/model/dynamic_config.go | 78 --
pkg/admin/model/entity.go | 50 -
pkg/admin/model/match.go | 113 --
pkg/admin/model/mock_rule.go | 69 --
pkg/admin/model/monitor.go | 40 -
pkg/admin/model/override.go | 100 --
pkg/admin/model/provider.go | 79 --
pkg/admin/model/service_detail_dto.go | 24 -
pkg/admin/model/service_dto.go | 49 -
pkg/admin/model/tag_route.go | 46 -
pkg/admin/model/traffic.go | 240 -----
pkg/admin/model/util/override_utils.go | 65 --
pkg/admin/model/util/override_utils_test.go | 79 --
pkg/admin/model/util/sync_utils.go | 214 ----
pkg/admin/model/util/sync_utils_test.go | 126 ---
pkg/admin/monitor/prometheus/metrics.go | 65 --
pkg/admin/monitor/prometheus/types.go | 25 -
pkg/admin/providers/mock/api/mock.pb.go | 252 -----
pkg/admin/providers/mock/api/mock_triple.pb.go | 169 ---
pkg/admin/providers/mock/mock_provider.go | 80 --
pkg/admin/router/router.go | 217 ----
pkg/admin/services/consumer_service.go | 25 -
pkg/admin/services/consumer_service_impl.go | 50 -
pkg/admin/services/generic_service_Impl.go | 65 --
pkg/admin/services/mock_rule_service.go | 40 -
pkg/admin/services/mock_rule_service_impl.go | 100 --
pkg/admin/services/mock_rule_service_impl_test.go | 178 ----
pkg/admin/services/monitor_service.go | 31 -
pkg/admin/services/override_service.go | 29 -
pkg/admin/services/override_service_impl.go | 364 -------
pkg/admin/services/override_service_impl_test.go | 332 ------
pkg/admin/services/prometheus_service_impl.go | 252 -----
pkg/admin/services/prometheus_service_impl_test.go | 180 ----
pkg/admin/services/provider_service.go | 33 -
pkg/admin/services/provider_service_impl.go | 374 -------
pkg/admin/services/provider_service_impl_test.go | 283 -----
pkg/admin/services/route_service.go | 39 -
pkg/admin/services/route_service_impl.go | 299 ------
pkg/admin/services/route_service_impl_test.go | 592 ----------
pkg/admin/services/service_testing_v3.go | 231 ----
pkg/admin/services/traffic/accesslog.go | 94 --
pkg/admin/services/traffic/argument.go | 93 --
.../services/traffic/generic_rule_operation.go | 320 ------
pkg/admin/services/traffic/gray.go | 75 --
pkg/admin/services/traffic/mock.go | 86 --
pkg/admin/services/traffic/region.go | 108 --
pkg/admin/services/traffic/retry.go | 100 --
pkg/admin/services/traffic/timeout.go | 101 --
pkg/admin/services/traffic/timeout_test.go | 319 ------
pkg/admin/services/traffic/weight.go | 101 --
pkg/admin/util/base_service_metadata.go | 72 --
pkg/admin/util/monitor_utils.go | 32 -
pkg/admin/util/monitor_utils_test.go | 59 -
pkg/config/core/resources/store/config.go | 2 +
pkg/config/plugins/runtime/k8s/config.go | 44 +
pkg/core/ca/issuer/issuer.go | 161 +++
pkg/core/kubeclient/client/kube.go | 149 ---
.../managers/dataplane/dataplane_manager.go} | 18 +-
pkg/core/plugins/interfaces.go | 5 +
pkg/core/plugins/registry.go | 6 +
.../resources/apis/mesh/zone_ingress_helpers.go | 72 ++
.../resources/apis/mesh/zz_generated.resources.go | 220 +++-
.../apis/system/zz_generated.resources.go | 2 -
pkg/core/resources/model/resource.go | 21 +
pkg/dds/cache/builder.go | 66 ++
.../cache/cache_suite_test.go} | 17 +-
pkg/dds/cache/snapshot.go | 140 +++
pkg/dds/cache/snapshot_test.go | 223 ++++
pkg/dds/client/dds_client.go | 130 +++
.../client/remote_suite_test.go} | 9 +-
pkg/dds/client/stream.go | 167 +++
pkg/dds/features.go | 53 +
pkg/{admin/util => dds/hash}/hash.go | 33 +-
pkg/{admin/util/hash.go => dds/mux/zone_watch.go} | 25 +-
pkg/dds/reconcile/interfaces.go | 40 +
pkg/dds/reconcile/reconciler.go | 178 ++++
pkg/dds/reconcile/snapshot_generator.go | 132 +++
pkg/dds/store/sync.go | 382 +++++++
pkg/{admin/util/yaml_parser.go => dds/types.go} | 24 +-
pkg/{admin/setup.go => dds/util/client_id.go} | 32 +-
pkg/dds/util/meta.go | 105 ++
pkg/dds/util/resource_test.go | 60 ++
pkg/dds/util/resources.go | 172 +++
.../util/util_suite_test.go} | 9 +-
.../leader/nacos/leader_elector.go} | 58 +-
pkg/plugins/leader/plugin.go | 6 +
.../leader/zookeeper/leader_elector.go} | 49 +-
pkg/plugins/policies/core/ordered/ordered.go | 5 +-
pkg/plugins/policies/imports.go | 5 -
.../servicenamemapping/api/v1alpha1/rest.yaml | 122 ---
.../servicenamemapping/api/v1alpha1/schema.yaml | 30 -
.../api/v1alpha1/servicenamemapping.go | 10 -
.../servicenamemapping/api/v1alpha1/validator.go | 11 -
.../api/v1alpha1/zz_generated.deepcopy.go | 25 -
.../api/v1alpha1/zz_generated.resource.go | 144 ---
.../k8s/v1alpha1/groupversion_info.go | 20 -
.../k8s/v1alpha1/zz_generated.deepcopy.go | 75 --
.../k8s/v1alpha1/zz_generated.types.go | 108 --
.../servicenamemapping/plugin/v1alpha1/plugin.go | 30 -
.../servicenamemapping/zz_generated.plugin.go | 16 -
.../native/api/v1alpha1/zz_generated.deepcopy.go | 125 ++-
.../k8s/native/api/v1alpha1/zz_generated.mesh.go | 199 +++-
.../k8s/native/api/v1alpha1/zz_generated.system.go | 5 -
.../mysql/events/listener.go} | 31 +-
pkg/plugins/resources/mysql/plugin.go | 51 +
pkg/plugins/resources/mysql/store.go | 55 +
.../nacos/events/listener.go} | 31 +-
pkg/plugins/resources/nacos/plugin.go | 51 +
pkg/plugins/resources/nacos/store.go | 55 +
.../zookeeper/events/listener.go} | 31 +-
pkg/plugins/resources/zookeeper/plugin.go | 51 +
pkg/plugins/resources/zookeeper/store.go | 55 +
pkg/plugins/runtime/k8s/containers/factory.go | 216 ++++
.../runtime/k8s/controllers/egress_converter.go | 69 ++
pkg/plugins/runtime/k8s/controllers/endpoints.go | 70 ++
.../runtime/k8s/controllers/inbound_converter.go | 223 ++++
.../runtime/k8s/controllers/ingress_converter.go | 168 +++
.../runtime/k8s/controllers/outbound_converter.go | 176 +++
.../runtime/k8s/controllers/pod_controller.go | 301 +++++-
.../runtime/k8s/controllers/pod_converter.go | 105 ++
.../runtime/k8s/controllers/probes.go} | 18 +-
.../runtime/k8s/controllers/service_controller.go | 65 ++
.../k8s/controllers/serviceless_name_extractor.go | 79 ++
pkg/plugins/runtime/k8s/metadata/annotations.go | 210 ++++
pkg/plugins/runtime/k8s/util/util.go | 200 ++++
.../components.go} | 11 +-
.../mock/api/mock.proto => registry/registry.go} | 22 +-
.../components.go} | 10 +-
pkg/tls/cert.go | 145 ++-
pkg/tls/keypair.go | 12 +-
pkg/{admin/util/Tool.go => tls/parse.go} | 48 +-
201 files changed, 7842 insertions(+), 14118 deletions(-)