This is an automated email from the ASF dual-hosted git repository.
littlecui pushed a change to branch test
in repository
https://gitbox.apache.org/repos/asf/servicecomb-service-center.git.
omit be88acd SCB-2094 Bug fixes
omit 34f4bc8 SCB-2094 Bug fixes
omit ff8f40f SCB-2094 Bug fixes
add d198992 SCB-2094 Bug fixes (#764)
add 094deff Incremental synchronization of sc: sync between sc and syncer
(#755)
add 915ecf5 how to raise pr (#767)
add 563f03c refactor the role module of rbac (#736)
add fc5ec76 Incremental synchronization of sc: sync between sc syncers
(#757)
add e37a1b1 add goimports check (#769)
add 4376fc5 [SCD-2133] governance northbound Interface / abstract access
layer (#766)
add 0c9258e [SCB-2094] implement mongo instance/dependence/engine
interface (#759)
add 5a9691c static check and clear in the syncer folder (#770)
add 1a8351a [SCB-2094] Heartbeat interface optimization (#772)
add c1d8c70 SCB-2094 Decouple etcd/util and service pkg (#774)
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (be88acd)
\
N -- N -- N refs/heads/test (c1d8c70)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
.github/PULL_REQUEST_TEMPLATE.md | 3 +-
.github/workflows/golangci-lint.yml | 4 +-
.gitignore | 2 +
client/apis.go | 1 +
client/client_lb.go | 3 +-
client/client_lb_test.go | 3 +-
client/config.go | 3 +-
client/instance.go | 3 +-
client/websocket.go | 3 +-
cmd/scserver/main.go | 6 +-
cmd/syncer/conf/chassis.yaml | 8 +
cmd/syncer/conf/microservice.yaml | 3 +
cmd/syncer/syncer.go | 1 +
datasource/account.go | 1 +
datasource/datasource.go | 1 +
datasource/dep.go | 1 +
datasource/dependency_util.go | 47 +
.../dependency_util_test.go | 13 +-
datasource/engine.go | 3 +-
datasource/etcd/account.go | 13 +-
datasource/etcd/account_test.go | 7 +-
datasource/etcd/bootstrap/bootstrap.go | 33 +-
datasource/etcd/cache/common.go | 3 +-
datasource/etcd/cache/dependency.go | 3 +-
datasource/etcd/cache/filter_consistency.go | 1 +
datasource/etcd/cache/filter_consumer.go | 1 +
datasource/etcd/cache/filter_instances.go | 1 +
datasource/etcd/cache/filter_permission.go | 1 +
datasource/etcd/cache/filter_service.go | 1 +
datasource/etcd/cache/filter_tags.go | 5 +-
datasource/etcd/cache/filter_version.go | 1 +
datasource/etcd/cache/instance.go | 5 +-
datasource/etcd/client/buildin/buildin.go | 1 +
datasource/etcd/client/client.go | 1 +
datasource/etcd/client/client_test.go | 3 +-
datasource/etcd/client/config.go | 3 +-
datasource/etcd/client/embedded/embededetcd.go | 7 +-
datasource/etcd/client/lease_task.go | 3 +-
datasource/etcd/client/lease_task_test.go | 3 +-
datasource/etcd/client/manager.go | 3 +-
datasource/etcd/client/metrics.go | 3 +-
datasource/etcd/client/remote/etcd.go | 6 +-
datasource/etcd/client/remote/etcd_test.go | 13 +-
datasource/etcd/client/remote/logger.go | 3 +-
datasource/etcd/client/remote/tracing.go | 3 +-
datasource/etcd/client/types.go | 3 +-
datasource/etcd/config.go | 5 +-
datasource/etcd/dep.go | 1 +
datasource/etcd/dep_test.go | 3 +-
datasource/etcd/engine.go | 7 +-
datasource/etcd/engine_test.go | 3 +-
datasource/etcd/etcd.go | 9 +-
datasource/etcd/etcd_suite_test.go | 9 +-
datasource/etcd/event/dependency_event_handler.go | 5 +-
.../event/dependency_rule_event_handler_test.go | 3 +-
datasource/etcd/event/instance_event_handler.go | 47 +-
datasource/etcd/event/rule_event_handler.go | 1 +
.../etcd/event/schema_summary_event_handler.go | 3 +-
datasource/etcd/event/service_event_handler.go | 3 +-
datasource/etcd/event/tag_event_handler.go | 1 +
datasource/etcd/job/job.go | 3 +-
datasource/etcd/kv/instance_event_handler.go | 5 +-
datasource/etcd/kv/instance_event_handler_test.go | 5 +-
datasource/etcd/kv/kv.go | 3 +-
datasource/etcd/kv/kv_test.go | 3 +-
datasource/etcd/kv/types.go | 3 +-
datasource/etcd/ms.go | 7 +-
datasource/etcd/ms_test.go | 9 +-
datasource/etcd/mux/mux.go | 3 +-
datasource/etcd/path/key_convertor.go | 3 +-
datasource/etcd/path/key_convertor_test.go | 3 +-
datasource/etcd/path/key_generator.go | 10 +-
datasource/etcd/path/key_generator_test.go | 7 +-
datasource/etcd/role.go | 134 +++
datasource/etcd/role_test.go | 88 ++
datasource/etcd/sd/aggregate/common.go | 3 +-
datasource/etcd/sd/aggregate/conflict_checker.go | 3 +-
datasource/etcd/sd/cache_kv.go | 3 +-
datasource/etcd/sd/cacher_test.go | 3 +-
datasource/etcd/sd/config.go | 3 +-
datasource/etcd/sd/config_test.go | 3 +-
datasource/etcd/sd/etcd/adaptor_test.go | 7 +-
datasource/etcd/sd/etcd/cacher_kv.go | 5 +-
datasource/etcd/sd/etcd/cacher_kv_test.go | 7 +-
datasource/etcd/sd/etcd/common.go | 3 +-
datasource/etcd/sd/etcd/indexer_cache.go | 1 +
datasource/etcd/sd/etcd/indexer_etcd.go | 3 +-
datasource/etcd/sd/etcd/indexer_test.go | 3 +-
datasource/etcd/sd/etcd/listwatch.go | 3 +-
datasource/etcd/sd/etcd/listwatch_inner.go | 1 +
datasource/etcd/sd/etcd/listwatch_test.go | 5 +-
datasource/etcd/sd/etcd/metrics_test.go | 3 +-
datasource/etcd/sd/etcd/watcher_inner.go | 3 +-
datasource/etcd/sd/etcd/watcher_test.go | 3 +-
datasource/etcd/sd/event_proxy.go | 3 +-
datasource/etcd/sd/indexer_test.go | 3 +-
datasource/etcd/sd/k8s/adaptor/cacher_index.go | 2 +-
datasource/etcd/sd/k8s/adaptor/cacher_instance.go | 7 +-
datasource/etcd/sd/k8s/adaptor/cacher_service.go | 2 +-
datasource/etcd/sd/k8s/adaptor/common.go | 7 +-
datasource/etcd/sd/k8s/adaptor/convertor.go | 9 +-
datasource/etcd/sd/k8s/adaptor/kube_client.go | 9 +-
datasource/etcd/sd/k8s/adaptor/listwatcher.go | 3 +-
datasource/etcd/sd/manager.go | 1 +
datasource/etcd/sd/manager_test.go | 5 +-
datasource/etcd/sd/metrics.go | 3 +-
datasource/etcd/sd/servicecenter/aggregate.go | 5 +-
datasource/etcd/sd/servicecenter/aggregate_test.go | 6 +-
datasource/etcd/sd/servicecenter/indexer.go | 3 +-
datasource/etcd/sd/servicecenter/syncer.go | 6 +-
datasource/etcd/sd/servicecenter/syncer_test.go | 3 +-
datasource/etcd/sd/types.go | 5 +-
datasource/etcd/system.go | 1 +
datasource/etcd/system_test.go | 3 +-
datasource/etcd/util.go | 7 +-
datasource/etcd/util/dependency.go | 1 +
datasource/etcd/util/dependency_query.go | 3 +-
datasource/etcd/util/dependency_test.go | 7 -
datasource/etcd/util/dependency_util.go | 3 +-
datasource/etcd/util/domain_util.go | 3 +-
datasource/etcd/util/domain_util_test.go | 3 +-
datasource/etcd/util/heartbeat_util.go | 1 +
datasource/etcd/util/heartbeat_util_test.go | 3 +-
datasource/etcd/util/instance_util.go | 60 +-
datasource/etcd/util/instance_util_test.go | 5 +-
datasource/etcd/util/microservice_util.go | 18 +-
datasource/etcd/util/rule_util.go | 3 +-
datasource/etcd/util/schema_util.go | 1 +
datasource/etcd/util/schema_util_test.go | 3 +-
datasource/etcd/util/tag_util.go | 1 +
datasource/etcd/util/tag_util_test.go | 3 +-
datasource/etcd/util/util.go | 1 +
datasource/etcd/util/util_suite_test.go | 15 +-
datasource/etcd/util/versionrule.go | 88 +-
datasource/etcd/util/versionrule_test.go | 75 --
datasource/etcd/value/parser.go | 1 +
datasource/etcd/value/parser_test.go | 3 +-
datasource/etcd/version.go | 3 +-
datasource/manager.go | 1 +
datasource/manager_test.go | 10 +-
datasource/mongo/account.go | 14 +-
datasource/mongo/account_test.go | 17 +-
datasource/mongo/bootstrap/bootstrap.go | 8 +-
datasource/mongo/client/common.go | 1 +
datasource/mongo/client/mongo.go | 15 +-
datasource/mongo/client/mongo_test.go | 3 +-
datasource/mongo/common.go | 34 +
datasource/mongo/database.go | 64 +-
datasource/mongo/dep.go | 341 ++++++-
datasource/mongo/dep_test.go | 351 +++++++
datasource/mongo/engine.go | 216 +++-
.../mongo/heartbeat/{healthcheck.go => common.go} | 16 +-
datasource/mongo/heartbeat/healthcheck.go | 1 +
.../mongo/heartbeat/heartbeatchecker/heartbeat.go | 13 +-
.../heartbeat/heartbeatchecker/heartbeat_test.go | 23 +-
.../heartbeat/heartbeatchecker/heartbeatchecker.go | 10 +-
.../heartbeatchecker/heartbeatchecker_test.go | 12 +-
datasource/mongo/heartbeat/manager.go | 5 +-
datasource/mongo/mongo.go | 4 +-
datasource/mongo/mongo_suite_test.go | 9 +-
datasource/mongo/ms.go | 1030 ++++++++++++++++++--
datasource/mongo/ms_test.go | 635 +++++++++---
datasource/mongo/ops.go | 1 +
.../dao/role_dao.go => datasource/mongo/role.go | 34 +-
datasource/mongo/system.go | 1 +
datasource/mongo/{ops.go => util.go} | 17 +-
datasource/ms.go | 13 +-
datasource/{system.go => ms_util.go} | 23 +-
.../util/schema_util_test.go => ms_util_test.go} | 16 +-
.../rbac/dao/role_dao.go => datasource/role.go | 28 +-
datasource/system.go | 1 +
docs/openapi/v1-gov.yaml | 277 ++++++
docs/openapi/v4.yaml | 186 +++-
docs/user-guides/rbac.md | 105 +-
etc/conf/app.yaml | 10 +
examples/governance/limiter.json | 12 +-
examples/governance/loadbalancer.json | 7 -
examples/governance/marker.json | 13 +-
examples/governance/retry.json | 18 +
frontend/main.go | 3 +-
go.mod | 10 +-
go.sum | 48 +-
integration/admin_test.go | 5 +-
integration/governance_test.go | 9 +-
integration/health_test.go | 5 +-
integration/instances_test.go | 8 +-
integration/integrationtest_suite_test.go | 7 +-
integration/microservices_test.go | 5 +-
integration/rules_test.go | 9 +-
integration/schema_test.go | 7 +-
integration/tags_test.go | 9 +-
pkg/cache/cache.go | 3 +-
pkg/cache/tree.go | 3 +-
pkg/chain/callback.go | 1 +
pkg/chain/chain_test.go | 3 +-
pkg/chain/invocation.go | 1 +
pkg/dump/dump.go | 7 +
pkg/errors/text.go | 2 +
pkg/etcdsync/mutex.go | 7 +-
pkg/etcdsync/mutex_test.go | 6 +-
pkg/gopool/goroutines.go | 5 +-
pkg/gov/governance.go | 20 +-
pkg/gov/governance_test.go | 14 +-
pkg/grace/grace.go | 3 +-
pkg/metrics/calculator_test.go | 3 +-
pkg/metrics/gatherer.go | 7 +-
pkg/metrics/manager_test.go | 3 +-
pkg/metrics/metrics_test.go | 3 +-
pkg/notify/notice.go | 3 +-
pkg/notify/notification_service.go | 3 +-
pkg/notify/notification_test.go | 3 +-
pkg/notify/processor.go | 1 +
pkg/notify/subscriber.go | 1 +
pkg/plugin/loader.go | 3 +-
pkg/proto/service.go | 1 +
pkg/proto/service_ex.go | 1 +
pkg/queue/taskqueue.go | 1 +
pkg/queue/uniqueue.go | 1 +
pkg/rbacframe/account.go | 23 +-
pkg/rbacframe/api.go | 34 +-
pkg/rbacframe/api_test.go | 17 +-
pkg/rbacframe/resource_dao.go | 9 +
pkg/rbacframe/{error.go => role.go} | 22 +-
pkg/rest/client.go | 3 +-
pkg/signal/signal.go | 3 +-
pkg/task/executor.go | 1 +
pkg/task/service_async.go | 7 +-
pkg/tlsutil/tlsutil.go | 5 +-
pkg/util/context_grpc.go | 1 +
pkg/util/context_grpc_test.go | 3 +-
pkg/util/sys.go | 3 +-
pkg/util/uuid.go | 3 +-
pkg/validate/rule.go | 3 +-
pkg/validate/validator.go | 3 +-
pkg/validate/version_func.go | 106 ++
pkg/validate/version_func_test.go | 100 ++
scctl/bootstrap/bootstrap.go | 22 +-
scctl/etcd/client.go | 5 +-
scctl/pkg/cmd/cmd.go | 5 +-
scctl/pkg/cmd/help.go | 7 +-
scctl/pkg/model/types.go | 5 +-
scctl/pkg/plugin/diagnose/cmd.go | 3 +-
scctl/pkg/plugin/diagnose/compare_holder.go | 1 +
scctl/pkg/plugin/diagnose/compare_holder_test.go | 3 +-
scctl/pkg/plugin/diagnose/diagnose.go | 1 +
scctl/pkg/plugin/diagnose/diagnose_test.go | 3 +-
scctl/pkg/plugin/get/cluster/cluster_cmd.go | 1 +
scctl/pkg/plugin/get/instance/instance_cmd.go | 3 +-
scctl/pkg/plugin/get/instance/printer.go | 3 +-
scctl/pkg/plugin/get/schema/schema_cmd.go | 11 +-
scctl/pkg/plugin/get/schema/writer.go | 3 +-
scctl/pkg/plugin/get/service/service_cmd.go | 3 +-
scctl/pkg/plugin/health/cmd.go | 1 +
scctl/pkg/plugin/version/cmd.go | 1 +
scctl/pkg/progress-bar/progress-bar.go | 3 +-
scctl/pkg/writer/writer.go | 3 +-
scripts/ut.sh | 2 +-
server/alarm/common.go | 3 +
server/alarm/service.go | 3 +-
server/api.go | 7 +-
server/bootstrap/bootstrap.go | 67 +-
server/broker/broker_suite_test.go | 7 +-
server/broker/config.go | 3 +-
server/broker/controller.go | 3 +-
server/broker/controller_test.go | 3 +-
server/broker/service.go | 1 +
server/broker/service_test.go | 1 +
server/config/config.go | 5 +-
server/config/config_test.go | 9 +-
server/config/types.go | 2 +-
server/config/util.go | 5 +-
server/config/util_test.go | 7 +-
server/connection/grpc/stream.go | 3 +-
server/connection/grpc/stream_test.go | 5 +-
server/connection/ws/publisher.go | 3 +-
server/connection/ws/websocket.go | 3 +-
server/connection/ws/websocket_test.go | 12 +-
server/core/core.go | 3 +-
server/core/microservice.go | 3 +-
server/core/microservice_test.go | 3 +-
server/handler/accesslog/handler.go | 3 +-
server/handler/accesslog/handler_test.go | 2 +-
server/handler/auth/auth.go | 3 +-
server/handler/cache/cache.go | 3 +-
server/handler/context/context.go | 3 +-
server/handler/context/v3.go | 5 +-
server/handler/context/v4.go | 5 +-
server/handler/maxbody/maxbody.go | 3 +-
server/handler/metrics/metrics.go | 5 +-
server/handler/tracing/tracing.go | 5 +-
server/health/health.go | 1 +
server/health/health_test.go | 5 +-
server/interceptor/access/access.go | 3 +-
server/interceptor/cors/cors.go | 3 +-
server/interceptor/interceptors.go | 3 +-
server/metrics/connection.go | 3 +-
server/metrics/http.go | 9 +-
server/metrics/meta.go | 3 +-
server/metrics/sys.go | 5 +-
server/notify/instance_subscriber.go | 3 +-
server/plugin/auditlog/auditlog.go | 3 +-
server/plugin/auth/auth.go | 3 +-
server/plugin/auth/buildin/buidlin_test.go | 19 +-
server/plugin/auth/buildin/buildin.go | 23 +-
server/plugin/common.go | 3 +-
server/plugin/plugin.go | 3 +-
server/plugin/plugin_test.go | 5 +-
server/plugin/quota/buildin/buildin.go | 1 +
server/plugin/quota/buildin/common.go | 1 +
server/plugin/quota/buildin/common_test.go | 3 +-
server/plugin/quota/quota.go | 3 +-
server/plugin/quota/unlimit/unlimit.go | 1 +
server/plugin/security/tlsconf/buildin/buildin.go | 1 +
server/plugin/security/tlsconf/buildin/tlsconf.go | 9 +-
.../security/tlsconf/buildin/tlsconf_test.go | 3 +-
server/plugin/security/tlsconf/tlsconf.go | 1 +
server/plugin/tracing/pzipkin/buildin.go | 7 +-
server/plugin/tracing/pzipkin/buildin_test.go | 5 +-
server/plugin/tracing/pzipkin/common.go | 9 +-
server/plugin/tracing/pzipkin/common_test.go | 5 +-
server/plugin/tracing/pzipkin/file_collector.go | 7 +-
.../plugin/tracing/pzipkin/file_collector_test.go | 5 +-
server/plugin/tracing/pzipkin/span.go | 3 +-
server/plugin/tracing/pzipkin/span_test.go | 3 +-
server/plugin/tracing/tracing.go | 1 +
server/plugin/uuid/buildin/buildin.go | 1 +
server/plugin/uuid/context/context.go | 1 +
server/resource/register.go | 1 +
server/resource/v1/gov_resource.go | 88 +-
server/resource/v1/gov_resource_test.go | 18 +-
server/resource/v4/auth_resource.go | 7 +-
server/resource/v4/auth_resource_test.go | 238 -----
server/resource/v4/rbac_resource_test.go | 458 +++++++++
server/resource/v4/role_resource.go | 145 +++
server/rest/admin/controller_v4.go | 6 +-
server/rest/admin/service.go | 1 +
server/rest/admin/service_test.go | 5 +-
server/rest/controller/rest_util.go | 5 +-
server/rest/controller/v3/main_controller.go | 3 +-
server/rest/controller/v4/dependency_controller.go | 5 +-
server/rest/controller/v4/instance_controller.go | 7 +-
server/rest/controller/v4/instance_watcher.go | 3 +-
server/rest/controller/v4/main_controller.go | 5 +-
.../rest/controller/v4/microservice_controller.go | 5 +-
server/rest/controller/v4/query_rule_controller.go | 7 +-
server/rest/controller/v4/schema_controller.go | 7 +-
server/rest/controller/v4/tag_controller.go | 7 +-
server/rest/govern/controller_v4.go | 3 +-
server/rest/govern/govern_suite_test.go | 9 +-
server/rest/govern/service.go | 1 +
server/rest/govern/service_test.go | 7 +-
server/rest/pprof.go | 3 +-
server/rest/server.go | 3 +-
server/rest/server_mux.go | 3 +-
.../cors.go => rest/syncer/service/service.go} | 39 +-
.../syncer/service/service_test.go} | 56 +-
server/{broker/broker.go => rest/syncer/syncer.go} | 8 +-
.../syncer_controller.go} | 22 +-
server/server.go | 24 +-
server/service/dependency.go | 23 +-
server/service/dependency_test.go | 3 +-
server/service/dependency_validator.go | 6 +-
server/service/gov/config_distributor.go | 42 +-
server/service/gov/config_distributor_test.go | 9 +-
server/service/gov/kie/kie_distributor.go | 206 ++++
server/service/gov/kie/validate.go | 116 +++
server/service/gov/mock/mock.go | 27 +-
server/service/instance.go | 31 +-
server/service/instance_test.go | 7 +-
server/service/instance_validator.go | 5 +-
server/service/microservice.go | 160 +--
server/service/microservice_test.go | 5 +-
server/service/microservice_validator.go | 8 +-
server/service/rbac/authr_plugin.go | 5 +-
server/service/rbac/blocker_test.go | 5 +-
server/service/rbac/dao/account_dao.go | 1 +
server/service/rbac/dao/account_dao_test.go | 5 +-
server/service/rbac/dao/role_dao.go | 53 +-
server/service/rbac/decision.go | 62 +-
server/service/rbac/decision_test.go | 13 +-
server/service/rbac/password.go | 14 +-
server/service/rbac/permission.go | 56 ++
server/service/rbac/private.key | 51 -
server/service/rbac/rbac.go | 20 +-
server/service/rbac/rbac.pub | 14 -
server/service/rbac/{rbca_test.go => rbac_test.go} | 94 +-
server/service/rbac/resource.go | 129 +++
server/service/rbac/{decision.go => role.go} | 38 +-
server/service/rule.go | 1 +
server/service/rule_test.go | 3 +-
server/service/rule_validator.go | 3 +-
server/service/schema_validator.go | 3 +-
server/service/service_suite_test.go | 8 +-
server/service/tag.go | 1 +
server/service/tag_test.go | 5 +-
server/service/tag_validator.go | 3 +-
server/service/validate.go | 9 +-
server/service/watch.go | 62 +-
server/service/watch_test.go | 3 +-
.../syncernotify}/common.go | 16 +-
server/syncernotify/notify_service.go | 82 ++
.../syncer_publisher.go} | 57 +-
server/syncernotify/websocket.go | 246 +++++
server/syncernotify/websocket_test.go | 153 +++
syncer/client/sync_client.go | 23 +-
syncer/client/sync_client_test.go | 75 ++
syncer/client/watch_client.go | 169 ++++
syncer/client/watch_client_test.go | 30 +
syncer/cmd/daemon.go | 1 +
syncer/cmd/root.go | 1 +
syncer/config/config.go | 2 +
syncer/config/config_test.go | 3 +-
syncer/config/const.go | 1 -
syncer/config/merge.go | 1 -
syncer/config/verify.go | 13 +-
syncer/etcd/option.go | 2 -
syncer/grpc/grpc.go | 1 -
syncer/grpc/grpc_test.go | 8 +
syncer/pkg/mock/mockplugin/instance.go | 12 +-
syncer/pkg/mock/mockplugin/service.go | 4 +-
syncer/pkg/mock/mockservicecenter/instance.go | 22 +-
syncer/pkg/mock/mockservicecenter/service.go | 17 +-
syncer/pkg/mock/mockservicecenter/servicecenter.go | 30 +-
syncer/pkg/syssig/signal.go | 4 +-
syncer/pkg/syssig/signal_test.go | 12 +-
syncer/pkg/ticker/ticker.go | 4 +-
syncer/pkg/utils/addr.go | 1 +
syncer/pkg/utils/{addr_test.go => error.go} | 17 +-
syncer/pkg/utils/files.go | 1 +
syncer/plugins/eureka/eureka.go | 4 +-
syncer/plugins/eureka/instance.go | 17 +-
syncer/plugins/eureka/service.go | 3 +-
syncer/plugins/eureka/transform.go | 15 +-
syncer/plugins/eureka/type.go | 14 +-
syncer/plugins/export.go | 8 +-
syncer/plugins/plugin.go | 1 +
syncer/plugins/servicecenter.go | 9 +-
syncer/plugins/servicecenter/instance.go | 16 +-
syncer/plugins/servicecenter/schemas.go | 8 +-
syncer/plugins/servicecenter/service.go | 6 +-
syncer/plugins/servicecenter/servicecenter.go | 2 +
syncer/plugins/servicecenter/transform.go | 4 +-
syncer/proto/syncer.pb.go | 376 +++++--
syncer/proto/syncer.proto | 15 +
syncer/proto/types.go | 1 +
.../servicecenter/hello-server/main.go | 12 +-
.../hello-server/servicecenter/servicecenter.go | 15 +-
syncer/serf/serf.go | 7 +-
syncer/serf/serf_test.go | 13 +-
syncer/server/convert.go | 8 +-
syncer/server/handler.go | 162 ++-
syncer/server/handler_test.go | 296 ++++++
syncer/server/http.go | 43 +
syncer/server/server.go | 169 +++-
.../{plugins/servicecenter => server}/transform.go | 155 +--
syncer/servicecenter/exclude.go | 1 +
syncer/servicecenter/servicecenter.go | 97 ++
syncer/servicecenter/servicecenter_test.go | 98 ++
syncer/servicecenter/storage/operation.go | 8 +-
syncer/servicecenter/storage/storage.go | 6 +-
syncer/servicecenter/sync.go | 5 +-
syncer/version/version.go | 10 +-
test/test.go | 8 +-
version/version.go | 3 +-
464 files changed, 8654 insertions(+), 2193 deletions(-)
create mode 100644 cmd/syncer/conf/chassis.yaml
create mode 100644 cmd/syncer/conf/microservice.yaml
create mode 100644 datasource/dependency_util.go
copy pkg/util/uuid_test.go => datasource/dependency_util_test.go (78%)
create mode 100644 datasource/etcd/role.go
create mode 100644 datasource/etcd/role_test.go
create mode 100644 datasource/mongo/common.go
create mode 100644 datasource/mongo/dep_test.go
copy datasource/mongo/heartbeat/{healthcheck.go => common.go} (67%)
copy server/service/rbac/dao/role_dao.go => datasource/mongo/role.go (57%)
copy datasource/mongo/{ops.go => util.go} (77%)
copy datasource/{system.go => ms_util.go} (68%)
copy datasource/{etcd/util/schema_util_test.go => ms_util_test.go} (71%)
copy server/service/rbac/dao/role_dao.go => datasource/role.go (59%)
create mode 100644 docs/openapi/v1-gov.yaml
delete mode 100644 examples/governance/loadbalancer.json
create mode 100644 examples/governance/retry.json
copy pkg/rbacframe/{error.go => role.go} (70%)
create mode 100644 pkg/validate/version_func.go
create mode 100644 pkg/validate/version_func_test.go
delete mode 100644 server/resource/v4/auth_resource_test.go
create mode 100644 server/resource/v4/rbac_resource_test.go
create mode 100644 server/resource/v4/role_resource.go
copy server/{interceptor/cors/cors.go => rest/syncer/service/service.go} (61%)
copy server/{config/config_test.go => rest/syncer/service/service_test.go}
(56%)
copy server/{broker/broker.go => rest/syncer/syncer.go} (82%)
copy server/rest/{controller/v3/instance_watcher.go =>
syncer/syncer_controller.go} (67%)
create mode 100644 server/service/gov/kie/kie_distributor.go
create mode 100644 server/service/gov/kie/validate.go
create mode 100644 server/service/rbac/permission.go
delete mode 100644 server/service/rbac/private.key
delete mode 100644 server/service/rbac/rbac.pub
rename server/service/rbac/{rbca_test.go => rbac_test.go} (60%)
create mode 100644 server/service/rbac/resource.go
copy server/service/rbac/{decision.go => role.go} (58%)
copy {datasource/etcd/sd/servicecenter => server/syncernotify}/common.go (79%)
create mode 100644 server/syncernotify/notify_service.go
copy server/{connection/ws/publisher.go => syncernotify/syncer_publisher.go}
(69%)
create mode 100644 server/syncernotify/websocket.go
create mode 100644 server/syncernotify/websocket_test.go
create mode 100644 syncer/client/sync_client_test.go
create mode 100644 syncer/client/watch_client.go
create mode 100644 syncer/client/watch_client_test.go
copy syncer/pkg/utils/{addr_test.go => error.go} (76%)
create mode 100644 syncer/server/handler_test.go
create mode 100644 syncer/server/http.go
copy syncer/{plugins/servicecenter => server}/transform.go (53%)
