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 eb548404756c7615cc4415cb347d7c096dac0513
Merge: 6bbae263 97a7dbe2
Author: Ken Liu <ken.lj...@gmail.com>
AuthorDate: Sun Mar 24 12:26:45 2024 +0800
Merge pull request #226 from sjmshsh/master
new version of the control plane
Makefile | 260 +-
api/ca/ca.pb.go | 330 --
api/ca/ca.proto | 50 -
api/ca/ca_grpc.pb.go | 121 -
api/dds/dds.pb.go | 277 --
api/dds/dds.proto | 43 -
api/dds/dds_grpc.pb.go | 153 -
api/generic/insights.go | 59 +
api/mesh/options.pb.go | 614 +++
api/mesh/options.proto | 87 +
api/mesh/snp.pb.go | 265 --
api/mesh/snp.proto | 44 -
api/mesh/snp_grpc.pb.go | 106 -
api/mesh/v1alpha1/condition_route.pb.go | 233 +
api/mesh/v1alpha1/condition_route.proto | 26 +
api/mesh/v1alpha1/dataplane.pb.go | 1149 +++++
api/mesh/v1alpha1/dataplane.proto | 217 +
api/mesh/v1alpha1/dataplane_helper.go | 518 +++
api/mesh/v1alpha1/dataplane_insight.pb.go | 997 ++++
api/mesh/v1alpha1/dataplane_insight.proto | 158 +
api/mesh/v1alpha1/dataplane_insight_helper.go | 183 +
api/mesh/v1alpha1/dds.pb.go | 1132 +++++
api/mesh/v1alpha1/dds.proto | 164 +
api/mesh/v1alpha1/dds_grpc.pb.go | 657 +++
api/mesh/v1alpha1/dynamic_config.pb.go | 618 +++
api/mesh/v1alpha1/dynamic_config.proto | 51 +
api/mesh/v1alpha1/dynamic_config_helper.go | 31 +
api/mesh/v1alpha1/envoy_admin.pb.go | 151 +
api/mesh/v1alpha1/envoy_admin.proto | 10 +
.../v1alpha1/envoy_admin_inter_cp_forward.pb.go | 106 +
.../v1alpha1/envoy_admin_inter_cp_forward.proto | 13 +
.../envoy_admin_inter_cp_forward_grpc.pb.go | 177 +
api/mesh/v1alpha1/known_backends.go | 11 +
api/mesh/v1alpha1/mapping.pb.go | 508 +++
api/mesh/v1alpha1/mapping.proto | 59 +
api/mesh/v1alpha1/mapping_grpc.pb.go | 192 +
api/mesh/v1alpha1/mapping_helper.go | 18 +
api/mesh/v1alpha1/mesh.pb.go | 1364 ++++++
api/mesh/v1alpha1/mesh.proto | 183 +
api/mesh/v1alpha1/mesh_insight.pb.go | 760 ++++
api/mesh/v1alpha1/mesh_insight.proto | 66 +
api/mesh/v1alpha1/metadata.pb.go | 650 +++
api/mesh/v1alpha1/metadata.proto | 61 +
api/mesh/v1alpha1/metadata_grpc.pb.go | 173 +
api/mesh/v1alpha1/metrics.pb.go | 753 +++
api/mesh/v1alpha1/metrics.proto | 117 +
api/mesh/v1alpha1/mux.pb.go | 260 ++
api/mesh/v1alpha1/mux.proto | 21 +
api/mesh/v1alpha1/mux_grpc.pb.go | 136 +
api/mesh/v1alpha1/selector.pb.go | 160 +
api/mesh/v1alpha1/selector.proto | 11 +
api/mesh/v1alpha1/tag_route.pb.go | 491 ++
api/mesh/v1alpha1/tag_route.proto | 45 +
api/mesh/v1alpha1/traffic_helper.go | 69 +
api/mesh/v1alpha1/zone_ingress.pb.go | 397 ++
api/mesh/v1alpha1/zone_ingress.proto | 42 +
api/mesh/v1alpha1/zone_ingress_insight.pb.go | 177 +
api/mesh/v1alpha1/zone_ingress_insight.proto | 24 +
api/mesh/v1alpha1/zone_ingress_insight_helpers.go | 75 +
api/mesh/v1alpha1/zoneegress.pb.go | 271 ++
api/mesh/v1alpha1/zoneegress.proto | 36 +
api/mesh/v1alpha1/zoneegressinsight.pb.go | 177 +
api/mesh/v1alpha1/zoneegressinsight.proto | 24 +
api/mesh/v1alpha1/zoneegressoverview.pb.go | 191 +
api/mesh/v1alpha1/zoneegressoverview.proto | 24 +
api/mesh/v1alpha1/zoneingress_overview.pb.go | 192 +
api/mesh/v1alpha1/zoneingress_overview.proto | 23 +
api/resource/v1alpha1/authentication.pb.go | 2000 --------
api/resource/v1alpha1/authentication.proto | 59 -
api/resource/v1alpha1/authorization.pb.go | 3627 ---------------
api/resource/v1alpha1/authorization.proto | 92 -
api/resource/v1alpha1/resource_deepcopy.go | 161 -
api/resource/v1alpha1/servicemapping.pb.go | 642 ---
api/resource/v1alpha1/servicemapping.proto | 32 -
api/resource/v1alpha1/toClient_deepcopy.go | 77 -
api/resource/v1alpha1/traffic.pb.go | 4798 --------------------
api/resource/v1alpha1/traffic.proto | 116 -
api/system/v1alpha1/config.pb.go | 164 +
api/system/v1alpha1/config.proto | 22 +
api/system/v1alpha1/datasource.pb.go | 250 +
api/system/v1alpha1/datasource.proto | 30 +
api/system/v1alpha1/inter_cp_ping.pb.go | 252 +
api/system/v1alpha1/inter_cp_ping.proto | 16 +
api/system/v1alpha1/inter_cp_ping_grpc.pb.go | 104 +
api/system/v1alpha1/secret.pb.go | 171 +
api/system/v1alpha1/secret.proto | 22 +
api/system/v1alpha1/zone.pb.go | 172 +
api/system/v1alpha1/zone.proto | 24 +
api/system/v1alpha1/zone_helpers.go | 25 +
api/system/v1alpha1/zone_insight.pb.go | 731 +++
api/system/v1alpha1/zone_insight.proto | 108 +
app/dubbo-cp/README.md | 2 -
app/dubbo-cp/cmd/root.go | 69 +-
app/dubbo-cp/cmd/run.go | 164 +-
app/dubbo-cp/main.go | 8 +-
app/dubbo-ui/fs.go | 1 -
app/dubboctl/cmd/build.go | 11 +-
app/dubboctl/cmd/client.go | 2 +
app/dubboctl/cmd/common.go | 4 +-
app/dubboctl/cmd/completion_util.go | 7 +-
app/dubboctl/cmd/create.go | 12 +-
app/dubboctl/cmd/create_test.go | 2 +
app/dubboctl/cmd/dashboard_all_cmds.go | 13 +-
app/dubboctl/cmd/deploy.go | 18 +-
app/dubboctl/cmd/generate.go | 30 +
app/dubboctl/cmd/generate_certificate.go | 120 +
app/dubboctl/cmd/manifest_diff.go | 11 +-
app/dubboctl/cmd/manifest_generate.go | 16 +-
app/dubboctl/cmd/manifest_install.go | 8 +-
app/dubboctl/cmd/manifest_test.go | 2 +
app/dubboctl/cmd/manifest_uninstall.go | 8 +-
app/dubboctl/cmd/profile_diff.go | 11 +-
app/dubboctl/cmd/profile_list.go | 11 +-
app/dubboctl/cmd/profile_test.go | 4 +-
app/dubboctl/cmd/prompt/prompt.go | 11 +-
app/dubboctl/cmd/proxy.go | 188 +
app/dubboctl/cmd/proxy_context.go | 121 +
app/dubboctl/cmd/registry.go | 2 +
app/dubboctl/cmd/repository.go | 14 +-
app/dubboctl/cmd/root.go | 14 +-
app/dubboctl/cmd/root_test.go | 7 +-
app/dubboctl/identifier/env.go | 2 +
.../apis/dubbo.apache.org/v1alpha1/types.go | 4 +-
app/dubboctl/internal/builders/builders.go | 2 +
app/dubboctl/internal/builders/builders_test.go | 2 +
app/dubboctl/internal/builders/dockerfile/build.go | 6 +
app/dubboctl/internal/builders/pack/build.go | 21 +-
app/dubboctl/internal/builders/pack/build_test.go | 8 +-
app/dubboctl/internal/docker/creds/credentials.go | 10 +-
.../internal/docker/creds/credentials_test.go | 9 +-
app/dubboctl/internal/docker/docker_client.go | 6 +
.../internal/docker/docker_client_ssh_test.go | 9 +-
app/dubboctl/internal/docker/docker_client_test.go | 8 +-
.../internal/docker/docker_client_windows_test.go | 9 +-
app/dubboctl/internal/docker/pusher.go | 10 +-
app/dubboctl/internal/docker/pusher_test.go | 11 +-
app/dubboctl/internal/dubbo/client.go | 10 +-
app/dubboctl/internal/dubbo/deployer.go | 2 +
app/dubboctl/internal/dubbo/dubbo.go | 11 +-
app/dubboctl/internal/dubbo/repositories_test.go | 7 +-
app/dubboctl/internal/dubbo/repository.go | 9 +-
app/dubboctl/internal/dubbo/template.go | 2 +
app/dubboctl/internal/dubbo/templates.go | 2 +
app/dubboctl/internal/dubbo/templates_embedded.go | 2 +
app/dubboctl/internal/dubbo/templates_test.go | 8 +-
app/dubboctl/internal/envoy/envoy.go | 240 +
app/dubboctl/internal/envoy/memory_limit_darwin.go | 22 +
app/dubboctl/internal/envoy/memory_limit_linux.go | 69 +
.../internal/envoy/memory_limit_windows.go | 22 +
app/dubboctl/internal/envoy/remote_bootstrap.go | 254 ++
app/dubboctl/internal/filesystem/filesystem.go | 3 +-
app/dubboctl/internal/kube/client.go | 5 +
app/dubboctl/internal/kube/client_test.go | 10 +-
app/dubboctl/internal/kube/common.go | 13 +-
app/dubboctl/internal/kube/common_test.go | 3 +
app/dubboctl/internal/kube/component.go | 9 +-
app/dubboctl/internal/kube/component_test.go | 2 +
app/dubboctl/internal/kube/object.go | 8 +-
app/dubboctl/internal/kube/object_test.go | 2 +
app/dubboctl/internal/kube/operator.go | 5 +-
app/dubboctl/internal/kube/port_foward.go | 11 +-
app/dubboctl/internal/manifest/common.go | 8 +-
app/dubboctl/internal/manifest/render/render.go | 22 +-
.../internal/manifest/render/render_test.go | 2 +
app/dubboctl/internal/manifest/tree.go | 9 +-
app/dubboctl/internal/mock/builder.go | 2 +
app/dubboctl/internal/mock/pusher.go | 2 +
app/dubboctl/internal/registry/registry.go | 4 +-
app/dubboctl/internal/registry/zk/zk.go | 4 +
.../internal/ssh/ssh_agent_conf_windows.go | 2 +
app/dubboctl/internal/ssh/ssh_dialer.go | 4 +
app/dubboctl/internal/ssh/terminal.go | 3 +
app/dubboctl/internal/util/config_test.go | 5 +-
app/dubboctl/internal/util/env.go | 4 +-
app/dubboctl/internal/util/file.go | 3 +
app/dubboctl/internal/util/filter.go | 2 +
app/dubboctl/internal/util/names.go | 2 +
app/dubboctl/internal/util/yaml.go | 4 +
app/dubboctl/main.go | 2 +
conf/admin.yml | 65 -
conf/dubbo-cp.yaml | 23 +
.../dubbo.apache.org_authenticationpolicies.yaml | 146 -
.../dubbo.apache.org_authorizationpolicies.yaml | 233 -
.../crds/dubbo.apache.org_conditionroutes.yaml | 105 -
.../crds/dubbo.apache.org_dynamicconfigs.yaml | 219 -
.../admin/crds/dubbo.apache.org_tagroutes.yaml | 128 -
.../admin/crds/dubbo.io_conditionroutes.yaml | 50 +
.../admin/crds/dubbo.io_dataplaneinsights.yaml | 50 +
deploy/charts/admin/crds/dubbo.io_dataplanes.yaml | 50 +
deploy/charts/admin/crds/dubbo.io_datasources.yaml | 50 +
.../charts/admin/crds/dubbo.io_dynamicconfigs.yaml | 50 +
deploy/charts/admin/crds/dubbo.io_mappings.yaml | 50 +
deploy/charts/admin/crds/dubbo.io_meshes.yaml | 50 +
.../charts/admin/crds/dubbo.io_meshinsights.yaml | 50 +
deploy/charts/admin/crds/dubbo.io_metadata.yaml | 50 +
deploy/charts/admin/crds/dubbo.io_secrets.yaml | 50 +
.../admin/crds/dubbo.io_servicenamemappings.yaml | 59 +
deploy/charts/admin/crds/dubbo.io_tagroutes.yaml | 50 +
.../charts/admin/crds/dubbo.io_zoneegresses.yaml | 50 +
.../charts/admin/crds/dubbo.io_zoneingresses.yaml | 50 +
.../admin/crds/dubbo.io_zoneingressinsights.yaml | 51 +
.../charts/admin/crds/dubbo.io_zoneinsights.yaml | 50 +
deploy/charts/admin/crds/dubbo.io_zones.yaml | 50 +
deploy/embedded.go | 4 +-
.../dubbo.apache.org_servicenamemappings.yaml | 2 +-
dev/examples/k8s/example-peerauthentication.yaml | 39 -
dev/examples/k8s/example-traffic.yaml | 68 -
docs/guides/new-policies.md | 17 +
go.mod | 219 +-
go.sum | 481 +-
mk/api.mk | 55 +
mk/check.mk | 83 +
mk/dependencies/clang-format.sh | 29 +
mk/dependencies/container-structure-test.sh | 25 +
mk/dependencies/deps.lock | 1 +
mk/dependencies/etcd.sh | 24 +
mk/dependencies/go-deps.sh | 73 +
mk/dependencies/go-deps.versions | 11 +
mk/dependencies/golangci-lint.sh | 17 +
mk/dependencies/hadolint.sh | 30 +
mk/dependencies/helm.sh | 17 +
mk/dependencies/k3d.sh | 9 +
mk/dependencies/kind.sh | 18 +
mk/dependencies/kubebuilder.sh | 28 +
mk/dependencies/kubernetes.sh | 27 +
mk/dependencies/protoc.sh | 35 +
mk/dependencies/shellcheck.sh | 27 +
mk/dev.mk | 76 +
mk/generate.mk | 127 +
mk/run.mk | 16 +
pkg/admin/bootstrap.go | 185 -
pkg/admin/cache/README.md | 48 -
pkg/admin/cache/cache.go | 71 -
pkg/admin/cache/interface_registry_cache.go | 22 -
pkg/admin/cache/registry/extension.go | 50 -
pkg/admin/cache/registry/kube/cache.go | 445 --
pkg/admin/cache/registry/kube/registry.go | 77 -
pkg/admin/cache/registry/universal/cache.go | 522 ---
pkg/admin/cache/registry/universal/mapping.go | 97 -
pkg/admin/cache/registry/universal/registry.go | 174 -
.../service_instances_changed_listener_impl.go | 230 -
pkg/admin/cache/selector/application_selector.go | 56 -
pkg/admin/cache/selector/multi_selector.go | 124 -
pkg/admin/cache/selector/selector.go | 58 -
pkg/admin/cache/selector/service_selector.go | 66 -
pkg/admin/component.go | 35 +
pkg/admin/config/config.go | 46 -
pkg/admin/config/governance_config.go | 216 -
.../config/mock_config/governance_config_mock.go | 164 -
pkg/admin/constant/const.go | 90 -
pkg/admin/constant/kubenetes.go | 42 -
pkg/admin/handlers/condition_route.go | 244 -
pkg/admin/handlers/mock_rule.go | 135 -
pkg/admin/handlers/overrides.go | 258 --
pkg/admin/handlers/service.go | 409 --
pkg/admin/handlers/tag_route.go | 232 -
pkg/admin/handlers/traffic/accesslog.go | 126 -
pkg/admin/handlers/traffic/argument.go | 134 -
pkg/admin/handlers/traffic/gray.go | 126 -
pkg/admin/handlers/traffic/mock.go | 135 -
pkg/admin/handlers/traffic/region.go | 135 -
pkg/admin/handlers/traffic/retry.go | 134 -
pkg/admin/handlers/traffic/timeout.go | 134 -
pkg/admin/handlers/traffic/weight.go | 134 -
pkg/admin/imports/imports.go | 30 -
pkg/admin/mapper/mock_rule_mapper.go | 61 -
pkg/admin/mapper/mock_rule_mapper_mock.go | 126 -
pkg/admin/model/base.go | 24 -
pkg/admin/model/common.go | 26 -
pkg/admin/model/condition_route.go | 41 -
pkg/admin/model/consumer.go | 51 -
pkg/admin/model/dubbo.go | 30 +
pkg/admin/model/dynamic_config.go | 76 -
pkg/admin/model/entity.go | 50 -
pkg/admin/model/match.go | 108 -
pkg/admin/model/mock_rule.go | 69 -
pkg/admin/model/monitor.go | 40 -
pkg/admin/model/override.go | 98 -
pkg/admin/model/provider.go | 75 -
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 | 238 -
pkg/admin/model/util/override_utils.go | 61 -
pkg/admin/model/util/override_utils_test.go | 74 -
pkg/admin/model/util/sync_utils.go | 209 -
pkg/admin/model/util/sync_utils_test.go | 122 -
pkg/admin/providers/mock/api/mock.pb.go | 248 -
pkg/admin/providers/mock/api/mock.proto | 35 -
pkg/admin/providers/mock/api/mock_triple.pb.go | 164 -
pkg/admin/providers/mock/mock_provider.go | 78 -
pkg/admin/router/router.go | 213 -
pkg/admin/server/server.go | 91 +
pkg/admin/services/consumer_service.go | 23 -
pkg/admin/services/consumer_service_impl.go | 50 -
pkg/admin/services/generic_service_Impl.go | 66 -
pkg/admin/services/mock_rule_service.go | 38 -
pkg/admin/services/mock_rule_service_impl.go | 95 -
pkg/admin/services/mock_rule_service_impl_test.go | 174 -
pkg/admin/services/monitor_service.go | 29 -
pkg/admin/services/override_service.go | 27 -
pkg/admin/services/override_service_impl.go | 361 --
pkg/admin/services/override_service_impl_test.go | 328 --
pkg/admin/services/prometheus_service_impl.go | 249 -
pkg/admin/services/prometheus_service_impl_test.go | 177 -
pkg/admin/services/provider_service.go | 30 -
pkg/admin/services/provider_service_impl.go | 369 --
pkg/admin/services/provider_service_impl_test.go | 282 --
pkg/admin/services/route_service.go | 37 -
pkg/admin/services/route_service_impl.go | 298 --
pkg/admin/services/route_service_impl_test.go | 588 ---
pkg/admin/services/service_testing_v3.go | 226 -
pkg/admin/services/traffic/accesslog.go | 89 -
pkg/admin/services/traffic/argument.go | 88 -
.../services/traffic/generic_rule_operation.go | 314 --
pkg/admin/services/traffic/gray.go | 72 -
pkg/admin/services/traffic/mock.go | 84 -
pkg/admin/services/traffic/region.go | 103 -
pkg/admin/services/traffic/retry.go | 99 -
pkg/admin/services/traffic/timeout.go | 100 -
pkg/admin/services/traffic/timeout_test.go | 313 --
pkg/admin/services/traffic/weight.go | 96 -
pkg/admin/setup.go | 37 -
pkg/admin/util/Tool.go | 56 -
pkg/admin/util/base_service_metadata.go | 70 -
pkg/admin/util/hash.go | 34 -
pkg/admin/util/monitor_utils.go | 30 -
pkg/admin/util/monitor_utils_test.go | 57 -
pkg/admin/util/yaml_parser.go | 32 -
pkg/admin/util/yaml_parser_test.go | 61 -
pkg/authority/server/authority.go | 122 -
pkg/authority/server/authority_test.go | 309 --
pkg/authority/setup.go | 48 -
pkg/bufman/bootstrap.go | 21 +-
.../bufanalysistesting/bufanalysistesting.go | 9 +-
.../bufanalysistesting/bufanalysistesting_test.go | 7 +-
pkg/bufman/bufpkg/bufapimodule/bufapimodule.go | 5 +-
pkg/bufman/bufpkg/bufapimodule/module_reader.go | 7 +-
.../bufpkg/bufapimodule/module_reader_test.go | 12 +-
pkg/bufman/bufpkg/bufapimodule/module_resolver.go | 10 +-
.../bufpkg/bufapimodule/module_resolver_test.go | 12 +-
.../bufpkg/bufcheck/bufbreaking/bufbreaking.go | 7 +-
.../bufbreakingconfig/bufbreakingconfig.go | 2 +
pkg/bufman/bufpkg/bufcheck/bufbreaking/handler.go | 7 +-
.../internal/bufbreakingcheck/bufbreakingcheck.go | 7 +-
.../bufbreaking/internal/bufbreakingcheck/util.go | 7 +-
.../internal/bufbreakingv1/bufbreakingv1.go | 4 +-
.../internal/bufbreakingv1/bufbreakingv1_test.go | 2 +
.../bufbreakingv1beta1/bufbreakingv1beta1.go | 4 +-
.../bufbreakingv1beta1/bufbreakingv1beta1_test.go | 2 +
pkg/bufman/bufpkg/bufcheck/bufcheck.go | 2 +
pkg/bufman/bufpkg/bufcheck/buflint/buflint.go | 7 +-
.../buflint/buflintconfig/buflintconfig.go | 2 +
pkg/bufman/bufpkg/bufcheck/buflint/handler.go | 7 +-
.../buflint/internal/buflintbuild/buflintbuild.go | 2 +
.../buflint/internal/buflintcheck/buflintcheck.go | 2 +
.../bufcheck/buflint/internal/buflintcheck/util.go | 2 +
.../buflint/internal/buflintv1/buflintv1.go | 4 +-
.../buflint/internal/buflintv1/buflintv1_test.go | 2 +
.../internal/buflintv1beta1/buflintv1beta1.go | 4 +-
.../internal/buflintv1beta1/buflintv1beta1_test.go | 2 +
pkg/bufman/bufpkg/bufcheck/internal/config.go | 2 +
pkg/bufman/bufpkg/bufcheck/internal/helper.go | 2 +
.../internal/internaltesting/internaltesting.go | 7 +-
pkg/bufman/bufpkg/bufcheck/internal/rule.go | 2 +
pkg/bufman/bufpkg/bufcheck/internal/runner.go | 17 +-
.../bufpkg/bufcheck/internal/version_spec.go | 2 +
pkg/bufman/bufpkg/bufconfig/bufconfig.go | 2 +
pkg/bufman/bufpkg/bufconfig/get.go | 12 +-
pkg/bufman/bufpkg/bufconfig/read.go | 2 +
pkg/bufman/bufpkg/bufconfig/write.go | 8 +-
pkg/bufman/bufpkg/bufconfig/write_test.go | 7 +-
pkg/bufman/bufpkg/bufconnect/errors.go | 4 +-
pkg/bufman/bufpkg/bufconnect/errors_test.go | 2 +
pkg/bufman/bufpkg/bufconnect/interceptors.go | 7 +-
pkg/bufman/bufpkg/bufconnect/interceptors_test.go | 12 +-
.../bufpkg/bufconnect/static_token_provider.go | 2 +
.../bufconnect/static_token_provider_test.go | 7 +-
pkg/bufman/bufpkg/bufgraph/bufgraph.go | 7 +-
pkg/bufman/bufpkg/bufgraph/builder.go | 7 +-
pkg/bufman/bufpkg/bufimage/bufimage.go | 9 +-
.../bufpkg/bufimage/bufimagebuild/bufimagebuild.go | 7 +-
.../bufpkg/bufimage/bufimagebuild/builder.go | 24 +-
.../bufimage/bufimagemodify/bufimagemodify.go | 10 +-
.../bufimage/bufimagemodify/cc_enable_arenas.go | 9 +-
.../bufimage/bufimagemodify/csharp_namespace.go | 13 +-
.../bufimage/bufimagemodify/file_option_sweeper.go | 7 +-
.../bufpkg/bufimage/bufimagemodify/go_package.go | 11 +-
.../bufimage/bufimagemodify/java_multiple_files.go | 9 +-
.../bufimagemodify/java_outer_classname.go | 13 +-
.../bufpkg/bufimage/bufimagemodify/java_package.go | 11 +-
.../bufimagemodify/java_string_check_utf8.go | 9 +-
.../bufimage/bufimagemodify/multi_modifier.go | 2 +
.../bufimage/bufimagemodify/objc_class_prefix.go | 13 +-
.../bufpkg/bufimage/bufimagemodify/optimize_for.go | 10 +-
.../bufimagemodify/php_metadata_namespace.go | 9 +-
.../bufimage/bufimagemodify/php_namespace.go | 11 +-
.../bufpkg/bufimage/bufimagemodify/ruby_package.go | 13 +-
.../bufpkg/bufimage/bufimageutil/bufimageutil.go | 11 +-
.../bufpkg/bufimage/bufimageutil/image_index.go | 10 +-
.../bufimage/bufimageutil/source_paths_remap.go | 4 +-
pkg/bufman/bufpkg/bufimage/image_file.go | 5 +-
pkg/bufman/bufpkg/bufimage/import_tracker.go | 11 +-
pkg/bufman/bufpkg/bufimage/util.go | 18 +-
pkg/bufman/bufpkg/bufimage/validate.go | 2 +
pkg/bufman/bufpkg/buflock/buflock.go | 2 +
pkg/bufman/bufpkg/buflock/lock_file.go | 2 +
pkg/bufman/bufpkg/bufmanifest/bucket.go | 2 +
pkg/bufman/bufpkg/bufmanifest/mapper.go | 7 +-
pkg/bufman/bufpkg/bufmanifest/mapper_test.go | 9 +-
pkg/bufman/bufpkg/bufmodule/bufmodule.go | 7 +-
.../bufmodule/bufmodulebuild/bufmodulebuild.go | 7 +-
.../bufmodulebuild/module_bucket_builder.go | 2 +
.../bufmodulebuild/module_file_set_builder.go | 8 +-
.../bufmodulebuild/module_include_builder.go | 7 +-
pkg/bufman/bufpkg/bufmodule/bufmodulebuild/util.go | 2 +
.../bufmodule/bufmodulecache/bufmodulecache.go | 5 +-
.../bufpkg/bufmodule/bufmodulecache/cache_stats.go | 4 +-
.../bufmodule/bufmodulecache/cas_module_cacher.go | 10 +-
.../bufmodule/bufmodulecache/cas_module_reader.go | 7 +-
.../bufmodulecache/cas_module_reader_test.go | 15 +-
pkg/bufman/bufpkg/bufmodule/bufmodulecache/util.go | 11 +-
.../bufmodule/bufmoduleconfig/bufmoduleconfig.go | 4 +-
.../bufpkg/bufmodule/bufmoduleconfig/config.go | 2 +
.../bufmodule/bufmoduleconfig/config_test.go | 9 +-
.../bufmoduleprotocompile/bufmoduleprotocompile.go | 7 +-
.../bufmoduleprotocompile/path_resolver.go | 7 +-
.../bufpkg/bufmodule/bufmoduleref/bufmoduleref.go | 7 +-
.../bufmodule/bufmoduleref/bufmoduleref_test.go | 9 +-
.../bufmodule/bufmoduleref/module_owner_test.go | 2 +
.../bufpkg/bufmodule/bufmoduleref/module_pin.go | 7 +-
.../bufmodule/bufmoduleref/module_pin_test.go | 7 +-
.../bufmoduleref/module_reference_test.go | 7 +-
.../bufpkg/bufmodule/bufmoduleref/validate.go | 2 +
.../bufpkg/bufmodule/bufmoduleref/validate_test.go | 2 +
.../bufpkg/bufmodule/bufmodulestat/file_walker.go | 7 +-
.../bufmodule/bufmoduletesting/bufmoduletesting.go | 2 +
.../bufmoduletesting/bufmoduletesting_test.go | 7 +-
.../bufmoduletesting/bufmoduletesting_unix.go | 7 +-
.../bufmoduletesting/bufmoduletesting_windows.go | 7 +-
.../bufmoduletesting/test_module_reader.go | 2 +
pkg/bufman/bufpkg/bufmodule/internal/internal.go | 3 +-
.../bufpkg/bufmodule/internal/internal_test.go | 7 +-
pkg/bufman/bufpkg/bufmodule/module.go | 2 +
pkg/bufman/bufpkg/bufmodule/module_file.go | 2 +
pkg/bufman/bufpkg/bufmodule/module_file_set.go | 2 +
pkg/bufman/bufpkg/bufmodule/module_read_bucket.go | 2 +
pkg/bufman/bufpkg/bufmodule/module_test.go | 9 +-
.../bufpkg/bufmodule/multi_module_read_bucket.go | 2 +
pkg/bufman/bufpkg/bufmodule/nop_module_reader.go | 2 +
pkg/bufman/bufpkg/bufmodule/nop_module_resolver.go | 2 +
.../bufpkg/bufmodule/single_module_read_bucket.go | 2 +
pkg/bufman/bufpkg/bufmodule/targeting_module.go | 2 +
.../bufpkg/bufmodule/targeting_module_test.go | 9 +-
pkg/bufman/bufpkg/bufmodule/util.go | 7 +-
pkg/bufman/bufpkg/bufmodule/validate.go | 2 +
pkg/bufman/bufpkg/bufmodule/workspace.go | 2 +
pkg/bufman/bufpkg/bufplugin/bufplugin.go | 2 +
pkg/bufman/bufpkg/bufplugin/bufplugin_test.go | 9 +-
.../bufplugin/bufpluginconfig/bufpluginconfig.go | 2 +
.../bufpkg/bufplugin/bufpluginconfig/config.go | 9 +-
pkg/bufman/bufpkg/bufplugin/bufpluginconfig/get.go | 12 +-
.../bufpkg/bufplugin/bufplugindocker/docker.go | 9 +-
.../bufplugin/bufpluginref/bufpluginref_test.go | 2 +
.../bufplugin/bufpluginref/plugin_identity.go | 2 +
.../bufplugin/bufpluginref/plugin_reference.go | 2 +
pkg/bufman/bufpkg/bufplugin/plugin.go | 7 +-
pkg/bufman/bufpkg/bufpluginexec/binary_handler.go | 16 +-
pkg/bufman/bufpkg/bufpluginexec/bufpluginexec.go | 10 +-
pkg/bufman/bufpkg/bufpluginexec/generator.go | 10 +-
pkg/bufman/bufpkg/bufpluginexec/normalize.go | 3 +
pkg/bufman/bufpkg/bufpluginexec/normalize_test.go | 6 +
.../bufpkg/bufpluginexec/protoc_proxy_handler.go | 24 +-
pkg/bufman/bufpkg/bufpluginexec/version.go | 3 +
pkg/bufman/bufpkg/bufpluginexec/version_test.go | 3 +
pkg/bufman/bufpkg/bufpluginexec/wasm_handler.go | 15 +-
.../bufpkg/bufpluginexec/wasm_handler_test.go | 2 +
pkg/bufman/bufpkg/bufreflect/bufreflect.go | 9 +-
.../bufpkg/bufremoteplugin/bufremoteplugin.go | 2 +
pkg/bufman/bufpkg/bufstudioagent/buffer_codec.go | 8 +-
pkg/bufman/bufpkg/bufstudioagent/bufstudioagent.go | 3 +
.../bufpkg/bufstudioagent/bufstudioagent_test.go | 13 +-
.../bufpkg/bufstudioagent/plain_post_handler.go | 12 +-
pkg/bufman/bufpkg/bufstyle/analyzer_provider.go | 3 +
pkg/bufman/bufpkg/bufstyle/analyzers.go | 2 +
pkg/bufman/bufpkg/bufstyle/bufstyle.go | 4 +-
pkg/bufman/bufpkg/bufstyle/cmd/bufstyle/main.go | 7 +-
pkg/bufman/bufpkg/buftesting/buftesting.go | 13 +-
pkg/bufman/bufpkg/bufwasm/bufwasm.go | 12 +-
pkg/bufman/bufpkg/bufwkt/cmd/wkt-go-data/main.go | 10 +-
pkg/bufman/config/config.go | 8 +-
pkg/bufman/controllers/authn.go | 2 +
pkg/bufman/controllers/commit.go | 2 +
pkg/bufman/controllers/doc.go | 2 +
pkg/bufman/controllers/repository.go | 2 +
pkg/bufman/controllers/search.go | 7 +-
pkg/bufman/controllers/tag.go | 2 +
pkg/bufman/controllers/token.go | 2 +
pkg/bufman/controllers/user.go | 2 +
pkg/bufman/core/parser/document_generator.go | 10 +-
pkg/bufman/core/parser/proto_parser.go | 9 +-
pkg/bufman/core/resolve/resolve.go | 7 +-
pkg/bufman/core/search/db_search.go | 2 +
pkg/bufman/core/search/search.go | 2 +
pkg/bufman/core/security/page_token.go | 7 +-
pkg/bufman/core/security/security.go | 2 +
pkg/bufman/core/storage/db_storage.go | 2 +
pkg/bufman/core/storage/disk_storage.go | 2 +
pkg/bufman/core/storage/storage.go | 2 +
pkg/bufman/core/validity/viliditor.go | 2 +
pkg/bufman/dal/commit_files.gen.go | 10 +-
pkg/bufman/dal/commits.gen.go | 10 +-
pkg/bufman/dal/file_blobs.gen.go | 10 +-
pkg/bufman/dal/gen.go | 6 +-
pkg/bufman/dal/repositories.gen.go | 10 +-
pkg/bufman/dal/tags.gen.go | 10 +-
pkg/bufman/dal/tokens.gen.go | 10 +-
pkg/bufman/dal/users.gen.go | 10 +-
pkg/bufman/e/base_error.go | 1 +
pkg/bufman/gen/data/dataspdx/dataspdx.gen.go | 4 +-
.../auditv1alpha1connect/service.connect.go | 10 +-
.../registryv1alpha1connect/admin.connect.go | 10 +-
.../registryv1alpha1connect/authn.connect.go | 10 +-
.../registryv1alpha1connect/authz.connect.go | 10 +-
.../registryv1alpha1connect/convert.connect.go | 10 +-
.../registryv1alpha1connect/display.connect.go | 10 +-
.../registryv1alpha1connect/doc.connect.go | 10 +-
.../registryv1alpha1connect/docker.connect.go | 10 +-
.../registryv1alpha1connect/download.connect.go | 10 +-
.../registryv1alpha1connect/generate.connect.go | 10 +-
.../registryv1alpha1connect/github.connect.go | 10 +-
.../registryv1alpha1connect/image.connect.go | 10 +-
.../registryv1alpha1connect/jsonschema.connect.go | 10 +-
.../registryv1alpha1connect/labels.connect.go | 10 +-
.../organization.connect.go | 10 +-
.../registryv1alpha1connect/owner.connect.go | 10 +-
.../registryv1alpha1connect/plugin.connect.go | 10 +-
.../plugin_curation.connect.go | 10 +-
.../registryv1alpha1connect/push.connect.go | 10 +-
.../recommendation.connect.go | 10 +-
.../registryv1alpha1connect/reference.connect.go | 10 +-
.../registryv1alpha1connect/repository.connect.go | 10 +-
.../repository_branch.connect.go | 10 +-
.../repository_commit.connect.go | 10 +-
.../repository_tag.connect.go | 10 +-
.../registryv1alpha1connect/resolve.connect.go | 10 +-
.../registryv1alpha1connect/resource.connect.go | 10 +-
.../registryv1alpha1connect/schema.connect.go | 10 +-
.../registryv1alpha1connect/scim_token.connect.go | 10 +-
.../registryv1alpha1connect/search.connect.go | 10 +-
.../registryv1alpha1connect/studio.connect.go | 10 +-
.../studio_request.connect.go | 10 +-
.../registryv1alpha1connect/sync.connect.go | 10 +-
.../registryv1alpha1connect/token.connect.go | 10 +-
.../registryv1alpha1connect/user.connect.go | 10 +-
.../registryv1alpha1connect/webhook.connect.go | 10 +-
.../admin.connect.go | 10 +-
.../authn.connect.go | 10 +-
.../authz.connect.go | 10 +-
.../convert.connect.go | 10 +-
.../display.connect.go | 10 +-
.../registryv1alpha1v1alpha1connect/doc.connect.go | 10 +-
.../docker.connect.go | 10 +-
.../download.connect.go | 10 +-
.../generate.connect.go | 10 +-
.../github.connect.go | 10 +-
.../image.connect.go | 10 +-
.../jsonschema.connect.go | 10 +-
.../labels.connect.go | 10 +-
.../organization.connect.go | 10 +-
.../owner.connect.go | 10 +-
.../plugin.connect.go | 10 +-
.../plugin_curation.connect.go | 10 +-
.../push.connect.go | 10 +-
.../recommendation.connect.go | 10 +-
.../reference.connect.go | 10 +-
.../repository.connect.go | 10 +-
.../repository_branch.connect.go | 10 +-
.../repository_commit.connect.go | 10 +-
.../repository_tag.connect.go | 10 +-
.../resolve.connect.go | 10 +-
.../resource.connect.go | 10 +-
.../schema.connect.go | 10 +-
.../scim_token.connect.go | 10 +-
.../search.connect.go | 10 +-
.../studio.connect.go | 10 +-
.../studio_request.connect.go | 10 +-
.../sync.connect.go | 10 +-
.../token.connect.go | 10 +-
.../user.connect.go | 10 +-
.../webhook.connect.go | 10 +-
.../webhookv1alpha1connect/event.connect.go | 10 +-
pkg/bufman/gen/proto/go/audit/v1alpha1/event.pb.go | 14 +-
.../gen/proto/go/audit/v1alpha1/service.pb.go | 9 +-
.../gen/proto/go/audit/v1alpha1/service_grpc.pb.go | 3 +
pkg/bufman/gen/proto/go/breaking/v1/config.pb.go | 8 +-
pkg/bufman/gen/proto/go/image/v1/image.pb.go | 9 +-
pkg/bufman/gen/proto/go/lint/v1/config.pb.go | 8 +-
.../gen/proto/go/module/v1alpha1/module.pb.go | 16 +-
.../gen/proto/go/registry/v1alpha1/admin.pb.go | 8 +-
.../proto/go/registry/v1alpha1/admin_grpc.pb.go | 3 +
.../gen/proto/go/registry/v1alpha1/authn.pb.go | 8 +-
.../proto/go/registry/v1alpha1/authn_grpc.pb.go | 3 +
.../gen/proto/go/registry/v1alpha1/authz.pb.go | 8 +-
.../proto/go/registry/v1alpha1/authz_grpc.pb.go | 3 +
.../gen/proto/go/registry/v1alpha1/convert.pb.go | 13 +-
.../proto/go/registry/v1alpha1/convert_grpc.pb.go | 3 +
.../gen/proto/go/registry/v1alpha1/display.pb.go | 8 +-
.../proto/go/registry/v1alpha1/display_grpc.pb.go | 3 +
.../gen/proto/go/registry/v1alpha1/doc.pb.go | 8 +-
.../gen/proto/go/registry/v1alpha1/doc_grpc.pb.go | 3 +
.../gen/proto/go/registry/v1alpha1/docker.pb.go | 9 +-
.../proto/go/registry/v1alpha1/docker_grpc.pb.go | 3 +
.../gen/proto/go/registry/v1alpha1/download.pb.go | 13 +-
.../proto/go/registry/v1alpha1/download_grpc.pb.go | 3 +
.../gen/proto/go/registry/v1alpha1/generate.pb.go | 14 +-
.../proto/go/registry/v1alpha1/generate_grpc.pb.go | 3 +
.../proto/go/registry/v1alpha1/git_metadata.pb.go | 9 +-
.../gen/proto/go/registry/v1alpha1/github.pb.go | 8 +-
.../proto/go/registry/v1alpha1/github_grpc.pb.go | 3 +
.../gen/proto/go/registry/v1alpha1/image.pb.go | 13 +-
.../proto/go/registry/v1alpha1/image_grpc.pb.go | 3 +
.../proto/go/registry/v1alpha1/jsonschema.pb.go | 8 +-
.../go/registry/v1alpha1/jsonschema_grpc.pb.go | 3 +
.../gen/proto/go/registry/v1alpha1/labels.pb.go | 9 +-
.../proto/go/registry/v1alpha1/labels_grpc.pb.go | 3 +
.../gen/proto/go/registry/v1alpha1/module.pb.go | 9 +-
.../proto/go/registry/v1alpha1/organization.pb.go | 9 +-
.../go/registry/v1alpha1/organization_grpc.pb.go | 3 +
.../gen/proto/go/registry/v1alpha1/owner.pb.go | 8 +-
.../proto/go/registry/v1alpha1/owner_grpc.pb.go | 3 +
.../gen/proto/go/registry/v1alpha1/plugin.pb.go | 9 +-
.../go/registry/v1alpha1/plugin_curation.pb.go | 14 +-
.../registry/v1alpha1/plugin_curation_grpc.pb.go | 3 +
.../proto/go/registry/v1alpha1/plugin_grpc.pb.go | 3 +
.../gen/proto/go/registry/v1alpha1/push.pb.go | 13 +-
.../gen/proto/go/registry/v1alpha1/push_grpc.pb.go | 3 +
.../go/registry/v1alpha1/recommendation.pb.go | 9 +-
.../go/registry/v1alpha1/recommendation_grpc.pb.go | 3 +
.../gen/proto/go/registry/v1alpha1/reference.pb.go | 8 +-
.../go/registry/v1alpha1/reference_grpc.pb.go | 3 +
.../proto/go/registry/v1alpha1/repository.pb.go | 9 +-
.../go/registry/v1alpha1/repository_branch.pb.go | 9 +-
.../registry/v1alpha1/repository_branch_grpc.pb.go | 3 +
.../go/registry/v1alpha1/repository_commit.pb.go | 9 +-
.../registry/v1alpha1/repository_commit_grpc.pb.go | 3 +
.../go/registry/v1alpha1/repository_grpc.pb.go | 3 +
.../go/registry/v1alpha1/repository_tag.pb.go | 9 +-
.../go/registry/v1alpha1/repository_tag_grpc.pb.go | 3 +
.../gen/proto/go/registry/v1alpha1/resolve.pb.go | 13 +-
.../proto/go/registry/v1alpha1/resolve_grpc.pb.go | 3 +
.../gen/proto/go/registry/v1alpha1/resource.pb.go | 8 +-
.../proto/go/registry/v1alpha1/resource_grpc.pb.go | 3 +
.../gen/proto/go/registry/v1alpha1/role.pb.go | 8 +-
.../gen/proto/go/registry/v1alpha1/schema.pb.go | 9 +-
.../proto/go/registry/v1alpha1/schema_grpc.pb.go | 3 +
.../proto/go/registry/v1alpha1/scim_token.pb.go | 9 +-
.../go/registry/v1alpha1/scim_token_grpc.pb.go | 3 +
.../gen/proto/go/registry/v1alpha1/search.pb.go | 8 +-
.../proto/go/registry/v1alpha1/search_grpc.pb.go | 3 +
.../gen/proto/go/registry/v1alpha1/studio.pb.go | 8 +-
.../proto/go/registry/v1alpha1/studio_grpc.pb.go | 3 +
.../go/registry/v1alpha1/studio_request.pb.go | 9 +-
.../go/registry/v1alpha1/studio_request_grpc.pb.go | 3 +
.../gen/proto/go/registry/v1alpha1/sync.pb.go | 13 +-
.../gen/proto/go/registry/v1alpha1/sync_grpc.pb.go | 3 +
.../gen/proto/go/registry/v1alpha1/token.pb.go | 9 +-
.../proto/go/registry/v1alpha1/token_grpc.pb.go | 3 +
.../gen/proto/go/registry/v1alpha1/user.pb.go | 9 +-
.../gen/proto/go/registry/v1alpha1/user_grpc.pb.go | 3 +
.../go/registry/v1alpha1/verification_status.pb.go | 8 +-
.../gen/proto/go/registry/v1alpha1/webhook.pb.go | 9 +-
.../proto/go/registry/v1alpha1/webhook_grpc.pb.go | 3 +
.../gen/proto/go/studio/v1alpha1/invoke.pb.go | 8 +-
.../gen/proto/go/wasmplugin/v1/wasmplugin.pb.go | 8 +-
.../gen/proto/go/webhook/v1alpha1/event.pb.go | 14 +-
.../gen/proto/go/webhook/v1alpha1/event_grpc.pb.go | 3 +
pkg/bufman/gorm_gen/gorm_gen.go | 5 +-
pkg/bufman/handlers/grpc_handlers/authn.go | 2 +
pkg/bufman/handlers/grpc_handlers/commit.go | 2 +
pkg/bufman/handlers/grpc_handlers/docs.go | 2 +
pkg/bufman/handlers/grpc_handlers/download.go | 2 +
pkg/bufman/handlers/grpc_handlers/push.go | 2 +
pkg/bufman/handlers/grpc_handlers/repository.go | 2 +
pkg/bufman/handlers/grpc_handlers/resolve.go | 2 +
pkg/bufman/handlers/grpc_handlers/tag.go | 2 +
pkg/bufman/handlers/grpc_handlers/token.go | 2 +
pkg/bufman/handlers/grpc_handlers/user.go | 2 +
pkg/bufman/handlers/http_handlers/authn.go | 7 +-
pkg/bufman/handlers/http_handlers/commit.go | 7 +-
pkg/bufman/handlers/http_handlers/common.go | 5 +-
pkg/bufman/handlers/http_handlers/doc.go | 7 +-
pkg/bufman/handlers/http_handlers/repository.go | 7 +-
pkg/bufman/handlers/http_handlers/search.go | 7 +-
pkg/bufman/handlers/http_handlers/tag.go | 7 +-
pkg/bufman/handlers/http_handlers/token.go | 7 +-
pkg/bufman/handlers/http_handlers/user.go | 7 +-
pkg/bufman/interceptors/auth.go | 7 +-
pkg/bufman/interceptors/init.go | 4 +-
pkg/bufman/mapper/commit_mapper.go | 7 +-
pkg/bufman/mapper/repository_mapper.go | 2 +
pkg/bufman/mapper/token_mapper.go | 2 +
pkg/bufman/model/commit.go | 7 +-
pkg/bufman/model/file.go | 2 +
pkg/bufman/model/repository.go | 7 +-
pkg/bufman/model/tag.go | 7 +-
pkg/bufman/model/token.go | 7 +-
pkg/bufman/model/user.go | 7 +-
pkg/bufman/pkg/app/app.go | 2 +
pkg/bufman/pkg/app/app_test.go | 2 +
pkg/bufman/pkg/app/appcmd/appcmd.go | 8 +-
pkg/bufman/pkg/app/appcmd/appcmd_test.go | 8 +-
.../pkg/app/appcmd/appcmdtesting/appcmdtesting.go | 9 +-
pkg/bufman/pkg/app/appcmd/cobra.go | 3 +-
pkg/bufman/pkg/app/appcmd/webpages.go | 9 +-
pkg/bufman/pkg/app/appflag/appflag.go | 7 +-
pkg/bufman/pkg/app/appflag/builder.go | 17 +-
pkg/bufman/pkg/app/appflag/container.go | 5 +-
pkg/bufman/pkg/app/applog/applog.go | 7 +-
pkg/bufman/pkg/app/applog/applog_test.go | 3 +
pkg/bufman/pkg/app/appname/appname.go | 2 +
pkg/bufman/pkg/app/appname/appname_unix_test.go | 7 +-
pkg/bufman/pkg/app/appname/container.go | 2 +
pkg/bufman/pkg/app/appproto/appproto.go | 10 +-
pkg/bufman/pkg/app/appproto/appproto_test.go | 3 +
.../pkg/app/appproto/appprotoos/appprotoos.go | 8 +-
.../pkg/app/appproto/appprotoos/response_writer.go | 13 +-
pkg/bufman/pkg/app/appproto/generator.go | 10 +-
pkg/bufman/pkg/app/appproto/response_builder.go | 10 +-
pkg/bufman/pkg/app/appproto/response_writer.go | 9 +-
pkg/bufman/pkg/app/appverbose/appverbose.go | 2 +
pkg/bufman/pkg/app/appverbose/container.go | 4 +-
pkg/bufman/pkg/app/stderr_container.go | 2 +
pkg/bufman/pkg/app/stdin_container.go | 2 +
pkg/bufman/pkg/app/stdout_container.go | 2 +
pkg/bufman/pkg/bandeps/bandeps.go | 7 +-
pkg/bufman/pkg/bandeps/checker.go | 12 +-
pkg/bufman/pkg/bandeps/cmd/bandeps/main.go | 10 +-
pkg/bufman/pkg/bandeps/key_rwlock.go | 5 +-
pkg/bufman/pkg/bandeps/state.go | 12 +-
pkg/bufman/pkg/cert/certclient/certclient.go | 2 +
pkg/bufman/pkg/command/command.go | 2 +
pkg/bufman/pkg/command/process.go | 2 +
pkg/bufman/pkg/command/runner.go | 2 +
pkg/bufman/pkg/command/runner_unix_test.go | 2 +
pkg/bufman/pkg/dag/dag.go | 1 -
pkg/bufman/pkg/dag/dag_test.go | 2 +
pkg/bufman/pkg/diff/diff.go | 2 +
pkg/bufman/pkg/diff/diffmyers/diffmyers_test.go | 7 +-
pkg/bufman/pkg/encoding/encoding.go | 3 +
pkg/bufman/pkg/encoding/encoding_test.go | 2 +
pkg/bufman/pkg/filelock/filelock_test.go | 2 +
pkg/bufman/pkg/filelock/lock.go | 2 +
pkg/bufman/pkg/filelock/locker.go | 2 +
.../pkg/filepathextended/filepathextended.go | 7 +-
pkg/bufman/pkg/git/cloner.go | 17 +-
.../pkg/git/cmd/git-ls-files-unstaged/main.go | 2 +
pkg/bufman/pkg/git/git.go | 7 +-
pkg/bufman/pkg/git/lister.go | 2 +
pkg/bufman/pkg/git/object_reader.go | 7 +-
pkg/bufman/pkg/git/ref_branch.go | 4 +-
pkg/bufman/pkg/git/repository.go | 2 +
pkg/bufman/pkg/git/tree.go | 2 +
.../pkg/github/githubtesting/archive_reader.go | 10 +-
.../pkg/github/githubtesting/githubtesting.go | 7 +-
pkg/bufman/pkg/httpauth/env_authenticator.go | 2 +
pkg/bufman/pkg/httpauth/httpauth.go | 2 +
pkg/bufman/pkg/httpauth/multi_authenticator.go | 2 +
pkg/bufman/pkg/httpauth/netrc_authenticator.go | 2 +
pkg/bufman/pkg/httpauth/nop_authenticator.go | 2 +
pkg/bufman/pkg/interrupt/interrupt_windows.go | 4 +-
pkg/bufman/pkg/ioextended/ioextended.go | 2 +
.../pkg/licenseheader/cmd/license-header/main.go | 10 +-
pkg/bufman/pkg/licenseheader/licenseheader_test.go | 2 +
pkg/bufman/pkg/manifest/digest.go | 2 +
pkg/bufman/pkg/manifest/digest_test.go | 7 +-
pkg/bufman/pkg/manifest/manifest.go | 2 +
pkg/bufman/pkg/manifest/manifest_test.go | 9 +-
pkg/bufman/pkg/manifest/module.go | 2 +
pkg/bufman/pkg/manifest/module_test.go | 7 +-
pkg/bufman/pkg/manifest/storage.go | 7 +-
pkg/bufman/pkg/manifest/storage_test.go | 9 +-
pkg/bufman/pkg/netextended/netextended_test.go | 2 +
pkg/bufman/pkg/netrc/netrc.go | 7 +-
pkg/bufman/pkg/netrc/netrc_unix_test.go | 7 +-
pkg/bufman/pkg/normalpath/normalpath.go | 2 +
pkg/bufman/pkg/normalpath/normalpath_test.go | 2 +
pkg/bufman/pkg/normalpath/normalpath_unix_test.go | 7 +-
.../pkg/normalpath/normalpath_windows_test.go | 7 +-
.../pkg/observabilityzap/observabilityzap.go | 3 +
.../pkg/observabilityzap/tracer_provider_closer.go | 3 +
pkg/bufman/pkg/observabilityzap/zapexporter.go | 3 +
pkg/bufman/pkg/protodescriptor/protodescriptor.go | 14 +-
pkg/bufman/pkg/protoencoding/json_marshaler.go | 3 +
pkg/bufman/pkg/protoencoding/json_unmarshaler.go | 1 +
pkg/bufman/pkg/protoencoding/protoencoding.go | 6 +-
.../pkg/protoencoding/reparse_unrecognized.go | 1 +
pkg/bufman/pkg/protoencoding/resolver.go | 8 +-
pkg/bufman/pkg/protogenutil/named_helper.go | 2 +
pkg/bufman/pkg/protogenutil/protogenutil.go | 11 +-
pkg/bufman/pkg/protosource/field.go | 4 +-
pkg/bufman/pkg/protosource/file.go | 9 +-
pkg/bufman/pkg/protosource/file_import.go | 4 +-
pkg/bufman/pkg/protosource/files.go | 7 +-
pkg/bufman/pkg/protosource/location.go | 4 +-
pkg/bufman/pkg/protosource/location_store.go | 2 +
pkg/bufman/pkg/protosource/method.go | 2 +
.../pkg/protosource/option_extension_descriptor.go | 3 +
.../option_extension_descriptor_test.go | 5 +
pkg/bufman/pkg/protosource/protosource.go | 10 +-
pkg/bufman/pkg/protosource/reserved_name.go | 4 +-
pkg/bufman/pkg/protosource/tag_range_test.go | 2 +
pkg/bufman/pkg/protostat/protostat.go | 2 +
.../pkg/protostat/protostatos/file_walker.go | 2 +
.../pkg/protostat/protostatos/protostatos.go | 4 +-
.../pkg/protostat/protostatstorage/file_walker.go | 7 +-
pkg/bufman/pkg/prototesting/prototesting.go | 17 +-
pkg/bufman/pkg/prototime/prototime.go | 2 +
pkg/bufman/pkg/protoversion/protoversion_test.go | 2 +
pkg/bufman/pkg/spdx/cmd/spdx-go-data/main.go | 10 +-
pkg/bufman/pkg/spdx/cmd/spdx-ts-data/main.go | 7 +-
pkg/bufman/pkg/spdx/spdx.go | 2 +
pkg/bufman/pkg/storage/cmd/ddiff/main.go | 7 +-
pkg/bufman/pkg/storage/cmd/storage-go-data/main.go | 10 +-
pkg/bufman/pkg/storage/copy.go | 7 +-
pkg/bufman/pkg/storage/diff.go | 2 +
pkg/bufman/pkg/storage/errors.go | 2 +
pkg/bufman/pkg/storage/external_paths.go | 2 +
pkg/bufman/pkg/storage/limit.go | 2 +
pkg/bufman/pkg/storage/map.go | 2 +
pkg/bufman/pkg/storage/multi.go | 2 +
.../pkg/storage/storagearchive/storagearchive.go | 10 +-
pkg/bufman/pkg/storage/storagegit/bucket.go | 2 +
pkg/bufman/pkg/storage/storagemem/bucket.go | 2 +
.../pkg/storage/storagemem/read_object_closer.go | 2 +
pkg/bufman/pkg/storage/storagemem/storagemem.go | 2 +
.../pkg/storage/storagemem/write_object_closer.go | 2 +
pkg/bufman/pkg/storage/storageos/bucket.go | 10 +-
pkg/bufman/pkg/storage/storageos/provider.go | 4 +-
pkg/bufman/pkg/storage/storageutil/storageutil.go | 2 +
pkg/bufman/pkg/storage/util.go | 2 +
pkg/bufman/pkg/thread/thread.go | 2 +
pkg/bufman/pkg/tmp/tmp.go | 7 +-
.../pkg/transport/http/httpserver/httpserver.go | 5 +
pkg/bufman/pkg/uuidutil/uuidutil.go | 2 +
pkg/bufman/pkg/uuidutil/uuidutil_test.go | 2 +
pkg/bufman/pkg/zaputil/zaputil.go | 2 +
pkg/bufman/router/grpc_router.go | 32 +-
pkg/bufman/router/http_router.go | 9 +-
pkg/bufman/services/authz_service.go | 7 +-
pkg/bufman/services/commit_service.go | 7 +-
pkg/bufman/services/docs_service.go | 7 +-
pkg/bufman/services/download_service.go | 7 +-
pkg/bufman/services/push_service.go | 10 +-
pkg/bufman/services/repository_service.go | 10 +-
pkg/bufman/services/tag_service.go | 5 +
pkg/bufman/services/token_service.go | 10 +-
pkg/bufman/services/user_service.go | 10 +-
pkg/bufman/setup.go | 7 +-
pkg/config/admin/address_config.go | 76 -
pkg/config/admin/config.go | 57 +-
pkg/config/app/dubbo-cp/config.go | 283 +-
pkg/config/app/dubbo-cp/dubbo-cp.default.yaml | 63 -
pkg/config/app/dubboctl/proxy_config.go | 179 +
pkg/config/bufman/config.go | 35 +-
pkg/config/config.go | 25 +-
pkg/config/core/config.go | 52 +
pkg/config/core/resources/store/config.go | 250 +
pkg/config/dds/config.go | 35 -
pkg/config/dds/debounce/config.go | 32 -
pkg/config/deprecate.go | 42 +
pkg/config/diagnostics/config.go | 41 +
pkg/config/display.go | 6 +-
pkg/config/dp-server/config.go | 219 +
pkg/config/dubbo/config.go | 67 +
pkg/config/eventbus/config.go | 34 +
pkg/config/intercp/config.go | 111 +
pkg/config/kube/config.go | 41 -
pkg/config/loader.go | 65 +-
pkg/config/multizone/dds.go | 149 +
pkg/config/multizone/multicluster.go | 122 +
pkg/config/plugins/resources/k8s/config.go | 49 +
pkg/config/plugins/resources/mysql/config.go | 30 +
pkg/config/plugins/resources/zookeeper/config.go | 44 +
pkg/config/plugins/runtime/config.go | 64 +
pkg/config/plugins/runtime/k8s/config.go | 193 +
pkg/config/security/config.go | 33 -
pkg/config/server/config.go | 31 -
pkg/config/types/duration.go | 65 +
pkg/config/types/keys.go | 56 +
pkg/config/types/tls.go | 83 +
pkg/config/util.go | 57 -
pkg/config/webhook/config.go | 29 -
pkg/config/xds/bootstrap/config.go | 122 +
.../xds/bootstrap/types/bootstrap_request.go | 49 +
pkg/config/xds/config.go | 79 +
pkg/core/admin/client.go | 191 +
pkg/core/admin/dds_client.go | 192 +
pkg/core/admin/sanitize.go | 54 +
pkg/core/alias.go | 85 +-
pkg/core/bootstrap/autoconfig.go | 43 +
pkg/core/bootstrap/bootstrap.go | 492 +-
pkg/core/bootstrap/plugins.go | 45 +
pkg/core/ca/issuer/issuer.go | 161 +
pkg/core/cert/provider/certelection.go | 79 -
pkg/core/cert/provider/storage.go | 239 -
pkg/core/cert/provider/storage_test.go | 247 -
pkg/core/cert/provider/util.go | 294 --
pkg/core/cert/provider/util_test.go | 201 -
pkg/core/cert/setup.go | 28 -
pkg/core/client/cert/client.go | 220 -
pkg/core/client/webhook/client.go | 149 -
pkg/core/cmd/util.go | 2 +
pkg/core/cmd/version/version.go | 12 +-
pkg/core/config/manager/manager.go | 86 +
pkg/core/consts/const.go | 81 +
pkg/core/datasource/datasource_suite_test.go | 30 +
pkg/core/datasource/dynamic.go | 78 +
pkg/core/datasource/loader.go | 30 +
pkg/core/datasource/static.go | 86 +
pkg/core/datasource/static_test.go | 112 +
pkg/core/datasource/validator.go | 45 +
pkg/core/dns/lookup/cache.go | 41 +
pkg/core/dns/lookup/cache_suite_test.go | 13 +
pkg/core/dns/lookup/cache_test.go | 57 +
pkg/core/dns/lookup/interface.go | 7 +
pkg/core/election/kube/leaderelection.go | 151 -
pkg/core/election/kube/leaderelection_test.go | 144 -
pkg/core/election/universe/leaderelection.go | 36 -
pkg/core/endpoint/endpoint.go | 47 -
pkg/core/endpoint/endpoint_test.go | 36 -
pkg/core/extensions/reg_client_factory.go | 35 +
pkg/core/gen/apis/dubbo.apache.org/v1alpha1/doc.go | 19 -
.../gen/apis/dubbo.apache.org/v1alpha1/register.go | 68 -
.../gen/apis/dubbo.apache.org/v1alpha1/types.go | 143 -
.../v1alpha1/zz_generated.deepcopy.go | 390 --
.../gen/generated/clientset/versioned/clientset.go | 121 -
pkg/core/gen/generated/clientset/versioned/doc.go | 20 -
.../versioned/fake/clientset_generated.go | 86 -
.../gen/generated/clientset/versioned/fake/doc.go | 20 -
.../generated/clientset/versioned/fake/register.go | 57 -
.../generated/clientset/versioned/scheme/doc.go | 20 -
.../clientset/versioned/scheme/register.go | 57 -
.../v1alpha1/authenticationpolicy.go | 178 -
.../v1alpha1/authorizationpolicy.go | 178 -
.../dubbo.apache.org/v1alpha1/conditionroute.go | 178 -
.../typed/dubbo.apache.org/v1alpha1/doc.go | 20 -
.../v1alpha1/dubbo.apache.org_client.go | 132 -
.../dubbo.apache.org/v1alpha1/dynamicconfig.go | 178 -
.../typed/dubbo.apache.org/v1alpha1/fake/doc.go | 20 -
.../v1alpha1/fake/fake_authenticationpolicy.go | 130 -
.../v1alpha1/fake/fake_authorizationpolicy.go | 130 -
.../v1alpha1/fake/fake_conditionroute.go | 130 -
.../v1alpha1/fake/fake_dubbo.apache.org_client.go | 61 -
.../v1alpha1/fake/fake_dynamicconfig.go | 130 -
.../v1alpha1/fake/fake_servicenamemapping.go | 130 -
.../v1alpha1/fake/fake_tagroute.go | 130 -
.../v1alpha1/generated_expansion.go | 31 -
.../v1alpha1/servicenamemapping.go | 178 -
.../typed/dubbo.apache.org/v1alpha1/tagroute.go | 178 -
.../externalversions/dubbo.apache.org/interface.go | 46 -
.../v1alpha1/authenticationpolicy.go | 90 -
.../v1alpha1/authorizationpolicy.go | 90 -
.../dubbo.apache.org/v1alpha1/conditionroute.go | 90 -
.../dubbo.apache.org/v1alpha1/dynamicconfig.go | 90 -
.../dubbo.apache.org/v1alpha1/interface.go | 80 -
.../v1alpha1/servicenamemapping.go | 90 -
.../dubbo.apache.org/v1alpha1/tagroute.go | 90 -
.../informers/externalversions/factory.go | 180 -
.../informers/externalversions/generic.go | 72 -
.../internalinterfaces/factory_interfaces.go | 40 -
.../v1alpha1/authenticationpolicy.go | 100 -
.../v1alpha1/authorizationpolicy.go | 100 -
.../dubbo.apache.org/v1alpha1/conditionroute.go | 100 -
.../dubbo.apache.org/v1alpha1/dynamicconfig.go | 100 -
.../v1alpha1/expansion_generated.go | 67 -
.../v1alpha1/servicenamemapping.go | 100 -
.../listers/dubbo.apache.org/v1alpha1/tagroute.go | 100 -
pkg/core/governance/governance_config.go | 198 +
pkg/core/governance/governance_config_mock.go | 169 +
pkg/core/jwt/util.go | 77 -
pkg/core/jwt/util_test.go | 66 -
pkg/core/kubeclient/client/fake.go | 79 -
pkg/core/kubeclient/client/kube.go | 181 -
pkg/core/kubeclient/setup.go | 33 -
pkg/core/labels/collection.go | 68 -
pkg/core/labels/collection_test.go | 77 -
pkg/core/labels/instance.go | 166 -
pkg/core/labels/instance_test.go | 128 -
pkg/core/logger/log.go | 3 +
.../condition_route/condition_route_manager.go | 41 +
.../managers/apis/dataplane/dataplane_manager.go | 146 +
.../managers/apis/dataplane/dataplane_validator.go | 32 +
.../managers/apis/dynamic_config/dynamic_config.go | 41 +
pkg/core/managers/apis/mapping/mapping_manager.go | 55 +
pkg/core/managers/apis/mesh/mesh_manager.go | 179 +
pkg/core/managers/apis/mesh/mesh_validator.go | 32 +
.../managers/apis/metadata/metadata_manager.go | 74 +
pkg/core/managers/apis/tag_route/tag_route.go | 41 +
pkg/core/model/model.go | 240 -
pkg/core/model/model_test.go | 102 -
pkg/core/monitor/prometheus/metrics.go | 60 -
pkg/core/monitor/prometheus/types.go | 23 -
pkg/core/plugins/global.go | 30 +
pkg/core/plugins/interfaces.go | 100 +
pkg/core/plugins/registry.go | 188 +
pkg/core/queue/delay.go | 247 -
pkg/core/queue/delay_test.go | 172 -
pkg/core/queue/instance.go | 94 -
pkg/core/queue/instance_test.go | 116 -
pkg/core/reg_client/client.go | 25 +
pkg/core/reg_client/factory/factory.go | 32 +
pkg/core/reg_client/nacos/nacos.go | 77 +
pkg/core/reg_client/zookeeper/zookeeper.go | 106 +
pkg/core/registry/mapping.go | 80 +
pkg/core/registry/notify.go | 176 +
pkg/core/registry/registry.go | 142 +
pkg/core/registry/resource_meta.go | 65 +
.../service_instances_changed_listener_impl.go | 229 +
pkg/core/resources/apis/mesh/dataplane_helpers.go | 183 +
.../resources/apis/mesh/dataplane_validator.go | 212 +
pkg/core/resources/apis/mesh/mapping_helpers.go | 25 +
pkg/core/resources/apis/mesh/mesh_helpers.go | 152 +
pkg/core/resources/apis/mesh/meta_validator.go | 56 +
pkg/core/resources/apis/mesh/validators.go | 341 ++
.../resources/apis/mesh/zone_egress_helpers.go | 72 +
.../resources/apis/mesh/zone_egress_validator.go | 46 +
.../resources/apis/mesh/zone_ingress_helpers.go | 75 +
.../resources/apis/mesh/zone_ingress_validator.go | 70 +
.../resources/apis/mesh/zz_generated.resources.go | 1322 ++++++
.../apis/system/zz_generated.resources.go | 556 +++
pkg/core/resources/manager/cache.go | 142 +
pkg/core/resources/manager/cache_test.go | 252 +
pkg/core/resources/manager/customizable_manager.go | 97 +
pkg/core/resources/manager/manager.go | 222 +
pkg/core/resources/manager/manager_suite_test.go | 30 +
pkg/core/resources/manager/manager_test.go | 143 +
pkg/core/resources/model/display_name.go | 47 +
pkg/core/resources/model/resource.go | 539 +++
pkg/core/resources/model/rest/api.go | 88 +
pkg/core/resources/model/rest/converter.go | 97 +
pkg/core/resources/model/rest/list.go | 75 +
pkg/core/resources/model/rest/resource.go | 28 +
pkg/core/resources/model/rest/unmarshaller.go | 157 +
.../resources/model/rest/unversioned/resource.go | 109 +
pkg/core/resources/model/rest/v1alpha1/meta.go | 65 +
pkg/core/resources/model/rest/v1alpha1/resource.go | 41 +
pkg/core/resources/model/utils.go | 117 +
pkg/core/resources/registry/global.go | 43 +
pkg/core/resources/registry/registry.go | 153 +
pkg/core/resources/store/customizable_store.go | 98 +
pkg/core/resources/store/options.go | 458 ++
pkg/core/resources/store/pagination_store.go | 134 +
pkg/core/resources/store/store.go | 216 +
pkg/core/resources/store/transactions.go | 93 +
pkg/core/runtime/builder.go | 414 +-
pkg/core/runtime/component/component.go | 49 +-
.../runtime/component/component_manager_test.go | 84 +
pkg/core/runtime/component/component_suite_test.go | 30 +
pkg/core/runtime/component/leader.go | 40 +
pkg/core/runtime/component/resilient.go | 80 +
pkg/core/runtime/runtime.go | 213 +-
pkg/core/schema/ast/ast.go | 120 -
pkg/core/schema/ast/ast_test.go | 66 -
pkg/core/schema/collection/name.go | 43 -
pkg/core/schema/collection/name_test.go | 87 -
pkg/core/schema/collection/names.go | 40 -
pkg/core/schema/collection/schema.go | 94 -
pkg/core/schema/collection/schema_test.go | 94 -
pkg/core/schema/collection/schemas.go | 241 -
pkg/core/schema/collection/schemas_test.go | 421 --
pkg/core/schema/collections/collections.gen.go | 128 -
pkg/core/schema/gvk/gvk.gen.go | 29 -
pkg/core/schema/resource/schema.go | 239 -
pkg/core/schema/resource/schema_test.go | 216 -
pkg/core/schema/schema.go | 127 -
pkg/core/schema/schema_test.go | 75 -
pkg/core/tools/channels/closed.go | 28 -
pkg/core/tools/endpoint/endpoint.go | 142 -
pkg/core/tools/endpoint/endpoint_test.go | 268 --
pkg/core/tools/generate/key.go | 25 -
pkg/core/tools/resource/camelcase.go | 84 -
pkg/core/user/context.go | 18 +
pkg/core/user/user.go | 40 +
pkg/core/validation/validation.go | 50 -
pkg/core/validators/common_validators.go | 216 +
pkg/core/validators/messages.go | 59 +
pkg/core/validators/types.go | 214 +
pkg/core/validators/types_test.go | 257 ++
pkg/core/validators/validators_suite_test.go | 30 +
pkg/core/xds/features.go | 33 +
pkg/core/xds/matched_policies.go | 46 +
pkg/core/xds/metadata.go | 220 +
pkg/core/xds/resource.go | 190 +
pkg/core/xds/sockets.go | 24 +
pkg/core/xds/types.go | 275 ++
pkg/cp-server/server/server.go | 111 -
pkg/cp-server/setup.go | 27 -
pkg/dds/cache/builder.go | 68 +
pkg/dds/cache/cache_suite_test.go | 30 +
pkg/dds/cache/snapshot.go | 146 +
pkg/dds/cache/snapshot_test.go | 233 +
pkg/dds/client/dds_client.go | 136 +
pkg/dds/client/remote_suite_test.go | 30 +
pkg/dds/client/stream.go | 174 +
pkg/dds/context/context.go | 238 +
pkg/dds/features.go | 56 +
pkg/dds/global/components.go | 188 +
pkg/dds/hash/hash.go | 52 +
pkg/dds/kube/crdclient/cache_handler.go | 92 -
pkg/dds/kube/crdclient/client.go | 256 --
pkg/dds/kube/crdclient/client_test.go | 196 -
pkg/dds/kube/crdclient/config.go | 102 -
pkg/dds/kube/crdclient/config_test.go | 97 -
pkg/dds/kube/crdclient/handler.go | 142 -
pkg/dds/kube/crdclient/handler_test.go | 290 --
pkg/dds/kube/crdclient/types.gen.go | 239 -
pkg/dds/mux/client.go | 322 ++
pkg/dds/mux/clientstream.go | 74 +
pkg/dds/mux/server.go | 170 +
pkg/dds/mux/serverstream.go | 74 +
pkg/dds/mux/session.go | 191 +
pkg/dds/mux/version.go | 55 +
pkg/dds/mux/zone_sync.go | 165 +
pkg/dds/mux/zone_watch.go | 141 +
pkg/dds/reconcile/interfaces.go | 47 +
pkg/dds/reconcile/reconciler.go | 188 +
pkg/dds/reconcile/snapshot_generator.go | 189 +
pkg/dds/server/components.go | 140 +
pkg/dds/server/dds.go | 70 +
pkg/dds/server/error_recorder_stream.go | 65 +
pkg/dds/server/event_based_watchdog.go | 107 +
pkg/dds/server/metrics.go | 25 +
pkg/dds/server/nack_backoff.go | 59 +
pkg/dds/server/resource_retry_forcer.go | 99 +
pkg/dds/server/server.go | 152 -
pkg/dds/server/streamwrapper.go | 86 +
pkg/dds/server/type_adjust_callbacks.go | 45 +
pkg/dds/service/envoy_admin_processor.go | 186 +
pkg/dds/service/envoy_admin_rpcs.go | 42 +
pkg/dds/service/server.go | 282 ++
pkg/dds/setup.go | 62 -
pkg/dds/storage/generate.go | 202 -
pkg/dds/storage/storage.go | 351 --
pkg/dds/storage/storage_test.go | 947 ----
pkg/dds/storage/validate.go | 365 --
pkg/dds/storage/validate_test.go | 2414 ----------
pkg/dds/store/sync.go | 402 ++
pkg/dds/types.go | 30 +
pkg/dds/util/client_id.go | 48 +
pkg/dds/util/meta.go | 111 +
pkg/dds/util/resource_test.go | 67 +
pkg/dds/util/resources.go | 178 +
pkg/dds/util/util_suite_test.go | 30 +
pkg/dds/zone/components.go | 132 +
pkg/defaults/components.go | 130 +
pkg/defaults/components_test.go | 119 +
pkg/defaults/defaults_suite_test.go | 30 +
pkg/defaults/mesh.go | 54 +
pkg/defaults/zone.go | 104 +
pkg/diagnostics/components.go | 30 +
pkg/diagnostics/server.go | 100 +
pkg/dp-server/components.go | 33 +
pkg/dp-server/server/server.go | 155 +
pkg/dubbo/client/stream.go | 112 +
pkg/dubbo/client/sync_client.go | 95 +
pkg/dubbo/components.go | 72 +
pkg/dubbo/metadata/register_request.go | 20 +
pkg/dubbo/metadata/server.go | 80 +
pkg/dubbo/pusher/interface.go | 36 +
pkg/dubbo/pusher/pushed_items.go | 35 +
pkg/dubbo/pusher/pusher.go | 234 +
pkg/dubbo/pusher/resource_changed_callbacks.go | 121 +
pkg/dubbo/pusher/revision.go | 24 +
pkg/dubbo/servicemapping/register_request.go | 58 +
pkg/dubbo/servicemapping/server.go | 381 ++
pkg/events/enventbus_suite_test.go | 30 +
pkg/events/enventbus_test.go | 81 +
pkg/events/eventbus.go | 105 +
pkg/events/interfaces.go | 82 +
pkg/hds/cache/cache_suite_test.go | 30 +
pkg/hds/cache/snapshot.go | 91 +
pkg/hds/cache/snapshot_test.go | 220 +
pkg/hds/callbacks/chain.go | 64 +
pkg/hds/callbacks/interface.go | 41 +
pkg/hds/components.go | 81 +
pkg/hds/server/server.go | 203 +
pkg/hds/tracker/callbacks.go | 239 +
pkg/hds/tracker/hds_suite_test.go | 30 +
pkg/hds/tracker/healthcheck_generator.go | 186 +
pkg/hds/tracker/healthcheck_generator_test.go | 160 +
pkg/hds/tracker/reconciler.go | 59 +
pkg/hds/tracker/testdata/hds.1.golden.yaml | 31 +
pkg/hds/tracker/testdata/hds.2.golden.yaml | 31 +
pkg/hds/tracker/testdata/hds.3.golden.yaml | 31 +
pkg/intercp/catalog/catalog.go | 89 +
pkg/intercp/catalog/config_catalog.go | 137 +
pkg/intercp/catalog/heartbeat_component.go | 148 +
pkg/intercp/catalog/heartbeats.go | 57 +
pkg/intercp/catalog/server.go | 64 +
pkg/intercp/catalog/writer.go | 88 +
pkg/intercp/client/client.go | 71 +
pkg/intercp/client/pool.go | 135 +
pkg/intercp/components.go | 50 +
pkg/intercp/envoyadmin/forwarding_dds_client.go | 215 +
pkg/intercp/envoyadmin/server.go | 116 +
pkg/intercp/server/server.go | 120 +
pkg/log/logger.go | 151 +
pkg/plugins/bootstrap/k8s/plugin.go | 254 ++
pkg/plugins/bootstrap/k8s/scheme.go | 51 +
pkg/plugins/bootstrap/universal/plugin.go | 57 +
pkg/plugins/common/k8s/composite_validator.go | 64 +
pkg/plugins/common/k8s/converter.go | 32 +
pkg/plugins/common/k8s/names.go | 40 +
pkg/plugins/common/mysql/connection.go | 69 +
pkg/plugins/common/zookeeper/connection.go | 34 +
pkg/plugins/common/zookeeper/listener.go | 30 +
pkg/plugins/common/zookeeper/zk_listener.go | 62 +
pkg/plugins/config/k8s/plugin.go | 48 +
pkg/plugins/config/k8s/store.go | 221 +
pkg/plugins/config/universal/plugin.go | 35 +
pkg/plugins/extensions/k8s/context.go | 79 +
pkg/plugins/extensions/logger/context.go | 48 +
pkg/plugins/leader/memory/leader_elector.go | 57 +
pkg/plugins/leader/mysql/leader_elector.go | 111 +
pkg/plugins/leader/mysql/lock.go | 91 +
pkg/plugins/leader/plugin.go | 45 +
pkg/plugins/policies/core/core.go | 36 +
pkg/plugins/policies/core/defaults/consts.go | 37 +
pkg/plugins/policies/core/generator/generator.go | 49 +
pkg/plugins/policies/core/matchers/dataplane.go | 29 +
pkg/plugins/policies/core/ordered/ordered.go | 24 +
pkg/plugins/policies/core/rules/rules.go | 209 +
pkg/plugins/policies/core/xds/cluster.go | 122 +
pkg/plugins/policies/core/xds/clusters.go | 84 +
pkg/plugins/policies/core/xds/endpoints.go | 61 +
pkg/plugins/policies/core/xds/http_filters.go | 35 +
pkg/plugins/policies/core/xds/listeners.go | 65 +
pkg/plugins/policies/core/xds/split.go | 82 +
pkg/plugins/policies/scheme.go | 35 +
pkg/plugins/resources/k8s/caching_converter.go | 87 +
pkg/plugins/resources/k8s/converter.go | 90 +
pkg/plugins/resources/k8s/events/listener.go | 217 +
pkg/plugins/resources/k8s/mapper.go | 66 +
pkg/plugins/resources/k8s/native/.gitignore | 24 +
.../k8s/native/api/v1alpha1/groupversion_info.go | 53 +
.../resources/k8s/native/api/v1alpha1/spec.go | 35 +
.../native/api/v1alpha1/zz_generated.deepcopy.go | 1003 ++++
.../k8s/native/api/v1alpha1/zz_generated.mesh.go | 1187 +++++
.../k8s/native/api/v1alpha1/zz_generated.system.go | 411 ++
.../resources/k8s/native/pkg/model/resources.go | 63 +
.../resources/k8s/native/pkg/registry/global.go | 48 +
.../k8s/native/pkg/registry/interfaces.go | 35 +
.../resources/k8s/native/pkg/registry/registry.go | 109 +
pkg/plugins/resources/k8s/plugin.go | 66 +
pkg/plugins/resources/k8s/store.go | 323 ++
pkg/plugins/resources/memory/memory_suite_test.go | 30 +
pkg/plugins/resources/memory/plugin.go | 54 +
pkg/plugins/resources/memory/store.go | 377 ++
.../resources/memory/store_template_test.go | 32 +
pkg/plugins/resources/traditional/path_util.go | 68 +
pkg/plugins/resources/traditional/plugin.go | 62 +
pkg/plugins/resources/traditional/resource_meta.go | 65 +
pkg/plugins/resources/traditional/store.go | 856 ++++
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 | 224 +
.../runtime/k8s/controllers/ingress_converter.go | 168 +
.../runtime/k8s/controllers/outbound_converter.go | 176 +
.../runtime/k8s/controllers/pod_controller.go | 397 ++
.../runtime/k8s/controllers/pod_converter.go | 140 +
pkg/plugins/runtime/k8s/controllers/probes.go | 30 +
.../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/metadata/labels.go | 25 +
pkg/plugins/runtime/k8s/plugin.go | 134 +
pkg/plugins/runtime/k8s/util/names.go | 23 +
pkg/plugins/runtime/k8s/util/util.go | 200 +
pkg/plugins/runtime/k8s/webhooks/defaulter.go | 106 +
.../k8s/webhooks/owner_reference_mutator.go | 94 +
pkg/plugins/runtime/k8s/webhooks/pod_mutator.go | 59 +
pkg/plugins/runtime/k8s/webhooks/validation.go | 268 ++
pkg/plugins/runtime/universal/plugin.go | 60 +
pkg/plugins/util/ccache/key.go | 22 +
pkg/plugins/util/channels/closed.go | 27 +
pkg/proxy/cgroups/cgroups.go | 59 +
pkg/proxy/command/base_command.go | 44 +
pkg/proxy/command/build_command_darwin.go | 43 +
pkg/proxy/command/build_command_linux.go | 44 +
pkg/proxy/command/build_command_windows.go | 39 +
pkg/snp/model/model.go | 23 -
pkg/snp/server/servicemapping.go | 299 --
pkg/snp/setup.go | 40 -
pkg/test/api_types.go | 35 +
pkg/test/clock.go | 44 +
pkg/test/component.go | 168 +
pkg/test/const.go | 33 +
pkg/test/ginkgo.go | 103 +
pkg/test/grpc/clientstream.go | 124 +
pkg/test/grpc/serverstream.go | 156 +
pkg/test/matchers/golden.go | 127 +
pkg/test/matchers/golden/update_files.go | 37 +
pkg/test/matchers/keys.go | 127 +
pkg/test/matchers/port.go | 33 +
pkg/test/matchers/proto.go | 75 +
pkg/test/network.go | 39 +
pkg/test/resources/builders/dataplane_builder.go | 279 ++
pkg/test/resources/model/resource.go | 96 +
pkg/test/resources/registry.go | 26 +
pkg/test/resources/samples/dataplane_samples.go | 52 +
pkg/test/resources/validation.go | 116 +
pkg/test/resources/validation/validation.go | 115 +
pkg/test/runtime/runtime.go | 184 +
pkg/test/store/failing.go | 53 +
pkg/test/store/load.go | 70 +
pkg/test/store/owner_test_templates.go | 251 +
pkg/test/store/store_test_template.go | 567 +++
pkg/test/within.go | 47 +
pkg/tls/cert.go | 203 +
pkg/tls/keypair.go | 80 +
pkg/tls/parse.go | 48 +
pkg/util/cache/prometheus_status_counter.go | 63 +
pkg/util/cache/v3/cache.go | 59 +
pkg/util/channels/closed.go | 28 +
pkg/util/envoy/raw.go | 62 +
pkg/util/files/files.go | 48 +
pkg/util/files/lookup_binary.go | 79 +
pkg/util/files/project.go | 60 +
pkg/util/grpc/reverse_unary_rpcs.go | 132 +
pkg/util/http/client.go | 48 +
pkg/util/http/client_test.go | 131 +
pkg/util/http/http_suite_test.go | 30 +
pkg/util/http/tls.go | 62 +
pkg/util/k8s/name_converter.go | 44 +
pkg/util/maps/maps_suite_test.go | 30 +
pkg/util/maps/sorted_keys.go | 30 +
pkg/util/maps/sorted_keys_test.go | 28 +
pkg/util/maps/sync.go | 81 +
pkg/util/net/ips.go | 81 +
pkg/util/net/ips_test.go | 47 +
pkg/util/net/net_suite_test.go | 30 +
pkg/util/net/tcpsock.go | 51 +
pkg/util/net/tcpsock_test.go | 215 +
pkg/util/os/fs.go | 45 +
pkg/util/os/limits.go | 71 +
pkg/util/os/limits_test.go | 41 +
pkg/util/os/limits_windows.go | 30 +
pkg/util/os/os_suite_test.go | 30 +
pkg/util/pointer/pointer.go | 39 +
pkg/util/prometheus/gorestful_middleware.go | 61 +
pkg/util/proto/any.go | 103 +
pkg/util/proto/any_test.go | 46 +
pkg/util/proto/google_proto.go | 180 +
pkg/util/proto/google_proto_test.go | 69 +
pkg/util/proto/proto.go | 124 +
pkg/util/proto/proto_suite_test.go | 30 +
pkg/util/proto/types.go | 108 +
pkg/util/protocol/protocol.go | 54 +
pkg/util/protocol/protocol_suite_test.go | 30 +
pkg/util/protocol/protocol_test.go | 131 +
pkg/util/rsa/keygen.go | 30 +
pkg/util/rsa/pem.go | 123 +
pkg/util/template/render.go | 56 +
pkg/util/watchdog/watchdog.go | 90 +
pkg/util/watchdog/watchdog_suite_test.go | 30 +
pkg/util/watchdog/watchdog_test.go | 167 +
pkg/util/xds/callbacks.go | 117 +
pkg/util/xds/logger.go | 52 +
pkg/util/xds/logging_callbacks.go | 94 +
pkg/util/xds/metric_sanitizer.go | 31 +
pkg/util/xds/noop_callbacks.go | 54 +
pkg/util/xds/stats_callbacks.go | 204 +
pkg/util/xds/v3/cache.go | 512 +++
pkg/util/xds/v3/callbacks.go | 245 +
pkg/util/xds/v3/callbacks_chain.go | 125 +
pkg/util/xds/v3/callbacks_chain_test.go | 228 +
pkg/util/xds/v3/control_plane_id_callbacks.go | 58 +
pkg/util/xds/v3/noop_callbacks.go | 67 +
pkg/util/xds/v3/versioner.go | 69 +
pkg/util/xds/v3/watchdog_callbacks.go | 197 +
pkg/util/xds/v3/xds_suite_test.go | 30 +
pkg/util/yaml/split.go | 41 +
pkg/version/compatibility.go | 80 +
pkg/version/version.go | 108 +
pkg/webhook/patch/dubbosdk.go | 332 --
pkg/webhook/patch/dubbosdk_test.go | 1073 -----
pkg/webhook/server/server.go | 75 -
pkg/webhook/setup.go | 51 -
pkg/webhook/webhook/server.go | 240 -
pkg/webhook/webhook/server_test.go | 395 --
pkg/xds/bootstrap/components.go | 50 +
pkg/xds/bootstrap/generator.go | 333 ++
pkg/xds/bootstrap/handler.go | 158 +
pkg/xds/bootstrap/parameters.go | 72 +
pkg/xds/bootstrap/templatae_v3.go | 541 +++
pkg/xds/bootstrap/types/bootstrap_request.go | 70 +
pkg/xds/bootstrap/types/bootstrap_response.go | 56 +
pkg/xds/cache/cla/cache.go | 81 +
pkg/xds/cache/mesh/cache.go | 95 +
pkg/xds/cache/once/cache.go | 82 +
pkg/xds/cache/once/once.go | 63 +
pkg/xds/cache/sha256/hash.go | 29 +
pkg/xds/components.go | 42 +
pkg/xds/context/context.go | 78 +
pkg/xds/context/mesh_context_builder.go | 207 +
pkg/xds/context/resources.go | 74 +
pkg/xds/envoy/api_version.go | 26 +
pkg/xds/envoy/clusters/cluster_builder.go | 104 +
pkg/xds/envoy/clusters/configurers.go | 115 +
.../envoy/clusters/v3/alt_stat_name_configurer.go | 38 +
pkg/xds/envoy/clusters/v3/configurer.go | 41 +
.../envoy/clusters/v3/eds_cluster_configurer.go | 40 +
.../clusters/v3/endpoint_cluster_configurer.go | 74 +
pkg/xds/envoy/clusters/v3/http2_configurer.go | 63 +
pkg/xds/envoy/clusters/v3/http_configurer.go | 42 +
pkg/xds/envoy/clusters/v3/lb_subset_configurer.go | 51 +
.../clusters/v3/pass_through_cluster_configurer.go | 32 +
.../v3/update_common_http_protocol_options.go | 50 +
.../clusters/v3/upstream_bind_config_configurer.go | 42 +
pkg/xds/envoy/endpoints/endpoints.go | 41 +
pkg/xds/envoy/endpoints/v3/endpoints.go | 151 +
pkg/xds/envoy/imports.go | 374 ++
pkg/xds/envoy/listeners/filter_chain_builder.go | 138 +
.../envoy/listeners/filter_chain_configurers.go | 214 +
.../listeners/filter_chain_match_configurers.go | 93 +
pkg/xds/envoy/listeners/listener_builder.go | 152 +
pkg/xds/envoy/listeners/listener_configurers.go | 110 +
.../listeners/v3/additional_address_configurer.go | 61 +
pkg/xds/envoy/listeners/v3/configurer.go | 113 +
.../listeners/v3/direct_response_configurer.go | 106 +
.../listeners/v3/filter_chain_match_configurer.go | 41 +
.../envoy/listeners/v3/grpc_stats_configurer.go | 52 +
.../v3/http_connection_manager_configurer.go | 67 +
.../listeners/v3/http_inbound_routes_cofigurer.go | 51 +
.../listeners/v3/http_outbound_route_configurer.go | 51 +
.../envoy/listeners/v3/http_route_configurer.go | 91 +
.../envoy/listeners/v3/http_router_configuer.go | 52 +
.../listeners/v3/inbound_listener_configurer.go | 53 +
pkg/xds/envoy/listeners/v3/kafka_configurer.go | 54 +
.../v3/original_dsst_forwarder_configurer.go | 35 +
.../listeners/v3/outbound_listener_configurer.go | 51 +
.../envoy/listeners/v3/pipe_listener_configurer.go | 39 +
.../listeners/v3/static_endpoints_configurer.go | 104 +
pkg/xds/envoy/listeners/v3/tags_metadata.go | 47 +
pkg/xds/envoy/listeners/v3/tcp_proxy_configurer.go | 91 +
.../envoy/listeners/v3/tls_inspector_configurer.go | 45 +
.../v3/transparent_proxying_configurer.go | 33 +
pkg/xds/envoy/listeners/v3/triple_configurer.go | 51 +
pkg/xds/envoy/listeners/v3/util.go | 160 +
pkg/xds/envoy/metadata/v3/metadata.go | 95 +
pkg/xds/envoy/names/resource_names.go | 129 +
pkg/xds/envoy/route.go | 62 +
.../common_route_configuration_configurer.go | 33 +
pkg/xds/envoy/routes/route_builder.go | 87 +
.../envoy/routes/route_configuration_builder.go | 102 +
.../routes/route_configuration_configurers.go | 67 +
pkg/xds/envoy/routes/route_configurers.go | 408 ++
.../v3/common_route_configuration_configurer.go | 33 +
pkg/xds/envoy/routes/v3/ratelimit.go | 104 +
.../routes/v3/reset_tags_header_configurer.go | 33 +
.../routes/v3/route_configuration_configurer.go | 53 +
pkg/xds/envoy/routes/v3/tags_header_configurer.go | 42 +
pkg/xds/envoy/sockets.go | 40 +
pkg/xds/envoy/tags/match.go | 285 ++
pkg/xds/envoy/tags/serialize.go | 35 +
pkg/xds/envoy/types.go | 245 +
pkg/xds/envoy/virtualhosts/builder.go | 136 +
pkg/xds/envoy/virtualhosts/configurer.go | 92 +
pkg/xds/envoy/virtualhosts/redirect_configurer.go | 66 +
pkg/xds/envoy/virtualhosts/route_configurer.go | 79 +
pkg/xds/envoy/virtualhosts/routes_configurer.go | 34 +
pkg/xds/generator/consts.go | 29 +
pkg/xds/generator/core/resource_generator.go | 48 +
pkg/xds/generator/inbound_proxy_generator.go | 143 +
pkg/xds/generator/ingress_proxy_generator.go | 39 +
pkg/xds/generator/outbound_proxy_generator.go | 352 ++
pkg/xds/generator/proxy_template.go | 76 +
pkg/xds/runtime/context.go | 39 +
pkg/xds/server/callbacks/dataplane_callbacks.go | 178 +
pkg/xds/server/callbacks/dataplane_lifecycle.go | 273 ++
.../server/callbacks/dataplane_metadata_tracker.go | 69 +
pkg/xds/server/callbacks/dataplane_status_sink.go | 183 +
.../server/callbacks/dataplane_status_tracker.go | 292 ++
pkg/xds/server/callbacks/dataplane_sync_tracker.go | 83 +
pkg/xds/server/callbacks/nack_backoff.go | 59 +
pkg/xds/server/components.go | 71 +
pkg/xds/server/v3/components.go | 126 +
pkg/xds/server/v3/context.go | 83 +
pkg/xds/server/v3/reconcile.go | 230 +
pkg/xds/server/v3/resource_warming_forcer.go | 157 +
pkg/xds/sync/componenets.go | 83 +
pkg/xds/sync/dataplane_proxy_builder.go | 98 +
pkg/xds/sync/dataplane_watchdog.go | 167 +
pkg/xds/sync/dataplane_watchdoy_factory.go | 72 +
pkg/xds/sync/ingress_proxy_builder.go | 45 +
pkg/xds/sync/interfaces.go | 48 +
pkg/xds/topology/dataplane.go | 89 +
pkg/xds/topology/outbound.go | 124 +
test/cert/tls.crt | 18 +
test/cert/tls.key | 27 +
test/failer.go | 115 -
test/failer_test.go | 47 -
test/manager/condition_route.go | 18 +
test/manager/dataplane.go | 18 +
test/manager/dynamic_config.go | 18 +
test/manager/mapping.go | 18 +
test/manager/metadata.go | 18 +
test/manager/tag_route.go | 18 +
test/testclient/ddsc.go | 411 --
test/testclient/test.yml | 63 -
test/util/retry/retry.go | 182 -
test/util/retry/retry_test.go | 53 -
tools/README.md | 84 -
tools/code-generator-gen/main.go | 97 -
tools/code-generator-gen/register.go.tmpl | 54 -
tools/code-generator-gen/typesgen.go.tmpl | 45 -
tools/common.sh | 30 +
tools/deepcopy-gen/generate.go | 70 -
tools/deepcopy-gen/template.go.tmpl | 56 -
tools/dev/install-dev-tools.sh | 42 +
tools/gen.sh | 36 -
tools/policy-gen/bootstrap/main.go | 5 +
tools/policy-gen/bootstrap/root.go | 207 +
tools/policy-gen/crd-extract-openapi.sh | 48 +
tools/policy-gen/generate-policy-helm.sh | 45 +
tools/policy-gen/generate-policy-import.sh | 21 +
tools/policy-gen/generator/cmd/core_resource.go | 184 +
tools/policy-gen/generator/cmd/k8s_resource.go | 193 +
tools/policy-gen/generator/cmd/openapi.go | 54 +
tools/policy-gen/generator/cmd/pluginfile.go | 95 +
tools/policy-gen/generator/cmd/root.go | 54 +
tools/policy-gen/generator/main.go | 9 +
.../policy-gen/generator/pkg/parse/policyconfig.go | 127 +
tools/policy-gen/generator/pkg/save/template.go | 31 +
tools/policy-gen/templates/endpoints.yaml | 122 +
tools/policy-gen/templates/schema.yaml | 14 +
tools/resource-gen/cmd/cmd.go | 80 -
tools/resource-gen/collections.go | 181 -
tools/resource-gen/collections_test.go | 161 -
tools/resource-gen/common.go | 103 -
tools/resource-gen/common_test.go | 130 -
tools/resource-gen/genutils/util.go | 141 +
tools/resource-gen/main.go | 432 ++
tools/resource-gen/metadata.yaml | 92 -
tools/tools.go | 12 +
tools/types-gen/main.go | 111 -
tools/types-gen/types.go.tmpl | 97 -
tools/xds-client/README.md | 21 +
tools/xds-client/main.go | 192 +
tools/xds-client/stream/client.go | 162 +
1552 files changed, 82521 insertions(+), 51476 deletions(-)
