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 44916210 Merge pull request #181 from sjmshsh/control-plane
add 28832148 增强
add fe577ec5 fix test
add 9c4aca2c fmt
new 68144314 Merge pull request #185 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/generic/insights.go | 5 +-
api/mesh/options.pb.go | 9 +-
api/mesh/v1alpha1/dataplane.pb.go | 15 +-
api/mesh/v1alpha1/dataplane_helper.go | 2 +
api/mesh/v1alpha1/dataplane_insight.pb.go | 15 +-
api/mesh/v1alpha1/dataplane_insight_helper.go | 12 +-
api/mesh/v1alpha1/envoy_admin.pb.go | 8 +-
api/mesh/v1alpha1/mesh.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 | 13 +-
api/mesh/v1alpha1/zone_ingress_insight.pb.go | 13 +-
api/mesh/v1alpha1/zone_ingress_insight_helpers.go | 5 +-
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/root.go | 4 +-
app/dubbo-cp/cmd/run.go | 12 +-
go.mod | 1 +
go.sum | 105 ++++
pkg/admin/bootstrap.go | 20 +-
pkg/admin/cache/interface_registry_cache.go | 4 +-
pkg/admin/cache/registry/extension.go | 3 +
pkg/admin/cache/registry/kube/cache.go | 18 +-
pkg/admin/cache/registry/kube/registry.go | 3 +
pkg/admin/cache/registry/universal/cache.go | 5 +
pkg/admin/cache/registry/universal/mapping.go | 7 +-
pkg/admin/cache/registry/universal/registry.go | 8 +-
.../service_instances_changed_listener_impl.go | 13 +-
pkg/admin/cache/selector/application_selector.go | 5 +-
pkg/admin/cache/selector/multi_selector.go | 7 +-
pkg/admin/cache/selector/service_selector.go | 5 +-
pkg/admin/config/config.go | 7 +-
pkg/admin/config/governance_config.go | 8 +-
.../config/mock_config/governance_config_mock.go | 3 +
pkg/admin/handlers/condition_route.go | 8 +-
pkg/admin/handlers/mock_rule.go | 8 +-
pkg/admin/handlers/overrides.go | 8 +-
pkg/admin/handlers/service.go | 20 +-
pkg/admin/handlers/tag_route.go | 8 +-
pkg/admin/handlers/traffic/accesslog.go | 8 +-
pkg/admin/handlers/traffic/argument.go | 8 +-
pkg/admin/handlers/traffic/gray.go | 8 +-
pkg/admin/handlers/traffic/mock.go | 8 +-
pkg/admin/handlers/traffic/region.go | 8 +-
pkg/admin/handlers/traffic/retry.go | 8 +-
pkg/admin/handlers/traffic/timeout.go | 8 +-
pkg/admin/handlers/traffic/weight.go | 8 +-
pkg/admin/imports/imports.go | 7 +-
pkg/admin/mapper/mock_rule_mapper.go | 2 +
pkg/admin/mapper/mock_rule_mapper_mock.go | 7 +-
pkg/admin/model/consumer.go | 5 +
pkg/admin/model/dynamic_config.go | 4 +-
pkg/admin/model/match.go | 5 +
pkg/admin/model/override.go | 2 +
pkg/admin/model/provider.go | 4 +
pkg/admin/model/traffic.go | 2 +
pkg/admin/model/util/override_utils.go | 6 +-
pkg/admin/model/util/override_utils_test.go | 5 +
pkg/admin/model/util/sync_utils.go | 5 +
pkg/admin/model/util/sync_utils_test.go | 8 +-
pkg/admin/monitor/prometheus/metrics.go | 9 +-
pkg/admin/monitor/prometheus/types.go | 4 +-
pkg/admin/providers/mock/api/mock.pb.go | 8 +-
pkg/admin/providers/mock/api/mock_triple.pb.go | 5 +
pkg/admin/providers/mock/mock_provider.go | 12 +-
pkg/admin/router/router.go | 10 +-
pkg/admin/services/consumer_service.go | 4 +-
pkg/admin/services/generic_service_Impl.go | 11 +-
pkg/admin/services/mock_rule_service.go | 2 +
pkg/admin/services/mock_rule_service_impl.go | 7 +-
pkg/admin/services/mock_rule_service_impl_test.go | 8 +-
pkg/admin/services/monitor_service.go | 2 +
pkg/admin/services/override_service.go | 4 +-
pkg/admin/services/override_service_impl.go | 7 +-
pkg/admin/services/override_service_impl_test.go | 8 +-
pkg/admin/services/prometheus_service_impl.go | 7 +-
pkg/admin/services/prometheus_service_impl_test.go | 9 +-
pkg/admin/services/provider_service.go | 5 +-
pkg/admin/services/provider_service_impl.go | 7 +-
pkg/admin/services/provider_service_impl_test.go | 15 +-
pkg/admin/services/route_service.go | 4 +-
pkg/admin/services/route_service_impl.go | 5 +-
pkg/admin/services/route_service_impl_test.go | 8 +-
pkg/admin/services/service_testing_v3.go | 5 +
pkg/admin/services/traffic/accesslog.go | 7 +-
pkg/admin/services/traffic/argument.go | 7 +-
.../services/traffic/generic_rule_operation.go | 10 +-
pkg/admin/services/traffic/gray.go | 5 +-
pkg/admin/services/traffic/mock.go | 2 +
pkg/admin/services/traffic/region.go | 7 +-
pkg/admin/services/traffic/retry.go | 5 +-
pkg/admin/services/traffic/timeout.go | 5 +-
pkg/admin/services/traffic/timeout_test.go | 12 +-
pkg/admin/services/traffic/weight.go | 7 +-
pkg/admin/setup.go | 5 +-
pkg/admin/util/base_service_metadata.go | 2 +
pkg/admin/util/monitor_utils.go | 2 +
pkg/admin/util/monitor_utils_test.go | 2 +
pkg/admin/util/yaml_parser.go | 4 +-
pkg/bufman/bootstrap.go | 9 +-
.../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 | 5 +-
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 +-
pkg/bufman/gen/data/datawkt/datawkt.gen.go | 308 ++++++++++-
.../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 | 8 +-
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 | 7 +-
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 | 9 +-
pkg/bufman/router/http_router.go | 7 +-
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 | 5 +-
pkg/config/admin/address_config.go | 2 +
pkg/config/admin/config.go | 5 +-
pkg/config/app/dubbo-cp/config.go | 20 +-
pkg/config/dp-server/config.go | 7 +-
pkg/config/intercp/config.go | 6 +
pkg/config/multizone/multicluster.go | 10 +-
pkg/config/plugins/runtime/config.go | 2 +-
pkg/config/plugins/runtime/universal/config.go | 13 +-
pkg/config/xds/bootstrap/config.go | 17 +-
pkg/config/xds/config.go | 10 +-
pkg/core/bootstrap/bootstrap.go | 14 +-
pkg/core/cmd/version/version.go | 5 +-
pkg/core/datasource/dynamic.go | 11 +-
pkg/core/datasource/loader.go | 3 +
pkg/core/datasource/static.go | 8 +-
pkg/core/dns/lookup/cache.go | 5 +-
pkg/core/dns/lookup/interface.go | 4 +-
pkg/core/kubeclient/client/kube.go | 14 +-
pkg/core/monitor/prometheus/metrics.go | 9 +-
pkg/core/monitor/prometheus/types.go | 4 +-
pkg/core/plugins/interfaces.go | 2 +-
pkg/core/resources/apis/mesh/dataplane_helpers.go | 5 +-
.../resources/apis/mesh/dataplane_validator.go | 212 ++++++++
pkg/core/resources/apis/mesh/validators.go | 341 +++++++++++++
.../resources/apis/mesh/zz_generated.resources.go | 2 +
.../apis/system/zz_generated.resources.go | 2 +
pkg/core/runtime/builder.go | 8 +-
pkg/core/runtime/runtime.go | 2 +-
pkg/core/xds/metadata.go | 11 +-
pkg/core/xds/resource.go | 7 +-
pkg/core/xds/types.go | 10 +-
pkg/defaults/components.go | 18 +-
pkg/defaults/mesh.go | 3 +
pkg/defaults/zone.go | 16 +-
pkg/gc/collector.go | 5 +-
pkg/gc/components.go | 5 +-
pkg/hds/cache/snapshot.go | 6 +-
pkg/hds/callbacks/chain.go | 3 +
pkg/hds/callbacks/interface.go | 3 +
pkg/hds/components.go | 10 +-
pkg/hds/server/server.go | 21 +-
pkg/hds/tracker/callbacks.go | 21 +-
pkg/hds/tracker/healthcheck_generator.go | 17 +-
pkg/hds/tracker/reconciler.go | 8 +-
pkg/intercp/catalog/catalog.go | 5 +-
pkg/intercp/catalog/config_catalog.go | 5 +-
pkg/intercp/catalog/heartbeat_component.go | 10 +-
pkg/intercp/catalog/heartbeats.go | 4 +-
pkg/intercp/catalog/server.go | 3 +
pkg/intercp/catalog/writer.go | 5 +-
pkg/intercp/client/client.go | 3 +
pkg/intercp/client/pool.go | 12 +-
pkg/intercp/server/server.go | 16 +-
pkg/plugins/bootstrap/k8s/plugin.go | 2 +-
pkg/plugins/policies/core/defaults/consts.go | 4 +-
pkg/plugins/policies/core/rules/rules.go | 3 +
pkg/plugins/policies/core/xds/cluster.go | 3 +
pkg/plugins/policies/core/xds/clusters.go | 7 +-
pkg/plugins/policies/core/xds/endpoints.go | 9 +-
pkg/plugins/policies/core/xds/http_filters.go | 1 +
pkg/plugins/policies/core/xds/listeners.go | 7 +-
pkg/plugins/policies/core/xds/split.go | 4 +-
.../api/v1alpha1/servicenamemapping.go | 2 +-
.../api/v1alpha1/zz_generated.deepcopy.go | 2 -
.../api/v1alpha1/zz_generated.resource.go | 5 +
.../k8s/v1alpha1/groupversion_info.go | 1 +
.../k8s/v1alpha1/zz_generated.deepcopy.go | 5 +-
.../k8s/v1alpha1/zz_generated.types.go | 4 +
.../native/api/v1alpha1/zz_generated.deepcopy.go | 1 +
.../k8s/native/api/v1alpha1/zz_generated.mesh.go | 5 +
.../k8s/native/api/v1alpha1/zz_generated.system.go | 5 +
pkg/plugins/resources/k8s/store.go | 3 +-
pkg/plugins/runtime/k8s/plugin.go | 1 +
.../dubbo/dubbo_test.go => pkg/test/api_types.go | 19 +-
pkg/{util/os/limits_windows.go => test/clock.go} | 26 +-
.../native/api/v1alpha1/spec.go => test/const.go} | 20 +-
pkg/test/ginkgo.go | 103 ++++
pkg/test/grpc/clientstream.go | 124 +++++
pkg/test/grpc/serverstream.go | 156 ++++++
pkg/test/matchers/golden.go | 127 +++++
.../test/matchers/golden/update_files.go | 24 +-
pkg/test/matchers/keys.go | 127 +++++
app/dubboctl/main.go => pkg/test/matchers/port.go | 13 +-
pkg/test/matchers/proto.go | 75 +++
.../dubbo/dubbo_test.go => pkg/test/network.go | 21 +-
pkg/test/resources/builders/dataplane_builder.go | 279 ++++++++++
pkg/test/resources/model/resource.go | 96 ++++
.../resources/registry.go} | 12 +-
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 | 178 +++++++
.../model/resources.go => test/store/failing.go} | 48 +-
pkg/test/store/load.go | 70 +++
pkg/test/store/store_test_template.go | 567 +++++++++++++++++++++
.../bootstrap/autoconfig.go => test/within.go} | 34 +-
pkg/tls/cert.go | 2 +
pkg/tls/keypair.go | 2 +
pkg/util/protocol/protocol.go | 4 +-
pkg/xds/context/context.go | 3 +
pkg/xds/context/mesh_context_builder.go | 14 +-
pkg/xds/context/resources.go | 5 +-
pkg/xds/envoy/clusters/cluster_builder.go | 8 +-
pkg/xds/envoy/clusters/configurers.go | 9 +-
.../envoy/clusters/v3/alt_stat_name_configurer.go | 2 +
.../clusters/v3/endpoint_cluster_configurer.go | 13 +-
pkg/xds/envoy/clusters/v3/http2_configurer.go | 5 +-
pkg/xds/envoy/clusters/v3/lb_subset_configurer.go | 5 +-
.../clusters/v3/pass_through_cluster_configurer.go | 4 +-
.../v3/update_common_http_protocol_options.go | 6 +-
pkg/xds/envoy/endpoints/endpoints.go | 4 +
pkg/xds/envoy/endpoints/v3/endpoints.go | 5 +
pkg/xds/envoy/listeners/filter_chain_builder.go | 11 +-
.../envoy/listeners/filter_chain_configurers.go | 12 +-
.../listeners/filter_chain_match_configurers.go | 7 +-
pkg/xds/envoy/listeners/listener_builder.go | 8 +-
pkg/xds/envoy/listeners/listener_configurers.go | 8 +-
.../listeners/v3/additional_address_configurer.go | 5 +-
.../listeners/v3/direct_response_configurer.go | 10 +-
.../listeners/v3/filter_chain_match_configurer.go | 4 +-
.../envoy/listeners/v3/grpc_stats_configurer.go | 6 +-
.../v3/http_connection_manager_configurer.go | 7 +-
.../listeners/v3/http_inbound_routes_cofigurer.go | 5 +-
.../listeners/v3/http_outbound_route_configurer.go | 5 +-
.../envoy/listeners/v3/http_route_configurer.go | 6 +-
.../envoy/listeners/v3/http_router_configuer.go | 5 +-
.../listeners/v3/inbound_listener_configurer.go | 7 +-
pkg/xds/envoy/listeners/v3/kafka_configurer.go | 4 +-
.../v3/original_dsst_forwarder_configurer.go | 5 +-
.../listeners/v3/outbound_listener_configurer.go | 5 +-
.../listeners/v3/static_endpoints_configurer.go | 9 +-
pkg/xds/envoy/listeners/v3/tags_metadata.go | 6 +-
pkg/xds/envoy/listeners/v3/tcp_proxy_configurer.go | 7 +-
.../envoy/listeners/v3/tls_inspector_configurer.go | 5 +-
.../v3/transparent_proxying_configurer.go | 5 +-
pkg/xds/envoy/listeners/v3/util.go | 10 +-
pkg/xds/envoy/metadata/v3/metadata.go | 5 +-
pkg/xds/envoy/names/resource_names.go | 2 +
.../common_route_configuration_configurer.go | 5 +-
pkg/xds/envoy/routes/route_builder.go | 8 +-
.../envoy/routes/route_configuration_builder.go | 8 +-
.../routes/route_configuration_configurers.go | 5 +-
pkg/xds/envoy/routes/route_configurers.go | 16 +-
.../v3/common_route_configuration_configurer.go | 5 +-
pkg/xds/envoy/routes/v3/ratelimit.go | 11 +-
.../routes/v3/reset_tags_header_configurer.go | 5 +-
.../routes/v3/route_configuration_configurer.go | 4 +-
pkg/xds/envoy/routes/v3/tags_header_configurer.go | 7 +-
pkg/xds/envoy/tags/match.go | 12 +-
pkg/xds/envoy/tags/serialize.go | 5 +-
pkg/xds/envoy/types.go | 14 +-
pkg/xds/envoy/virtualhosts/builder.go | 8 +-
pkg/xds/envoy/virtualhosts/configurer.go | 5 +-
pkg/xds/envoy/virtualhosts/route_configurer.go | 5 +-
pkg/xds/envoy/virtualhosts/routes_configurer.go | 5 +-
pkg/xds/generator/inbound_proxy_generator.go | 9 +-
pkg/xds/generator/ingress_proxy_generator.go | 3 +
pkg/xds/generator/outbound_proxy_generator.go | 3 +
pkg/xds/generator/proxy_template.go | 3 +
pkg/xds/server/callbacks/dataplane_callbacks.go | 12 +-
pkg/xds/server/callbacks/dataplane_lifecycle.go | 15 +-
pkg/xds/server/callbacks/dataplane_status_sink.go | 13 +-
.../server/callbacks/dataplane_status_tracker.go | 14 +-
pkg/xds/server/components.go | 6 +-
pkg/xds/server/v3/components.go | 6 +-
pkg/xds/server/v3/reconcile.go | 19 +-
pkg/xds/server/v3/resource_warming_forcer.go | 15 +-
pkg/xds/sync/dataplane_proxy_builder.go | 11 +-
pkg/xds/topology/dataplane.go | 13 +-
tools/xds-client/main.go | 26 +-
tools/xds-client/stream/client.go | 15 +-
802 files changed, 7406 insertions(+), 1165 deletions(-)
create mode 100644 pkg/core/resources/apis/mesh/dataplane_validator.go
create mode 100644 pkg/core/resources/apis/mesh/validators.go
copy app/dubboctl/internal/dubbo/dubbo_test.go => pkg/test/api_types.go (79%)
copy pkg/{util/os/limits_windows.go => test/clock.go} (72%)
copy pkg/{plugins/resources/k8s/native/api/v1alpha1/spec.go => test/const.go}
(65%)
create mode 100644 pkg/test/ginkgo.go
create mode 100644 pkg/test/grpc/clientstream.go
create mode 100644 pkg/test/grpc/serverstream.go
create mode 100644 pkg/test/matchers/golden.go
copy app/dubbo-ui/fs.go => pkg/test/matchers/golden/update_files.go (66%)
create mode 100644 pkg/test/matchers/keys.go
copy app/dubboctl/main.go => pkg/test/matchers/port.go (77%)
create mode 100644 pkg/test/matchers/proto.go
copy app/dubboctl/internal/dubbo/dubbo_test.go => pkg/test/network.go (71%)
create mode 100644 pkg/test/resources/builders/dataplane_builder.go
create mode 100644 pkg/test/resources/model/resource.go
copy pkg/{util/os/limits_windows.go => test/resources/registry.go} (84%)
create mode 100644 pkg/test/resources/samples/dataplane_samples.go
create mode 100644 pkg/test/resources/validation.go
create mode 100644 pkg/test/resources/validation/validation.go
create mode 100644 pkg/test/runtime/runtime.go
copy pkg/{plugins/resources/k8s/native/pkg/model/resources.go =>
test/store/failing.go} (53%)
create mode 100644 pkg/test/store/load.go
create mode 100644 pkg/test/store/store_test_template.go
copy pkg/{core/bootstrap/autoconfig.go => test/within.go} (59%)
