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 <[email protected]> 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(-)
