This is an automated email from the ASF dual-hosted git repository.
alexstocks pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/dubbo-go-samples.git
The following commit(s) were added to refs/heads/master by this push:
new e7a8938c refactor:polaris examples (#466)
e7a8938c is described below
commit e7a8938c4dbc8cbe87a609bf4cd57e39603decc1
Author: liaochuntao <[email protected]>
AuthorDate: Sat Dec 3 11:44:54 2022 +0800
refactor:polaris examples (#466)
* refactor:polaris examples
* examples:finish polaris examples
* examples:finish polaris examples
* examples:finish polaris examples
* examples:finish polaris examples
* examples:finish polaris examples
* examples:finish polaris examples
* examples:finish polaris examples
* examples:finish polaris examples
* examples:finish polaris examples
---
go.mod | 10 +-
go.sum | 122 +++++++++++++++------
polaris/limit/README-zh.md | 91 +++++++++++++++
polaris/limit/README.md | 91 +++++++++++++++
.../limit}/go-client/cmd/main.go | 29 ++---
.../limit/go-client/conf/dubbogo.yml | 6 +-
.../limit}/go-server/cmd/server.go | 1 +
.../limit}/go-server/conf/dubbogo.yaml | 8 +-
polaris/limit/images/dubbogo-ratelimit-rule.png | Bin 0 -> 113890 bytes
polaris/registry/README-zh.md | 62 +++++++++++
polaris/registry/README.md | 61 +++++++++++
.../registry}/go-client/cmd/main.go | 0
.../registry/go-client/conf/dubbogo.yml | 4 +-
.../registry}/go-server/cmd/server.go | 0
.../registry/go-server/conf/dubbogo.yml | 4 +-
polaris/router/README-zh.md | 121 ++++++++++++++++++++
polaris/router/README.md | 121 ++++++++++++++++++++
.../router}/go-client/cmd/main.go | 27 ++---
.../router}/go-client/conf/dubbogo.yaml | 7 +-
.../router/go-server/server-dev}/cmd/server.go | 5 +-
.../router/go-server/server-dev}/conf/dubbogo.yaml | 9 +-
.../router/go-server/server-pre}/cmd/server.go | 5 +-
.../router/go-server/server-pre}/conf/dubbogo.yaml | 11 +-
.../router/go-server/server-prod}/cmd/server.go | 5 +-
.../go-server/server-prod}/conf/dubbogo.yaml | 11 +-
polaris/router/images/dubbogo-route-rule-dev.png | Bin 0 -> 103117 bytes
polaris/router/images/dubbogo-route-rule-pre.png | Bin 0 -> 102704 bytes
polaris/router/images/dubbogo-route-rule-prod.png | Bin 0 -> 97770 bytes
28 files changed, 711 insertions(+), 100 deletions(-)
diff --git a/go.mod b/go.mod
index 5de4c3e8..611e5467 100644
--- a/go.mod
+++ b/go.mod
@@ -1,13 +1,13 @@
module github.com/apache/dubbo-go-samples
require (
- dubbo.apache.org/dubbo-go/v3 v3.0.3-0.20220730033103-013f0b2804ce
+ dubbo.apache.org/dubbo-go/v3 v3.0.4-rc1
github.com/SkyAPM/go2sky v1.5.0
github.com/SkyAPM/go2sky-plugins/dubbo-go
v0.0.0-20220718123631-cb8f743b16cf
- github.com/apache/dubbo-go-hessian2 v1.11.3
- github.com/dubbogo/gost v1.12.6-0.20220719055648-01d5bc07b111
+ github.com/apache/dubbo-go-hessian2 v1.11.4
+ github.com/dubbogo/gost v1.13.2
github.com/dubbogo/grpc-go v1.42.10
- github.com/dubbogo/triple v1.1.9
+ github.com/dubbogo/triple v1.2.2-rc2
github.com/golang/protobuf v1.5.2
github.com/opentracing/opentracing-go v1.2.0
github.com/openzipkin-contrib/zipkin-go-opentracing v0.4.5
@@ -15,7 +15,7 @@ require (
github.com/pkg/errors v0.9.1
github.com/seata/seata-go v0.1.0-rc1
github.com/stretchr/testify v1.8.1
- github.com/uber/jaeger-client-go v2.29.1+incompatible
+ github.com/uber/jaeger-client-go v2.30.0+incompatible
go.opentelemetry.io/otel v1.11.0
go.opentelemetry.io/otel/exporters/jaeger v1.10.0
go.opentelemetry.io/otel/sdk v1.10.0
diff --git a/go.sum b/go.sum
index 3fd6c137..06de2816 100644
--- a/go.sum
+++ b/go.sum
@@ -37,8 +37,8 @@ contrib.go.opencensus.io/exporter/prometheus v0.4.1/go.mod
h1:t9wvfitlUjGXG2IXAZ
dmitri.shuralyov.com/gpu/mtl v0.0.0-20190408044501-666a987793e9/go.mod
h1:H6x//7gZCb22OMCxBHrMx7a5I7Hp++hsVxbQ4BYO7hU=
dubbo.apache.org/dubbo-go/v3 v3.0.2-0.20220508105316-b27ec53b7bab/go.mod
h1:Ytn9MtmsFYkpa1bzW/3loUFBgm7eJ3M3+XWRurhbBZc=
dubbo.apache.org/dubbo-go/v3 v3.0.2/go.mod
h1:bODgByAf72kzG/5YIfZIODXx81pY3gaAdIQ8B4mN/Yk=
-dubbo.apache.org/dubbo-go/v3 v3.0.3-0.20220730033103-013f0b2804ce
h1:9+VXWxpKrQdswArGMZ2IlU25ufwjqSZevS+9iAWPzYY=
-dubbo.apache.org/dubbo-go/v3 v3.0.3-0.20220730033103-013f0b2804ce/go.mod
h1:wdk8Y3AiAB0mCrJmNZkZOGV5ik5b7PGIIwDD5L5D0Z8=
+dubbo.apache.org/dubbo-go/v3 v3.0.4-rc1
h1:bmzXdYK3Xn1Na1ybpIWpNuzx2CiskhC5MD/b3pPkItg=
+dubbo.apache.org/dubbo-go/v3 v3.0.4-rc1/go.mod
h1:GVCUBZwVkqFJFCtSgIUS7APbv2RBT4KB7sNuLK7D+ko=
github.com/BurntSushi/toml v0.3.1/go.mod
h1:xHWCNGjB5oqiDr8zfno3MHue2Ht5sIBksp03qcyfWMU=
github.com/BurntSushi/toml v1.1.0
h1:ksErzDEI1khOiGPgpwuI7x2ebx/uXQNw7xJpn9Eq1+I=
github.com/BurntSushi/toml v1.1.0/go.mod
h1:CxXYINrC8qIiEnFrOxCa7Jy5BFHlXnUU2pbicEuybxQ=
@@ -76,17 +76,18 @@ github.com/alecthomas/units
v0.0.0-20190717042225-c3de453c63f4/go.mod h1:ybxpYRF
github.com/alecthomas/units v0.0.0-20190924025748-f65c72e2690d/go.mod
h1:rBZYJk541a8SKzHPHnH3zbiI+7dagKZ0cgpgrD7Fyho=
github.com/alibaba/sentinel-golang v1.0.4
h1:i0wtMvNVdy7vM4DdzYrlC4r/Mpk1OKUUBurKKkWhEo8=
github.com/alibaba/sentinel-golang v1.0.4/go.mod
h1:Lag5rIYyJiPOylK8Kku2P+a23gdKMMqzQS7wTnjWEpk=
-github.com/aliyun/alibaba-cloud-sdk-go v1.61.18
h1:zOVTBdCKFd9JbCKz9/nt+FovbjPFmb7mUnp8nH9fQBA=
github.com/aliyun/alibaba-cloud-sdk-go v1.61.18/go.mod
h1:v8ESoHo4SyHmuB4b1tJqDHxfTGEciD+yhvOU/5s1Rfk=
+github.com/aliyun/alibaba-cloud-sdk-go v1.61.1704
h1:PpfENOj/vPfhhy9N2OFRjpue0hjM5XqAp2thFmkXXIk=
+github.com/aliyun/alibaba-cloud-sdk-go v1.61.1704/go.mod
h1:RcDobYh8k5VP6TNybz9m++gL3ijVI5wueVr0EM10VsU=
github.com/antihax/optional v1.0.0/go.mod
h1:uupD/76wgC+ih3iEmQUL+0Ugr19nfwCT1kdvxnR2qWY=
-github.com/apache/dubbo-getty v1.4.8
h1:Q9WKXmVu4Dm16cMJHamegRbxpDiYaGIU+MnPGhJhNyk=
github.com/apache/dubbo-getty v1.4.8/go.mod
h1:cPJlbcHUTNTpiboMQjMHhE9XBni11LiBiG8FdrDuVzk=
+github.com/apache/dubbo-getty v1.4.9-0.20221022181821-4dc6252ce98c
h1:2LE4IlyVBBlMo0ZDI+vq9YIb35dyij1YR5EnNWVPnNQ=
+github.com/apache/dubbo-getty v1.4.9-0.20221022181821-4dc6252ce98c/go.mod
h1:6qmrqBSPGs3B35zwEuGhEYNVsx1nfGT/xzV2yOt2amM=
github.com/apache/dubbo-go-hessian2 v1.9.1/go.mod
h1:xQUjE7F8PX49nm80kChFvepA/AvqAZ0oh/UaB6+6pBE=
github.com/apache/dubbo-go-hessian2 v1.9.3/go.mod
h1:xQUjE7F8PX49nm80kChFvepA/AvqAZ0oh/UaB6+6pBE=
github.com/apache/dubbo-go-hessian2 v1.11.0/go.mod
h1:7rEw9guWABQa6Aqb8HeZcsYPHsOS7XT1qtJvkmI6c5w=
-github.com/apache/dubbo-go-hessian2 v1.11.1/go.mod
h1:7rEw9guWABQa6Aqb8HeZcsYPHsOS7XT1qtJvkmI6c5w=
-github.com/apache/dubbo-go-hessian2 v1.11.3
h1:QSJhGLHBtnvb2kKrZ4uxpXxHGgGHqQkXXLI8rcQmEpg=
-github.com/apache/dubbo-go-hessian2 v1.11.3/go.mod
h1:7rEw9guWABQa6Aqb8HeZcsYPHsOS7XT1qtJvkmI6c5w=
+github.com/apache/dubbo-go-hessian2 v1.11.4
h1:u8spEogpaZ82/k3bmv1PLYnha/wiwsIme15FuZZgkiI=
+github.com/apache/dubbo-go-hessian2 v1.11.4/go.mod
h1:QP9Tc0w/B/mDopjusebo/c7GgEfl6Lz8jeuFg8JA6yw=
github.com/apache/thrift v0.12.0/go.mod
h1:cp2SuWMxlEZw2r+iP2GNCdIi4C1qmUzdZFSVb+bacwQ=
github.com/apache/thrift v0.13.0/go.mod
h1:cp2SuWMxlEZw2r+iP2GNCdIi4C1qmUzdZFSVb+bacwQ=
github.com/armon/circbuf v0.0.0-20150827004946-bbbad097214e/go.mod
h1:3U/XgcO3hCbHZ8TKRvWD2dDTCfh9M9ya+I9JpbB7O8o=
@@ -182,6 +183,8 @@ github.com/davecgh/go-spew v1.1.1
h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c
github.com/davecgh/go-spew v1.1.1/go.mod
h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
github.com/dgrijalva/jwt-go v3.2.0+incompatible/go.mod
h1:E3ru+11k8xSBh+hMPgOLZmtrrCbhqsmaPHjLKYnJCaQ=
github.com/dgryski/go-sip13 v0.0.0-20181026042036-e10d5fee7954/go.mod
h1:vAd38F8PWV+bWy6jNmig1y/TA+kYO4g3RSRF0IAv0no=
+github.com/dlclark/regexp2 v1.7.0
h1:7lJfhqlPssTb1WQx4yvTHN0uElPEv52sbaECrAQxjAo=
+github.com/dlclark/regexp2 v1.7.0/go.mod
h1:DHkYz0B9wPfa6wondMfaivmHpzrQ3v9q8cnmRbL6yW8=
github.com/dubbogo/go-zookeeper v1.0.3/go.mod
h1:fn6n2CAEer3novYgk9ULLwAjuV8/g4DdC2ENwRb6E+c=
github.com/dubbogo/go-zookeeper v1.0.4-0.20211212162352-f9d2183d89d5
h1:XoR8SSVziXe698dt4uZYDfsmHpKLemqAgFyndQsq5Kw=
github.com/dubbogo/go-zookeeper v1.0.4-0.20211212162352-f9d2183d89d5/go.mod
h1:fn6n2CAEer3novYgk9ULLwAjuV8/g4DdC2ENwRb6E+c=
@@ -190,8 +193,10 @@ github.com/dubbogo/gost v1.11.18/go.mod
h1:vIcP9rqz2KsXHPjsAwIUtfJIJjppQLQDcYaZT
github.com/dubbogo/gost v1.11.23/go.mod
h1:PhJ8+qZJx+Txjx1KthNPuVkCvUca0jRLgKWj/noGgeI=
github.com/dubbogo/gost v1.11.25/go.mod
h1:iovrPhv0hyakhQGVr4jwiECBL9HXNuBY4VV3HWK5pM0=
github.com/dubbogo/gost v1.12.5/go.mod
h1:f0bcP1xpBUdDgiNjNYKF6F3qlA+RFKs0k980FhoEn/g=
-github.com/dubbogo/gost v1.12.6-0.20220719055648-01d5bc07b111
h1:ydfcIHE0slI/R1plWVKaJWpgwo60EuZ5MQyQ3ZiOITQ=
-github.com/dubbogo/gost v1.12.6-0.20220719055648-01d5bc07b111/go.mod
h1:f0bcP1xpBUdDgiNjNYKF6F3qlA+RFKs0k980FhoEn/g=
+github.com/dubbogo/gost v1.12.6-0.20220824084206-300e27e9e524/go.mod
h1:0YHTGJtjHiYlWtVEkZnyrvhr7rR+23GczNaJrgc2v38=
+github.com/dubbogo/gost v1.13.1/go.mod
h1:9HMXBv+WBMRWhF3SklpqDjkS/01AKWm2SrVdz/A0xJI=
+github.com/dubbogo/gost v1.13.2 h1:z4dczJ5KYu9CAbHWevzTVI/7a7vGQ1vECfmzKHacov0=
+github.com/dubbogo/gost v1.13.2/go.mod
h1:2vbZ7bo4PgR7stX1He5XBvQgP6wx4A7q7IFHZU3hVmE=
github.com/dubbogo/grpc-go v1.42.9/go.mod
h1:F1T9hnUvYGW4JLK1QNriavpOkhusU677ovPzLkk6zHM=
github.com/dubbogo/grpc-go v1.42.10
h1:CoyCdtqKJEar/3rPa6peZbDqYZ/mVsCqAxB6TfTSkhQ=
github.com/dubbogo/grpc-go v1.42.10/go.mod
h1:JMkPt1mIHL96GAFeYsMoMjew6f1ROKycikGzZQH1s5U=
@@ -199,8 +204,8 @@ github.com/dubbogo/jsonparser v1.0.1/go.mod
h1:tYAtpctvSP/tWw4MeelsowSPgXQRVHHWb
github.com/dubbogo/net v0.0.4/go.mod
h1:1CGOnM7X3he+qgGNqjeADuE5vKZQx/eMSeUkpU3ujIc=
github.com/dubbogo/triple v1.0.9/go.mod
h1:1t9me4j4CTvNDcsMZy6/OGarbRyAUSY0tFXGXHCp7Iw=
github.com/dubbogo/triple v1.1.8/go.mod
h1:9pgEahtmsY/avYJp3dzUQE8CMMVe1NtGBmUhfICKLJk=
-github.com/dubbogo/triple v1.1.9
h1:U3ZDh9tyeitp/arSB5qR4wFnbK8MMYm/F4kzn6JokaA=
-github.com/dubbogo/triple v1.1.9/go.mod
h1:9pgEahtmsY/avYJp3dzUQE8CMMVe1NtGBmUhfICKLJk=
+github.com/dubbogo/triple v1.2.2-rc2
h1:2AaLd+uKwnNnR3qOIXTNPU/OHk77qIDNGMX3GstEtaY=
+github.com/dubbogo/triple v1.2.2-rc2/go.mod
h1:8qprF2uJX82IE5hjiIuswp416sEr0oL/+bb7IjiizYs=
github.com/dustin/go-humanize v0.0.0-20171111073723-bb3d318650d4/go.mod
h1:HtrtbFcZ19U5GC7JDqmcUSB87Iq5E25KnS6fMYU6eOk=
github.com/dustin/go-humanize v1.0.0
h1:VSnTsYCnlFHaM2/igO1h6X3HA71jcobQuxemgkq4zYo=
github.com/dustin/go-humanize v1.0.0/go.mod
h1:HtrtbFcZ19U5GC7JDqmcUSB87Iq5E25KnS6fMYU6eOk=
@@ -211,8 +216,8 @@ github.com/eapache/queue v1.1.0/go.mod
h1:6eCeP0CKFpHLu8blIFXhExK/dRa7WDZfr6jVFP
github.com/edsrzf/mmap-go v1.0.0/go.mod
h1:YO35OhQPt3KJa3ryjFM5Bs14WD66h8eGKpfaBNrHW5M=
github.com/elazarl/go-bindata-assetfs v1.0.1/go.mod
h1:v+YaWX3bdea5J/mo8dSETolEo7R71Vk1u8bnjau5yw4=
github.com/emicklei/go-restful/v3 v3.7.4/go.mod
h1:6n3XBCmQQb25CM2LCACGz8ukIrRry+4bhvbpWn3mrbc=
-github.com/emicklei/go-restful/v3 v3.8.0
h1:eCZ8ulSerjdAiaNpF7GxXIE7ZCMo1moN1qX+S609eVw=
-github.com/emicklei/go-restful/v3 v3.8.0/go.mod
h1:6n3XBCmQQb25CM2LCACGz8ukIrRry+4bhvbpWn3mrbc=
+github.com/emicklei/go-restful/v3 v3.10.1
h1:rc42Y5YTp7Am7CS630D7JmhRjq4UlEUuEKfrDac4bSQ=
+github.com/emicklei/go-restful/v3 v3.10.1/go.mod
h1:6n3XBCmQQb25CM2LCACGz8ukIrRry+4bhvbpWn3mrbc=
github.com/envoyproxy/go-control-plane v0.6.9/go.mod
h1:SBwIajubJHhxtWwsL9s8ss4safvEdbitLhGGK48rN6g=
github.com/envoyproxy/go-control-plane v0.9.0/go.mod
h1:YTl/9mNaCwkRvm6d1a2C3ymFceY/DCBVvsKhRF0iEA4=
github.com/envoyproxy/go-control-plane
v0.9.1-0.20191026205805-5f8ba28d4473/go.mod
h1:YTl/9mNaCwkRvm6d1a2C3ymFceY/DCBVvsKhRF0iEA4=
@@ -231,6 +236,7 @@ github.com/evanphx/json-patch/v5 v5.5.0/go.mod
h1:G79N1coSVB93tBe7j6PhzjmR3/2Vvl
github.com/fastly/go-utils v0.0.0-20180712184237-d95a45783239/go.mod
h1:Gdwt2ce0yfBxPvZrHkprdPPTTS3N5rwmLE8T22KBXlw=
github.com/fatih/camelcase v1.0.0/go.mod
h1:yN2Sb0lFhZJUdVvtELVWefmrXpuZESvPmqwoZc+/fpc=
github.com/fatih/color v1.7.0/go.mod
h1:Zm6kSWBoL9eyXnKyktHP6abPY2pDugNf5KwzbycvMj4=
+github.com/fatih/color v1.9.0/go.mod
h1:eQcE1qtQxscV5RaZvpXrrb8Drkc3/DdQ+uUYCNjL+zU=
github.com/fatih/structs v1.1.0/go.mod
h1:9NiDSp5zOcgEDl+j00MP/WkGVPOlPRLejGD8Ga6PJ7M=
github.com/fogleman/gg v1.2.1-0.20190220221249-0403632d5b90/go.mod
h1:R/bRT+9gY/C5z7JzPU0zXsXHKM4/ayA+zqcVNZzPa1k=
github.com/form3tech-oss/jwt-go v3.2.2+incompatible
h1:TcekIExNqud5crz4xD2pavyTgWiPvpYe4Xau31I0PRk=
@@ -241,11 +247,11 @@ github.com/frankban/quicktest v1.10.0
h1:Gfh+GAJZOAoKZsIZeZbdn2JF10kN1XHNvjsvQK8
github.com/frankban/quicktest v1.10.0/go.mod
h1:ui7WezCLWMWxVWr1GETZY3smRy0G4KWq9vcPtJmFl7Y=
github.com/fsnotify/fsnotify v1.4.7/go.mod
h1:jwhsz4b93w/PPRr/qN1Yymfu8t87LnFCMoQvtojpjFo=
github.com/fsnotify/fsnotify v1.4.9/go.mod
h1:znqG4EE+3YCdAaPaxE2ZRY/06pZUdp0tY4IgpuI1SZQ=
-github.com/fsnotify/fsnotify v1.5.4
h1:jRbGcIw6P2Meqdwuo0H1p6JVLbL5DHKAKlYndzMwVZI=
github.com/fsnotify/fsnotify v1.5.4/go.mod
h1:OVB6XrOHzAwXMpEM7uPOzcehqUV2UqJxmVXmkdnm1bU=
+github.com/fsnotify/fsnotify v1.6.0
h1:n+5WquG0fcWoWp6xPWfHdbskMCQaFnG6PfBrh1Ky4HY=
+github.com/fsnotify/fsnotify v1.6.0/go.mod
h1:sl3t1tCWJFWoRz9R8WJCbQihKKwmorjAbSClcnxKAGw=
github.com/getsentry/raven-go v0.2.0
h1:no+xWJRb5ZI7eE8TWgIq1jLulQiIoLG0IfYxv5JYMGs=
github.com/getsentry/raven-go v0.2.0/go.mod
h1:KungGk8q33+aIAZUIVWZDr2OfAEBsO49PX4NzFV5kcQ=
-github.com/ghodss/yaml v1.0.0 h1:wQHKEahhL6wmXdzwWG11gIVCkOv05bNOh+Rxn0yngAk=
github.com/ghodss/yaml v1.0.0/go.mod
h1:4dBDuWmgqj2HViK6kFavaiC9ZROes6MMH2rRYeMEF04=
github.com/glycerine/go-unsnap-stream
v0.0.0-20181221182339-f9677308dec2/go.mod
h1:/20jfyN9Y5QPEAprSgKAUr+glWDY39ZiUEAYOEv5dsE=
github.com/glycerine/goconvey v0.0.0-20190410193231-58a59202ab31/go.mod
h1:Ogl1Tioa0aV7gstGFO7KhffUsb9M4ydbEbbxpcEDc24=
@@ -318,8 +324,9 @@ github.com/golang/mock v1.4.0/go.mod
h1:UOMv5ysSaYNkG+OFQykRIcU/QvvxJf3p21QfJ2Bt
github.com/golang/mock v1.4.1/go.mod
h1:UOMv5ysSaYNkG+OFQykRIcU/QvvxJf3p21QfJ2Bt3cw=
github.com/golang/mock v1.4.3/go.mod
h1:UOMv5ysSaYNkG+OFQykRIcU/QvvxJf3p21QfJ2Bt3cw=
github.com/golang/mock v1.4.4/go.mod
h1:l3mdAwkq5BuhzHwde/uurv3sEJeZMXNpwsxVWU71h+4=
-github.com/golang/mock v1.5.0 h1:jlYHihg//f7RRwuPfptm04yp4s7O6Kw8EZiVYIGcH0g=
github.com/golang/mock v1.5.0/go.mod
h1:CWnOUgYIOo4TcNZ0wHX3YZCqsaM1I1Jvs6v3mP3KVu8=
+github.com/golang/mock v1.6.0 h1:ErTB+efbowRARo13NNdxyJji2egdxLGQhRaY+DUumQc=
+github.com/golang/mock v1.6.0/go.mod
h1:p6yTPP+5HYm5mzsMV8JkE6ZKdX+/wYM6Hr+LicevLPs=
github.com/golang/protobuf v1.2.0/go.mod
h1:6lQm79b+lXiMfvg/cZm0SGofjICqVBUtrP5yJMmIC1U=
github.com/golang/protobuf v1.3.1/go.mod
h1:6lQm79b+lXiMfvg/cZm0SGofjICqVBUtrP5yJMmIC1U=
github.com/golang/protobuf v1.3.2/go.mod
h1:6lQm79b+lXiMfvg/cZm0SGofjICqVBUtrP5yJMmIC1U=
@@ -363,8 +370,9 @@ github.com/google/go-cmp v0.5.4/go.mod
h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/
github.com/google/go-cmp v0.5.5/go.mod
h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/gNBxE=
github.com/google/go-cmp v0.5.6/go.mod
h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/gNBxE=
github.com/google/go-cmp v0.5.7/go.mod
h1:n+brtR0CgQNWTVd5ZUFpTBC8YFBDLK/h/bpaJ8/DtOE=
-github.com/google/go-cmp v0.5.8 h1:e6P7q2lk1O+qJJb4BtCQXlK8vWEO8V1ZeuEdJNOqZyg=
github.com/google/go-cmp v0.5.8/go.mod
h1:17dUlkBOakJ0+DkrSSNjCkIjxS6bF9zb3elmeNGIjoY=
+github.com/google/go-cmp v0.5.9 h1:O2Tfq5qg4qc4AmwVlvv0oLiVAGB7enBSJ2x2DqQFi38=
+github.com/google/go-cmp v0.5.9/go.mod
h1:17dUlkBOakJ0+DkrSSNjCkIjxS6bF9zb3elmeNGIjoY=
github.com/google/gofuzz v1.0.0/go.mod
h1:dBl0BpW6vV/+mYPU4Po3pmUjxk6FQPldtuIdl/M65Eg=
github.com/google/martian v2.1.0+incompatible/go.mod
h1:9I4somxYTbIHy5NJKHRl3wXiIaQGbYVAs8BPL6v8lEs=
github.com/google/martian/v3 v3.0.0/go.mod
h1:y5Zk1BBys9G+gd6Jrk0W3cC1+ELVxBWuIGO+w/tUAp0=
@@ -408,8 +416,10 @@ github.com/grpc-ecosystem/grpc-opentracing
v0.0.0-20180507213350-8e809c8a8645 h1
github.com/grpc-ecosystem/grpc-opentracing
v0.0.0-20180507213350-8e809c8a8645/go.mod
h1:6iZfnjpejD4L/4DwD7NryNaJyCQdzwWwH2MWhCA90Kw=
github.com/hashicorp/consul/api v1.1.0/go.mod
h1:VmuI/Lkw1nC05EYQWNKwWGbkg+FbDBtguAZLlVdkD9Q=
github.com/hashicorp/consul/api v1.3.0/go.mod
h1:MmDNSzIMUjNpY/mQ398R4bk2FnqQLoPndWW5VkKPlCE=
+github.com/hashicorp/consul/api v1.13.0/go.mod
h1:ZlVrynguJKcYr54zGaDbaL3fOvKC9m72FhPvA8T35KQ=
github.com/hashicorp/consul/sdk v0.1.1/go.mod
h1:VKf9jXwCTEY1QZP2MOLRhb5i/I/ssyNV1vwHyQBF0x8=
github.com/hashicorp/consul/sdk v0.3.0/go.mod
h1:VKf9jXwCTEY1QZP2MOLRhb5i/I/ssyNV1vwHyQBF0x8=
+github.com/hashicorp/consul/sdk v0.8.0/go.mod
h1:GBvyrGALthsZObzUGsfgHZQDXjg4lOjagTIwIR1vPms=
github.com/hashicorp/errwrap v1.0.0/go.mod
h1:YH+1FKiLXxHSkmPseP+kNlulaMuP3n2brvKWEqk/Jc4=
github.com/hashicorp/errwrap v1.1.0
h1:OxrOeh75EUXMY8TBjag2fzXGZ40LB6IKw45YeGUDY2I=
github.com/hashicorp/errwrap v1.1.0/go.mod
h1:YH+1FKiLXxHSkmPseP+kNlulaMuP3n2brvKWEqk/Jc4=
@@ -417,13 +427,16 @@ github.com/hashicorp/go-cleanhttp v0.5.0/go.mod
h1:JpRdi6/HCYpAwUzNwuwqhbovhLtng
github.com/hashicorp/go-cleanhttp v0.5.1/go.mod
h1:JpRdi6/HCYpAwUzNwuwqhbovhLtngrth3wmdIIUrZ80=
github.com/hashicorp/go-hclog v0.0.0-20180709165350-ff2cf002a8dd/go.mod
h1:9bjs9uLqI8l75knNv3lV1kA55veR+WUPSiKIWcQHudI=
github.com/hashicorp/go-hclog v0.8.0/go.mod
h1:5CU+agLiy3J7N7QjHK5d05KxGsuXiQLrjA0H7acj2lQ=
+github.com/hashicorp/go-hclog v0.12.0/go.mod
h1:whpDNt7SSdeAju8AWKIWsul05p54N/39EeqMAyrmvFQ=
github.com/hashicorp/go-hclog v0.14.1/go.mod
h1:whpDNt7SSdeAju8AWKIWsul05p54N/39EeqMAyrmvFQ=
github.com/hashicorp/go-hclog v0.16.2/go.mod
h1:whpDNt7SSdeAju8AWKIWsul05p54N/39EeqMAyrmvFQ=
github.com/hashicorp/go-immutable-radix v1.0.0/go.mod
h1:0y9vanUI8NX6FsYoO3zeMjhV/C5i9g4Q3DwcSNZ4P60=
github.com/hashicorp/go-immutable-radix v1.3.1/go.mod
h1:0y9vanUI8NX6FsYoO3zeMjhV/C5i9g4Q3DwcSNZ4P60=
github.com/hashicorp/go-kms-wrapping/entropy v0.1.0/go.mod
h1:d1g9WGtAunDNpek8jUIEJnBlbgKS1N2Q61QkHiZyR1g=
+github.com/hashicorp/go-kms-wrapping/entropy/v2 v2.0.0/go.mod
h1:xvb32K2keAc+R8DSFG2IwDcydK9DBQE+fGA5fsw6hSk=
github.com/hashicorp/go-msgpack v0.5.3/go.mod
h1:ahLV/dePpqEmjfWmKiqvPkv/twdG7iPBM1vqhUKIvfM=
github.com/hashicorp/go-multierror v1.0.0/go.mod
h1:dHtQlpGsu+cZNNAkkCN/P3hoUDHhCYQXV3UM06sGGrk=
+github.com/hashicorp/go-multierror v1.1.0/go.mod
h1:spPvp8C1qA32ftKqdAHm4hHTbPw+vmowP0z+KUhOZdA=
github.com/hashicorp/go-multierror v1.1.1
h1:H5DkEtf6CXdFp0N0Em5UCwQpXMWke8IA0+lD48awMYo=
github.com/hashicorp/go-multierror v1.1.1/go.mod
h1:iw975J/qwKPdAO1clOe2L8331t/9/fmwbPZ6JB6eMoM=
github.com/hashicorp/go-plugin v1.0.1/go.mod
h1:++UyYGoz3o5w9ZzAdZxtQKrWWP+iqPBn3cQptSMzBuY=
@@ -432,6 +445,7 @@ github.com/hashicorp/go-retryablehttp v0.5.3/go.mod
h1:9B5zBasrRhHXnJnui7y6sL7es
github.com/hashicorp/go-retryablehttp v0.5.4/go.mod
h1:9B5zBasrRhHXnJnui7y6sL7es7NDiJgTc6Er0maI1Xs=
github.com/hashicorp/go-rootcerts v1.0.0/go.mod
h1:K6zTfqpRlCUIjkwsN4Z+hiSfzSTQa6eBIzfwKfwNnHU=
github.com/hashicorp/go-rootcerts v1.0.1/go.mod
h1:pqUvnprVnM5bf7AOirdbb01K4ccR319Vf4pU3K5EGc8=
+github.com/hashicorp/go-rootcerts v1.0.2/go.mod
h1:pqUvnprVnM5bf7AOirdbb01K4ccR319Vf4pU3K5EGc8=
github.com/hashicorp/go-secure-stdlib/base62 v0.1.1/go.mod
h1:EdWO6czbmthiwZ3/PUsDV+UD1D5IRU4ActiaWGwt0Yw=
github.com/hashicorp/go-secure-stdlib/mlock v0.1.1/go.mod
h1:zq93CJChV6L9QTfGKtfBxKqD7BqqXx5O04A/ns2p5+I=
github.com/hashicorp/go-secure-stdlib/parseutil v0.1.1/go.mod
h1:QmrqtbKuxxSWTN3ETMPuB+VtEiBJ/A9XhoYGv8E1uD8=
@@ -456,15 +470,20 @@ github.com/hashicorp/hcl v1.0.0
h1:0Anlzjpi4vEasTeNFn2mLJgTSwt0+6sfsiTG8qcWGx4=
github.com/hashicorp/hcl v1.0.0/go.mod
h1:E5yfLk+7swimpb2L/Alb/PJmXilQ/rhwaUYs4T20WEQ=
github.com/hashicorp/logutils v1.0.0/go.mod
h1:QIAnNjmIWmVIIkWDTG1z5v++HQmx9WQRO+LraFDTW64=
github.com/hashicorp/mdns v1.0.0/go.mod
h1:tL+uN++7HEJ6SQLQ2/p+z2pH24WQKWjBPkE0mNTz8vQ=
+github.com/hashicorp/mdns v1.0.4/go.mod
h1:mtBihi+LeNXGtG8L9dX59gAEa12BDtBQSp4v/YAJqrc=
github.com/hashicorp/memberlist v0.1.3/go.mod
h1:ajVTdAv/9Im8oMAAj5G31PhhMCZJV2pPBoIllUwCN7I=
+github.com/hashicorp/memberlist v0.3.0/go.mod
h1:MS2lj3INKhZjWNqd3N0m3J+Jxf3DAOnAH9VT3Sh9MUE=
github.com/hashicorp/serf v0.8.2/go.mod
h1:6hOLApaqBFA1NXqRQAsxw9QxuDEvNxSQRwA/JwenrHc=
+github.com/hashicorp/serf v0.9.6/go.mod
h1:TXZNMjZQijwlDvp+r0b63xZ45H7JmCmgg4gpTwn9UV4=
github.com/hashicorp/vault/api v1.0.4/go.mod
h1:gDcqh3WGcR1cpF5AJz/B1UFheUEneMoIospckxBxk6Q=
github.com/hashicorp/vault/sdk v0.1.13/go.mod
h1:B+hVj7TpuQY1Y/GPbCpffmgd+tSEwvhkWnjtSYCaS2M=
github.com/hashicorp/vault/sdk v0.3.0/go.mod
h1:aZ3fNuL5VNydQk8GcLJ2TV8YCRVvyaakYkhZRoVuhj0=
-github.com/hashicorp/vault/sdk v0.5.3
h1:PWY8sq/9pRrK9vUIy75qCH2Jd8oeENAgkaa/qbhzFrs=
-github.com/hashicorp/vault/sdk v0.5.3/go.mod
h1:DoGraE9kKGNcVgPmTuX357Fm6WAx1Okvde8Vp3dPDoU=
+github.com/hashicorp/vault/sdk v0.6.0
h1:6Z+In5DXHiUfZvIZdMx7e2loL1PPyDjA4bVh9ZTIAhs=
+github.com/hashicorp/vault/sdk v0.6.0/go.mod
h1:+DRpzoXIdMvKc88R4qxr+edwy/RvH5QK8itmxLiDHLc=
github.com/hashicorp/yamux v0.0.0-20180604194846-3520598351bb/go.mod
h1:+NfK9FKeTrX5uv1uIXGdwYDTeHna2qgaIlx54MXqjAM=
github.com/hashicorp/yamux v0.0.0-20181012175058-2f1d1f20f75d/go.mod
h1:+NfK9FKeTrX5uv1uIXGdwYDTeHna2qgaIlx54MXqjAM=
+github.com/hjson/hjson-go/v4 v4.0.0
h1:wlm6IYYqHjOdXH1gHev4VoXCaW20HdQAGCxdOEEg2cs=
+github.com/hjson/hjson-go/v4 v4.0.0/go.mod
h1:KaYt3bTw3zhBjYqnXkYywcYctk0A2nxeEFTse3rH13E=
github.com/hpcloud/tail v1.0.0/go.mod
h1:ab1qPbhIpdTxEkNHXyeSf5vhxWSCs/tWer42PpOxQnU=
github.com/hudl/fargo v1.3.0/go.mod
h1:y3CKSmjA+wD2gak7sUSXTAoopbhU08POFhmITJgmKTg=
github.com/ianlancetaylor/demangle v0.0.0-20181102032728-5e5cf60278f6/go.mod
h1:aSSvb/t6k1mPoxDqO4vJh6VOCGPwU4O0C2/Eqndh1Sc=
@@ -511,8 +530,8 @@ github.com/kisielk/errcheck v1.2.0/go.mod
h1:/BMXB+zMLi60iA8Vv6Ksmxu/1UDYcXs4uQL
github.com/kisielk/errcheck v1.5.0/go.mod
h1:pFxgyoBC7bSaBwPgfKdkLd5X25qrDl4LWUI2bnpBCr8=
github.com/kisielk/gotool v1.0.0/go.mod
h1:XhKaO+MFFWcvkIS/tQcRk01m1F5IRFswLeQ+oQHNcck=
github.com/knadh/koanf v1.4.1/go.mod
h1:1cfH5223ZeZUOs8FU2UdTmaNfHpqgtjV0+NHjRO43gs=
-github.com/knadh/koanf v1.4.2 h1:2itp+cdC6miId4pO4Jw7c/3eiYD26Z/Sz3ATJMwHxIs=
-github.com/knadh/koanf v1.4.2/go.mod
h1:4NCo0q4pmU398vF9vq2jStF9MWQZ8JEDcDMHlDCr4h0=
+github.com/knadh/koanf v1.4.4 h1:d2jY5nCCeoaiqvEKSBW9rEc93EfNy/XWgWsSB3j7JEA=
+github.com/knadh/koanf v1.4.4/go.mod
h1:Hgyjp4y8v44hpZtPzs7JZfRAW5AhN7KfZcwv1RYggDs=
github.com/koding/multiconfig v0.0.0-20171124222453-69c27309b2d7/go.mod
h1:Y2SaZf2Rzd0pXkLVhLlCiAXFCLSXAIbTKDivVgff/AM=
github.com/konsorten/go-windows-terminal-sequences v1.0.1/go.mod
h1:T0+1ngSBFLxvqU3pZ+m/2kptfBszLMUkC4ZK/EgS/cQ=
github.com/konsorten/go-windows-terminal-sequences v1.0.3/go.mod
h1:T0+1ngSBFLxvqU3pZ+m/2kptfBszLMUkC4ZK/EgS/cQ=
@@ -548,14 +567,19 @@ github.com/mattn/go-isatty v0.0.3/go.mod
h1:M+lRXTBqGeGNdLjl/ufCoiOlB5xdOkqRJdNx
github.com/mattn/go-isatty v0.0.4/go.mod
h1:M+lRXTBqGeGNdLjl/ufCoiOlB5xdOkqRJdNxMWT7Zi4=
github.com/mattn/go-isatty v0.0.8/go.mod
h1:Iq45c/XA43vh69/j3iqttzPXn0bhXyGjM0Hdxcsrc5s=
github.com/mattn/go-isatty v0.0.10/go.mod
h1:qgIWMr58cqv1PHHyhnkY9lrL7etaEgOFcMEpPG5Rm84=
+github.com/mattn/go-isatty v0.0.11/go.mod
h1:PhnuNfih5lzO57/f3n+odYbM4JtupLOxQOAqxQCu2WE=
github.com/mattn/go-isatty v0.0.12/go.mod
h1:cbi8OIDigv2wuxKPP5vlRcQ1OAZbq2CE4Kysco4FUpU=
github.com/mattn/go-isatty v0.0.14
h1:yVuAays6BHfxijgZPzw+3Zlu5yQgKGP2/hcQbHb7S9Y=
github.com/mattn/go-isatty v0.0.14/go.mod
h1:7GGIvUiUoEMVVmxf/4nioHXj79iQHKdU27kJ6hsGG94=
github.com/mattn/go-runewidth v0.0.2/go.mod
h1:LwmH8dsx7+W8Uxz3IHJYH5QSwggIsqBzpuz5H//U1FU=
-github.com/matttproud/golang_protobuf_extensions v1.0.1
h1:4hp9jkHxhMHkqkrB3Ix0jegS5sx/RkqARlsWZ6pIwiU=
github.com/matttproud/golang_protobuf_extensions v1.0.1/go.mod
h1:D8He9yQNgCq6Z5Ld7szi9bcBfOoFv/3dc6xSMkL2PC0=
+github.com/matttproud/golang_protobuf_extensions v1.0.4
h1:mmDVorXM7PCGKw94cs5zkfA9PSy5pEvNWRP0ET0TIVo=
+github.com/matttproud/golang_protobuf_extensions v1.0.4/go.mod
h1:BSXmuO+STAnVfrANrmjBb36TMTDstsz7MSK+HVaYKv4=
github.com/miekg/dns v1.0.14/go.mod
h1:W1PPwlIAgtquWBMBEV9nkV9Cazfe8ScdGz/Lj7v3Nrg=
+github.com/miekg/dns v1.1.26/go.mod
h1:bPDLeHnStXmXAq1m/Ch/hvfNHr14JKNPMBo3VZKjuso=
+github.com/miekg/dns v1.1.41/go.mod
h1:p6aan82bvRIyn+zDIv9xYNUpwa73JcSh9BKwknJysuI=
github.com/mitchellh/cli v1.0.0/go.mod
h1:hNIlj7HEI86fIcpObd7a0FcrxTWetlwJDGcceTlRvqc=
+github.com/mitchellh/cli v1.1.0/go.mod
h1:xcISNoH86gajksDmfB23e/pu+B+GeFRMYmoHXxx3xhI=
github.com/mitchellh/copystructure v1.0.0/go.mod
h1:SNtv71yrdKgLRyLFxmLdkAbkKEFWgYaq1OVrnRcwhnw=
github.com/mitchellh/copystructure v1.2.0
h1:vpKXTN4ewci03Vljg/q9QvCGUDttBOGBIa15WveJJGw=
github.com/mitchellh/copystructure v1.2.0/go.mod
h1:qLl+cE2AmVv+CoeAwDPye/v+N2HKCj9FbZEVFJRxO9s=
@@ -589,8 +613,10 @@ github.com/mschoch/smat v0.2.0/go.mod
h1:kc9mz7DoBKqDyiRL7VZN8KvXQMWeTaVnttLRXOl
github.com/mwitkow/go-conntrack v0.0.0-20161129095857-cc309e4a2223/go.mod
h1:qRWi+5nqEBWmkhHvq77mSJWrCKwh8bxhgT7d/eI7P4U=
github.com/mwitkow/go-conntrack v0.0.0-20190716064945-2f068394615f/go.mod
h1:qRWi+5nqEBWmkhHvq77mSJWrCKwh8bxhgT7d/eI7P4U=
github.com/nacos-group/nacos-sdk-go v1.0.8/go.mod
h1:hlAPn3UdzlxIlSILAyOXKxjFSvDJ9oLzTJ9hLAK1KzA=
-github.com/nacos-group/nacos-sdk-go v1.1.1
h1:beczWcOoTaVBMgCgikqvZflrN5Xbw7pWAWpxl+VJGIA=
github.com/nacos-group/nacos-sdk-go v1.1.1/go.mod
h1:UHOtQNQY/qpk2dhg6gDq8u5+/CEIc3+lWmrmxEzX0/g=
+github.com/nacos-group/nacos-sdk-go v1.1.3
h1:xNlSC9li2A11ifTA8HCqgM6NRImGUJA4X+gGK5muJuQ=
+github.com/nacos-group/nacos-sdk-go v1.1.3/go.mod
h1:cBv9wy5iObs7khOqov1ERFQrCuTR4ILpgaiaVMxEmGI=
+github.com/nacos-group/nacos-sdk-go/v2 v2.1.2/go.mod
h1:ys/1adWeKXXzbNWfRNbaFlX/t6HVLWdpsNDvmoWTw0g=
github.com/natefinch/lumberjack v2.0.0+incompatible
h1:4QJd3OLAMgj7ph+yZTuX13Ld4UpgHp07nNdFX7mqFfM=
github.com/natefinch/lumberjack v2.0.0+incompatible/go.mod
h1:Wi9p2TTF5DG5oU+6YfsmYQpsTIOm0B1VNzQg9Mw6nPk=
github.com/nats-io/jwt v0.3.0/go.mod
h1:fRYCDE99xlTsqUzISS1Bi75UBJ6ljOJQOAAu5VglpSg=
@@ -606,6 +632,8 @@ github.com/oklog/oklog v0.3.2/go.mod
h1:FCV+B7mhrz4o+ueLpx+KqkyXRGMWOYEvfiXtdGtb
github.com/oklog/run v1.0.0/go.mod
h1:dlhp/R75TPv97u0XWUtDeV/lRKWPKSdTuV0TZvrmrQA=
github.com/oklog/ulid v1.3.1/go.mod
h1:CirwcVhetQ6Lv90oh/F+FBtV6XMibvdAFo93nm5qn4U=
github.com/olekukonko/tablewriter v0.0.0-20170122224234-a0225b3f23b5/go.mod
h1:vsDQFd/mU46D+Z4whnwzcISnGGzXWMclvtLoiIKAKIo=
+github.com/oliveagle/jsonpath v0.0.0-20180606110733-2e52cf6e6852
h1:Yl0tPBa8QPjGmesFh1D0rDy+q1Twx6FyU7VWHi8wZbI=
+github.com/oliveagle/jsonpath v0.0.0-20180606110733-2e52cf6e6852/go.mod
h1:eqOVx5Vwu4gd2mmMZvVZsgIqNSaW3xxRThUJ0k/TPk4=
github.com/onsi/ginkgo v1.6.0/go.mod
h1:lLunBs/Ym6LB5Z9jYTR76FiuTmxDTDusOGeTQH+WWjE=
github.com/onsi/ginkgo v1.7.0/go.mod
h1:lLunBs/Ym6LB5Z9jYTR76FiuTmxDTDusOGeTQH+WWjE=
github.com/onsi/gomega v1.4.3/go.mod
h1:ex+gbHU/CVuBBDIJjb2X0qEXbFg53c61hWP/1CpauHY=
@@ -645,9 +673,11 @@ github.com/pkg/profile v1.2.1/go.mod
h1:hJw3o1OdXxsrSjjVksARp5W95eeEaEfptyVZyv6J
github.com/pmezard/go-difflib v1.0.0
h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM=
github.com/pmezard/go-difflib v1.0.0/go.mod
h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4=
github.com/polarismesh/polaris-go v1.0.2/go.mod
h1:pXNvQS2mL3HzyAj9PhKUjJsfAgbXFA1EBmBG7Yc2KdE=
-github.com/polarismesh/polaris-go v1.1.0
h1:nFvn3q3XaVFhzF7pBnIySrN0ZZBwvbbYXC5r2DpsQN0=
github.com/polarismesh/polaris-go v1.1.0/go.mod
h1:tquawfjEKp1W3ffNJQSzhfditjjoZ7tvhOCElN7Efzs=
+github.com/polarismesh/polaris-go v1.3.0-alpha
h1:Oxan/TnCsxrM3lSk205Z/jkJ1bcRl4QFXLndPFwXUN0=
+github.com/polarismesh/polaris-go v1.3.0-alpha/go.mod
h1:HsN0ierETIujHpmnnYJ3qkwQw4QGAECuHvBZTDaw1tI=
github.com/posener/complete v1.1.1/go.mod
h1:em0nMJCgc9GFtwrmVmEMR/ZL6WyhyjMBndrE9hABlRI=
+github.com/posener/complete v1.2.3/go.mod
h1:WZIdtGGp+qx0sLrYKtIRAruyNpv6hFCicSgv7Sy7s/s=
github.com/power-devops/perfstat v0.0.0-20210106213030-5aafc221ea8c
h1:ncq/mPwQF4JjgDlrVEn3C11VoGHZN7m8qihwgMEtzYw=
github.com/power-devops/perfstat v0.0.0-20210106213030-5aafc221ea8c/go.mod
h1:OmDBASR4679mdNQnz2pUhc2G8CO2JrUAVFDRBDP/hJE=
github.com/prometheus/client_golang v0.9.1/go.mod
h1:7SWBe2y4D6OKWSNQJUaRYU/AaXPKyh/dDVn+NZz0KFw=
@@ -789,8 +819,9 @@ github.com/tmc/grpc-websocket-proxy
v0.0.0-20201229170055-e5319fda7802 h1:uruHq4
github.com/tmc/grpc-websocket-proxy v0.0.0-20201229170055-e5319fda7802/go.mod
h1:ncp9v5uamzpCO7NfCPTXjqaC+bZgJeR0sMTm6dMHP7U=
github.com/toolkits/concurrent v0.0.0-20150624120057-a4371d70e3e3/go.mod
h1:QDlpd3qS71vYtakd2hmdpqhJ9nwv6mD6A30bQ1BPBFE=
github.com/tv42/httpunix v0.0.0-20150427012821-b75d8614f926/go.mod
h1:9ESjWnEqriFuLhtthL60Sar/7RFoluCcXsuvEwTV5KM=
-github.com/uber/jaeger-client-go v2.29.1+incompatible
h1:R9ec3zO3sGpzs0abd43Y+fBZRJ9uiH6lXyR/+u6brW4=
github.com/uber/jaeger-client-go v2.29.1+incompatible/go.mod
h1:WVhlPFC8FDjOFMMWRy2pZqQJSXxYSwNYOkTr/Z6d3Kk=
+github.com/uber/jaeger-client-go v2.30.0+incompatible
h1:D6wyKGCecFaSRUpo8lCVbaOOb6ThwMmTEbhRwtKR97o=
+github.com/uber/jaeger-client-go v2.30.0+incompatible/go.mod
h1:WVhlPFC8FDjOFMMWRy2pZqQJSXxYSwNYOkTr/Z6d3Kk=
github.com/uber/jaeger-lib v2.4.1+incompatible
h1:td4jdvLcExb4cBISKIpHuGoVXh+dVKhn2Um6rjCsSsg=
github.com/uber/jaeger-lib v2.4.1+incompatible/go.mod
h1:ComeNDZlWwrWnDv8aPp0Ba6+uUTzImX/AauajbLI56U=
github.com/ugorji/go v1.2.6 h1:tGiWC9HENWE2tqYycIqFTNorMmFRVhNwCpDOpWqnk8E=
@@ -818,15 +849,18 @@ go.etcd.io/bbolt v1.3.5/go.mod
h1:G5EMThwa9y8QZGBClrRx5EY+Yw9kAhnjy3bSjsnlVTQ=
go.etcd.io/etcd v0.0.0-20191023171146-3cf2f69b5738
h1:VcrIfasaLFkyjk6KNlXQSzO+B0fZcnECiDrKJsfxka0=
go.etcd.io/etcd v0.0.0-20191023171146-3cf2f69b5738/go.mod
h1:dnLIgRNXwCJa5e+c6mIZCrds/GIG4ncV9HhK5PX7jPg=
go.etcd.io/etcd/api/v3 v3.5.0-alpha.0/go.mod
h1:mPcW6aZJukV6Aa81LSKpBjQXTWlXB5r74ymPoSWa3Sw=
-go.etcd.io/etcd/api/v3 v3.5.4 h1:OHVyt3TopwtUQ2GKdd5wu3PmmipR4FTwCqoEjSyRdIc=
go.etcd.io/etcd/api/v3 v3.5.4/go.mod
h1:5GB2vv4A4AOn3yk7MftYGHkUfGtDHnEraIjym4dYz5A=
-go.etcd.io/etcd/client/pkg/v3 v3.5.4
h1:lrneYvz923dvC14R54XcA7FXoZ3mlGZAgmwhfm7HqOg=
+go.etcd.io/etcd/api/v3 v3.5.6 h1:Cy2qx3npLcYqTKqGJzMypnMv2tiRyifZJ17BlWIWA7A=
+go.etcd.io/etcd/api/v3 v3.5.6/go.mod
h1:KFtNaxGDw4Yx/BA4iPPwevUTAuqcsPxzyX8PHydchN8=
go.etcd.io/etcd/client/pkg/v3 v3.5.4/go.mod
h1:IJHfcCEKxYu1Os13ZdwCwIUTUVGYTSAM3YSwc9/Ac1g=
+go.etcd.io/etcd/client/pkg/v3 v3.5.6
h1:TXQWYceBKqLp4sa87rcPs11SXxUA/mHwH975v+BDvLU=
+go.etcd.io/etcd/client/pkg/v3 v3.5.6/go.mod
h1:ggrwbk069qxpKPq8/FKkQ3Xq9y39kbFR4LnKszpRXeQ=
go.etcd.io/etcd/client/v2 v2.305.0-alpha.0
h1:jZepGpOeJATxsbMNBZczDS2jHdK/QVHM1iPe9jURJ8o=
go.etcd.io/etcd/client/v2 v2.305.0-alpha.0/go.mod
h1:kdV+xzCJ3luEBSIeQyB/OEKkWKd8Zkux4sbDeANrosU=
go.etcd.io/etcd/client/v3 v3.5.0-alpha.0/go.mod
h1:wKt7jgDgf/OfKiYmCq5WFGxOFAkVMLxiiXgLDFhECr8=
-go.etcd.io/etcd/client/v3 v3.5.4
h1:p83BUL3tAYS0OT/r0qglgc3M1JjhM0diV8DSWAhVXv4=
go.etcd.io/etcd/client/v3 v3.5.4/go.mod
h1:ZaRkVgBZC+L+dLCjTcF1hRXpgZXQPOvnA/Ak/gq3kiY=
+go.etcd.io/etcd/client/v3 v3.5.6
h1:coLs69PWCXE9G4FKquzNaSHrRyMCAXwF+IX1tAPVO8E=
+go.etcd.io/etcd/client/v3 v3.5.6/go.mod
h1:f6GRinRMCsFVv9Ht42EyY7nfsVGwrNO0WEoS2pRKzQk=
go.etcd.io/etcd/pkg/v3 v3.5.0-alpha.0
h1:3yLUEC0nFCxw/RArImOyRUI4OAFbg4PFpBbAhSNzKNY=
go.etcd.io/etcd/pkg/v3 v3.5.0-alpha.0/go.mod
h1:tV31atvwzcybuqejDoY3oaNRTtlD2l/Ot78Pc9w7DMY=
go.etcd.io/etcd/raft/v3 v3.5.0-alpha.0
h1:DvYJotxV9q1Lkn7pknzAbFO/CLtCVidCr2K9qRLJ8pA=
@@ -843,7 +877,6 @@ go.opencensus.io v0.22.4/go.mod
h1:yxeiOL68Rb0Xd1ddK5vPZ/oVn4vY4Ynel7k9FzqtOIw=
go.opencensus.io v0.23.0 h1:gqCw0LfLxScz8irSi8exQc7fyQ0fKQU/qnC/X8+V/1M=
go.opencensus.io v0.23.0/go.mod h1:XItmlyltB5F7CS4xOC1DcqMoFqwtC6OG2xF7mCv7P7E=
go.opentelemetry.io/otel v1.7.0/go.mod
h1:5BdUoMIz5WEs0vt0CUEMtSSaTSHBBVwrhnz7+nrD5xk=
-go.opentelemetry.io/otel v1.8.0/go.mod
h1:2pkj+iMj0o03Y+cW6/m8Y4WkRdYN3AvCXCnzRMp9yvM=
go.opentelemetry.io/otel v1.10.0/go.mod
h1:NbvWjCthWHKBEUMpf0/v8ZRZlni86PpGFEMA9pnQSnQ=
go.opentelemetry.io/otel v1.11.0
h1:kfToEGMDq6TrVrJ9Vht84Y8y9enykSZzDDZglV0kIEk=
go.opentelemetry.io/otel v1.11.0/go.mod
h1:H2KtuEphyMvlhZ+F7tg9GRhAOe60moNx61Ex+WmiKkk=
@@ -852,7 +885,6 @@ go.opentelemetry.io/otel/exporters/jaeger v1.10.0/go.mod
h1:n9IGyx0fgyXXZ/i0foLH
go.opentelemetry.io/otel/sdk v1.10.0
h1:jZ6K7sVn04kk/3DNUdJ4mqRlGDiXAVuIG+MMENpTNdY=
go.opentelemetry.io/otel/sdk v1.10.0/go.mod
h1:vO06iKzD5baltJz1zarxMCNHFpUlUiOy4s65ECtn6kE=
go.opentelemetry.io/otel/trace v1.7.0/go.mod
h1:fzLSB9nqR2eXzxPXb2JW9IKE+ScyXA48yyE4TNvoHqU=
-go.opentelemetry.io/otel/trace v1.8.0/go.mod
h1:0Bt3PXY8w+3pheS3hQUt+wow8b1ojPaTBoTCh2zIFI4=
go.opentelemetry.io/otel/trace v1.10.0/go.mod
h1:Sij3YYczqAdz+EhmGhE6TpTxUO5/F/AzrK+kxfGqySM=
go.opentelemetry.io/otel/trace v1.11.0
h1:20U/Vj42SX+mASlXLmSGBg6jpI1jQtv682lZtTAOVFI=
go.opentelemetry.io/otel/trace v1.11.0/go.mod
h1:nyYjis9jy0gytE9LXGU+/m1sHTKbRY0fX0hulNNDP1U=
@@ -870,8 +902,9 @@ go.uber.org/goleak v1.1.11/go.mod
h1:cwTWslyiVhfpKIDGSZEM2HlOvcqm+tG4zioyIeLoqMQ
go.uber.org/multierr v1.1.0/go.mod
h1:wR5kodmAFQ0UK8QlbwjlSNy0Z68gJhDJUG5sjR94q/0=
go.uber.org/multierr v1.3.0/go.mod
h1:VgVr7evmIr6uPjLBxg28wmKNXyqE9akIJ5XnfpiKl+4=
go.uber.org/multierr v1.5.0/go.mod
h1:FeouvMocqHpRaaGuG9EjoKcStLC43Zu/fmqdUMPcKYU=
-go.uber.org/multierr v1.6.0 h1:y6IPFStTAIT5Ytl7/XYmHvzXQ7S3g/IeZW9hyZ5thw4=
go.uber.org/multierr v1.6.0/go.mod
h1:cdWPpRnG4AhwMwsgIHip0KRBQjJy5kYEpYjJxpXp9iU=
+go.uber.org/multierr v1.8.0 h1:dg6GjLku4EH+249NNmoIciG9N/jURbDG+pFlTkhzIC8=
+go.uber.org/multierr v1.8.0/go.mod
h1:7EAYxJLBy9rStEaz58O2t4Uvip6FSURkq8/ppBp95ak=
go.uber.org/tools v0.0.0-20190618225709-2cfd321de3ee/go.mod
h1:vJERXedbb3MVM5f9Ejo0C68/HhF8uaILCdgjnY+goOA=
go.uber.org/zap v1.10.0/go.mod h1:vwi/ZaCAaUcBkycHslxD9B2zi4UTXhF60s6SWpuDF0Q=
go.uber.org/zap v1.13.0/go.mod h1:zwrFLgMcdUuIBviXEYEH1YKNaOBnKXsx2IPda5bBwHM=
@@ -887,6 +920,7 @@ golang.org/x/crypto
v0.0.0-20190308221718-c2843e01d9a2/go.mod h1:djNgcEr1/C05ACk
golang.org/x/crypto v0.0.0-20190510104115-cbcb75029529/go.mod
h1:yigFU9vqHzYiE8UmvKecakEJjdnWj3jj499lnFckfCI=
golang.org/x/crypto v0.0.0-20190605123033-f99c8df09eb5/go.mod
h1:yigFU9vqHzYiE8UmvKecakEJjdnWj3jj499lnFckfCI=
golang.org/x/crypto v0.0.0-20190701094942-4def268fd1a4/go.mod
h1:yigFU9vqHzYiE8UmvKecakEJjdnWj3jj499lnFckfCI=
+golang.org/x/crypto v0.0.0-20190923035154-9ee001bba392/go.mod
h1:/lpIB1dKB+9EgE3H3cr1v9wB50oz8l4C4h62xy7jSTY=
golang.org/x/crypto v0.0.0-20191011191535-87dc89f01550/go.mod
h1:yigFU9vqHzYiE8UmvKecakEJjdnWj3jj499lnFckfCI=
golang.org/x/crypto v0.0.0-20200622213623-75b288015ac9/go.mod
h1:LzIPMQfyMNhhGPhUkYOs5KpL4U8rLKemX1yGLhDgUto=
golang.org/x/crypto v0.0.0-20201002170205-7f63de1d35b0/go.mod
h1:LzIPMQfyMNhhGPhUkYOs5KpL4U8rLKemX1yGLhDgUto=
@@ -956,6 +990,7 @@ golang.org/x/net v0.0.0-20190620200207-3b0461eec859/go.mod
h1:z5CRVTTTmAJ677TzLL
golang.org/x/net v0.0.0-20190628185345-da137c7871d7/go.mod
h1:z5CRVTTTmAJ677TzLLGU+0bjPO0LkuOLi4/5GtJWs/s=
golang.org/x/net v0.0.0-20190724013045-ca1201d0de80/go.mod
h1:z5CRVTTTmAJ677TzLLGU+0bjPO0LkuOLi4/5GtJWs/s=
golang.org/x/net v0.0.0-20190813141303-74dc4d7220e7/go.mod
h1:z5CRVTTTmAJ677TzLLGU+0bjPO0LkuOLi4/5GtJWs/s=
+golang.org/x/net v0.0.0-20190923162816-aa69164e4478/go.mod
h1:z5CRVTTTmAJ677TzLLGU+0bjPO0LkuOLi4/5GtJWs/s=
golang.org/x/net v0.0.0-20191002035440-2ec189313ef0/go.mod
h1:z5CRVTTTmAJ677TzLLGU+0bjPO0LkuOLi4/5GtJWs/s=
golang.org/x/net v0.0.0-20191209160850-c0dbc17a3553/go.mod
h1:z5CRVTTTmAJ677TzLLGU+0bjPO0LkuOLi4/5GtJWs/s=
golang.org/x/net v0.0.0-20200114155413-6afb5195e5aa/go.mod
h1:z5CRVTTTmAJ677TzLLGU+0bjPO0LkuOLi4/5GtJWs/s=
@@ -977,12 +1012,14 @@ golang.org/x/net
v0.0.0-20201110031124-69a78807bb2b/go.mod h1:sp8m0HH+o8qH0wwXwY
golang.org/x/net v0.0.0-20201202161906-c7110b5ffcbb/go.mod
h1:sp8m0HH+o8qH0wwXwYZr8TS3Oi6o0r6Gce1SSxlDquU=
golang.org/x/net v0.0.0-20210226172049-e18ecbb05110/go.mod
h1:m0MpNAwzfU5UDzcl9v0D8zg8gWTRqZa9RBIspLL5mdg=
golang.org/x/net v0.0.0-20210405180319-a5a99cb37ef4/go.mod
h1:p54w0d4576C0XHj96bSt6lcn1PtDYWL6XObtHCRCNQM=
+golang.org/x/net v0.0.0-20210410081132-afb366fc7cd1/go.mod
h1:9tjilg8BloeKEkVJvy7fQ90B1CfIiPueXVOjqfkSzI8=
golang.org/x/net v0.0.0-20210525063256-abc453219eb5/go.mod
h1:9nx3DQGgdP8bBQD5qxJ1jj9UTztislL4KSBs9R2vV5Y=
golang.org/x/net v0.0.0-20210917221730-978cfadd31cf/go.mod
h1:9nx3DQGgdP8bBQD5qxJ1jj9UTztislL4KSBs9R2vV5Y=
golang.org/x/net v0.0.0-20211015210444-4f30a5c0130f/go.mod
h1:9nx3DQGgdP8bBQD5qxJ1jj9UTztislL4KSBs9R2vV5Y=
golang.org/x/net v0.0.0-20211029224645-99673261e6eb/go.mod
h1:9nx3DQGgdP8bBQD5qxJ1jj9UTztislL4KSBs9R2vV5Y=
golang.org/x/net v0.0.0-20211105192438-b53810dc28af/go.mod
h1:9nx3DQGgdP8bBQD5qxJ1jj9UTztislL4KSBs9R2vV5Y=
golang.org/x/net v0.0.0-20211112202133-69e39bad7dc2/go.mod
h1:9nx3DQGgdP8bBQD5qxJ1jj9UTztislL4KSBs9R2vV5Y=
+golang.org/x/net v0.0.0-20220425223048-2871e0cb64e4/go.mod
h1:CfG3xpIq0wQ8r1q4Su4UZFWDARRcnwPjda9FqA0JpMk=
golang.org/x/net v0.0.0-20220722155237-a158d28d115b
h1:PxfKdU9lEEDYjdIzOtC4qFWgkU2rGHdKlKowJSMN9h0=
golang.org/x/net v0.0.0-20220722155237-a158d28d115b/go.mod
h1:XRhObCWvk6IyKnWLug+ECip1KBveYUHfp+8e9klMJ9c=
golang.org/x/oauth2 v0.0.0-20180821212333-d2e6202438be/go.mod
h1:N/0e6XlmueqKjAGxoOufVs8QHGRruUQn6yWY3a++T0U=
@@ -1028,6 +1065,8 @@ golang.org/x/sys
v0.0.0-20190624142023-c5567b49c5d0/go.mod h1:h1NjWce9XRLGQEsW7w
golang.org/x/sys v0.0.0-20190726091711-fc99dfbffb4e/go.mod
h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
golang.org/x/sys v0.0.0-20190826190057-c7b8b68b1456/go.mod
h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
golang.org/x/sys v0.0.0-20190916202348-b4ddaad3f8a3/go.mod
h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
+golang.org/x/sys v0.0.0-20190922100055-0a153f010e69/go.mod
h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
+golang.org/x/sys v0.0.0-20190924154521-2837fb4f24fe/go.mod
h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
golang.org/x/sys v0.0.0-20191001151750-bb3f8db39f24/go.mod
h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
golang.org/x/sys v0.0.0-20191005200804-aed5e4c7ecf9/go.mod
h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
golang.org/x/sys v0.0.0-20191008105621-543471e840be/go.mod
h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
@@ -1039,6 +1078,7 @@ golang.org/x/sys
v0.0.0-20200106162015-b016eb3dc98e/go.mod h1:h1NjWce9XRLGQEsW7w
golang.org/x/sys v0.0.0-20200113162924-86b910548bc1/go.mod
h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
golang.org/x/sys v0.0.0-20200116001909-b77594299b42/go.mod
h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
golang.org/x/sys v0.0.0-20200122134326-e047566fdf82/go.mod
h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
+golang.org/x/sys v0.0.0-20200124204421-9fbb57f87de9/go.mod
h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
golang.org/x/sys v0.0.0-20200202164722-d101bd2416d5/go.mod
h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
golang.org/x/sys v0.0.0-20200212091648-12a6c2dcc1e4/go.mod
h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
golang.org/x/sys v0.0.0-20200223170610-d5e6a3e2c0ae/go.mod
h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
@@ -1061,6 +1101,7 @@ golang.org/x/sys
v0.0.0-20201214210602-f9fddec55a1e/go.mod h1:h1NjWce9XRLGQEsW7w
golang.org/x/sys v0.0.0-20201223074533-0d417f636930/go.mod
h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
golang.org/x/sys v0.0.0-20210119212857-b64e53b001e4/go.mod
h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
golang.org/x/sys v0.0.0-20210124154548-22da62e12c0c/go.mod
h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
+golang.org/x/sys v0.0.0-20210303074136-134d130e1a04/go.mod
h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
golang.org/x/sys v0.0.0-20210316164454-77fc1eacc6aa/go.mod
h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
golang.org/x/sys v0.0.0-20210330210617-4fbd30eecc44/go.mod
h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
golang.org/x/sys v0.0.0-20210403161142-5e06dd20ab57/go.mod
h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
@@ -1075,13 +1116,16 @@ golang.org/x/sys
v0.0.0-20210816074244-15123e1e1f71/go.mod h1:oPkhp1MJrh7nUepCBc
golang.org/x/sys v0.0.0-20211019181941-9d821ace8654/go.mod
h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
golang.org/x/sys v0.0.0-20211106132015-ebca88c72f68/go.mod
h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
golang.org/x/sys v0.0.0-20211117180635-dee7805ff2e1/go.mod
h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
+golang.org/x/sys v0.0.0-20211216021012-1d35b9e2eb4e/go.mod
h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
golang.org/x/sys v0.0.0-20220111092808-5a964db01320/go.mod
h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
golang.org/x/sys v0.0.0-20220114195835-da31bd327af9/go.mod
h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
golang.org/x/sys v0.0.0-20220128215802-99c3d69c2c27/go.mod
h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
golang.org/x/sys v0.0.0-20220412211240-33da011f77ad/go.mod
h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
+golang.org/x/sys v0.0.0-20220503163025-988cb79eb6c6/go.mod
h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
golang.org/x/sys v0.0.0-20220520151302-bc2c85ada10a/go.mod
h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
-golang.org/x/sys v0.0.0-20220722155257-8c9f86f7a55f
h1:v4INt8xihDGvnrfjMDVXGxw9wrfxYyCjk0KbXjhR55s=
golang.org/x/sys v0.0.0-20220722155257-8c9f86f7a55f/go.mod
h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
+golang.org/x/sys v0.0.0-20220908164124-27713097b956
h1:XeJjHH1KiLpKGb6lvMiksZ9l0fVUh+AmGcm0nOMEBOY=
+golang.org/x/sys v0.0.0-20220908164124-27713097b956/go.mod
h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
golang.org/x/term v0.0.0-20201126162022-7de9c90e9dd1/go.mod
h1:bj7SfCRtBDWHUb9snDiAeCFNEtKQo2Wmx5Cou7ajbmo=
golang.org/x/term v0.0.0-20210927222741-03fcf44c2211/go.mod
h1:jbD1KX2456YbFQfuXm/mYQcufACuNUgVhRMnK/tPxf8=
golang.org/x/text v0.0.0-20170915032832-14c0d48ead0c/go.mod
h1:NqM8EUOU14njkJ3fqMW+pc6Ldnwhi/IjpwHt7yyuwOQ=
@@ -1100,8 +1144,9 @@ golang.org/x/time
v0.0.0-20181108054448-85acf8d2951c/go.mod h1:tRJNPiyCQ0inRvYxb
golang.org/x/time v0.0.0-20190308202827-9d24e82272b4/go.mod
h1:tRJNPiyCQ0inRvYxbN9jk5I+vvW/OXSQhTDSoE431IQ=
golang.org/x/time v0.0.0-20191024005414-555d28b269f0/go.mod
h1:tRJNPiyCQ0inRvYxbN9jk5I+vvW/OXSQhTDSoE431IQ=
golang.org/x/time v0.0.0-20200630173020-3af7569d3a1e/go.mod
h1:tRJNPiyCQ0inRvYxbN9jk5I+vvW/OXSQhTDSoE431IQ=
-golang.org/x/time v0.0.0-20201208040808-7e3f01d25324
h1:Hir2P/De0WpUhtrKGGjvSb2YxUgyZ7EFOSLIcSSpiwE=
golang.org/x/time v0.0.0-20201208040808-7e3f01d25324/go.mod
h1:tRJNPiyCQ0inRvYxbN9jk5I+vvW/OXSQhTDSoE431IQ=
+golang.org/x/time v0.0.0-20220722155302-e5dcc9cfc0b9
h1:ftMN5LMiBFjbzleLqtoBZk7KdJwhuybIU+FckUHgoyQ=
+golang.org/x/time v0.0.0-20220722155302-e5dcc9cfc0b9/go.mod
h1:tRJNPiyCQ0inRvYxbN9jk5I+vvW/OXSQhTDSoE431IQ=
golang.org/x/tools v0.0.0-20180221164845-07fd8470d635/go.mod
h1:n7NCudcB/nEzxVGmLbDWY5pfWTLqBcC2KZ6jyYvM4mQ=
golang.org/x/tools v0.0.0-20180525024113-a5b4c53f6e8b/go.mod
h1:n7NCudcB/nEzxVGmLbDWY5pfWTLqBcC2KZ6jyYvM4mQ=
golang.org/x/tools v0.0.0-20180828015842-6cd1fcedba52/go.mod
h1:n7NCudcB/nEzxVGmLbDWY5pfWTLqBcC2KZ6jyYvM4mQ=
@@ -1121,6 +1166,7 @@ golang.org/x/tools
v0.0.0-20190606124116-d0a3d012864b/go.mod h1:/rFqwRUd4F7ZHNgw
golang.org/x/tools v0.0.0-20190621195816-6e04913cbbac/go.mod
h1:/rFqwRUd4F7ZHNgwSSTFct+R/Kf4OFW1sUzUTQQTgfc=
golang.org/x/tools v0.0.0-20190628153133-6cdbf07be9d0/go.mod
h1:/rFqwRUd4F7ZHNgwSSTFct+R/Kf4OFW1sUzUTQQTgfc=
golang.org/x/tools v0.0.0-20190816200558-6889da9d5479/go.mod
h1:b+2E5dAYhXwXZwtnZ6UAqBI28+e2cm9otk0dWdXHAEo=
+golang.org/x/tools v0.0.0-20190907020128-2ca718005c18/go.mod
h1:b+2E5dAYhXwXZwtnZ6UAqBI28+e2cm9otk0dWdXHAEo=
golang.org/x/tools v0.0.0-20190911174233-4f2ddba30aff/go.mod
h1:b+2E5dAYhXwXZwtnZ6UAqBI28+e2cm9otk0dWdXHAEo=
golang.org/x/tools v0.0.0-20191012152004-8de300cfc20a/go.mod
h1:b+2E5dAYhXwXZwtnZ6UAqBI28+e2cm9otk0dWdXHAEo=
golang.org/x/tools v0.0.0-20191029041327-9cc4af7d6b2c/go.mod
h1:b+2E5dAYhXwXZwtnZ6UAqBI28+e2cm9otk0dWdXHAEo=
@@ -1156,6 +1202,7 @@ golang.org/x/tools
v0.0.0-20200825202427-b303f430e36d/go.mod h1:njjCfa9FT2d7l9Bc
golang.org/x/tools v0.0.0-20200928182047-19e03678916f/go.mod
h1:z6u4i615ZeAfBE4XtMziQW1fSVJXACjjbWkB/mvPzlU=
golang.org/x/tools v0.0.0-20201014170642-d1624618ad65/go.mod
h1:z6u4i615ZeAfBE4XtMziQW1fSVJXACjjbWkB/mvPzlU=
golang.org/x/tools v0.0.0-20210106214847-113979e3529a/go.mod
h1:emZCQorbCU4vsT4fOWvOPXz4eW1wZW4PmDk9uLelYpA=
+golang.org/x/tools v0.1.1/go.mod
h1:o0xws9oXOQQZyjljx8fwUC0k7L1pTE6eaCbjGeHmOkk=
golang.org/x/tools v0.1.2/go.mod
h1:o0xws9oXOQQZyjljx8fwUC0k7L1pTE6eaCbjGeHmOkk=
golang.org/x/tools v0.1.3/go.mod
h1:o0xws9oXOQQZyjljx8fwUC0k7L1pTE6eaCbjGeHmOkk=
golang.org/x/tools v0.1.5/go.mod
h1:o0xws9oXOQQZyjljx8fwUC0k7L1pTE6eaCbjGeHmOkk=
@@ -1235,8 +1282,9 @@ google.golang.org/genproto
v0.0.0-20200825200019-8632dd797987/go.mod h1:FWY/as6D
google.golang.org/genproto v0.0.0-20210106152847-07624b53cd92/go.mod
h1:FWY/as6DDZQgahTzZj3fqbO1CbirC29ZNUFHwi0/+no=
google.golang.org/genproto v0.0.0-20210602131652-f16073e35f0c/go.mod
h1:UODoCrxHCcBojKKwX1terBiRUaqAsFqJiF615XL43r0=
google.golang.org/genproto v0.0.0-20210624195500-8bfb893ecb84/go.mod
h1:SzzZ/N+nwJDaO1kznhnlzqS8ocJICar6hYhVyhi++24=
-google.golang.org/genproto v0.0.0-20211104193956-4c6863e31247
h1:ZONpjmFT5e+I/0/xE3XXbG5OIvX2hRYzol04MhKBl2E=
google.golang.org/genproto v0.0.0-20211104193956-4c6863e31247/go.mod
h1:5CzLGKJ67TSI2B9POpiiyGha0AjJvZIUgRMt1dSmuhc=
+google.golang.org/genproto v0.0.0-20220504150022-98cd25cafc72
h1:iif0mpUetMBqcQPUoq+JnCcmzvfpp8wRx515va8wP1c=
+google.golang.org/genproto v0.0.0-20220504150022-98cd25cafc72/go.mod
h1:RAyBrSAP7Fh3Nc84ghnVLDPuV51xc9agzmm4Ph6i0Q4=
google.golang.org/grpc v1.8.0/go.mod
h1:yo6s7OP7yaDglbqo1J04qKzAhqBH6lvTonzMVmEdcZw=
google.golang.org/grpc v1.14.0/go.mod
h1:yo6s7OP7yaDglbqo1J04qKzAhqBH6lvTonzMVmEdcZw=
google.golang.org/grpc v1.17.0/go.mod
h1:6QZJwpn2B+Zp71q/5VxRsJ6NXXVCE5NRUHRo+f3cWCs=
@@ -1266,6 +1314,8 @@ google.golang.org/grpc v1.40.0/go.mod
h1:ogyxbiOoUXAkP+4+xa6PZSE9DZgIHtSpzjDTB9K
google.golang.org/grpc v1.41.0/go.mod
h1:U3l9uK9J0sini8mHphKoXyaqDA/8VyGnDee1zzIUK6k=
google.golang.org/grpc v1.42.0/go.mod
h1:k+4IHHFw41K8+bbowsex27ge2rCb65oeWqe4jJ590SU=
google.golang.org/grpc v1.45.0/go.mod
h1:lN7owxKUQEqMfSyQikvvk5tf/6zMPsrK+ONuO11+0rQ=
+google.golang.org/grpc v1.46.0/go.mod
h1:vN9eftEi1UMyUsIF80+uQXhHjbXYbm0uXoFCACuMGWk=
+google.golang.org/grpc v1.46.2/go.mod
h1:vN9eftEi1UMyUsIF80+uQXhHjbXYbm0uXoFCACuMGWk=
google.golang.org/grpc v1.47.0/go.mod
h1:vN9eftEi1UMyUsIF80+uQXhHjbXYbm0uXoFCACuMGWk=
google.golang.org/grpc v1.48.0/go.mod
h1:vN9eftEi1UMyUsIF80+uQXhHjbXYbm0uXoFCACuMGWk=
google.golang.org/grpc v1.51.0 h1:E1eGv1FTqoLIdnBCZufiSHgKjlqG6fKFf6pPWtMTh8U=
@@ -1299,8 +1349,9 @@ gopkg.in/errgo.v2 v2.1.0/go.mod
h1:hNsd1EY+bozCKY1Ytp96fpM3vjJbqLJn88ws8XvfDNI=
gopkg.in/fsnotify.v1 v1.4.7/go.mod
h1:Tz8NjZHkW78fSQdbUxIjBTcgA1z1m8ZHf0WmKUhAMys=
gopkg.in/gcfg.v1 v1.2.3/go.mod h1:yesOnuUOFQAhST5vPY4nbZsb/huCgGGXlipJsBn0b3o=
gopkg.in/ini.v1 v1.42.0/go.mod h1:pNLf8WUiyNEtQjuu5G5vTm06TEv9tsIgeAvK8hOrP4k=
-gopkg.in/ini.v1 v1.51.0 h1:AQvPpx3LzTDM0AjnIRlVFwFFGC+npRopjZxLJj6gdno=
gopkg.in/ini.v1 v1.51.0/go.mod h1:pNLf8WUiyNEtQjuu5G5vTm06TEv9tsIgeAvK8hOrP4k=
+gopkg.in/ini.v1 v1.66.2 h1:XfR1dOYubytKy4Shzc2LHrrGhU0lDCfDGG1yLPmpgsI=
+gopkg.in/ini.v1 v1.66.2/go.mod h1:pNLf8WUiyNEtQjuu5G5vTm06TEv9tsIgeAvK8hOrP4k=
gopkg.in/natefinch/lumberjack.v2 v2.0.0
h1:1Lc07Kr7qY4U2YPouBjpCLxpiyxIVoxqXgkXLknAOE8=
gopkg.in/natefinch/lumberjack.v2 v2.0.0/go.mod
h1:l0ndWWf7gzL7RNwBG7wST/UCcT4T24xpD6X8LsfU/+k=
gopkg.in/resty.v1 v1.12.0/go.mod
h1:mDo4pnntr5jdWRML875a/NmxYqAlA73dVijT2AXvQQo=
@@ -1319,7 +1370,6 @@ gopkg.in/yaml.v2 v2.4.0
h1:D8xgwECY7CYvx+Y2n4sBz93Jn9JRvxdiyyo8CTfuKaY=
gopkg.in/yaml.v2 v2.4.0/go.mod h1:RDklbk79AGWmwhnvt/jBztapEOGDOx6ZbXqjP6csGnQ=
gopkg.in/yaml.v3 v3.0.0-20200313102051-9f266ea9e77c/go.mod
h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=
gopkg.in/yaml.v3 v3.0.0-20210107192922-496545a6307b/go.mod
h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=
-gopkg.in/yaml.v3 v3.0.0/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=
gopkg.in/yaml.v3 v3.0.1 h1:fxVm/GzAzEWqLHuvctI91KS9hhNmmWOoWu0XTYJS7CA=
gopkg.in/yaml.v3 v3.0.1/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=
gotest.tools v2.2.0+incompatible/go.mod
h1:DsYFclhRJ6vuDpmuTbkuFWG+y2sxOXAzmJt81HFBacw=
diff --git a/polaris/limit/README-zh.md b/polaris/limit/README-zh.md
new file mode 100644
index 00000000..70d059d0
--- /dev/null
+++ b/polaris/limit/README-zh.md
@@ -0,0 +1,91 @@
+# Dubbo Go & Polaris TpsLimiter Example
+
+[English](./README.md) | 中文
+
+## 使用服务限流功能
+
+在 dubbogo 中快速体验北极星的服务限流能力
+
+## 北极星服务端安装
+
+[北极星服务端单机版本安装文档](https://polarismesh.cn/docs/%E4%BD%BF%E7%94%A8%E6%8C%87%E5%8D%97/%E6%9C%8D%E5%8A%A1%E7%AB%AF%E5%AE%89%E8%A3%85/%E5%8D%95%E6%9C%BA%E7%89%88%E5%AE%89%E8%A3%85/)
+
+[北极星服务端集群版本安装文档](https://polarismesh.cn/docs/%E4%BD%BF%E7%94%A8%E6%8C%87%E5%8D%97/%E6%9C%8D%E5%8A%A1%E7%AB%AF%E5%AE%89%E8%A3%85/%E9%9B%86%E7%BE%A4%E7%89%88%E5%AE%89%E8%A3%85/)
+
+## 如何使用
+
+[北极星服务限流使用文档](https://polarismesh.cn/docs/%E5%8C%97%E6%9E%81%E6%98%9F%E6%98%AF%E4%BB%80%E4%B9%88/%E5%8A%9F%E8%83%BD%E7%89%B9%E6%80%A7/%E6%B5%81%E9%87%8F%E7%AE%A1%E7%90%86/#%E8%AE%BF%E9%97%AE%E9%99%90%E6%B5%81)
+
+### dubbogo.yaml 配置文件
+
+在使用 PolarisMesh 的服务限流能力时，需要先启用 PolarisMesh 在 dubbogo 中的注册发现功能。
+
+```yaml
+dubbo:
+ registries:
+ polarisMesh:
+ protocol: polaris
+ address: ${北极星服务端IP}:8091
+ namespace: ${北极星命名空间信息}
+ token: ${北极星资源鉴权 token} # 如果北极星服务端开启了针对客户端的鉴权，则需要配置该参数
+ provider:
+ services:
+ UserProvider:
+ interface: org.apache.dubbo.UserProvider.Test
+ tps.limiter: polaris-limit # 配置 tps.limiter 为 polaris-limiter 即可
+
+```
+
+注意：PolarisMesh 的服务限流能力是工作在 Provider 侧的。
+
+### 如何配置服务限流参数
+
+dubbogo 中的 PolarisMesh TpsLimiter 扩展点实现，能够根据用户配置的限流规则，自动的从当前 RPC
调用上下文以及请求信息中识别出需要参与限流的请求标签信息
+
+
+
+- 请求匹配规则为 **请求参数(QUERY)**
+ - 标签来源: RPC 调用中方法的入参，即 Invoaction.Arguments()
+ - 标签键规则
+ - 方法仅有一个入参: param.$.${fieldName}, **param.** 为固定前缀，后面的表达式为标准的 JSONPath
expressions，[参考文档](https://goessner.net/articles/JsonPath/)
+ - 方法有多个参数: param[${index}].$.${fieldName}, **param[${index}].**
为固定前缀，${index} 代表是方法入参中的第几个参数，下标起始位置从 0 开始；后面的表达式为标准的 JSONPath
expressions，[参考文档](https://goessner.net/articles/JsonPath/)
+- 请求匹配规则为 **请求头(HEADER)**:
+ - 标签来源: RPC 调用的额外标签信息，即 Invoaction.Attachments()
+
+### 运行服务提供者
+
+进入 go-server 的 cmd 目录，执行以下命令
+
+```
+ export DUBBO_GO_CONFIG_PATH="../conf/dubbogo.yaml"
+ go run .
+```
+
+当看到以下日志时即表示 server 端启动成功
+
+```log
+INFO dubbo/dubbo_protocol.go:84 [DUBBO Protocol] Export service:
+```
+
+
+### 运行服务调用者
+
+进入 go-client 的 cmd 目录，执行以下命令
+
+
+```
+ export DUBBO_GO_CONFIG_PATH="../conf/dubbogo.yml"
+ go run .
+```
+
+当看到以下日志时即表示 go-client 成功发现 go-server 并发起了 RPC 调用
+
+```log
+INFO cmd/main.go:75 response: &{A001 Alex Stocks 18 2022-11-19
12:52:38.092 +0800 CST}
+```
+
+当看到以下日志时即表示在 PolarisMesh 针对 go-server 配置的限流策略已生效
+
+```log
+ERROR handler/rejected_execution_handler_only_log.go:73 The invocation
was rejected
+```
diff --git a/polaris/limit/README.md b/polaris/limit/README.md
new file mode 100644
index 00000000..74a1c08c
--- /dev/null
+++ b/polaris/limit/README.md
@@ -0,0 +1,91 @@
+# Dubbo Go & Polaris TpsLimiter Example
+
+English | [中文](./README-zh.md)
+
+## Use the service current limit function
+
+Quickly experience Polaris' service current limiting capabilities in dubbogo
+
+## Polaris server installation
+
+[Polaris Server Standalone Version Installation
Documentation](https://polarismesh.cn/docs/%E4%BD%BF%E7%94%A8%E6%8C%87%E5%8D%97/%E6%9C%8D%E5%8A%A1%E7%AB%AF%E5%AE%89%E8%A3%85/%E5%8D%95%E6%9C%BA%E7%89%88%E5%AE%89%E8%A3%85/)
+
+[Polaris Server Cluster Version Installation
Documentation](https://polarismesh.cn/docs/%E4%BD%BF%E7%94%A8%E6%8C%87%E5%8D%97/%E6%9C%8D%E5%8A%A1%E7%AB%AF%E5%AE%89%E8%A3%85/%E9%9B%86%E7%BE%A4%E7%89%88%E5%AE%89%E8%A3%85/)
+
+## how to use
+
+[Polaris Service Current Limitation
Documentation](https://polarismesh.cn/docs/%E5%8C%97%E6%9E%81%E6%98%9F%E6%98%AF%E4%BB%80%E4%B9%88/%E5%8A%9F%E8%83%BD%E7%89%B9%E6%80%A7/%E6%B5%81%E9%87%8F%E7%AE%A1%E7%90%86/#%E8%AE%BF%E9%97%AE%E9%99%90%E6%B5%81)
+
+### dubbogo.yaml configuration file
+
+When using PolarisMesh's service current limiting capability, you need to
enable PolarisMesh's registration discovery function in dubbogo firstly.
+
+````yaml
+dubbo:
+ registries:
+ polarisMesh:
+ protocol: polaris
+ address: ${Polaris server IP}:8091
+ namespace: ${Polaris namespace information}
+ token: ${Polaris resource authentication token} # If the Polaris server
has enabled authentication for the client, you need to configure this parameter
+ provider:
+ services:
+ UserProvider:
+ interface: org.apache.dubbo.UserProvider.Test
+ tps.limiter: polaris-limit # Configure tps.limiter as polaris-limiter
+
+````
+
+Note: The service current limiting capability of PolarisMesh works on the
Provider side.
+
+### How to configure service current limit parameters
+
+The implementation of the PolarisMesh TpsLimiter extension point in dubbogo
can automatically identify the request tag information that needs to
participate in current limiting from the current RPC call context and request
information according to the current limiting rules configured by the user.
+
+
+
+- The request matching rule is **Request parameter(QUERY)**
+ - Tag source: the input parameter of the method in the RPC call, namely
Invoaction.Arguments()
+ - Tag key rules
+ - The method has only one input parameter: param.$.${fieldName},
**param.** is a fixed prefix, the following expressions are standard JSONPath
expressions, [reference document](https://goessner.net/ articles/JsonPath/)
+ - The method has multiple parameters: param[${index}].$.${fieldName},
**param[${index}].** is a fixed prefix, ${index} represents the first parameter
in the method parameter Several parameters, the starting position of the
subscript starts from 0; the following expressions are standard JSONPath
expressions, [reference document](https://goessner.net/articles/JsonPath/)
+- The request matching rule is **request header (HEADER)**:
+ - Tag source: Additional tag information for RPC calls, i.e.
Invoaction.Attachments()
+
+### Running the service provider
+
+Enter the cmd directory of go-server and execute the following command
+
+````
+ export DUBBO_GO_CONFIG_PATH="../conf/dubbogo.yml"
+ go run .
+````
+
+When you see the following log, it means that the server side started
successfully
+
+````log
+INFO dubbo/dubbo_protocol.go:84 [DUBBO Protocol] Export service:
+````
+
+
+### Run the service caller
+
+Enter the cmd directory of go-client and execute the following command
+
+
+````
+ export DUBBO_GO_CONFIG_PATH="../conf/dubbogo.yml"
+ go run .
+````
+
+When you see the following log, it means that go-client successfully
discovered go-server and made an RPC call
+
+````log
+INFO cmd/main.go:75 response: &{A001 Alex Stocks 18 2022-11-19 12:52:38.092
+0800 CST}
+````
+
+When you see the following log, it means that the current limiting policy
configured for go-server in PolarisMesh has taken effect
+
+````log
+ERROR handler/rejected_execution_handler_only_log.go:73 The invocation was
rejected
+````
\ No newline at end of file
diff --git a/registry/polaris/go-client/cmd/main.go
b/polaris/limit/go-client/cmd/main.go
similarity index 79%
copy from registry/polaris/go-client/cmd/main.go
copy to polaris/limit/go-client/cmd/main.go
index e685d8a4..4acd43cb 100644
--- a/registry/polaris/go-client/cmd/main.go
+++ b/polaris/limit/go-client/cmd/main.go
@@ -19,7 +19,7 @@ package main
import (
"context"
- "os"
+ "errors"
"time"
)
@@ -63,19 +63,22 @@ func main() {
}
logger.Infof("\n\n\nstart to test dubbo")
- user, err := userProvider.GetUser(context.TODO(), &User{Name:
"Alex001"})
- if err != nil {
- logger.Errorf("error: %v\n", err)
- os.Exit(1)
- return
+
+ var successCount, failCount int64
+ for i := 0; i < 10; i++ {
+ time.Sleep(50 * time.Millisecond)
+ user, err := userProvider.GetUser(context.TODO(), &User{Name:
"Alex03"})
+ if err != nil {
+ failCount++
+ logger.Infof("error: %v\n", err)
+ } else {
+ successCount++
+ }
+ logger.Infof("response: %v\n", user)
}
- logger.Infof("response result: %v\n", user)
+ logger.Infof("successCount=%v, failCount=%v\n", successCount, failCount)
- user, err =
userProviderWithCustomRegistryGroupAndVersion.GetUser(context.TODO(),
&User{Name: "Alex001"})
- if err != nil {
- logger.Errorf("error: %v\n", err)
- os.Exit(1)
- return
+ if failCount == 0 {
+ panic(errors.New("need failCount > 0"))
}
- logger.Infof("response result: %v\n", user)
}
diff --git a/registry/polaris/go-client/conf/dubbogo.yaml
b/polaris/limit/go-client/conf/dubbogo.yml
similarity index 90%
copy from registry/polaris/go-client/conf/dubbogo.yaml
copy to polaris/limit/go-client/conf/dubbogo.yml
index 53eb4143..25d68437 100644
--- a/registry/polaris/go-client/conf/dubbogo.yaml
+++ b/polaris/limit/go-client/conf/dubbogo.yml
@@ -10,8 +10,8 @@ dubbo:
registries:
polarisMesh:
protocol: polaris
- address: 127.0.0.1:8091
- namespace: default
+ address: 183.47.111.80:8091
+ namespace: dubbogo
consumer:
references:
UserProvider:
@@ -20,4 +20,4 @@ dubbo:
UserProviderWithCustomGroupAndVersion:
protocol: dubbo
interface: org.apache.dubbo.UserProvider.Test2
- version: myInterfaceVersion # dubbo interface version must be same
with server
\ No newline at end of file
+ version: myInterfaceVersion # dubbo interface version must be same
with server
diff --git a/registry/polaris/go-server/cmd/server.go
b/polaris/limit/go-server/cmd/server.go
similarity index 98%
copy from registry/polaris/go-server/cmd/server.go
copy to polaris/limit/go-server/cmd/server.go
index 033dccf6..e201020a 100644
--- a/registry/polaris/go-server/cmd/server.go
+++ b/polaris/limit/go-server/cmd/server.go
@@ -28,6 +28,7 @@ import (
import (
"dubbo.apache.org/dubbo-go/v3/config"
+ _ "dubbo.apache.org/dubbo-go/v3/filter/tps/strategy"
_ "dubbo.apache.org/dubbo-go/v3/imports"
hessian "github.com/apache/dubbo-go-hessian2"
diff --git a/registry/polaris/go-server/conf/dubbogo.yaml
b/polaris/limit/go-server/conf/dubbogo.yaml
similarity index 72%
copy from registry/polaris/go-server/conf/dubbogo.yaml
copy to polaris/limit/go-server/conf/dubbogo.yaml
index 06fd8fb2..1da19714 100644
--- a/registry/polaris/go-server/conf/dubbogo.yaml
+++ b/polaris/limit/go-server/conf/dubbogo.yaml
@@ -10,8 +10,8 @@ dubbo:
registries:
polarisMesh:
protocol: polaris
- address: 127.0.0.1:8091
- namespace: default
+ address: 183.47.111.80:8091
+ namespace: dubbogo
protocols:
dubbo:
name: dubbo
@@ -20,7 +20,9 @@ dubbo:
services:
UserProvider:
interface: org.apache.dubbo.UserProvider.Test
+ tps.limiter: polaris-limit # the Limiter that judge if the TPS overs
the threshold, such as method-service or default
UserProviderWithCustomGroupAndVersion:
interface: org.apache.dubbo.UserProvider.Test2
version: myInterfaceVersion # dubbo interface version must be same
with client
- group: myInterfaceGroup # dubbo interface group must be same with
client
\ No newline at end of file
+ group: myInterfaceGroup # dubbo interface group must be same with
client
+ tps.limiter: polaris-limit # the Limiter that judge if the TPS overs
the threshold, such as method-service or default
diff --git a/polaris/limit/images/dubbogo-ratelimit-rule.png
b/polaris/limit/images/dubbogo-ratelimit-rule.png
new file mode 100644
index 00000000..efdd51ba
Binary files /dev/null and b/polaris/limit/images/dubbogo-ratelimit-rule.png
differ
diff --git a/polaris/registry/README-zh.md b/polaris/registry/README-zh.md
new file mode 100644
index 00000000..82a40424
--- /dev/null
+++ b/polaris/registry/README-zh.md
@@ -0,0 +1,62 @@
+# Dubbo Go & Polaris Registry Example
+
+English | [中文](./README-zh.md)
+
+## 使用服务注册发现功能
+
+在 dubbogo 中快速体验北极星的服务注册以及服务发现能力
+
+## 北极星服务端安装
+
+[北极星服务端单机版本安装文档](https://polarismesh.cn/docs/%E4%BD%BF%E7%94%A8%E6%8C%87%E5%8D%97/%E6%9C%8D%E5%8A%A1%E7%AB%AF%E5%AE%89%E8%A3%85/%E5%8D%95%E6%9C%BA%E7%89%88%E5%AE%89%E8%A3%85/)
+
+[北极星服务端集群版本安装文档](https://polarismesh.cn/docs/%E4%BD%BF%E7%94%A8%E6%8C%87%E5%8D%97/%E6%9C%8D%E5%8A%A1%E7%AB%AF%E5%AE%89%E8%A3%85/%E9%9B%86%E7%BE%A4%E7%89%88%E5%AE%89%E8%A3%85/)
+
+## 如何使用
+
+### dubbogo.yaml 配置文件
+
+当前 PolarisMesh 已实现了 dubbogo 的注册发现扩展点，因此你只需要调整你的 dubbogo.yaml 文件中的 registries
配置项，新增 protocol 为 polaris 的注册中心配置即可，可以参考下面的样例。
+
+```yaml
+dubbo:
+ registries:
+ polarisMesh:
+ protocol: polaris
+ address: ${北极星服务端IP}:8091
+ namespace: ${北极星命名空间信息}
+ token: ${北极星资源鉴权 token} # 如果北极星服务端开启了针对客户端的鉴权，则需要配置该参数
+```
+
+### 运行服务提供者
+
+进入 go-server 的 cmd 目录，执行以下命令
+
+```
+ export DUBBO_GO_CONFIG_PATH="../conf/dubbogo.yml"
+ go run .
+```
+
+当看到以下日志时即表示 server 端启动成功
+
+```log
+INFO dubbo/dubbo_protocol.go:84 [DUBBO Protocol] Export service:
+```
+
+
+### 运行服务调用者
+
+进入 go-client 的 cmd 目录，执行以下命令
+
+
+```
+ export DUBBO_GO_CONFIG_PATH="../conf/dubbogo.yml"
+ go run .
+```
+
+当看到以下日志时即表示 go-client 成功发现 go-server 并发起了 RPC 调用
+
+```log
+INFO cmd/main.go:75 response: &{A001 Alex Stocks 18 2022-11-19
12:52:38.092 +0800 CST}
+```
+
diff --git a/polaris/registry/README.md b/polaris/registry/README.md
new file mode 100644
index 00000000..b93cc325
--- /dev/null
+++ b/polaris/registry/README.md
@@ -0,0 +1,61 @@
+# Dubbo Go & Polaris Registry Example
+
+English | [中文](./README-zh.md)
+
+## Using the service registration discovery function
+
+Quickly experience Polaris' service registration and service discovery
capabilities in dubbogo
+
+## Polaris server installation
+
+[Polaris Server Standalone Version Installation
Documentation](https://polarismesh.cn/docs/%E4%BD%BF%E7%94%A8%E6%8C%87%E5%8D%97/%E6%9C%8D%E5%8A%A1%E7%AB%AF%E5%AE%89%E8%A3%85/%E5%8D%95%E6%9C%BA%E7%89%88%E5%AE%89%E8%A3%85/)
+
+[Polaris Server Cluster Version Installation
Documentation](https://polarismesh.cn/docs/%E4%BD%BF%E7%94%A8%E6%8C%87%E5%8D%97/%E6%9C%8D%E5%8A%A1%E7%AB%AF%E5%AE%89%E8%A3%85/%E9%9B%86%E7%BE%A4%E7%89%88%E5%AE%89%E8%A3%85/)
+
+## how to use
+
+### dubbogo.yaml configuration file
+
+Currently PolarisMesh has implemented the registration discovery extension
point of dubbogo, so you only need to adjust the registries configuration item
in your dubbogo.yaml file, and add the registry configuration of polaris as the
protocol. You can refer to the following example.
+
+````yaml
+dubbo:
+ registries:
+ polarisMesh:
+ protocol: polaris
+ address: ${Polaris server IP}:8091
+ namespace: ${Polaris namespace information}
+ token: ${Polaris resource authentication token} # If the Polaris server
has enabled authentication for the client, you need to configure this parameter
+````
+
+### Running the service provider
+
+Enter the cmd directory of go-server and execute the following command
+
+````
+ export DUBBO_GO_CONFIG_PATH="../conf/dubbogo.yml"
+ go run .
+````
+
+When you see the following log, it means that the server side started
successfully
+
+````log
+INFO dubbo/dubbo_protocol.go:84 [DUBBO Protocol] Export service:
+````
+
+
+### Run the service caller
+
+Enter the cmd directory of go-client and execute the following command
+
+
+````
+ export DUBBO_GO_CONFIG_PATH="../conf/dubbogo.yml"
+ go run .
+````
+
+When you see the following log, it means that go-client successfully
discovered go-server and made an RPC call
+
+````log
+INFO cmd/main.go:75 response: &{A001 Alex Stocks 18 2022-11-19 12:52:38.092
+0800 CST}
+````
\ No newline at end of file
diff --git a/registry/polaris/go-client/cmd/main.go
b/polaris/registry/go-client/cmd/main.go
similarity index 100%
copy from registry/polaris/go-client/cmd/main.go
copy to polaris/registry/go-client/cmd/main.go
diff --git a/registry/polaris/go-client/conf/dubbogo.yaml
b/polaris/registry/go-client/conf/dubbogo.yml
similarity index 90%
copy from registry/polaris/go-client/conf/dubbogo.yaml
copy to polaris/registry/go-client/conf/dubbogo.yml
index 53eb4143..2d08e702 100644
--- a/registry/polaris/go-client/conf/dubbogo.yaml
+++ b/polaris/registry/go-client/conf/dubbogo.yml
@@ -10,8 +10,8 @@ dubbo:
registries:
polarisMesh:
protocol: polaris
- address: 127.0.0.1:8091
- namespace: default
+ address: 183.47.111.80:8091
+ namespace: dubbogo
consumer:
references:
UserProvider:
diff --git a/registry/polaris/go-server/cmd/server.go
b/polaris/registry/go-server/cmd/server.go
similarity index 100%
copy from registry/polaris/go-server/cmd/server.go
copy to polaris/registry/go-server/cmd/server.go
diff --git a/registry/polaris/go-server/conf/dubbogo.yaml
b/polaris/registry/go-server/conf/dubbogo.yml
similarity index 91%
copy from registry/polaris/go-server/conf/dubbogo.yaml
copy to polaris/registry/go-server/conf/dubbogo.yml
index 06fd8fb2..7e54ac30 100644
--- a/registry/polaris/go-server/conf/dubbogo.yaml
+++ b/polaris/registry/go-server/conf/dubbogo.yml
@@ -10,8 +10,8 @@ dubbo:
registries:
polarisMesh:
protocol: polaris
- address: 127.0.0.1:8091
- namespace: default
+ address: 183.47.111.80:8091
+ namespace: dubbogo
protocols:
dubbo:
name: dubbo
diff --git a/polaris/router/README-zh.md b/polaris/router/README-zh.md
new file mode 100644
index 00000000..933ee346
--- /dev/null
+++ b/polaris/router/README-zh.md
@@ -0,0 +1,121 @@
+# Dubbo Go & Polaris Router Example
+
+[English](./README.md) | 中文
+
+## 使用服务路由功能
+
+在 dubbogo 中快速体验北极星的服务路由能力
+
+## 北极星服务端安装
+
+[北极星服务端单机版本安装文档](https://polarismesh.cn/docs/%E4%BD%BF%E7%94%A8%E6%8C%87%E5%8D%97/%E6%9C%8D%E5%8A%A1%E7%AB%AF%E5%AE%89%E8%A3%85/%E5%8D%95%E6%9C%BA%E7%89%88%E5%AE%89%E8%A3%85/)
+
+[北极星服务端集群版本安装文档](https://polarismesh.cn/docs/%E4%BD%BF%E7%94%A8%E6%8C%87%E5%8D%97/%E6%9C%8D%E5%8A%A1%E7%AB%AF%E5%AE%89%E8%A3%85/%E9%9B%86%E7%BE%A4%E7%89%88%E5%AE%89%E8%A3%85/)
+
+## 如何使用
+
+[北极星服务路由使用文档](https://polarismesh.cn/docs/%E5%8C%97%E6%9E%81%E6%98%9F%E6%98%AF%E4%BB%80%E4%B9%88/%E5%8A%9F%E8%83%BD%E7%89%B9%E6%80%A7/%E6%B5%81%E9%87%8F%E7%AE%A1%E7%90%86/#%E5%8A%A8%E6%80%81%E8%B7%AF%E7%94%B1)
+
+### dubbogo.yaml 配置文件
+
+在使用 PolarisMesh 的服务路由能力时，需要先启用 PolarisMesh 在 dubbogo 中的注册发现功能。
+
+```yaml
+dubbo:
+ registries:
+ polarisMesh:
+ protocol: polaris
+ address: ${北极星服务端IP}:8091
+ namespace: ${北极星命名空间信息}
+ token: ${北极星资源鉴权 token} # 如果北极星服务端开启了针对客户端的鉴权，则需要配置该参数
+ provider:
+ services:
+ UserProvider:
+ interface: org.apache.dubbo.UserProvider.Test
+```
+
+### 如何配置服务路由参数
+
+dubbogo 中的 PolarisMesh PriorityRouter 扩展点实现，能够根据用户配置的服务路由规则，自动的从当前 RPC
调用上下文以及请求信息中识别出需要参与服务路由的请求标签信息
+
+
+
+
+
+- 请求匹配规则为 **请求参数(QUERY)**
+ - 标签来源: RPC 调用中方法的入参，即 Invoaction.Arguments()
+ - 标签键规则
+ - 方法仅有一个入参: param.$.${fieldName}, **param.** 为固定前缀，后面的表达式为标准的 JSONPath
expressions，[参考文档](https://goessner.net/articles/JsonPath/)
+ - 方法有多个参数: param[${index}].$.${fieldName}, **param[${index}].**
为固定前缀，${index} 代表是方法入参中的第几个参数，下标起始位置从 0 开始；后面的表达式为标准的 JSONPath
expressions，[参考文档](https://goessner.net/articles/JsonPath/)
+- 请求匹配规则为 **请求头(HEADER)**:
+ - 标签来源: RPC 调用的额外标签信息，即 Invoaction.Attachments()
+
+### 运行服务提供者
+
+分别进入 server-prod、server-pre、server-dev 的 cmd 目录，执行以下命令
+
+```
+ export DUBBO_GO_CONFIG_PATH="../conf/dubbogo.yaml"
+ go run .
+```
+
+当看到以下日志时即表示 server 端启动成功
+
+```log
+INFO dubbo/dubbo_protocol.go:84 [DUBBO Protocol] Export service:
+```
+
+
+### 运行服务调用者
+
+进入 go-client 的 cmd 目录，执行以下命令
+
+
+```
+export DUBBO_GO_CONFIG_PATH="../conf/dubbogo.yml"
+export uid=user-1
+go run .
+```
+
+当看到以下日志时即表示 go-client 成功发现 go-server 并发起了 RPC 调用
+
+```log
+INFO cmd/main.go:75 response: &{A001 Alex Stocks 18 2022-11-19
12:52:38.092 +0800 CST}
+```
+
+分别执行以下命令
+
+```bash
+export uid=
+go run .
+
+export uid=user-1
+go run .
+
+export uid=user-2
+```
+
+当看到以下日志时即表示在 PolarisMesh 配置的路由策略已生效
+
+```log
+# export uid=
+2022-11-26T13:39:31.637+0800 INFO cmd/main.go:78 response: &{A001
[Prod] Alex Stocks 18 2022-11-26 13:39:31.637 +0800 CST}
+2022-11-26T13:39:31.842+0800 INFO cmd/main.go:78 response: &{A001
[Prod] Alex Stocks 18 2022-11-26 13:39:31.841 +0800 CST}
+2022-11-26T13:39:32.043+0800 INFO cmd/main.go:78 response: &{A001
[Prod] Alex Stocks 18 2022-11-26 13:39:32.043 +0800 CST}
+2022-11-26T13:39:32.247+0800 INFO cmd/main.go:78 response: &{A001
[Prod] Alex Stocks 18 2022-11-26 13:39:32.247 +0800 CST}
+2022-11-26T13:39:32.452+0800 INFO cmd/main.go:78 response: &{A001
[Prod] Alex Stocks 18 2022-11-26 13:39:32.452 +0800 CST}
+
+# export uid=user-1
+2022-11-26T13:39:51.053+0800 INFO cmd/main.go:78 response: &{A001 [Pre]
Alex Stocks 18 2022-11-26 13:39:51.053 +0800 CST}
+2022-11-26T13:39:51.257+0800 INFO cmd/main.go:78 response: &{A001 [Pre]
Alex Stocks 18 2022-11-26 13:39:51.257 +0800 CST}
+2022-11-26T13:39:51.459+0800 INFO cmd/main.go:78 response: &{A001 [Pre]
Alex Stocks 18 2022-11-26 13:39:51.459 +0800 CST}
+2022-11-26T13:39:51.662+0800 INFO cmd/main.go:78 response: &{A001 [Pre]
Alex Stocks 18 2022-11-26 13:39:51.662 +0800 CST}
+2022-11-26T13:39:51.866+0800 INFO cmd/main.go:78 response: &{A001 [Pre]
Alex Stocks 18 2022-11-26 13:39:51.866 +0800 CST}
+
+# export uid=user-2
+2022-11-26T13:42:39.351+0800 INFO cmd/main.go:78 response: &{A001 [Dev]
Alex Stocks 18 2022-11-26 13:42:39.351 +0800 CST}
+2022-11-26T13:42:39.555+0800 INFO cmd/main.go:78 response: &{A001 [Dev]
Alex Stocks 18 2022-11-26 13:42:39.555 +0800 CST}
+2022-11-26T13:42:39.760+0800 INFO cmd/main.go:78 response: &{A001 [Dev]
Alex Stocks 18 2022-11-26 13:42:39.76 +0800 CST}
+2022-11-26T13:42:39.962+0800 INFO cmd/main.go:78 response: &{A001 [Dev]
Alex Stocks 18 2022-11-26 13:42:39.961 +0800 CST}
+2022-11-26T13:42:40.165+0800 INFO cmd/main.go:78 response: &{A001 [Dev]
Alex Stocks 18 2022-11-26 13:42:40.165 +0800 CST}
+```
diff --git a/polaris/router/README.md b/polaris/router/README.md
new file mode 100644
index 00000000..c80aa783
--- /dev/null
+++ b/polaris/router/README.md
@@ -0,0 +1,121 @@
+# Dubbo Go & Polaris Router Example
+
+English | [中文](./README-zh.md)
+
+## Using the service routing function
+
+Quickly experience Polaris' service routing capabilities in dubbogo
+
+## Polaris server installation
+
+[Polaris Server Standalone Version Installation
Documentation](https://polarismesh.cn/docs/%E4%BD%BF%E7%94%A8%E6%8C%87%E5%8D%97/%E6%9C%8D%E5%8A%A1%E7%AB%AF%E5%AE%89%E8%A3%85/%E5%8D%95%E6%9C%BA%E7%89%88%E5%AE%89%E8%A3%85/)
+
+[Polaris Server Cluster Version Installation
Documentation](https://polarismesh.cn/docs/%E4%BD%BF%E7%94%A8%E6%8C%87%E5%8D%97/%E6%9C%8D%E5%8A%A1%E7%AB%AF%E5%AE%89%E8%A3%85/%E9%9B%86%E7%BE%A4%E7%89%88%E5%AE%89%E8%A3%85/)
+
+## how to use
+
+[Polaris Service Routing Usage
Document](https://polarismesh.cn/docs/%E5%8C%97%E6%9E%81%E6%98%9F%E6%98%AF%E4%BB%80%E4%B9%88/%E5%8A%9F%E8%83%BD%E7%89%B9%E6%80%A7/%E6%B5%81%E9%87%8F%E7%AE%A1%E7%90%86/#%E5%8A%A8%E6%80%81%E8%B7%AF%E7%94%B1)
+
+### dubbogo.yaml configuration file
+
+When using PolarisMesh's service route capability, you need to enable
PolarisMesh's registration discovery function in dubbogo firstly.
+
+````yaml
+dubbo:
+ registries:
+ polarisMesh:
+ protocol: polaris
+ address: ${Polaris server IP}:8091
+ namespace: ${Polaris namespace information}
+ token: ${Polaris resource authentication token} # If the Polaris server
has enabled authentication for the client, you need to configure this parameter
+ provider:
+ services:
+ UserProvider:
+ interface: org.apache.dubbo.UserProvider.Test
+````
+
+### How to configure service routing parameters
+
+The implementation of the PolarisMesh PriorityRouter extension point in
dubbogo can automatically identify the request label information that needs to
participate in service routing from the current RPC call context and request
information according to the service route rules configured by the user.
+
+
+
+
+
+- The request matching rule is **Request parameter(QUERY)**
+ - Tag source: the input parameter of the method in the RPC call, namely
Invoaction.Arguments()
+ - Tag key rules
+ - The method has only one input parameter: param.$.${fieldName},
**param.** is a fixed prefix, the following expressions are standard JSONPath
expressions, [reference document](https://goessner.net/ articles/JsonPath/)
+ - The method has multiple parameters: param[${index}].$.${fieldName},
**param[${index}].** is a fixed prefix, ${index} represents the first parameter
in the method parameter Several parameters, the starting position of the
subscript starts from 0; the following expressions are standard JSONPath
expressions, [reference document](https://goessner.net/articles/JsonPath/)
+- The request matching rule is **request header (HEADER)**:
+ - Tag source: Additional tag information for RPC calls, i.e.
Invoaction.Attachments()
+
+### Running the service provider
+
+Enter the cmd directory of server-prod, server-pre, and server-dev
respectively, and execute the following commands
+
+````
+ export DUBBO_GO_CONFIG_PATH="../conf/dubbogo.yaml"
+ go run .
+````
+
+When you see the following log, it means that the server side started
successfully
+
+````log
+INFO dubbo/dubbo_protocol.go:84 [DUBBO Protocol] Export service:
+````
+
+
+### Running the service caller
+
+Enter the cmd directory of go-client and execute the following command
+
+
+````
+export DUBBO_GO_CONFIG_PATH="../conf/dubbogo.yml"
+export uid=user-1
+go run .
+````
+
+When you see the following log, it means that go-client successfully
discovered go-server and made an RPC call
+
+````log
+INFO cmd/main.go:75 response: &{A001 Alex Stocks 18 2022-11-19 12:52:38.092
+0800 CST}
+````
+
+Execute the following commands respectively
+
+```bash
+export uid=
+go run .
+
+export uid=user-1
+go run .
+
+export uid=user-2
+````
+
+When you see the following log, it means that the routing policy configured in
PolarisMesh has taken effect
+
+```log
+# export uid=
+2022-11-26T13:39:31.637+0800 INFO cmd/main.go:78 response: &{A001
[Prod] Alex Stocks 18 2022-11-26 13:39:31.637 +0800 CST}
+2022-11-26T13:39:31.842+0800 INFO cmd/main.go:78 response: &{A001
[Prod] Alex Stocks 18 2022-11-26 13:39:31.841 +0800 CST}
+2022-11-26T13:39:32.043+0800 INFO cmd/main.go:78 response: &{A001
[Prod] Alex Stocks 18 2022-11-26 13:39:32.043 +0800 CST}
+2022-11-26T13:39:32.247+0800 INFO cmd/main.go:78 response: &{A001
[Prod] Alex Stocks 18 2022-11-26 13:39:32.247 +0800 CST}
+2022-11-26T13:39:32.452+0800 INFO cmd/main.go:78 response: &{A001
[Prod] Alex Stocks 18 2022-11-26 13:39:32.452 +0800 CST}
+
+# export uid=user-1
+2022-11-26T13:39:51.053+0800 INFO cmd/main.go:78 response: &{A001 [Pre]
Alex Stocks 18 2022-11-26 13:39:51.053 +0800 CST}
+2022-11-26T13:39:51.257+0800 INFO cmd/main.go:78 response: &{A001 [Pre]
Alex Stocks 18 2022-11-26 13:39:51.257 +0800 CST}
+2022-11-26T13:39:51.459+0800 INFO cmd/main.go:78 response: &{A001 [Pre]
Alex Stocks 18 2022-11-26 13:39:51.459 +0800 CST}
+2022-11-26T13:39:51.662+0800 INFO cmd/main.go:78 response: &{A001 [Pre]
Alex Stocks 18 2022-11-26 13:39:51.662 +0800 CST}
+2022-11-26T13:39:51.866+0800 INFO cmd/main.go:78 response: &{A001 [Pre]
Alex Stocks 18 2022-11-26 13:39:51.866 +0800 CST}
+
+# export uid=user-2
+2022-11-26T13:42:39.351+0800 INFO cmd/main.go:78 response: &{A001 [Dev]
Alex Stocks 18 2022-11-26 13:42:39.351 +0800 CST}
+2022-11-26T13:42:39.555+0800 INFO cmd/main.go:78 response: &{A001 [Dev]
Alex Stocks 18 2022-11-26 13:42:39.555 +0800 CST}
+2022-11-26T13:42:39.760+0800 INFO cmd/main.go:78 response: &{A001 [Dev]
Alex Stocks 18 2022-11-26 13:42:39.76 +0800 CST}
+2022-11-26T13:42:39.962+0800 INFO cmd/main.go:78 response: &{A001 [Dev]
Alex Stocks 18 2022-11-26 13:42:39.961 +0800 CST}
+2022-11-26T13:42:40.165+0800 INFO cmd/main.go:78 response: &{A001 [Dev]
Alex Stocks 18 2022-11-26 13:42:40.165 +0800 CST}
+```
diff --git a/registry/polaris/go-client/cmd/main.go
b/polaris/router/go-client/cmd/main.go
similarity index 79%
rename from registry/polaris/go-client/cmd/main.go
rename to polaris/router/go-client/cmd/main.go
index e685d8a4..67113a01 100644
--- a/registry/polaris/go-client/cmd/main.go
+++ b/polaris/router/go-client/cmd/main.go
@@ -24,6 +24,7 @@ import (
)
import (
+ "dubbo.apache.org/dubbo-go/v3/common/constant"
"dubbo.apache.org/dubbo-go/v3/config"
_ "dubbo.apache.org/dubbo-go/v3/imports"
@@ -63,19 +64,19 @@ func main() {
}
logger.Infof("\n\n\nstart to test dubbo")
- user, err := userProvider.GetUser(context.TODO(), &User{Name:
"Alex001"})
- if err != nil {
- logger.Errorf("error: %v\n", err)
- os.Exit(1)
- return
- }
- logger.Infof("response result: %v\n", user)
- user, err =
userProviderWithCustomRegistryGroupAndVersion.GetUser(context.TODO(),
&User{Name: "Alex001"})
- if err != nil {
- logger.Errorf("error: %v\n", err)
- os.Exit(1)
- return
+ uid := os.Getenv("uid")
+ atta := make(map[string]interface{})
+ atta["uid"] = uid
+ reqContext := context.WithValue(context.Background(),
constant.DubboCtxKey("attachment"), atta)
+
+ for i := 0; i < 5; i++ {
+ time.Sleep(200 * time.Millisecond)
+ user, err := userProvider.GetUser(reqContext, &User{Name:
"Alex001"})
+ if err != nil {
+ logger.Errorf("error: %v\n", err)
+ } else {
+ }
+ logger.Infof("response: %v\n", user)
}
- logger.Infof("response result: %v\n", user)
}
diff --git a/registry/polaris/go-client/conf/dubbogo.yaml
b/polaris/router/go-client/conf/dubbogo.yaml
similarity index 90%
rename from registry/polaris/go-client/conf/dubbogo.yaml
rename to polaris/router/go-client/conf/dubbogo.yaml
index 53eb4143..d06e5f3d 100644
--- a/registry/polaris/go-client/conf/dubbogo.yaml
+++ b/polaris/router/go-client/conf/dubbogo.yaml
@@ -1,3 +1,4 @@
+
dubbo:
application:
name: myApp # metadata: application=myApp; name=myApp
@@ -10,8 +11,8 @@ dubbo:
registries:
polarisMesh:
protocol: polaris
- address: 127.0.0.1:8091
- namespace: default
+ address: 183.47.111.80:8091
+ namespace: dubbogo
consumer:
references:
UserProvider:
@@ -20,4 +21,4 @@ dubbo:
UserProviderWithCustomGroupAndVersion:
protocol: dubbo
interface: org.apache.dubbo.UserProvider.Test2
- version: myInterfaceVersion # dubbo interface version must be same
with server
\ No newline at end of file
+ version: myInterfaceVersion # dubbo interface version must be same
with server
diff --git a/registry/polaris/go-server/cmd/server.go
b/polaris/router/go-server/server-dev/cmd/server.go
similarity index 93%
copy from registry/polaris/go-server/cmd/server.go
copy to polaris/router/go-server/server-dev/cmd/server.go
index 033dccf6..4266944e 100644
--- a/registry/polaris/go-server/cmd/server.go
+++ b/polaris/router/go-server/server-dev/cmd/server.go
@@ -28,6 +28,7 @@ import (
import (
"dubbo.apache.org/dubbo-go/v3/config"
+ _ "dubbo.apache.org/dubbo-go/v3/filter/tps/strategy"
_ "dubbo.apache.org/dubbo-go/v3/imports"
hessian "github.com/apache/dubbo-go-hessian2"
@@ -58,7 +59,7 @@ type UserProvider struct {
func (u *UserProvider) GetUser(ctx context.Context, req *User) (*User, error) {
logger.Infof("req:%#v", req)
- rsp := User{"A001", "Alex Stocks", 18, time.Now()}
+ rsp := User{"A001", "[Dev] Alex Stocks", 18, time.Now()}
logger.Infof("rsp:%#v", rsp)
return &rsp, nil
}
@@ -72,7 +73,7 @@ type UserProviderWithCustomGroupAndVersion struct {
func (u *UserProviderWithCustomGroupAndVersion) GetUser(ctx context.Context,
req *User) (*User, error) {
logger.Infof("req:%#v", req)
- rsp := User{"A001", "Alex Stocks from
UserProviderWithCustomGroupAndVersion", 18, time.Now()}
+ rsp := User{"A001", "[Dev] Alex Stocks", 18, time.Now()}
logger.Infof("rsp:%#v", rsp)
return &rsp, nil
}
diff --git a/registry/polaris/go-server/conf/dubbogo.yaml
b/polaris/router/go-server/server-dev/conf/dubbogo.yaml
similarity index 76%
copy from registry/polaris/go-server/conf/dubbogo.yaml
copy to polaris/router/go-server/server-dev/conf/dubbogo.yaml
index 06fd8fb2..3b3d3b38 100644
--- a/registry/polaris/go-server/conf/dubbogo.yaml
+++ b/polaris/router/go-server/server-dev/conf/dubbogo.yaml
@@ -6,12 +6,12 @@ dubbo:
organization: dubbo # metadata: organization=dubbo
owner: laurence # metadata: owner=laurence
version: myversion # metadata: app.version=myversion
- environment: pro # metadata: environment=pro
+ environment: dev # metadata: environment=pro
registries:
polarisMesh:
protocol: polaris
- address: 127.0.0.1:8091
- namespace: default
+ address: 183.47.111.80:8091
+ namespace: dubbogo
protocols:
dubbo:
name: dubbo
@@ -20,7 +20,8 @@ dubbo:
services:
UserProvider:
interface: org.apache.dubbo.UserProvider.Test
+ tps.limiter: polaris-limit # the Limiter that judge if the TPS overs
the threshold, such as method-service or default
UserProviderWithCustomGroupAndVersion:
interface: org.apache.dubbo.UserProvider.Test2
version: myInterfaceVersion # dubbo interface version must be same
with client
- group: myInterfaceGroup # dubbo interface group must be same with
client
\ No newline at end of file
+ group: myInterfaceGroup # dubbo interface group must be same with
client
diff --git a/registry/polaris/go-server/cmd/server.go
b/polaris/router/go-server/server-pre/cmd/server.go
similarity index 93%
copy from registry/polaris/go-server/cmd/server.go
copy to polaris/router/go-server/server-pre/cmd/server.go
index 033dccf6..af9e87b4 100644
--- a/registry/polaris/go-server/cmd/server.go
+++ b/polaris/router/go-server/server-pre/cmd/server.go
@@ -28,6 +28,7 @@ import (
import (
"dubbo.apache.org/dubbo-go/v3/config"
+ _ "dubbo.apache.org/dubbo-go/v3/filter/tps/strategy"
_ "dubbo.apache.org/dubbo-go/v3/imports"
hessian "github.com/apache/dubbo-go-hessian2"
@@ -58,7 +59,7 @@ type UserProvider struct {
func (u *UserProvider) GetUser(ctx context.Context, req *User) (*User, error) {
logger.Infof("req:%#v", req)
- rsp := User{"A001", "Alex Stocks", 18, time.Now()}
+ rsp := User{"A001", "[Pre] Alex Stocks", 18, time.Now()}
logger.Infof("rsp:%#v", rsp)
return &rsp, nil
}
@@ -72,7 +73,7 @@ type UserProviderWithCustomGroupAndVersion struct {
func (u *UserProviderWithCustomGroupAndVersion) GetUser(ctx context.Context,
req *User) (*User, error) {
logger.Infof("req:%#v", req)
- rsp := User{"A001", "Alex Stocks from
UserProviderWithCustomGroupAndVersion", 18, time.Now()}
+ rsp := User{"A001", "[Pre] Alex Stocks", 18, time.Now()}
logger.Infof("rsp:%#v", rsp)
return &rsp, nil
}
diff --git a/registry/polaris/go-server/conf/dubbogo.yaml
b/polaris/router/go-server/server-pre/conf/dubbogo.yaml
similarity index 74%
copy from registry/polaris/go-server/conf/dubbogo.yaml
copy to polaris/router/go-server/server-pre/conf/dubbogo.yaml
index 06fd8fb2..7cc24e0a 100644
--- a/registry/polaris/go-server/conf/dubbogo.yaml
+++ b/polaris/router/go-server/server-pre/conf/dubbogo.yaml
@@ -6,21 +6,22 @@ dubbo:
organization: dubbo # metadata: organization=dubbo
owner: laurence # metadata: owner=laurence
version: myversion # metadata: app.version=myversion
- environment: pro # metadata: environment=pro
+ environment: pre # metadata: environment=pro
registries:
polarisMesh:
protocol: polaris
- address: 127.0.0.1:8091
- namespace: default
+ address: 183.47.111.80:8091
+ namespace: dubbogo
protocols:
dubbo:
name: dubbo
- port: 20000
+ port: 21000
provider:
services:
UserProvider:
interface: org.apache.dubbo.UserProvider.Test
+ tps.limiter: polaris-limit # the Limiter that judge if the TPS overs
the threshold, such as method-service or default
UserProviderWithCustomGroupAndVersion:
interface: org.apache.dubbo.UserProvider.Test2
version: myInterfaceVersion # dubbo interface version must be same
with client
- group: myInterfaceGroup # dubbo interface group must be same with
client
\ No newline at end of file
+ group: myInterfaceGroup # dubbo interface group must be same with
client
diff --git a/registry/polaris/go-server/cmd/server.go
b/polaris/router/go-server/server-prod/cmd/server.go
similarity index 93%
rename from registry/polaris/go-server/cmd/server.go
rename to polaris/router/go-server/server-prod/cmd/server.go
index 033dccf6..d8a7e5df 100644
--- a/registry/polaris/go-server/cmd/server.go
+++ b/polaris/router/go-server/server-prod/cmd/server.go
@@ -28,6 +28,7 @@ import (
import (
"dubbo.apache.org/dubbo-go/v3/config"
+ _ "dubbo.apache.org/dubbo-go/v3/filter/tps/strategy"
_ "dubbo.apache.org/dubbo-go/v3/imports"
hessian "github.com/apache/dubbo-go-hessian2"
@@ -58,7 +59,7 @@ type UserProvider struct {
func (u *UserProvider) GetUser(ctx context.Context, req *User) (*User, error) {
logger.Infof("req:%#v", req)
- rsp := User{"A001", "Alex Stocks", 18, time.Now()}
+ rsp := User{"A001", "[Prod] Alex Stocks", 18, time.Now()}
logger.Infof("rsp:%#v", rsp)
return &rsp, nil
}
@@ -72,7 +73,7 @@ type UserProviderWithCustomGroupAndVersion struct {
func (u *UserProviderWithCustomGroupAndVersion) GetUser(ctx context.Context,
req *User) (*User, error) {
logger.Infof("req:%#v", req)
- rsp := User{"A001", "Alex Stocks from
UserProviderWithCustomGroupAndVersion", 18, time.Now()}
+ rsp := User{"A001", "[Prod] Alex Stocks", 18, time.Now()}
logger.Infof("rsp:%#v", rsp)
return &rsp, nil
}
diff --git a/registry/polaris/go-server/conf/dubbogo.yaml
b/polaris/router/go-server/server-prod/conf/dubbogo.yaml
similarity index 74%
rename from registry/polaris/go-server/conf/dubbogo.yaml
rename to polaris/router/go-server/server-prod/conf/dubbogo.yaml
index 06fd8fb2..aad43164 100644
--- a/registry/polaris/go-server/conf/dubbogo.yaml
+++ b/polaris/router/go-server/server-prod/conf/dubbogo.yaml
@@ -6,21 +6,22 @@ dubbo:
organization: dubbo # metadata: organization=dubbo
owner: laurence # metadata: owner=laurence
version: myversion # metadata: app.version=myversion
- environment: pro # metadata: environment=pro
+ environment: prod # metadata: environment=pro
registries:
polarisMesh:
protocol: polaris
- address: 127.0.0.1:8091
- namespace: default
+ address: 183.47.111.80:8091
+ namespace: dubbogo
protocols:
dubbo:
name: dubbo
- port: 20000
+ port: 22000
provider:
services:
UserProvider:
interface: org.apache.dubbo.UserProvider.Test
+ tps.limiter: polaris-limit # the Limiter that judge if the TPS overs
the threshold, such as method-service or default
UserProviderWithCustomGroupAndVersion:
interface: org.apache.dubbo.UserProvider.Test2
version: myInterfaceVersion # dubbo interface version must be same
with client
- group: myInterfaceGroup # dubbo interface group must be same with
client
\ No newline at end of file
+ group: myInterfaceGroup # dubbo interface group must be same with
client
diff --git a/polaris/router/images/dubbogo-route-rule-dev.png
b/polaris/router/images/dubbogo-route-rule-dev.png
new file mode 100644
index 00000000..b61ed0eb
Binary files /dev/null and b/polaris/router/images/dubbogo-route-rule-dev.png
differ
diff --git a/polaris/router/images/dubbogo-route-rule-pre.png
b/polaris/router/images/dubbogo-route-rule-pre.png
new file mode 100644
index 00000000..61eb8977
Binary files /dev/null and b/polaris/router/images/dubbogo-route-rule-pre.png
differ
diff --git a/polaris/router/images/dubbogo-route-rule-prod.png
b/polaris/router/images/dubbogo-route-rule-prod.png
new file mode 100644
index 00000000..0fd28f07
Binary files /dev/null and b/polaris/router/images/dubbogo-route-rule-prod.png
differ
