This is an automated email from the ASF dual-hosted git repository. liujun pushed a commit to branch control-plane in repository https://gitbox.apache.org/repos/asf/dubbo-kubernetes.git
commit 68144314a666b50eb8211cce8a6371b8e34ab659 Merge: 44916210 9c4aca2c Author: Ken Liu <[email protected]> AuthorDate: Tue Jan 30 14:04:53 2024 +0800 Merge pull request #185 from sjmshsh/control-plane Tests for new control plane implementation 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 + .../datasource/loader.go => test/api_types.go} | 18 +- pkg/{core/datasource/loader.go => test/clock.go} | 27 +- .../routes_configurer.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 +++++ .../matchers/golden/update_files.go} | 25 +- pkg/test/matchers/keys.go | 127 +++++ .../datasource/loader.go => test/matchers/port.go} | 16 +- pkg/test/matchers/proto.go | 75 +++ pkg/{admin/util/yaml_parser.go => test/network.go} | 27 +- pkg/test/resources/builders/dataplane_builder.go | 279 ++++++++++ pkg/test/resources/model/resource.go | 96 ++++ .../resources/registry.go} | 10 +- 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 +++++++ pkg/test/store/failing.go | 53 ++ pkg/test/store/load.go | 70 +++ pkg/test/store/store_test_template.go | 567 +++++++++++++++++++++ .../alt_stat_name_configurer.go => test/within.go} | 31 +- 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, 7460 insertions(+), 1121 deletions(-)
