Update workflows (#195 )

Update workflows Co-authored-by: Aleksandr Tolstikhin <atolstikhin@mtsbank.ru> Reviewed-on: #195 Co-authored-by: Александр Толстихин <tolstihin1996@mail.ru> Co-committed-by: Александр Толстихин <tolstihin1996@mail.ru>
hotfix (#186 )
2024-12-11 00:36:27 +03:00 · 2024-03-26 14:53:14 +03:00 · 2024-03-13 11:06:10 +03:00 · 2024-03-13 10:05:29 +03:00 · 2024-03-12 00:52:14 +03:00 · 2024-03-12 00:02:48 +03:00
25 changed files with 421 additions and 883 deletions
--- a/README.md
+++ b/README.md
@@ -9,8 +9,8 @@ to create a HTTP Server that could potentially be used for REST based API servic
 import (
 	"net/http"

-	"github.com/unistack-org/micro/v3/server"
-	httpServer "github.com/unistack-org/micro-server-http"
+	"go.unistack.org/micro/v4/server"
+	httpServer "go.unistack.org/micro-server-http/v4"
 )

 func main() {
@@ -37,9 +37,9 @@ Or as part of a service
 import (
 	"net/http"

-	"github.com/unistack-org/micro/v3"
-	"github.com/unistack-org/micro/v3/server"
-	httpServer "github.com/unistack-org/micro-server-http"
+	"go.unistack.org/micro/v4"
+	"go.unistack.org/micro/v4/server"
+	httpServer "go.unistack.org/micro-server-http/v4"
 )

 func main() {
--- a/go.mod
+++ b/go.mod
@@ -1,25 +1,25 @@
 module go.unistack.org/micro-server-http/v4

-go 1.23.0
+go 1.19

 require (
-	go.unistack.org/micro-client-http/v4 v4.1.0
-	go.unistack.org/micro-codec-yaml/v4 v4.1.0
-	go.unistack.org/micro-proto/v4 v4.1.0
-	go.unistack.org/micro/v4 v4.1.2
-	golang.org/x/net v0.35.0
+	go.unistack.org/micro-codec-yaml/v4 v4.0.0
+	go.unistack.org/micro-proto/v4 v4.0.1
+	go.unistack.org/micro/v4 v4.0.17
+	go.unistack.org/protoc-gen-go-micro/v4 v4.0.13
+	golang.org/x/net v0.22.0
 )

 require (
-	github.com/ash3in/uuidv8 v1.2.0 // indirect
+	github.com/fatih/structtag v1.2.0 // indirect
+	github.com/golang/protobuf v1.5.4 // indirect
 	github.com/google/gnostic v0.7.0 // indirect
-	github.com/google/gnostic-models v0.6.9 // indirect
-	github.com/google/uuid v1.6.0 // indirect
-	github.com/matoous/go-nanoid v1.5.1 // indirect
-	github.com/spf13/cast v1.7.1 // indirect
-	golang.org/x/sys v0.30.0 // indirect
-	google.golang.org/genproto/googleapis/rpc v0.0.0-20250227231956-55c901821b1e // indirect
-	google.golang.org/grpc v1.70.0 // indirect
-	google.golang.org/protobuf v1.36.5 // indirect
+	github.com/google/gnostic-models v0.6.9-0.20230804172637-c7be7c783f49 // indirect
+	golang.org/x/mod v0.16.0 // indirect
+	golang.org/x/sys v0.18.0 // indirect
+	golang.org/x/tools v0.19.0 // indirect
+	google.golang.org/protobuf v1.33.0 // indirect
+	gopkg.in/yaml.v2 v2.4.0 // indirect
 	gopkg.in/yaml.v3 v3.0.1 // indirect
+	sigs.k8s.io/yaml v1.4.0 // indirect
 )
--- a/go.sum
+++ b/go.sum
@@ -596,8 +596,6 @@ gioui.org v0.0.0-20210308172011-57750fc8a0a6/go.mod h1:RSH6KIUZ0p2xy5zHDxgAM4zum
 git.sr.ht/~sbinet/gg v0.3.1/go.mod h1:KGYtlADtqsqANL9ueOFkWymvzUvLMQllU5Ixo+8v3pc=
 github.com/BurntSushi/toml v0.3.1/go.mod h1:xHWCNGjB5oqiDr8zfno3MHue2Ht5sIBksp03qcyfWMU=
 github.com/BurntSushi/xgb v0.0.0-20160522181843-27f122750802/go.mod h1:IVnqGOEym/WlBOVXweHU+Q+/VP0lqqI8lqeDx9IjBqo=
-github.com/DATA-DOG/go-sqlmock v1.5.2 h1:OcvFkGmslmlZibjAjaHm3L//6LiuBgolP7OputlJIzU=
-github.com/DATA-DOG/go-sqlmock v1.5.2/go.mod h1:88MAG/4G7SMwSE3CeA0ZKzrT5CiOU3OJ+JlNzwDqpNU=
 github.com/JohnCGriffin/overflow v0.0.0-20211019200055-46fa312c352c/go.mod h1:X0CRv0ky0k6m906ixxpzmDRLvX58TFUKS2eePweuyxk=
 github.com/OneOfOne/xxhash v1.2.2/go.mod h1:HSdplMjZKSmBqAxg5vPj2TmRDmfkzw+cTzAElWljhcU=
 github.com/ajstarks/deck v0.0.0-20200831202436-30c9fc6549a9/go.mod h1:JynElWSGnm/4RlzPXRlREEwqTHAN3T56Bv2ITsFT3gY=
@@ -609,8 +607,6 @@ github.com/antihax/optional v1.0.0/go.mod h1:uupD/76wgC+ih3iEmQUL+0Ugr19nfwCT1kd
 github.com/apache/arrow/go/v10 v10.0.1/go.mod h1:YvhnlEePVnBS4+0z3fhPfUy7W1Ikj0Ih0vcRo/gZ1M0=
 github.com/apache/arrow/go/v11 v11.0.0/go.mod h1:Eg5OsL5H+e299f7u5ssuXsuHQVEGC4xei5aX110hRiI=
 github.com/apache/thrift v0.16.0/go.mod h1:PHK3hniurgQaNMZYaCLEqXKsYK8upmhPbmdP2FXSqgU=
-github.com/ash3in/uuidv8 v1.2.0 h1:2oogGdtCPwaVtyvPPGin4TfZLtOGE5F+W++E880G6SI=
-github.com/ash3in/uuidv8 v1.2.0/go.mod h1:BnU0wJBxnzdEKmVg4xckBkD+VZuecTFTUP3M0dWgyY4=
 github.com/boombuler/barcode v1.0.0/go.mod h1:paBWMcWSl3LHKBqUq+rly7CNSldXjb2rDl3JlRe0mD8=
 github.com/boombuler/barcode v1.0.1/go.mod h1:paBWMcWSl3LHKBqUq+rly7CNSldXjb2rDl3JlRe0mD8=
 github.com/buger/jsonparser v1.1.1/go.mod h1:6RYKKt7H4d4+iWqouImQ9R2FZql3VbhNgx27UK13J/0=
@@ -638,6 +634,7 @@ github.com/cncf/xds/go v0.0.0-20220314180256-7f1daf1720fc/go.mod h1:eXthEFrGJvWH
 github.com/cncf/xds/go v0.0.0-20230105202645-06c439db220b/go.mod h1:eXthEFrGJvWHgFFCl3hGmgk+/aYT6PnTQLykKQRLhEs=
 github.com/creack/pty v1.1.9/go.mod h1:oKZEueFk5CKHvIhNR5MUki03XCEU+Q6VDXinZuGJ33E=
 github.com/davecgh/go-spew v1.1.0/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
+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/docopt/docopt-go v0.0.0-20180111231733-ee0de3bc6815/go.mod h1:WwZ+bS3ebgob9U8Nd0kOddGdZWjyMGR8Wziv+TBNwSE=
 github.com/dustin/go-humanize v1.0.0/go.mod h1:HtrtbFcZ19U5GC7JDqmcUSB87Iq5E25KnS6fMYU6eOk=
@@ -654,11 +651,11 @@ github.com/envoyproxy/go-control-plane v0.10.3/go.mod h1:fJJn/j26vwOu972OllsvAgJ
 github.com/envoyproxy/protoc-gen-validate v0.1.0/go.mod h1:iSmxcyjqTsJpI2R4NaDN7+kN2VEUnK/pcBlmesArF7c=
 github.com/envoyproxy/protoc-gen-validate v0.6.7/go.mod h1:dyJXwwfPK2VSqiB9Klm1J6romD608Ba7Hij42vrOBCo=
 github.com/envoyproxy/protoc-gen-validate v0.9.1/go.mod h1:OKNgG7TCp5pF4d6XftA0++PMirau2/yoOwVac3AbF2w=
+github.com/fatih/structtag v1.2.0 h1:/OdNE99OxoI/PqaW/SuSK9uxxT3f/tcSZgon/ssNSx4=
+github.com/fatih/structtag v1.2.0/go.mod h1:mBJUNpUnHmRKrKlQQlmCrh5PuhftFbNv8Ys4/aAZl94=
 github.com/flowstack/go-jsonschema v0.1.1/go.mod h1:yL7fNggx1o8rm9RlgXv7hTBWxdBM0rVwpMwimd3F3N0=
 github.com/fogleman/gg v1.2.1-0.20190220221249-0403632d5b90/go.mod h1:R/bRT+9gY/C5z7JzPU0zXsXHKM4/ayA+zqcVNZzPa1k=
 github.com/fogleman/gg v1.3.0/go.mod h1:R/bRT+9gY/C5z7JzPU0zXsXHKM4/ayA+zqcVNZzPa1k=
-github.com/frankban/quicktest v1.14.6 h1:7Xjx+VpznH+oBnejlPUj8oUpdxnVs4f8XU8WnHkI4W8=
-github.com/frankban/quicktest v1.14.6/go.mod h1:4ptaffx2x8+WTWXmUCuVU6aPUX1/Mz7zb5vbUoiM6w0=
 github.com/ghodss/yaml v1.0.0/go.mod h1:4dBDuWmgqj2HViK6kFavaiC9ZROes6MMH2rRYeMEF04=
 github.com/go-fonts/dejavu v0.1.0/go.mod h1:4Wt4I4OU2Nq9asgDCteaAaWZOV24E+0/Pwo0gppep4g=
 github.com/go-fonts/latin-modern v0.2.0/go.mod h1:rQVLdDMK+mK1xscDwsqM5J8U2jrRa3T0ecnM9pNujks=
@@ -705,6 +702,7 @@ github.com/golang/protobuf v1.4.3/go.mod h1:oDoupMAO8OvCJWAcko0GGGIgR6R6ocIYbsSw
 github.com/golang/protobuf v1.5.0/go.mod h1:FsONVRAS9T7sI+LIUmWTfcYkHO4aIWwzhcaSAoJOfIk=
 github.com/golang/protobuf v1.5.1/go.mod h1:DopwsBzvsk0Fs44TXzsVbJyPhcCPeIwnvohx4u74HPM=
 github.com/golang/protobuf v1.5.2/go.mod h1:XVQd3VNwM+JqD3oG2Ue2ip4fOMUkwXdXDdiuN0vRsmY=
+github.com/golang/protobuf v1.5.3 h1:KhyjKVUg7Usr/dYsdSqoFveMYd5ko72D+zANwlG1mmg=
 github.com/golang/protobuf v1.5.3/go.mod h1:XVQd3VNwM+JqD3oG2Ue2ip4fOMUkwXdXDdiuN0vRsmY=
 github.com/golang/protobuf v1.5.4 h1:i7eJL8qZTpSEXOPTxNKhASYpMn+8e5Q6AdndVa1dWek=
 github.com/golang/protobuf v1.5.4/go.mod h1:lnTiLA8Wa4RWRcIUkrtSVa5nRhsEGBg48fD6rSs7xps=
@@ -713,11 +711,12 @@ github.com/golang/snappy v0.0.4/go.mod h1:/XxbfmMg8lxefKM7IXC3fBNl/7bRcc72aCRzEW
 github.com/google/btree v0.0.0-20180813153112-4030bb1f1f0c/go.mod h1:lNA+9X1NB3Zf8V7Ke586lFgjr2dZNuvo3lPJSGZ5JPQ=
 github.com/google/btree v1.0.0/go.mod h1:lNA+9X1NB3Zf8V7Ke586lFgjr2dZNuvo3lPJSGZ5JPQ=
 github.com/google/flatbuffers v2.0.8+incompatible/go.mod h1:1AeVuKshWv4vARoZatz6mlQ0JxURH0Kv5+zNeJKJCa8=
+github.com/google/gnostic v0.6.9 h1:ZK/5VhkoX835RikCHpSUJV9a+S3e1zLh59YnyWeBW+0=
+github.com/google/gnostic v0.6.9/go.mod h1:Nm8234We1lq6iB9OmlgNv3nH91XLLVZHCDayfA3xq+E=
 github.com/google/gnostic v0.7.0 h1:d7EpuFp8vVdML+y0JJJYiKeOLjKTdH/GvVkLOBWqJpw=
 github.com/google/gnostic v0.7.0/go.mod h1:IAcUyMl6vtC95f60EZ8oXyqTsOersP6HbwjeG7EyDPM=
+github.com/google/gnostic-models v0.6.9-0.20230804172637-c7be7c783f49 h1:0VpGH+cDhbDtdcweoyCVsF3fhN8kejK6rFe/2FFX2nU=
 github.com/google/gnostic-models v0.6.9-0.20230804172637-c7be7c783f49/go.mod h1:BkkQ4L1KS1xMt2aWSPStnn55ChGC0DPOn2FQYj+f25M=
-github.com/google/gnostic-models v0.6.9 h1:MU/8wDLif2qCXZmzncUQ/BOfxWfthHi63KqpoNbWqVw=
-github.com/google/gnostic-models v0.6.9/go.mod h1:CiWsm0s6BSQd1hRn8/QmxqB6BesYcbSZxsz9b0KuDBw=
 github.com/google/go-cmp v0.2.0/go.mod h1:oXzfMopK8JAjlY9xF4vHSVASa0yLyX7SntLO5aqRK0M=
 github.com/google/go-cmp v0.3.0/go.mod h1:8QqcDgzrUqlUb/G2PQTWiueGozuR1884gddMywk6iLU=
 github.com/google/go-cmp v0.3.1/go.mod h1:8QqcDgzrUqlUb/G2PQTWiueGozuR1884gddMywk6iLU=
@@ -728,13 +727,12 @@ github.com/google/go-cmp v0.5.1/go.mod h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/
 github.com/google/go-cmp v0.5.2/go.mod h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/gNBxE=
 github.com/google/go-cmp v0.5.3/go.mod h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/gNBxE=
 github.com/google/go-cmp v0.5.4/go.mod h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/gNBxE=
+github.com/google/go-cmp v0.5.5 h1:Khx7svrCpmxxtHBq5j2mp/xVjsi8hQMfNLvJFAlrGgU=
 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/go.mod h1:17dUlkBOakJ0+DkrSSNjCkIjxS6bF9zb3elmeNGIjoY=
 github.com/google/go-cmp v0.5.9/go.mod h1:17dUlkBOakJ0+DkrSSNjCkIjxS6bF9zb3elmeNGIjoY=
-github.com/google/go-cmp v0.6.0 h1:ofyhxvXcZhMsU5ulbFiLKl/XBFqE1GSq7atu8tAmTRI=
-github.com/google/go-cmp v0.6.0/go.mod h1:17dUlkBOakJ0+DkrSSNjCkIjxS6bF9zb3elmeNGIjoY=
 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=
 github.com/google/martian/v3 v3.1.0/go.mod h1:y5Zk1BBys9G+gd6Jrk0W3cC1+ELVxBWuIGO+w/tUAp0=
@@ -758,8 +756,6 @@ github.com/google/pprof v0.0.0-20210720184732-4bb14d4b1be1/go.mod h1:kpwsk12EmLe
 github.com/google/renameio v0.1.0/go.mod h1:KWCgfxg9yswjAJkECMjeO8J8rahYeXnNhOm40UhjYkI=
 github.com/google/uuid v1.1.2/go.mod h1:TIyPZe4MgqvfeYDBFedMoGGpEw/LqOeaOT+nhxU+yHo=
 github.com/google/uuid v1.3.0/go.mod h1:TIyPZe4MgqvfeYDBFedMoGGpEw/LqOeaOT+nhxU+yHo=
-github.com/google/uuid v1.6.0 h1:NIvaJDMOsjHA8n1jAhLSgzrAzy1Hgr+hNrb57e+94F0=
-github.com/google/uuid v1.6.0/go.mod h1:TIyPZe4MgqvfeYDBFedMoGGpEw/LqOeaOT+nhxU+yHo=
 github.com/googleapis/enterprise-certificate-proxy v0.0.0-20220520183353-fd19c99a87aa/go.mod h1:17drOmN3MwGY7t0e+Ei9b45FFGA3fBs3x36SsCg1hq8=
 github.com/googleapis/enterprise-certificate-proxy v0.1.0/go.mod h1:17drOmN3MwGY7t0e+Ei9b45FFGA3fBs3x36SsCg1hq8=
 github.com/googleapis/enterprise-certificate-proxy v0.2.0/go.mod h1:8C0jb7/mgJe/9KK8Lm7X9ctZC2t60YyIpYEI16jx0Qg=
@@ -797,18 +793,16 @@ github.com/klauspost/compress v1.15.9/go.mod h1:PhcZ0MbTNciWF3rruxRgKxI5NkcHHrHU
 github.com/klauspost/cpuid/v2 v2.0.9/go.mod h1:FInQzS24/EEf25PyTYn52gqo7WaD8xa0213Md/qVLRg=
 github.com/kr/fs v0.1.0/go.mod h1:FFnZGqtBN9Gxj7eW1uZ42v5BccTP0vu6NEaFoC2HwRg=
 github.com/kr/pretty v0.1.0/go.mod h1:dAy3ld7l9f0ibDNOQOHHMYYIIbhfbHSm3C4ZsoJORNo=
+github.com/kr/pretty v0.2.0/go.mod h1:ipq/a2n7PKx3OHsz4KJII5eveXtPO4qwEXGdVfWzfnI=
+github.com/kr/pretty v0.2.1 h1:Fmg33tUaq4/8ym9TJN1x7sLJnHVwhP33CNkpYV/7rwI=
 github.com/kr/pretty v0.2.1/go.mod h1:ipq/a2n7PKx3OHsz4KJII5eveXtPO4qwEXGdVfWzfnI=
 github.com/kr/pretty v0.3.0/go.mod h1:640gp4NfQd8pI5XOwp5fnNeVWj67G7CFk/SaSQn7NBk=
-github.com/kr/pretty v0.3.1 h1:flRD4NNwYAUpkphVc1HcthR4KEIFJ65n8Mw5qdRn3LE=
-github.com/kr/pretty v0.3.1/go.mod h1:hoEshYVHaxMs3cyo3Yncou5ZscifuDolrwPKZanG3xk=
 github.com/kr/pty v1.1.1/go.mod h1:pFQYn66WHrOpPYNljwOMqo10TkYh1fy3cYio2l3bCsQ=
 github.com/kr/text v0.1.0/go.mod h1:4Jbv+DJW3UT/LiOwJeYQe1efqtUx/iVham/4vfdArNI=
 github.com/kr/text v0.2.0 h1:5Nx0Ya0ZqY2ygV366QzturHI13Jq95ApcVaJBhpS+AY=
 github.com/kr/text v0.2.0/go.mod h1:eLer722TekiGuMkidMxC/pM04lWEeraHUUmBw8l2grE=
 github.com/lyft/protoc-gen-star v0.6.0/go.mod h1:TGAoBVkt8w7MPG72TrKIu85MIdXwDuzJYeZuUPFPNwA=
 github.com/lyft/protoc-gen-star v0.6.1/go.mod h1:TGAoBVkt8w7MPG72TrKIu85MIdXwDuzJYeZuUPFPNwA=
-github.com/matoous/go-nanoid v1.5.1 h1:aCjdvTyO9LLnTIi0fgdXhOPPvOHjpXN6Ik9DaNjIct4=
-github.com/matoous/go-nanoid v1.5.1/go.mod h1:zyD2a71IubI24efhpvkJz+ZwfwagzgSO6UNiFsZKN7U=
 github.com/mattn/go-isatty v0.0.12/go.mod h1:cbi8OIDigv2wuxKPP5vlRcQ1OAZbq2CE4Kysco4FUpU=
 github.com/mattn/go-isatty v0.0.16/go.mod h1:kYGgaQfpe5nmfYZH+SKPsOc2e4SrIfOl2e/yFXSvRLM=
 github.com/mattn/go-sqlite3 v1.14.14/go.mod h1:NyWgC/yNuGj7Q9rpYnZvas74GogHl5/Z4A/KQRfk6bU=
@@ -831,16 +825,12 @@ github.com/rogpeppe/fastuuid v1.2.0/go.mod h1:jVj6XXZzXRy/MSR5jhDC/2q6DgLz+nrA6L
 github.com/rogpeppe/go-internal v1.3.0/go.mod h1:M8bDsm7K2OlrFYOpmOWEs/qY81heoFRclV5y23lUDJ4=
 github.com/rogpeppe/go-internal v1.6.1/go.mod h1:xXDCJY+GAPziupqXw64V24skbSoqbTEfhy4qGm1nDQc=
 github.com/rogpeppe/go-internal v1.9.0/go.mod h1:WtVeX8xhTBvf0smdhujwtBcq4Qrzq/fJaraNFVN+nFs=
-github.com/rogpeppe/go-internal v1.13.1 h1:KvO1DLK/DRN07sQ1LQKScxyZJuNnedQ5/wKSR38lUII=
-github.com/rogpeppe/go-internal v1.13.1/go.mod h1:uMEvuHeurkdAXX61udpOXGD/AzZDWNMNyH2VO9fmH0o=
 github.com/ruudk/golang-pdf417 v0.0.0-20181029194003-1af4ab5afa58/go.mod h1:6lfFZQK844Gfx8o5WFuvpxWRwnSoipWe/p622j1v06w=
 github.com/ruudk/golang-pdf417 v0.0.0-20201230142125-a7e3863a1245/go.mod h1:pQAZKsJ8yyVxGRWYNEm9oFB8ieLgKFnamEyDmSA0BRk=
 github.com/spaolacci/murmur3 v0.0.0-20180118202830-f09979ecbc72/go.mod h1:JwIasOWyU6f++ZhiEuf87xNszmSA2myDM2Kzu9HwQUA=
 github.com/spf13/afero v1.3.3/go.mod h1:5KUK8ByomD5Ti5Artl0RtHeI5pTF7MIDuXL3yY520V4=
 github.com/spf13/afero v1.6.0/go.mod h1:Ai8FlHk4v/PARR026UzYexafAt9roJ7LcLMAmO6Z93I=
 github.com/spf13/afero v1.9.2/go.mod h1:iUV7ddyEEZPO5gA3zD4fJt6iStLlL+Lg4m2cihcDf8Y=
-github.com/spf13/cast v1.7.1 h1:cuNEagBQEHWN1FnbGEjCXL2szYEXqfJPbP2HNUaca9Y=
-github.com/spf13/cast v1.7.1/go.mod h1:ancEpBxwJDODSW/UG4rDrAqiKolqNNh2DX3mk86cAdo=
 github.com/stoewer/go-strcase v1.2.0/go.mod h1:IBiWB2sKIp3wVVQ3Y035++gc+knqhUQag1KpM8ahLw8=
 github.com/stretchr/objx v0.1.0/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME=
 github.com/stretchr/objx v0.4.0/go.mod h1:YvHI0jy2hoMjB+UWwv71VJQ9isScKT/TqJzVSSt89Yw=
@@ -876,14 +866,16 @@ go.opencensus.io v0.23.0/go.mod h1:XItmlyltB5F7CS4xOC1DcqMoFqwtC6OG2xF7mCv7P7E=
 go.opencensus.io v0.24.0/go.mod h1:vNK8G9p7aAivkbmorf4v+7Hgx+Zs0yY+0fOtgBfjQKo=
 go.opentelemetry.io/proto/otlp v0.7.0/go.mod h1:PqfVotwruBrMGOCsRd/89rSnXhoiJIqeYNgFYFoEGnI=
 go.opentelemetry.io/proto/otlp v0.15.0/go.mod h1:H7XAot3MsfNsj7EXtrA2q5xSNQ10UqI405h3+duxN4U=
-go.unistack.org/micro-client-http/v4 v4.1.0 h1:u1YwMmhPaQn0T0m6OSC6MBijHshDpwiNWMNib7KmSj8=
-go.unistack.org/micro-client-http/v4 v4.1.0/go.mod h1:RtddTKxsN5Zc6bzEON6CqpDL/Svfo13QoGXbIO1x3Os=
-go.unistack.org/micro-codec-yaml/v4 v4.1.0 h1:9utR2ka47CDEShbuF7QBAfv0lAFp06pXh77e2Byrt2s=
-go.unistack.org/micro-codec-yaml/v4 v4.1.0/go.mod h1:aMd5xKrJiUMvh6PNdYbO3G59JZfjSHRXdmNA4RCr8Mw=
-go.unistack.org/micro-proto/v4 v4.1.0 h1:qPwL2n/oqh9RE3RTTDgt28XK3QzV597VugQPaw9lKUk=
-go.unistack.org/micro-proto/v4 v4.1.0/go.mod h1:ArmK7o+uFvxSY3dbJhKBBX4Pm1rhWdLEFf3LxBrMtec=
-go.unistack.org/micro/v4 v4.1.2 h1:9SOlPYyPNNFpg1A7BsvhDyQm3gysLH1AhWbDCp1hyoY=
-go.unistack.org/micro/v4 v4.1.2/go.mod h1:lr3oYED8Ay1vjK68QqRw30QOtdk/ffpZqMFDasOUhKw=
+go.unistack.org/micro-codec-yaml/v4 v4.0.0 h1:DK/+fA69gmnvYmGHe3kqVR0pukS8ank5lPG4MfdPQEk=
+go.unistack.org/micro-codec-yaml/v4 v4.0.0/go.mod h1:UG4ouILbUfgNL7nvp7CpmD2IIzO8bQHjzDIahOvIAgM=
+go.unistack.org/micro-proto/v4 v4.0.1 h1:2RKHgtCOOcAFgKsnngGK5bqM/6MWXOjVCdw03dbuoF8=
+go.unistack.org/micro-proto/v4 v4.0.1/go.mod h1:ArmK7o+uFvxSY3dbJhKBBX4Pm1rhWdLEFf3LxBrMtec=
+go.unistack.org/micro/v4 v4.0.17 h1:mF7uM+J4ILdG+1fcwzKYCwDlxhdbF/e1WnGzKKLnIXc=
+go.unistack.org/micro/v4 v4.0.17/go.mod h1:ZDgU9931vm2l7X6RN/6UuwRIVp24GRdmQ7dKmegArk4=
+go.unistack.org/protoc-gen-go-micro/v4 v4.0.7 h1:c3CeBvjWV9MBrGGPaQCcHZrnuLY9sVJHv7vACI/dvuM=
+go.unistack.org/protoc-gen-go-micro/v4 v4.0.7/go.mod h1:9bsKAlESlPXPBSmY/NDLL//smZbhnEMrnWyG+M8zVFA=
+go.unistack.org/protoc-gen-go-micro/v4 v4.0.13 h1:7iqOK75ErgGJK6c7SjL7rDy9DBv2IjSFw2OZx5waUo8=
+go.unistack.org/protoc-gen-go-micro/v4 v4.0.13/go.mod h1:9bsKAlESlPXPBSmY/NDLL//smZbhnEMrnWyG+M8zVFA=
 golang.org/x/crypto v0.0.0-20190308221718-c2843e01d9a2/go.mod h1:djNgcEr1/C05ACkg1iLfiJU5Ep61QUkGW8qpdssI0+w=
 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=
@@ -949,6 +941,10 @@ golang.org/x/mod v0.5.1/go.mod h1:5OXOZSfqPIIbmVBIIKWRFfZjPR0E5r58TLhUjH0a2Ro=
 golang.org/x/mod v0.6.0-dev.0.20220419223038-86c51ed26bb4/go.mod h1:jJ57K6gSWd91VN4djpZkiMVwK6gcyfeH4XE8wZrZaV4=
 golang.org/x/mod v0.7.0/go.mod h1:iBbtSCu2XBx23ZKBPSOrRkjjQPZFPuis4dIYUhu/chs=
 golang.org/x/mod v0.8.0/go.mod h1:iBbtSCu2XBx23ZKBPSOrRkjjQPZFPuis4dIYUhu/chs=
+golang.org/x/mod v0.12.0 h1:rmsUpXtvNzj340zd98LZ4KntptpfRHwpFOHG188oHXc=
+golang.org/x/mod v0.12.0/go.mod h1:iBbtSCu2XBx23ZKBPSOrRkjjQPZFPuis4dIYUhu/chs=
+golang.org/x/mod v0.16.0 h1:QX4fJ0Rr5cPQCF7O9lh9Se4pmwfwskqZfq5moyldzic=
+golang.org/x/mod v0.16.0/go.mod h1:hTbmBsO62+eylJbnUtE2MGJUyE7QWk4xUqPFrRgJ+7c=
 golang.org/x/net v0.0.0-20180724234803-3673e40ba225/go.mod h1:mL1N/T3taQHkDXs73rZJwtUhF3w3ftmwwsq0BUmARs4=
 golang.org/x/net v0.0.0-20180826012351-8a410e7b638d/go.mod h1:mL1N/T3taQHkDXs73rZJwtUhF3w3ftmwwsq0BUmARs4=
 golang.org/x/net v0.0.0-20190108225652-1e06a53dbb7e/go.mod h1:mL1N/T3taQHkDXs73rZJwtUhF3w3ftmwwsq0BUmARs4=
@@ -1005,8 +1001,10 @@ golang.org/x/net v0.5.0/go.mod h1:DivGGAXEgPSlEBzxGzZI+ZLohi+xUj054jfeKui00ws=
 golang.org/x/net v0.6.0/go.mod h1:2Tu9+aMcznHK/AK1HMvgo6xiTLG5rD5rZLDS+rp2Bjs=
 golang.org/x/net v0.7.0/go.mod h1:2Tu9+aMcznHK/AK1HMvgo6xiTLG5rD5rZLDS+rp2Bjs=
 golang.org/x/net v0.8.0/go.mod h1:QVkue5JL9kW//ek3r6jTKnTFis1tRmNAW2P1shuFdJc=
-golang.org/x/net v0.35.0 h1:T5GQRQb2y08kTAByq9L4/bz8cipCdA8FbRTXewonqY8=
-golang.org/x/net v0.35.0/go.mod h1:EglIi67kWsHKlRzzVMUD93VMSWGFOMSZgxFjparz1Qk=
+golang.org/x/net v0.15.0 h1:ugBLEUaxABaB5AJqW9enI0ACdci2RUd4eP51NTBvuJ8=
+golang.org/x/net v0.15.0/go.mod h1:idbUs1IY1+zTqbi8yxTbhexhEEk5ur9LInksu6HrEpk=
+golang.org/x/net v0.22.0 h1:9sGLhx7iRIHEiX0oAJ3MRZMUCElJgy7Br1nO+AMN3Tc=
+golang.org/x/net v0.22.0/go.mod h1:JKghWKKOSdJwpW2GEx0Ja7fmaKnMsbu+MWVZTokSYmg=
 golang.org/x/oauth2 v0.0.0-20180821212333-d2e6202438be/go.mod h1:N/0e6XlmueqKjAGxoOufVs8QHGRruUQn6yWY3a++T0U=
 golang.org/x/oauth2 v0.0.0-20190226205417-e64efc72b421/go.mod h1:gOpvHmFTYa4IltrdGE7lF6nIHvwfUNPOp7c8zoXwtLw=
 golang.org/x/oauth2 v0.0.0-20190604053449-0f29369cfe45/go.mod h1:gOpvHmFTYa4IltrdGE7lF6nIHvwfUNPOp7c8zoXwtLw=
@@ -1051,6 +1049,7 @@ golang.org/x/sync v0.0.0-20220722155255-886fb9371eb4/go.mod h1:RxMgew5VJxzue5/jJ
 golang.org/x/sync v0.0.0-20220819030929-7fc1605a5dde/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
 golang.org/x/sync v0.0.0-20220929204114-8fcdb60fdcc0/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
 golang.org/x/sync v0.1.0/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
+golang.org/x/sync v0.3.0 h1:ftCYgMx6zT/asHUrPw8BLLscYtGznsLAnjq5RH9P66E=
 golang.org/x/sys v0.0.0-20180830151530-49385e6e1522/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY=
 golang.org/x/sys v0.0.0-20190215142949-d0b11bdaac8a/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY=
 golang.org/x/sys v0.0.0-20190312061237-fead79001313/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
@@ -1126,8 +1125,10 @@ golang.org/x/sys v0.2.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
 golang.org/x/sys v0.4.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
 golang.org/x/sys v0.5.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
 golang.org/x/sys v0.6.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
-golang.org/x/sys v0.30.0 h1:QjkSwP/36a20jFYWkSue1YwXzLmsV5Gfq7Eiy72C1uc=
-golang.org/x/sys v0.30.0/go.mod h1:/VUhepiaJMQUp4+oa/7Zr1D23ma6VTLIYjOOTFZPUcA=
+golang.org/x/sys v0.12.0 h1:CM0HF96J0hcLAwsHPJZjfdNzs0gftsLfgKt57wWHJ0o=
+golang.org/x/sys v0.12.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
+golang.org/x/sys v0.18.0 h1:DBdB3niSjOA/O0blCZBqDefyWNYveAYMNF1Wum0DYQ4=
+golang.org/x/sys v0.18.0/go.mod h1:/VUhepiaJMQUp4+oa/7Zr1D23ma6VTLIYjOOTFZPUcA=
 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/term v0.2.0/go.mod h1:TVmDHMZPmdnySmBfhjOoOdhjzdE1h4u1VwSiw2l1Nuc=
@@ -1149,8 +1150,6 @@ golang.org/x/text v0.5.0/go.mod h1:mrYo+phRRbMaCq/xk9113O4dZlRixOauAjOtrjsXDZ8=
 golang.org/x/text v0.6.0/go.mod h1:mrYo+phRRbMaCq/xk9113O4dZlRixOauAjOtrjsXDZ8=
 golang.org/x/text v0.7.0/go.mod h1:mrYo+phRRbMaCq/xk9113O4dZlRixOauAjOtrjsXDZ8=
 golang.org/x/text v0.8.0/go.mod h1:e1OnstbJyHTd6l/uOt8jFFHp6TRDWZR/bV3emEE/zU8=
-golang.org/x/text v0.22.0 h1:bofq7m3/HAFvbF51jz3Q9wLg3jkvSPuiZu/pD1XwgtM=
-golang.org/x/text v0.22.0/go.mod h1:YRoo4H8PVmsu+E3Ou7cqLVH8oXWIHVoX0jqUWALQhfY=
 golang.org/x/time v0.0.0-20181108054448-85acf8d2951c/go.mod h1:tRJNPiyCQ0inRvYxbN9jk5I+vvW/OXSQhTDSoE431IQ=
 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=
@@ -1217,9 +1216,14 @@ golang.org/x/tools v0.1.9/go.mod h1:nABZi5QlRsZVlzPpHl034qft6wpY4eDcsTt5AaioBiU=
 golang.org/x/tools v0.1.12/go.mod h1:hNGJHUnrk76NpqgfD5Aqm5Crs+Hm0VOH/i9J2+nxYbc=
 golang.org/x/tools v0.3.0/go.mod h1:/rWhSS2+zyEVwoJf8YAX6L2f0ntZ7Kn/mGgAWcipA5k=
 golang.org/x/tools v0.6.0/go.mod h1:Xwgl3UAJ/d3gWutnCtw505GrjyAbvKui8lOU390QaIU=
+golang.org/x/tools v0.11.0 h1:EMCa6U9S2LtZXLAMoWiR/R8dAQFRqbAitmbJ2UKhoi8=
+golang.org/x/tools v0.11.0/go.mod h1:anzJrxPjNtfgiYQYirP2CPGzGLxrH2u2QBhn6Bf3qY8=
+golang.org/x/tools v0.19.0 h1:tfGCXNR1OsFG+sVdLAitlpjAvD/I6dHDKnYrpEZUHkw=
+golang.org/x/tools v0.19.0/go.mod h1:qoJWxmGSIBmAeriMx19ogtrEPrGtDbPK634QFIcLAhc=
 golang.org/x/xerrors v0.0.0-20190717185122-a985d3407aa7/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0=
 golang.org/x/xerrors v0.0.0-20191011141410-1b5146add898/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0=
 golang.org/x/xerrors v0.0.0-20191204190536-9bdfabe68543/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0=
+golang.org/x/xerrors v0.0.0-20200804184101-5ec99f83aff1 h1:go1bK/D/BFZV2I8cIQd1NKEZ+0owSTG1fDTci4IqFcE=
 golang.org/x/xerrors v0.0.0-20200804184101-5ec99f83aff1/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0=
 golang.org/x/xerrors v0.0.0-20220411194840-2f41105eb62f/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0=
 golang.org/x/xerrors v0.0.0-20220517211312-f3a8303e98df/go.mod h1:K8+ghG5WaK9qNqU5K3HdILfMLy1f3aNYFI/wnl100a8=
@@ -1360,6 +1364,7 @@ google.golang.org/genproto v0.0.0-20211118181313-81c1377c94b1/go.mod h1:5CzLGKJ6
 google.golang.org/genproto v0.0.0-20211206160659-862468c7d6e0/go.mod h1:5CzLGKJ67TSI2B9POpiiyGha0AjJvZIUgRMt1dSmuhc=
 google.golang.org/genproto v0.0.0-20211208223120-3a66f561d7aa/go.mod h1:5CzLGKJ67TSI2B9POpiiyGha0AjJvZIUgRMt1dSmuhc=
 google.golang.org/genproto v0.0.0-20211221195035-429b39de9b1c/go.mod h1:5CzLGKJ67TSI2B9POpiiyGha0AjJvZIUgRMt1dSmuhc=
+google.golang.org/genproto v0.0.0-20220107163113-42d7afdf6368/go.mod h1:5CzLGKJ67TSI2B9POpiiyGha0AjJvZIUgRMt1dSmuhc=
 google.golang.org/genproto v0.0.0-20220126215142-9970aeb2e350/go.mod h1:5CzLGKJ67TSI2B9POpiiyGha0AjJvZIUgRMt1dSmuhc=
 google.golang.org/genproto v0.0.0-20220207164111-0872dc986b00/go.mod h1:5CzLGKJ67TSI2B9POpiiyGha0AjJvZIUgRMt1dSmuhc=
 google.golang.org/genproto v0.0.0-20220218161850-94dd64e39d7c/go.mod h1:kGP+zUP2Ddo0ayMi4YuN7C3WZyJvGLZRh8Z5wnAqvEI=
@@ -1434,8 +1439,6 @@ google.golang.org/genproto/googleapis/api v0.0.0-20230525234020-1aefcd67740a/go.
 google.golang.org/genproto/googleapis/api v0.0.0-20230525234035-dd9d682886f9/go.mod h1:vHYtlOoi6TsQ3Uk2yxR7NI5z8uoV+3pZtR4jmHIkRig=
 google.golang.org/genproto/googleapis/rpc v0.0.0-20230525234015-3fc162c6f38a/go.mod h1:xURIpW9ES5+/GZhnV6beoEtxQrnkRGIfP5VQG2tCBLc=
 google.golang.org/genproto/googleapis/rpc v0.0.0-20230525234030-28d5490b6b19/go.mod h1:66JfowdXAEgad5O9NnYcsNPLCPZJD++2L9X0PCMODrA=
-google.golang.org/genproto/googleapis/rpc v0.0.0-20250227231956-55c901821b1e h1:YA5lmSs3zc/5w+xsRcHqpETkaYyK63ivEPzNTcUUlSA=
-google.golang.org/genproto/googleapis/rpc v0.0.0-20250227231956-55c901821b1e/go.mod h1:LuRYeWDFV6WOn90g357N17oMCaxpgCnbi/44qJvDn2I=
 google.golang.org/grpc v1.19.0/go.mod h1:mqu4LbDTu4XGKhr4mRzUsmM4RtVoemTSY81AxZiDr8c=
 google.golang.org/grpc v1.20.1/go.mod h1:10oTOabMzJvdu6/UiuZezV6QK5dSlG84ov/aaiqXj38=
 google.golang.org/grpc v1.21.1/go.mod h1:oYelfM1adQP15Ek0mdvEgi9Df8B9CZIaU1084ijfRaM=
@@ -1475,8 +1478,6 @@ google.golang.org/grpc v1.50.1/go.mod h1:ZgQEeidpAuNRZ8iRrlBKXZQP1ghovWIVhdJRyCD
 google.golang.org/grpc v1.51.0/go.mod h1:wgNDFcnuBGmxLKI/qn4T+m5BtEBYXJPvibbUPsAIPww=
 google.golang.org/grpc v1.53.0/go.mod h1:OnIrk0ipVdj4N5d9IUoFUx72/VlD7+jUsHwZgwSMQpw=
 google.golang.org/grpc v1.54.0/go.mod h1:PUSEXI6iWghWaB6lXM4knEgpJNu2qUcKfDtNci3EC2g=
-google.golang.org/grpc v1.70.0 h1:pWFv03aZoHzlRKHWicjsZytKAiYCtNS0dHbXnIdq7jQ=
-google.golang.org/grpc v1.70.0/go.mod h1:ofIJqVKDXx/JiXrwr2IG4/zwdH9txy3IlF40RmcJSQw=
 google.golang.org/grpc/cmd/protoc-gen-go-grpc v1.1.0/go.mod h1:6Kw0yEErY5E/yWrBtf03jp27GLLJujG4z/JK95pnjjw=
 google.golang.org/protobuf v0.0.0-20200109180630-ec00e32a8dfd/go.mod h1:DFci5gLYBciE7Vtevhsrf46CRTquxDuWsQurQQe4oz8=
 google.golang.org/protobuf v0.0.0-20200221191635-4d8936d0db64/go.mod h1:kwYJMbMJ01Woi6D6+Kah6886xMZcty6N08ah7+eCXa0=
@@ -1495,16 +1496,22 @@ google.golang.org/protobuf v1.28.0/go.mod h1:HV8QOd/L58Z+nl8r43ehVNZIU/HEI6OcFqw
 google.golang.org/protobuf v1.28.1/go.mod h1:HV8QOd/L58Z+nl8r43ehVNZIU/HEI6OcFqwMG9pJV4I=
 google.golang.org/protobuf v1.29.1/go.mod h1:HV8QOd/L58Z+nl8r43ehVNZIU/HEI6OcFqwMG9pJV4I=
 google.golang.org/protobuf v1.30.0/go.mod h1:HV8QOd/L58Z+nl8r43ehVNZIU/HEI6OcFqwMG9pJV4I=
-google.golang.org/protobuf v1.36.5 h1:tPhr+woSbjfYvY6/GPufUoYizxw1cF/yFoxJ2fmpwlM=
-google.golang.org/protobuf v1.36.5/go.mod h1:9fA7Ob0pmnwhb644+1+CVWFRbNajQ6iRojtC/QF5bRE=
+google.golang.org/protobuf v1.31.0 h1:g0LDEJHgrBl9N9r17Ru3sqWhkIx2NB67okBHPwC7hs8=
+google.golang.org/protobuf v1.31.0/go.mod h1:HV8QOd/L58Z+nl8r43ehVNZIU/HEI6OcFqwMG9pJV4I=
+google.golang.org/protobuf v1.33.0 h1:uNO2rsAINq/JlFpSdYEKIZ0uKD/R9cpdv0T+yoGwGmI=
+google.golang.org/protobuf v1.33.0/go.mod h1:c6P6GXX6sHbq/GpV6MGZEdwhWPcYBgnhAHhKbcUYpos=
 gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
 gopkg.in/check.v1 v1.0.0-20180628173108-788fd7840127/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
-gopkg.in/check.v1 v1.0.0-20201130134442-10cb98267c6c h1:Hei/4ADfdWqJk1ZMxUNpqntNwaWcugrBjAiHlqqRiVk=
+gopkg.in/check.v1 v1.0.0-20190902080502-41f04d3bba15 h1:YR8cESwS4TdDjEe65xsg0ogRM/Nc3DYOhEAlW+xobZo=
+gopkg.in/check.v1 v1.0.0-20190902080502-41f04d3bba15/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
 gopkg.in/check.v1 v1.0.0-20201130134442-10cb98267c6c/go.mod h1:JHkPIbrfpd72SG/EVd6muEfDQjcINNoR0C8j2r3qZ4Q=
 gopkg.in/errgo.v2 v2.1.0/go.mod h1:hNsd1EY+bozCKY1Ytp96fpM3vjJbqLJn88ws8XvfDNI=
 gopkg.in/yaml.v2 v2.2.2/go.mod h1:hI93XBmqTisBFMUTm0b8Fm+jr3Dg1NNxqwp+5A1VGuI=
 gopkg.in/yaml.v2 v2.2.3/go.mod h1:hI93XBmqTisBFMUTm0b8Fm+jr3Dg1NNxqwp+5A1VGuI=
+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-20200615113413-eeeca48fe776/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.1 h1:fxVm/GzAzEWqLHuvctI91KS9hhNmmWOoWu0XTYJS7CA=
 gopkg.in/yaml.v3 v3.0.1/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=
@@ -1554,3 +1561,7 @@ rsc.io/binaryregexp v0.2.0/go.mod h1:qTv7/COck+e2FymRvadv62gMdZztPaShugOCi3I+8D8
 rsc.io/pdf v0.1.1/go.mod h1:n8OzWcQ6Sp37PL01nO98y4iUCRdTGarVfzxY20ICaU4=
 rsc.io/quote/v3 v3.1.0/go.mod h1:yEA65RcK8LyAZtP9Kv3t0HmxON59tX3rD+tICJqUlj0=
 rsc.io/sampler v1.3.0/go.mod h1:T1hPZKmBbMNahiBKFy5HrXp6adAjACjK9JXDnKaTXpA=
+sigs.k8s.io/yaml v1.3.0 h1:a2VclLzOGrwOHDiV8EfBGhvjHvP46CtW5j6POvhYGGo=
+sigs.k8s.io/yaml v1.3.0/go.mod h1:GeOyir5tyXNByN85N/dRIT9es5UQNerPYEKK56eTBm8=
+sigs.k8s.io/yaml v1.4.0 h1:Mk1wCc2gy/F0THH0TAp1QYyJNzRm2KCLy3o5ASXVI5E=
+sigs.k8s.io/yaml v1.4.0/go.mod h1:Ejl7/uTz7PSA4eKMyQCUTnhZYNmLIl+5c2lQPGR2BPY=
--- a/handler.go
+++ b/handler.go
@@ -6,29 +6,23 @@ import (
 	"io"
 	"net/http"
 	"reflect"
-	"slices"
-	"strconv"
 	"strings"
 	"sync"
-	"time"

 	"go.unistack.org/micro/v4/errors"
 	"go.unistack.org/micro/v4/logger"
 	"go.unistack.org/micro/v4/metadata"
-	"go.unistack.org/micro/v4/meter"
-	"go.unistack.org/micro/v4/options"
-	"go.unistack.org/micro/v4/semconv"
+	"go.unistack.org/micro/v4/register"
 	"go.unistack.org/micro/v4/server"
-	"go.unistack.org/micro/v4/tracer"
 	rhttp "go.unistack.org/micro/v4/util/http"
 	rflutil "go.unistack.org/micro/v4/util/reflect"
 )

 var (
-	DefaultErrorHandler = func(ctx context.Context, s server.Handler, w http.ResponseWriter, r *http.Request, err error, status int) {
+	DefaultErrorHandler = func(ctx context.Context, s interface{}, w http.ResponseWriter, r *http.Request, err error, status int) {
 		w.WriteHeader(status)
 		if _, cerr := w.Write([]byte(err.Error())); cerr != nil {
-			logger.DefaultLogger.Error(ctx, "write error", cerr)
+			logger.DefaultLogger.Error(ctx, fmt.Sprintf("write failed: %v", cerr))
 		}
 	}
 	DefaultContentType = "application/json"
@@ -41,10 +35,11 @@ type patHandler struct {
 }

 type httpHandler struct {
-	opts     server.HandlerOptions
+	opts     server.HandleOptions
 	hd       interface{}
 	handlers *rhttp.Trie
 	name     string
+	eps      []*register.Endpoint
 	sopts    server.Options
 	sync.RWMutex
 }
@@ -57,7 +52,11 @@ func (h *httpHandler) Handler() interface{} {
 	return h.hd
 }

-func (h *httpHandler) Options() server.HandlerOptions {
+func (h *httpHandler) Endpoints() []*register.Endpoint {
+	return h.eps
+}
+
+func (h *httpHandler) Options() server.HandleOptions {
 	return h.opts
 }

@@ -110,21 +109,20 @@ func (h *Server) HTTPHandlerFunc(handler interface{}) (http.HandlerFunc, error)
 			md = metadata.New(len(r.Header) + 8)
 		}
 		for k, v := range r.Header {
-			md[k] = append(md[k], v...)
+			md[k] = v[0]
 		}
-
-		md["RemoteAddr"] = append(md["RemoteAddr"], r.RemoteAddr)
-		md["Method"] = append(md["Method"], r.Method)
-		md["URL"] = append(md["URL"], r.URL.String())
-		md["Proto"] = append(md["Proto"], r.Proto)
-		md["Content-Length"] = append(md["Content-Length"], fmt.Sprintf("%d", r.ContentLength))
-		md["Transfer-Encoding"] = append(md["Transfer-Encoding"], r.TransferEncoding...)
-		md["Host"] = append(md["Host"], r.Host)
-		md["RequestURI"] = append(md["RequestURI"], r.RequestURI)
+		md["RemoteAddr"] = r.RemoteAddr
+		md["Method"] = r.Method
+		md["URL"] = r.URL.String()
+		md["Proto"] = r.Proto
+		md["Content-Length"] = fmt.Sprintf("%d", r.ContentLength)
+		md["Transfer-Encoding"] = r.TransferEncoding[0]
+		md["Host"] = r.Host
+		md["RequestURI"] = r.RequestURI
 		if r.TLS != nil {
-			md["TLS"] = append(md["TLS"], "true")
-			md["TLS-ALPN"] = append(md["TLS-ALPN"], r.TLS.NegotiatedProtocol)
-			md["TLS-ServerName"] = append(md["TLS-ServerName"], r.TLS.ServerName)
+			md["TLS"] = "true"
+			md["TLS-ALPN"] = r.TLS.NegotiatedProtocol
+			md["TLS-ServerName"] = r.TLS.ServerName
 		}

 		ctx = metadata.NewIncomingContext(ctx, md)
@@ -161,20 +159,18 @@ func (h *Server) HTTPHandlerFunc(handler interface{}) (http.HandlerFunc, error)
 		if !match && h.registerRPC {
 			microMethod, mok := md.Get(metadata.HeaderEndpoint)
 			if mok {
-				for i := range microMethod {
-					serviceMethod := strings.Split(microMethod[i], ".")
-					if len(serviceMethod) == 2 {
-						if shdlr, ok := h.handlers[serviceMethod[0]]; ok {
-							hdlr := shdlr.(*httpHandler)
-							fh, mp, err := hdlr.handlers.Search(http.MethodPost, "/"+microMethod[i])
-							if err == nil {
-								// match = true
-								for k, v := range mp {
-									matches[k] = v
-								}
-								hldr = fh.(*patHandler)
-								handler = hdlr
+				serviceMethod := strings.Split(microMethod, ".")
+				if len(serviceMethod) == 2 {
+					if shdlr, ok := h.handlers[serviceMethod[0]]; ok {
+						hdlr := shdlr.(*httpHandler)
+						fh, mp, err := hdlr.handlers.Search(http.MethodPost, "/"+microMethod)
+						if err == nil {
+							match = true
+							for k, v := range mp {
+								matches[k] = v
 							}
+							hldr = fh.(*patHandler)
+							handler = hdlr
 						}
 					}
 				}
@@ -196,7 +192,8 @@ func (h *Server) HTTPHandlerFunc(handler interface{}) (http.HandlerFunc, error)

 		cf, err := h.newCodec(ct)
 		if err != nil {
-			w.WriteHeader(http.StatusUnsupportedMediaType)
+			w.WriteHeader(http.StatusBadRequest)
+			_, _ = w.Write([]byte(err.Error()))
 			return
 		}

@@ -266,20 +263,17 @@ func (h *Server) HTTPHandlerFunc(handler interface{}) (http.HandlerFunc, error)
 			}
 			if nmd, ok := metadata.FromOutgoingContext(fctx); ok {
 				for k, v := range nmd {
-					md[k] = append(md[k], v...)
+					md[k] = v
 				}
 			}
-			ctx = metadata.NewOutgoingContext(ctx, md)

 			return err
 		}

 		// wrap the handler func
-		h.opts.Hooks.EachPrev(func(hook options.Hook) {
-			if h, ok := hook.(server.HookHandler); ok {
-				fn = h(fn)
-			}
-		})
+		// for i := len(handler.sopts.Hooks); i > 0; i-- {
+		//	fn = handler.sopts.Hooks[i-1](fn)
+		// }

 		if ct == "application/x-www-form-urlencoded" {
 			cf, err = h.newCodec(DefaultContentType)
@@ -296,21 +290,17 @@ func (h *Server) HTTPHandlerFunc(handler interface{}) (http.HandlerFunc, error)
 		w.Header().Set(metadata.HeaderContentType, ct)
 		if md, ok := metadata.FromOutgoingContext(ctx); ok {
 			for k, v := range md {
-				for i := range v {
-					w.Header().Set(k, v[i])
-				}
+				w.Header()[k] = []string{v}
 			}
 		}
 		if md := getRspHeader(ctx); md != nil {
 			for k, v := range md {
-				for _, vv := range v {
-					w.Header().Add(k, vv)
-				}
+				w.Header()[k] = v
 			}
 		}
 		if nct := w.Header().Get(metadata.HeaderContentType); nct != ct {
 			if cf, err = h.newCodec(nct); err != nil {
-				h.errorHandler(ctx, nil, w, r, err, http.StatusInternalServerError)
+				h.errorHandler(ctx, nil, w, r, err, http.StatusBadRequest)
 				return
 			}
 		}
@@ -331,7 +321,7 @@ func (h *Server) HTTPHandlerFunc(handler interface{}) (http.HandlerFunc, error)
 		}

 		if err != nil && handler.sopts.Logger.V(logger.ErrorLevel) {
-			handler.sopts.Logger.Error(handler.sopts.Context, "handler error", err)
+			handler.sopts.Logger.Error(handler.sopts.Context, fmt.Sprintf("handler err: %v", err))
 			return
 		}

@@ -341,7 +331,7 @@ func (h *Server) HTTPHandlerFunc(handler interface{}) (http.HandlerFunc, error)
 		w.WriteHeader(scode)

 		if _, cerr := w.Write(buf); cerr != nil {
-			handler.sopts.Logger.Error(ctx, "write failed", cerr)
+			handler.sopts.Logger.Error(ctx, fmt.Sprintf("write failed: %v", cerr))
 		}
 	}, nil
 }
@@ -352,36 +342,31 @@ func (h *Server) ServeHTTP(w http.ResponseWriter, r *http.Request) {
 		ct = htype
 	}

-	ts := time.Now()
-
 	ctx := context.WithValue(r.Context(), rspCodeKey{}, &rspCodeVal{})
 	ctx = context.WithValue(ctx, rspHeaderKey{}, &rspHeaderVal{})
-
 	md, ok := metadata.FromIncomingContext(ctx)
 	if !ok {
 		md = metadata.New(len(r.Header) + 8)
 	}
 	for k, v := range r.Header {
-		md[k] = append(md[k], v...)
+		md[k] = v[0]
 	}
-
-	md["RemoteAddr"] = append(md["RemoteAddr"], r.RemoteAddr)
+	md["RemoteAddr"] = r.RemoteAddr
 	if r.TLS != nil {
-		md["Scheme"] = append(md["Scheme"], "https")
+		md["Scheme"] = "https"
 	} else {
-		md["Scheme"] = append(md["Scheme"], "http")
+		md["Scheme"] = "http"
 	}
-	md["Method"] = append(md["Method"], r.Method)
-	md["URL"] = append(md["URL"], r.URL.String())
-	md["Proto"] = append(md["Proto"], r.Proto)
-	md["Content-Length"] = append(md["Content-Length"], fmt.Sprintf("%d", r.ContentLength))
+	md["Method"] = r.Method
+	md["URL"] = r.URL.String()
+	md["Proto"] = r.Proto
+	md["Content-Length"] = fmt.Sprintf("%d", r.ContentLength)
 	if len(r.TransferEncoding) > 0 {
-		md["TransferEncoding"] = append(md["Content-Length"], r.TransferEncoding...)
+		md["Transfer-Encoding"] = r.TransferEncoding[0]
 	}
-	md["Host"] = append(md["Host"], r.Host)
-	md["RequestURI"] = append(md["RequestURI"], r.RequestURI)
+	md["Host"] = r.Host
+	md["RequestURI"] = r.RequestURI
 	ctx = metadata.NewIncomingContext(ctx, md)
-	ctx = metadata.NewOutgoingContext(ctx, metadata.New(0))

 	path := r.URL.Path
 	if !strings.HasPrefix(path, "/") {
@@ -415,136 +400,39 @@ func (h *Server) ServeHTTP(w http.ResponseWriter, r *http.Request) {
 	if !match && h.registerRPC {
 		microMethod, mok := md.Get(metadata.HeaderEndpoint)
 		if mok {
-			for i := range microMethod {
-				serviceMethod := strings.Split(microMethod[i], ".")
-				if len(serviceMethod) == 2 {
-					if shdlr, ok := h.handlers[serviceMethod[0]]; ok {
-						hdlr := shdlr.(*httpHandler)
-						fh, mp, err := hdlr.handlers.Search(http.MethodPost, "/"+microMethod[i])
-						if err == nil {
-							match = true
-							for k, v := range mp {
-								matches[k] = v
-							}
-							hldr = fh.(*patHandler)
-							handler = hdlr
+			serviceMethod := strings.Split(microMethod, ".")
+			if len(serviceMethod) == 2 {
+				if shdlr, ok := h.handlers[serviceMethod[0]]; ok {
+					hdlr := shdlr.(*httpHandler)
+					fh, mp, err := hdlr.handlers.Search(http.MethodPost, "/"+microMethod)
+					if err == nil {
+						match = true
+						for k, v := range mp {
+							matches[k] = v
 						}
+						hldr = fh.(*patHandler)
+						handler = hdlr
 					}
 				}
 			}
 		}
 	}

-	var sp tracer.Span
 	if !match && h.hd != nil {
-		if hdlr, ok := h.hd.Handler().(http.Handler); ok {
-			endpointName := fmt.Sprintf("%s.%s", hldr.name, hldr.mtype.method.Name)
-			if !slices.Contains(tracer.DefaultSkipEndpoints, endpointName) {
-				ctx, sp = h.opts.Tracer.Start(ctx, "rpc-server",
-					tracer.WithSpanKind(tracer.SpanKindServer),
-					tracer.WithSpanLabels(
-						"endpoint", endpointName,
-					),
-				)
-				defer func() {
-					n := GetRspCode(ctx)
-					if s, _ := sp.Status(); s != tracer.SpanStatusError && n > 399 {
-						sp.SetStatus(tracer.SpanStatusError, http.StatusText(n))
-					}
-					sp.Finish()
-				}()
-			}
-
-			if !slices.Contains(meter.DefaultSkipEndpoints, endpointName) {
-				h.opts.Meter.Counter(semconv.ServerRequestInflight, "endpoint", endpointName, "server", "http").Inc()
-
-				defer func() {
-					n := GetRspCode(ctx)
-					if n > 399 {
-						h.opts.Meter.Counter(semconv.ServerRequestTotal, "endpoint", endpointName, "server", "http", "status", "success", "code", strconv.Itoa(n)).Inc()
-					} else {
-						h.opts.Meter.Counter(semconv.ServerRequestTotal, "endpoint", endpointName, "server", "http", "status", "failure", "code", strconv.Itoa(n)).Inc()
-					}
-					te := time.Since(ts)
-					h.opts.Meter.Summary(semconv.ServerRequestLatencyMicroseconds, "endpoint", endpointName, "server", "http").Update(te.Seconds())
-					h.opts.Meter.Histogram(semconv.ServerRequestDurationSeconds, "endpoint", endpointName, "server", "http").Update(te.Seconds())
-					h.opts.Meter.Counter(semconv.ServerRequestInflight, "endpoint", endpointName, "server", "http").Dec()
-				}()
-			}
-
-			hdlr.ServeHTTP(w, r.WithContext(ctx))
+		if hdlr, ok := h.hd.(http.Handler); ok {
+			hdlr.ServeHTTP(w, r)
 			return
 		}
 	} else if !match {
 		// check for http.HandlerFunc handlers
-		if !slices.Contains(tracer.DefaultSkipEndpoints, r.URL.Path) {
-			ctx, sp = h.opts.Tracer.Start(ctx, "rpc-server",
-				tracer.WithSpanKind(tracer.SpanKindServer),
-				tracer.WithSpanLabels(
-					"endpoint", r.URL.Path,
-					"server", "http",
-				),
-			)
-
-			defer func() {
-				if n := GetRspCode(ctx); n > 399 {
-					sp.SetStatus(tracer.SpanStatusError, http.StatusText(n))
-				} else {
-					sp.SetStatus(tracer.SpanStatusError, http.StatusText(http.StatusNotFound))
-				}
-				sp.Finish()
-			}()
-		}
 		if ph, _, err := h.pathHandlers.Search(r.Method, r.URL.Path); err == nil {
-			ph.(http.HandlerFunc)(w, r.WithContext(ctx))
+			ph.(http.HandlerFunc)(w, r)
 			return
 		}
 		h.errorHandler(ctx, nil, w, r, fmt.Errorf("not matching route found"), http.StatusNotFound)
 		return
 	}

-	endpointName := fmt.Sprintf("%s.%s", hldr.name, hldr.mtype.method.Name)
-
-	topts := []tracer.SpanOption{
-		tracer.WithSpanKind(tracer.SpanKindServer),
-		tracer.WithSpanLabels(
-			"endpoint", endpointName,
-			"server", "http",
-		),
-	}
-
-	if slices.Contains(tracer.DefaultSkipEndpoints, endpointName) {
-		topts = append(topts, tracer.WithSpanRecord(false))
-	}
-
-	ctx, sp = h.opts.Tracer.Start(ctx, "rpc-server", topts...)
-
-	if !slices.Contains(meter.DefaultSkipEndpoints, handler.name) {
-		defer func() {
-			te := time.Since(ts)
-			h.opts.Meter.Summary(semconv.ServerRequestLatencyMicroseconds, "endpoint", handler.name, "server", "http").Update(te.Seconds())
-			h.opts.Meter.Histogram(semconv.ServerRequestDurationSeconds, "endpoint", handler.name, "server", "http").Update(te.Seconds())
-			h.opts.Meter.Counter(semconv.ServerRequestInflight, "endpoint", handler.name, "server", "http").Dec()
-
-			n := GetRspCode(ctx)
-			if n > 399 {
-				h.opts.Meter.Counter(semconv.ServerRequestTotal, "endpoint", handler.name, "server", "http", "status", "failure", "code", strconv.Itoa(n)).Inc()
-			} else {
-				h.opts.Meter.Counter(semconv.ServerRequestTotal, "endpoint", handler.name, "server", "http", "status", "success", "code", strconv.Itoa(n)).Inc()
-			}
-		}()
-	}
-
-	defer func() {
-		n := GetRspCode(ctx)
-		if n > 399 {
-			if s, _ := sp.Status(); s != tracer.SpanStatusError {
-				sp.SetStatus(tracer.SpanStatusError, http.StatusText(n))
-			}
-		}
-		sp.Finish()
-	}()
-
 	// get fields from url values
 	if len(r.URL.RawQuery) > 0 {
 		umd, cerr := rflutil.URLMap(r.URL.RawQuery)
@@ -591,7 +479,6 @@ func (h *Server) ServeHTTP(w http.ResponseWriter, r *http.Request) {
 	if r.Body != nil {
 		var buf []byte
 		buf, err = io.ReadAll(r.Body)
-		r.Body.Close()
 		if err != nil && err != io.EOF {
 			h.errorHandler(ctx, handler, w, r, err, http.StatusInternalServerError)
 			return
@@ -636,23 +523,17 @@ func (h *Server) ServeHTTP(w http.ResponseWriter, r *http.Request) {
 		}
 		if nmd, ok := metadata.FromOutgoingContext(fctx); ok {
 			for k, v := range nmd {
-				md[k] = append(md[k], v...)
+				md[k] = v
 			}
 		}
-		ctx = metadata.NewOutgoingContext(ctx, md)
-
-		if err != nil && sp != nil {
-			sp.SetStatus(tracer.SpanStatusError, err.Error())
-		}

 		return err
 	}

-	h.opts.Hooks.EachPrev(func(hook options.Hook) {
-		if h, ok := hook.(server.HookHandler); ok {
-			fn = h(fn)
-		}
-	})
+	// wrap the handler func
+	// for i := len(handler.sopts.HdlrWrappers); i > 0; i-- {
+	//	fn = handler.sopts.HdlrWrappers[i-1](fn)
+	// }

 	if ct == "application/x-www-form-urlencoded" {
 		cf, err = h.newCodec(DefaultContentType)
@@ -669,9 +550,7 @@ func (h *Server) ServeHTTP(w http.ResponseWriter, r *http.Request) {
 	w.Header().Set(metadata.HeaderContentType, ct)
 	if md, ok := metadata.FromOutgoingContext(ctx); ok {
 		for k, v := range md {
-			for i := range v {
-				w.Header().Set(k, v[i])
-			}
+			w.Header()[k] = []string{v}
 		}
 	}
 	if md := getRspHeader(ctx); md != nil {
@@ -683,7 +562,7 @@ func (h *Server) ServeHTTP(w http.ResponseWriter, r *http.Request) {
 	}
 	if nct := w.Header().Get(metadata.HeaderContentType); nct != ct {
 		if cf, err = h.newCodec(nct); err != nil {
-			h.errorHandler(ctx, nil, w, r, err, http.StatusInternalServerError)
+			h.errorHandler(ctx, nil, w, r, err, http.StatusBadRequest)
 			return
 		}
 	}
@@ -703,18 +582,17 @@ func (h *Server) ServeHTTP(w http.ResponseWriter, r *http.Request) {
 		buf, err = cf.Marshal(replyv.Interface())
 	}

-	if err != nil {
-		if handler.sopts.Logger.V(logger.ErrorLevel) {
-			handler.sopts.Logger.Error(handler.sopts.Context, "handler error", err)
-		}
-		scode = http.StatusInternalServerError
-	} else if nscode := GetRspCode(ctx); nscode != 0 {
-		scode = nscode
+	if err != nil && handler.sopts.Logger.V(logger.ErrorLevel) {
+		handler.sopts.Logger.Error(handler.sopts.Context, fmt.Sprintf("handler err: %v", err))
+		return
 	}

+	if nscode := GetRspCode(ctx); nscode != 0 {
+		scode = nscode
+	}
 	w.WriteHeader(scode)

 	if _, cerr := w.Write(buf); cerr != nil {
-		handler.sopts.Logger.Error(ctx, "respoonse write error", cerr)
+		handler.sopts.Logger.Error(ctx, fmt.Sprintf("write failed: %v", cerr))
 	}
 }
--- a/handler/graphql/graphql.go
+++ b/handler/graphql/graphql.go
@@ -1,77 +0,0 @@
-//go:build ignore
-
-package graphql_handler
-
-import (
-	"context"
-	"fmt"
-
-	"github.com/99designs/gqlgen/graphql"
-	"go.unistack.org/micro/v4/logger"
-	"go.unistack.org/micro/v4/store"
-)
-
-var _ graphql.Cache = (*cacheWrapper)(nil)
-
-type Handler struct {
-	opts Options
-}
-
-type Option func(*Options)
-
-type Options struct {
-	cache *cacheWrapper
-	Path  string
-}
-
-type cacheWrapper struct {
-	s store.Store
-	l logger.Logger
-}
-
-func (c *cacheWrapper) Get(ctx context.Context, key string) (interface{}, bool) {
-	var val interface{}
-	if err := c.s.Read(ctx, key, val); err != nil && err != store.ErrNotFound {
-		c.l.Error(ctx, fmt.Sprintf("cache.Get %s failed", key), err)
-		return nil, false
-	}
-	return val, true
-}
-
-func (c *cacheWrapper) Add(ctx context.Context, key string, val interface{}) {
-	if err := c.s.Write(ctx, key, val); err != nil {
-		c.l.Error(ctx, fmt.Sprintf("cache.Add %s failed", key), err)
-	}
-}
-
-func Store(s store.Store) Option {
-	return func(o *Options) {
-		if o.cache == nil {
-			o.cache = &cacheWrapper{}
-		}
-		o.cache.s = s
-	}
-}
-
-func Logger(l logger.Logger) Option {
-	return func(o *Options) {
-		if o.cache == nil {
-			o.cache = &cacheWrapper{}
-		}
-		o.cache.l = l
-	}
-}
-
-func Path(path string) Option {
-	return func(o *Options) {
-		o.Path = path
-	}
-}
-
-func NewHandler(opts ...Option) *Handler {
-	options := Options{}
-	for _, o := range opts {
-		o(&options)
-	}
-	return &Handler{opts: options}
-}
--- a/handler/health/health.go
+++ b/handler/health/health.go
@@ -1,4 +1,4 @@
-package health_handler
+package health // import "go.unistack.org/micro-server-http/v4/handler/health"

 import (
 	"context"
@@ -7,36 +7,21 @@ import (
 	"go.unistack.org/micro/v4/errors"
 )

-var _ HealthServiceServer = &Handler{}
+var _ HealthServiceServer = (*Handler)(nil)

 type Handler struct {
 	opts Options
 }

-type (
-	CheckFunc func(context.Context) error
-	Option    func(*Options)
-)
+type CheckFunc func(context.Context) error

-type Stater interface {
-	Live() bool
-	Ready() bool
-	Health() bool
-}
+type Option func(*Options)

 type Options struct {
-	Version      string
-	Name         string
-	Staters      []Stater
-	LiveChecks   []CheckFunc
-	ReadyChecks  []CheckFunc
-	HealthChecks []CheckFunc
-}
-
-func Service(s ...Stater) Option {
-	return func(o *Options) {
-		o.Staters = append(o.Staters, s...)
-	}
+	Version     string
+	Name        string
+	LiveChecks  []CheckFunc
+	ReadyChecks []CheckFunc
 }

 func LiveChecks(fns ...CheckFunc) Option {
@@ -51,12 +36,6 @@ func ReadyChecks(fns ...CheckFunc) Option {
 	}
 }

-func HealthChecks(fns ...CheckFunc) Option {
-	return func(o *Options) {
-		o.HealthChecks = append(o.HealthChecks, fns...)
-	}
-}
-
 func Name(name string) Option {
 	return func(o *Options) {
 		o.Name = name
@@ -77,51 +56,18 @@ func NewHandler(opts ...Option) *Handler {
 	return &Handler{opts: options}
 }

-func (h *Handler) Healthy(ctx context.Context, req *codecpb.Frame, rsp *codecpb.Frame) error {
-	var err error
-
-	for _, s := range h.opts.Staters {
-		if !s.Health() {
-			return errors.ServiceUnavailable(h.opts.Name, "%v", err)
-		}
-	}
-
-	for _, fn := range h.opts.HealthChecks {
-		if err = fn(ctx); err != nil {
-			return errors.ServiceUnavailable(h.opts.Name, "%v", err)
-		}
-	}
-
-	return nil
-}
-
 func (h *Handler) Live(ctx context.Context, req *codecpb.Frame, rsp *codecpb.Frame) error {
 	var err error
-
-	for _, s := range h.opts.Staters {
-		if !s.Live() {
-			return errors.ServiceUnavailable(h.opts.Name, "%v", err)
-		}
-	}
-
 	for _, fn := range h.opts.LiveChecks {
 		if err = fn(ctx); err != nil {
 			return errors.ServiceUnavailable(h.opts.Name, "%v", err)
 		}
 	}
-
 	return nil
 }

 func (h *Handler) Ready(ctx context.Context, req *codecpb.Frame, rsp *codecpb.Frame) error {
 	var err error
-
-	for _, s := range h.opts.Staters {
-		if !s.Ready() {
-			return errors.ServiceUnavailable(h.opts.Name, "%v", err)
-		}
-	}
-
 	for _, fn := range h.opts.ReadyChecks {
 		if err = fn(ctx); err != nil {
 			return errors.ServiceUnavailable(h.opts.Name, "%v", err)
--- a/handler/health/health.proto
+++ b/handler/health/health.proto
@@ -1,29 +1,13 @@
 syntax = "proto3";

 package micro.server.http.v4.handler.health;
-option go_package = "go.unistack.org/micro-server-http/v4/handler/health;health_handler";
+option go_package = "go.unistack.org/micro-server-http/v4/handler/health;health";

 import "api/annotations.proto";
 import "openapiv3/annotations.proto";
 import "codec/frame.proto";

 service HealthService {
-  rpc Healthy(micro.codec.Frame) returns (micro.codec.Frame) {
-		option (micro.openapiv3.openapiv3_operation) = {
-      operation_id: "Healthy";
-      responses: {
-        default: {
-          reference: {
-            _ref: "micro.codec.Frame";
-          };
-        };
-      };
-    };
-		option (micro.api.http) = { 
-      get: "/health";
-      additional_bindings: { get: "/healthz"; }
-    };
-  };
 	rpc Live(micro.codec.Frame) returns (micro.codec.Frame) {
 		option (micro.openapiv3.openapiv3_operation) = {
      operation_id: "Live";
@@ -35,10 +19,7 @@ service HealthService {
        };
      };
    };
-		option (micro.api.http) = { 
-      get: "/live";
-      additional_bindings: { get: "/livez"; }
-    };
+		option (micro.api.http) = { get: "/live"; };
  };
 	rpc Ready(micro.codec.Frame) returns (micro.codec.Frame) {
 		option (micro.openapiv3.openapiv3_operation) = {
@@ -51,9 +32,7 @@ service HealthService {
        };
      };
    };
-		option (micro.api.http) = { get: "/ready";
-      additional_bindings: { get: "/readyz"; }
-    };
+		option (micro.api.http) = { get: "/ready"; };
  };
 	rpc Version(micro.codec.Frame) returns (micro.codec.Frame) {
 		option (micro.openapiv3.openapiv3_operation) = {
--- a/handler/health/health_micro.pb.go
+++ b/handler/health/health_micro.pb.go
@@ -1,30 +1,21 @@
 // Code generated by protoc-gen-go-micro. DO NOT EDIT.
 // versions:
-// - protoc-gen-go-micro v4.1.0
-// - protoc              v5.29.3
+// - protoc-gen-go-micro v4.0.2
+// - protoc              v4.23.4
 // source: health/health.proto

-package health_handler
+package health

 import (
 	context "context"
 	codec "go.unistack.org/micro-proto/v4/codec"
-	client "go.unistack.org/micro/v4/client"
 )

 var (
 	HealthServiceName = "HealthService"
 )

-type HealthServiceClient interface {
-	Healthy(ctx context.Context, req *codec.Frame, opts ...client.CallOption) (*codec.Frame, error)
-	Live(ctx context.Context, req *codec.Frame, opts ...client.CallOption) (*codec.Frame, error)
-	Ready(ctx context.Context, req *codec.Frame, opts ...client.CallOption) (*codec.Frame, error)
-	Version(ctx context.Context, req *codec.Frame, opts ...client.CallOption) (*codec.Frame, error)
-}
-
 type HealthServiceServer interface {
-	Healthy(ctx context.Context, req *codec.Frame, rsp *codec.Frame) error
 	Live(ctx context.Context, req *codec.Frame, rsp *codec.Frame) error
 	Ready(ctx context.Context, req *codec.Frame, rsp *codec.Frame) error
 	Version(ctx context.Context, req *codec.Frame, rsp *codec.Frame) error
--- a/handler/health/health_micro_http.pb.go
+++ b/handler/health/health_micro_http.pb.go
@@ -1,35 +1,19 @@
 // Code generated by protoc-gen-go-micro. DO NOT EDIT.
-// protoc-gen-go-micro version: v4.1.0
+// protoc-gen-go-micro version: v4.0.2
 // source: health/health.proto

-package health_handler
+package health

 import (
 	context "context"
-	v41 "go.unistack.org/micro-client-http/v4"
 	codec "go.unistack.org/micro-proto/v4/codec"
 	v4 "go.unistack.org/micro-server-http/v4"
-	client "go.unistack.org/micro/v4/client"
+	options "go.unistack.org/micro/v4/options"
 	server "go.unistack.org/micro/v4/server"
-	http "net/http"
 )

 var (
 	HealthServiceServerEndpoints = []v4.EndpointMetadata{
-		{
-			Name:   "HealthService.Healthy",
-			Path:   "/health",
-			Method: "GET",
-			Body:   "",
-			Stream: false,
-		},
-		{
-			Name:   "HealthService.Healthy",
-			Path:   "/healthz",
-			Method: "GET",
-			Body:   "",
-			Stream: false,
-		},
 		{
 			Name:   "HealthService.Live",
 			Path:   "/live",
@@ -37,13 +21,6 @@ var (
 			Body:   "",
 			Stream: false,
 		},
-		{
-			Name:   "HealthService.Live",
-			Path:   "/livez",
-			Method: "GET",
-			Body:   "",
-			Stream: false,
-		},
 		{
 			Name:   "HealthService.Ready",
 			Path:   "/ready",
@@ -51,13 +28,6 @@ var (
 			Body:   "",
 			Stream: false,
 		},
-		{
-			Name:   "HealthService.Ready",
-			Path:   "/readyz",
-			Method: "GET",
-			Body:   "",
-			Stream: false,
-		},
 		{
 			Name:   "HealthService.Version",
 			Path:   "/version",
@@ -68,95 +38,10 @@ var (
 	}
 )

-type healthServiceClient struct {
-	c    client.Client
-	name string
-}
-
-func NewHealthServiceClient(name string, c client.Client) HealthServiceClient {
-	return &healthServiceClient{c: c, name: name}
-}
-
-func (c *healthServiceClient) Healthy(ctx context.Context, req *codec.Frame, opts ...client.CallOption) (*codec.Frame, error) {
-	errmap := make(map[string]interface{}, 1)
-	errmap["default"] = &codec.Frame{}
-	opts = append(opts,
-		v41.ErrorMap(errmap),
-	)
-	opts = append(opts,
-		v41.Method(http.MethodGet),
-		v41.Path("/health"),
-	)
-	rsp := &codec.Frame{}
-	err := c.c.Call(ctx, c.c.NewRequest(c.name, "HealthService.Healthy", req), rsp, opts...)
-	if err != nil {
-		return nil, err
-	}
-	return rsp, nil
-}
-
-func (c *healthServiceClient) Live(ctx context.Context, req *codec.Frame, opts ...client.CallOption) (*codec.Frame, error) {
-	errmap := make(map[string]interface{}, 1)
-	errmap["default"] = &codec.Frame{}
-	opts = append(opts,
-		v41.ErrorMap(errmap),
-	)
-	opts = append(opts,
-		v41.Method(http.MethodGet),
-		v41.Path("/live"),
-	)
-	rsp := &codec.Frame{}
-	err := c.c.Call(ctx, c.c.NewRequest(c.name, "HealthService.Live", req), rsp, opts...)
-	if err != nil {
-		return nil, err
-	}
-	return rsp, nil
-}
-
-func (c *healthServiceClient) Ready(ctx context.Context, req *codec.Frame, opts ...client.CallOption) (*codec.Frame, error) {
-	errmap := make(map[string]interface{}, 1)
-	errmap["default"] = &codec.Frame{}
-	opts = append(opts,
-		v41.ErrorMap(errmap),
-	)
-	opts = append(opts,
-		v41.Method(http.MethodGet),
-		v41.Path("/ready"),
-	)
-	rsp := &codec.Frame{}
-	err := c.c.Call(ctx, c.c.NewRequest(c.name, "HealthService.Ready", req), rsp, opts...)
-	if err != nil {
-		return nil, err
-	}
-	return rsp, nil
-}
-
-func (c *healthServiceClient) Version(ctx context.Context, req *codec.Frame, opts ...client.CallOption) (*codec.Frame, error) {
-	errmap := make(map[string]interface{}, 1)
-	errmap["default"] = &codec.Frame{}
-	opts = append(opts,
-		v41.ErrorMap(errmap),
-	)
-	opts = append(opts,
-		v41.Method(http.MethodGet),
-		v41.Path("/version"),
-	)
-	rsp := &codec.Frame{}
-	err := c.c.Call(ctx, c.c.NewRequest(c.name, "HealthService.Version", req), rsp, opts...)
-	if err != nil {
-		return nil, err
-	}
-	return rsp, nil
-}
-
 type healthServiceServer struct {
 	HealthServiceServer
 }

-func (h *healthServiceServer) Healthy(ctx context.Context, req *codec.Frame, rsp *codec.Frame) error {
-	return h.HealthServiceServer.Healthy(ctx, req, rsp)
-}
-
 func (h *healthServiceServer) Live(ctx context.Context, req *codec.Frame, rsp *codec.Frame) error {
 	return h.HealthServiceServer.Live(ctx, req, rsp)
 }
@@ -169,9 +54,8 @@ func (h *healthServiceServer) Version(ctx context.Context, req *codec.Frame, rsp
 	return h.HealthServiceServer.Version(ctx, req, rsp)
 }

-func RegisterHealthServiceServer(s server.Server, sh HealthServiceServer, opts ...server.HandlerOption) error {
+func RegisterHealthServiceServer(s server.Server, sh HealthServiceServer, opts ...options.Option) error {
 	type healthService interface {
-		Healthy(ctx context.Context, req *codec.Frame, rsp *codec.Frame) error
 		Live(ctx context.Context, req *codec.Frame, rsp *codec.Frame) error
 		Ready(ctx context.Context, req *codec.Frame, rsp *codec.Frame) error
 		Version(ctx context.Context, req *codec.Frame, rsp *codec.Frame) error
@@ -180,6 +64,7 @@ func RegisterHealthServiceServer(s server.Server, sh HealthServiceServer, opts .
 		healthService
 	}
 	h := &healthServiceServer{sh}
-	opts = append(opts, v4.HandlerEndpoints(HealthServiceServerEndpoints))
-	return s.Handle(s.NewHandler(&HealthService{h}, opts...))
+	var nopts []options.Option
+	nopts = append(nopts, v4.HandlerEndpoints(HealthServiceServerEndpoints))
+	return s.Handle(&HealthService{h}, append(nopts, opts...)...)
 }
--- a/handler/meter/meter.go
+++ b/handler/meter/meter.go
@@ -1,4 +1,4 @@
-package meter_handler
+package meter // import "go.unistack.org/micro-server-http/v4/handler/meter"

 import (
 	"bytes"
@@ -12,6 +12,7 @@ import (
 	"go.unistack.org/micro/v4/logger"
 	"go.unistack.org/micro/v4/metadata"
 	"go.unistack.org/micro/v4/meter"
+	"go.unistack.org/micro/v4/options"
 )

 const (
@@ -32,10 +33,10 @@ var bufPool = sync.Pool{
 }

 // guard to fail early
-var _ MeterServiceServer = &Handler{}
+var _ MeterServiceServer = (*Handler)(nil)

 type Handler struct {
-	Options Options
+	opts Options
 }

 type Option func(*Options)
@@ -43,7 +44,7 @@ type Option func(*Options)
 type Options struct {
 	Meter           meter.Meter
 	Name            string
-	MeterOptions    []meter.Option
+	MeterOptions    []options.Option
 	DisableCompress bool
 }

@@ -65,7 +66,7 @@ func DisableCompress(g bool) Option {
 	}
 }

-func MeterOptions(opts ...meter.Option) Option {
+func MeterOptions(opts ...options.Option) Option {
 	return func(o *Options) {
 		o.MeterOptions = append(o.MeterOptions, opts...)
 	}
@@ -81,7 +82,7 @@ func NewOptions(opts ...Option) Options {

 func NewHandler(opts ...Option) *Handler {
 	options := NewOptions(opts...)
-	return &Handler{Options: options}
+	return &Handler{opts: options}
 }

 func (h *Handler) Metrics(ctx context.Context, req *codecpb.Frame, rsp *codecpb.Frame) error {
@@ -96,7 +97,7 @@ func (h *Handler) Metrics(ctx context.Context, req *codecpb.Frame, rsp *codecpb.

 	w := io.Writer(buf)

-	if md, ok := metadata.FromOutgoingContext(ctx); gzipAccepted(md) && ok && !h.Options.DisableCompress {
+	if md, ok := metadata.FromIncomingContext(ctx); gzipAccepted(md) && ok && !h.opts.DisableCompress {
 		omd, _ := metadata.FromOutgoingContext(ctx)
 		omd.Set(contentEncodingHeader, "gzip")
 		gz := gzipPool.Get().(*gzip.Writer)
@@ -109,8 +110,8 @@ func (h *Handler) Metrics(ctx context.Context, req *codecpb.Frame, rsp *codecpb.
 		gz.Flush()
 	}

-	if err := h.Options.Meter.Write(w, h.Options.MeterOptions...); err != nil {
-		log.Error(ctx, "http/meter write failed", err)
+	if err := h.opts.Meter.Write(w, h.opts.MeterOptions...); err != nil {
+		log.Error(ctx, "http/meter: write failed", err)
 		return nil
 	}

@@ -125,11 +126,8 @@ func gzipAccepted(md metadata.Metadata) bool {
 	if !ok {
 		return false
 	}
-	for i := range a {
-		if strings.Contains(a[i], "gzip") {
-			return true
-		}
+	if strings.Contains(a, "gzip") {
+		return true
 	}
-
 	return false
 }
--- a/handler/meter/meter.proto
+++ b/handler/meter/meter.proto
@@ -1,7 +1,7 @@
 syntax = "proto3";

-package micro.server.http.v3.handler.meter;
-option go_package = "go.unistack.org/micro-server-http/v4/handler/meter;meter_handler";
+package micro.server.http.v4.handler.meter;
+option go_package = "go.unistack.org/micro-server-http/v4/handler/meter;meter";

 import "api/annotations.proto";
 import "openapiv3/annotations.proto";
--- a/handler/meter/meter_micro.pb.go
+++ b/handler/meter/meter_micro.pb.go
@@ -1,25 +1,20 @@
 // Code generated by protoc-gen-go-micro. DO NOT EDIT.
 // versions:
-// - protoc-gen-go-micro v4.1.0
-// - protoc              v5.29.3
+// - protoc-gen-go-micro v4.0.2
+// - protoc              v4.23.4
 // source: meter/meter.proto

-package meter_handler
+package meter

 import (
 	context "context"
 	codec "go.unistack.org/micro-proto/v4/codec"
-	client "go.unistack.org/micro/v4/client"
 )

 var (
 	MeterServiceName = "MeterService"
 )

-type MeterServiceClient interface {
-	Metrics(ctx context.Context, req *codec.Frame, opts ...client.CallOption) (*codec.Frame, error)
-}
-
 type MeterServiceServer interface {
 	Metrics(ctx context.Context, req *codec.Frame, rsp *codec.Frame) error
 }
--- a/handler/meter/meter_micro_http.pb.go
+++ b/handler/meter/meter_micro_http.pb.go
@@ -1,17 +1,15 @@
 // Code generated by protoc-gen-go-micro. DO NOT EDIT.
-// protoc-gen-go-micro version: v4.1.0
+// protoc-gen-go-micro version: v4.0.2
 // source: meter/meter.proto

-package meter_handler
+package meter

 import (
 	context "context"
-	v41 "go.unistack.org/micro-client-http/v4"
 	codec "go.unistack.org/micro-proto/v4/codec"
 	v4 "go.unistack.org/micro-server-http/v4"
-	client "go.unistack.org/micro/v4/client"
+	options "go.unistack.org/micro/v4/options"
 	server "go.unistack.org/micro/v4/server"
-	http "net/http"
 )

 var (
@@ -26,33 +24,6 @@ var (
 	}
 )

-type meterServiceClient struct {
-	c    client.Client
-	name string
-}
-
-func NewMeterServiceClient(name string, c client.Client) MeterServiceClient {
-	return &meterServiceClient{c: c, name: name}
-}
-
-func (c *meterServiceClient) Metrics(ctx context.Context, req *codec.Frame, opts ...client.CallOption) (*codec.Frame, error) {
-	errmap := make(map[string]interface{}, 1)
-	errmap["default"] = &codec.Frame{}
-	opts = append(opts,
-		v41.ErrorMap(errmap),
-	)
-	opts = append(opts,
-		v41.Method(http.MethodGet),
-		v41.Path("/metrics"),
-	)
-	rsp := &codec.Frame{}
-	err := c.c.Call(ctx, c.c.NewRequest(c.name, "MeterService.Metrics", req), rsp, opts...)
-	if err != nil {
-		return nil, err
-	}
-	return rsp, nil
-}
-
 type meterServiceServer struct {
 	MeterServiceServer
 }
@@ -61,7 +32,7 @@ func (h *meterServiceServer) Metrics(ctx context.Context, req *codec.Frame, rsp
 	return h.MeterServiceServer.Metrics(ctx, req, rsp)
 }

-func RegisterMeterServiceServer(s server.Server, sh MeterServiceServer, opts ...server.HandlerOption) error {
+func RegisterMeterServiceServer(s server.Server, sh MeterServiceServer, opts ...options.Option) error {
 	type meterService interface {
 		Metrics(ctx context.Context, req *codec.Frame, rsp *codec.Frame) error
 	}
@@ -69,6 +40,7 @@ func RegisterMeterServiceServer(s server.Server, sh MeterServiceServer, opts ...
 		meterService
 	}
 	h := &meterServiceServer{sh}
-	opts = append(opts, v4.HandlerEndpoints(MeterServiceServerEndpoints))
-	return s.Handle(s.NewHandler(&MeterService{h}, opts...))
+	var nopts []options.Option
+	nopts = append(nopts, v4.HandlerEndpoints(MeterServiceServerEndpoints))
+	return s.Handle(&MeterService{h}, append(nopts, opts...)...)
 }
--- a/handler/meter/meter_test.go
+++ b/handler/meter/meter_test.go
@@ -0,0 +1,49 @@
+package meter
+
+import (
+	"context"
+	"testing"
+
+	codecpb "go.unistack.org/micro-proto/v4/codec"
+)
+
+func TestHandler_Metrics(t *testing.T) {
+	type fields struct {
+		opts Options
+	}
+	type args struct {
+		ctx context.Context
+		req *codecpb.Frame
+		rsp *codecpb.Frame
+	}
+	tests := []struct {
+		name    string
+		fields  fields
+		args    args
+		wantErr bool
+	}{
+		{
+			"Test #1",
+			fields{
+				opts: NewOptions(),
+			},
+			args{
+				context.Background(),
+				&codecpb.Frame{Data: []byte("gzip")},
+				&codecpb.Frame{},
+			},
+			true,
+		},
+	}
+	for _, tt := range tests {
+		t.Run(tt.name, func(t *testing.T) {
+			h := &Handler{
+				opts: tt.fields.opts,
+			}
+			if err := h.Metrics(tt.args.ctx, tt.args.req, tt.args.rsp); (err != nil) != tt.wantErr {
+				t.Errorf("Metrics() error = %v, wantErr %v", err, tt.wantErr)
+			}
+			t.Logf("RSP: %v", tt.args.rsp.Data)
+		})
+	}
+}
--- a/handler/pprof/pprof.go
+++ b/handler/pprof/pprof.go
@@ -1,46 +0,0 @@
-package pprof_handler
-
-import (
-	"expvar"
-	"net/http"
-	"net/http/pprof"
-	"path"
-	"strings"
-)
-
-func NewHandler(prefixPath string, initFuncs ...func()) http.HandlerFunc {
-	for _, fn := range initFuncs {
-		fn()
-	}
-
-	return func(w http.ResponseWriter, r *http.Request) {
-		switch {
-		case strings.EqualFold(r.RequestURI, prefixPath) && r.RequestURI[len(r.RequestURI)-1] != '/':
-			http.Redirect(w, r, r.RequestURI+"/", http.StatusMovedPermanently)
-		case strings.HasPrefix(r.RequestURI, path.Join(prefixPath, "cmdline")):
-			pprof.Cmdline(w, r)
-		case strings.HasPrefix(r.RequestURI, path.Join(prefixPath, "profile")):
-			pprof.Profile(w, r)
-		case strings.HasPrefix(r.RequestURI, path.Join(prefixPath, "symbol")):
-			pprof.Symbol(w, r)
-		case strings.HasPrefix(r.RequestURI, path.Join(prefixPath, "trace")):
-			pprof.Trace(w, r)
-		case strings.HasPrefix(r.RequestURI, path.Join(prefixPath, "goroutine")):
-			pprof.Handler("goroutine").ServeHTTP(w, r)
-		case strings.HasPrefix(r.RequestURI, path.Join(prefixPath, "threadcreate")):
-			pprof.Handler("threadcreate").ServeHTTP(w, r)
-		case strings.HasPrefix(r.RequestURI, path.Join(prefixPath, "mutex")):
-			pprof.Handler("mutex").ServeHTTP(w, r)
-		case strings.HasPrefix(r.RequestURI, path.Join(prefixPath, "heap")):
-			pprof.Handler("heap").ServeHTTP(w, r)
-		case strings.HasPrefix(r.RequestURI, path.Join(prefixPath, "block")):
-			pprof.Handler("block").ServeHTTP(w, r)
-		case strings.HasPrefix(r.RequestURI, path.Join(prefixPath, "allocs")):
-			pprof.Handler("allocs").ServeHTTP(w, r)
-		case strings.HasPrefix(r.RequestURI, path.Join(prefixPath, "vars")):
-			expvar.Handler().ServeHTTP(w, r)
-		default:
-			pprof.Index(w, r)
-		}
-	}
-}
--- a/handler/swagger-ui/swaggerui.go
+++ b/handler/swagger-ui/swaggerui.go
@@ -1,4 +1,4 @@
-package swaggerui_handler
+package swaggerui // import "go.unistack.org/micro-server-http/v4/handler/swagger-ui"

 import (
 	"embed"
--- a/handler/swagger-ui/swaggerui_test.go
+++ b/handler/swagger-ui/swaggerui_test.go
@@ -1,4 +1,4 @@
-package swaggerui_handler
+package swaggerui

 import (
 	"net/http"
--- a/handler/swagger/swagger.go
+++ b/handler/swagger/swagger.go
@@ -1,4 +1,4 @@
-package swagger_handler
+package swagger

 import (
 	"io/fs"
--- a/http.go
+++ b/http.go
@@ -1,5 +1,5 @@
 // Package http implements a go-micro.Server
-package http // import "go.unistack.org/micro-server-http/v3"
+package http // import "go.unistack.org/micro-server-http/v4"

 import (
 	"context"
@@ -11,11 +11,11 @@ import (
 	"reflect"
 	"strings"
 	"sync"
-	"sync/atomic"
 	"time"

 	"go.unistack.org/micro/v4/codec"
 	"go.unistack.org/micro/v4/logger"
+	"go.unistack.org/micro/v4/options"
 	"go.unistack.org/micro/v4/register"
 	"go.unistack.org/micro/v4/server"
 	rhttp "go.unistack.org/micro/v4/util/http"
@@ -25,16 +25,13 @@ import (
 var _ server.Server = (*Server)(nil)

 type Server struct {
-	hd           server.Handler
+	hd           interface{}
 	rsvc         *register.Service
-	handlers     map[string]server.Handler
+	handlers     map[string]interface{}
 	exit         chan chan error
-	errorHandler func(context.Context, server.Handler, http.ResponseWriter, *http.Request, error, int)
+	errorHandler func(context.Context, interface{}, http.ResponseWriter, *http.Request, error, int)
 	pathHandlers *rhttp.Trie
 	opts         server.Options
-	stateLive    *atomic.Uint32
-	stateReady   *atomic.Uint32
-	stateHealth  *atomic.Uint32
 	registerRPC  bool
 	sync.RWMutex
 	registered bool
@@ -61,7 +58,7 @@ func (h *Server) Options() server.Options {
 	return opts
 }

-func (h *Server) Init(opts ...server.Option) error {
+func (h *Server) Init(opts ...options.Option) error {
 	if len(opts) == 0 && h.init {
 		return nil
 	}
@@ -71,11 +68,11 @@ func (h *Server) Init(opts ...server.Option) error {
 	for _, o := range opts {
 		o(&h.opts)
 	}
-	if fn, ok := h.opts.Context.Value(errorHandlerKey{}).(func(ctx context.Context, s server.Handler, w http.ResponseWriter, r *http.Request, err error, status int)); ok && fn != nil {
+	if fn, ok := h.opts.Context.Value(errorHandlerKey{}).(func(ctx context.Context, s interface{}, w http.ResponseWriter, r *http.Request, err error, status int)); ok && fn != nil {
 		h.errorHandler = fn
 	}
 	if h.handlers == nil {
-		h.handlers = make(map[string]server.Handler)
+		h.handlers = make(map[string]interface{})
 	}
 	if h.pathHandlers == nil {
 		h.pathHandlers = rhttp.NewTrie()
@@ -102,10 +99,6 @@ func (h *Server) Init(opts ...server.Option) error {
 		h.RUnlock()
 		return err
 	}
-	if err := h.opts.Broker.Init(); err != nil {
-		h.RUnlock()
-		return err
-	}
 	if err := h.opts.Tracer.Init(); err != nil {
 		h.RUnlock()
 		return err
@@ -118,7 +111,6 @@ func (h *Server) Init(opts ...server.Option) error {
 		h.RUnlock()
 		return err
 	}
-
 	h.RUnlock()

 	h.Lock()
@@ -128,12 +120,24 @@ func (h *Server) Init(opts ...server.Option) error {
 	return nil
 }

-func (h *Server) Handle(handler server.Handler) error {
+func (h *Server) Handle(handler interface{}, opts ...options.Option) error {
+	options := server.NewHandleOptions(opts...)
+	var endpointMetadata []EndpointMetadata
+
+	if v, ok := options.Context.Value(handlerEndpointsKey{}).([]EndpointMetadata); ok {
+		endpointMetadata = v
+	}
+
 	// passed unknown handler
 	hdlr, ok := handler.(*httpHandler)
 	if !ok {
 		h.Lock()
-		h.hd = handler
+		if h.handlers == nil {
+			h.handlers = make(map[string]interface{})
+		}
+		for _, v := range endpointMetadata {
+			h.handlers[v.Name] = h.newHTTPHandler(handler, opts...)
+		}
 		h.Unlock()
 		return nil
 	}
@@ -146,21 +150,22 @@ func (h *Server) Handle(handler server.Handler) error {
 		return nil
 	}

-	// passed micro compat handler
-	h.Lock()
-	if h.handlers == nil {
-		h.handlers = make(map[string]server.Handler)
-	}
-	h.handlers[handler.Name()] = handler
-	h.Unlock()
-
 	return nil
 }

-func (h *Server) NewHandler(handler interface{}, opts ...server.HandlerOption) server.Handler {
-	options := server.NewHandlerOptions(opts...)
+func (h *Server) newHTTPHandler(handler interface{}, opts ...options.Option) *httpHandler {
+	options := server.NewHandleOptions(opts...)
+
+	eps := make([]*register.Endpoint, 0, len(options.Metadata))
+	for name, metadata := range options.Metadata {
+		eps = append(eps, &register.Endpoint{
+			Name:     name,
+			Metadata: metadata,
+		})
+	}

 	hdlr := &httpHandler{
+		eps:      eps,
 		hd:       handler,
 		opts:     options,
 		sopts:    h.opts,
@@ -169,10 +174,16 @@ func (h *Server) NewHandler(handler interface{}, opts ...server.HandlerOption) s

 	tp := reflect.TypeOf(handler)

-	registerCORS := false
-	if v, ok := options.Context.Value(registerCORSHandlerKey{}).(bool); ok && v {
-		registerCORS = true
-	}
+	/*
+		if len(options.Metadata) == 0 {
+			if h.registerRPC {
+				h.opts.Logger.Infof(h.opts.Context, "register rpc handler for http.MethodPost %s /%s", hn, hn)
+				if err := hdlr.handlers.Insert([]string{http.MethodPost}, "/"+hn, pth); err != nil {
+					h.opts.Logger.Errorf(h.opts.Context, "cant add rpc handler for http.MethodPost %s /%s", hn, hn)
+				}
+			}
+		}
+	*/

 	for hn, md := range options.Metadata {
 		var method reflect.Method
@@ -193,7 +204,7 @@ func (h *Server) NewHandler(handler interface{}, opts ...server.HandlerOption) s

 		mtype, err := prepareEndpoint(method)
 		if err != nil && h.opts.Logger.V(logger.ErrorLevel) {
-			h.opts.Logger.Error(h.opts.Context, "endpoint error", err)
+			h.opts.Logger.Error(h.opts.Context, fmt.Sprintf("%v", err))
 			continue
 		} else if mtype == nil {
 			h.opts.Logger.Error(h.opts.Context, fmt.Sprintf("nil mtype for %s", mname))
@@ -206,25 +217,13 @@ func (h *Server) NewHandler(handler interface{}, opts ...server.HandlerOption) s
 		pth := &patHandler{mtype: mtype, name: name, rcvr: rcvr}
 		hdlr.name = name

-		methods := md["Method"]
-		if registerCORS {
-			methods = append(methods, http.MethodOptions)
-		}
-
-		pattern := md["Path"]
-		for i := len(pattern) - 1; i >= 0; i-- {
-			if err := hdlr.handlers.Insert(methods, pattern[i], pth); err != nil {
-				h.opts.Logger.Error(h.opts.Context, fmt.Sprintf("cant add handler for %v %s: index %d", methods, md["Path"], i))
-			}
+		if err := hdlr.handlers.Insert([]string{md["Method"]}, md["Path"], pth); err != nil {
+			h.opts.Logger.Error(h.opts.Context, fmt.Sprintf("cant add handler for %s %s", md["Method"][0], md["Path"][0]))
 		}

 		if h.registerRPC {
-			methods := []string{http.MethodPost}
-			if registerCORS {
-				methods = append(methods, http.MethodOptions)
-			}
-
-			if err := hdlr.handlers.Insert(methods, "/"+hn, pth); err != nil {
+			h.opts.Logger.Info(h.opts.Context, fmt.Sprintf("register rpc handler for http.MethodPost %s /%s", hn, hn))
+			if err := hdlr.handlers.Insert([]string{http.MethodPost}, "/"+hn, pth); err != nil {
 				h.opts.Logger.Error(h.opts.Context, fmt.Sprintf("cant add rpc handler for http.MethodPost %s /%s", hn, hn))
 			}
 		}
@@ -255,7 +254,7 @@ func (h *Server) NewHandler(handler interface{}, opts ...server.HandlerOption) s

 		mtype, err := prepareEndpoint(method)
 		if err != nil && h.opts.Logger.V(logger.ErrorLevel) {
-			h.opts.Logger.Error(h.opts.Context, "prepare endpoint error", err)
+			h.opts.Logger.Error(h.opts.Context, fmt.Sprintf("%v", err))
 			continue
 		} else if mtype == nil {
 			h.opts.Logger.Error(h.opts.Context, fmt.Sprintf("nil mtype for %s", mname))
@@ -268,23 +267,13 @@ func (h *Server) NewHandler(handler interface{}, opts ...server.HandlerOption) s
 		pth := &patHandler{mtype: mtype, name: name, rcvr: rcvr}
 		hdlr.name = name

-		methods := []string{md.Method}
-		if registerCORS {
-			methods = append(methods, http.MethodOptions)
-		}
-
-		if err := hdlr.handlers.Insert(methods, md.Path, pth); err != nil {
+		if err := hdlr.handlers.Insert([]string{md.Method}, md.Path, pth); err != nil {
 			h.opts.Logger.Error(h.opts.Context, fmt.Sprintf("cant add handler for %s %s", md.Method, md.Path))
 		}

 		if h.registerRPC {
-			methods := []string{http.MethodPost}
-			if registerCORS {
-				methods = append(methods, http.MethodOptions)
-			}
-
 			h.opts.Logger.Info(h.opts.Context, fmt.Sprintf("register rpc handler for http.MethodPost %s /%s", hn, hn))
-			if err := hdlr.handlers.Insert(methods, "/"+hn, pth); err != nil {
+			if err := hdlr.handlers.Insert([]string{http.MethodPost}, "/"+hn, pth); err != nil {
 				h.opts.Logger.Error(h.opts.Context, fmt.Sprintf("cant add rpc handler for http.MethodPost %s /%s", hn, hn))
 			}
 		}
@@ -294,7 +283,15 @@ func (h *Server) NewHandler(handler interface{}, opts ...server.HandlerOption) s
 }

 func (h *Server) Register() error {
+	var eps []*register.Endpoint
 	h.RLock()
+	for _, hdlr := range h.handlers {
+		hd, ok := hdlr.(*httpHandler)
+		if !ok {
+			continue
+		}
+		eps = append(eps, hd.Endpoints()...)
+	}
 	rsvc := h.rsvc
 	config := h.opts
 	h.RUnlock()
@@ -311,6 +308,8 @@ func (h *Server) Register() error {
 	if err != nil {
 		return err
 	}
+	service.Nodes[0].Metadata.Set("protocol", "http")
+	service.Endpoints = eps

 	h.RLock()
 	registered := h.registered
@@ -333,7 +332,6 @@ func (h *Server) Register() error {
 	}

 	h.Lock()
-
 	h.registered = true
 	h.rsvc = service
 	h.Unlock()
@@ -352,7 +350,7 @@ func (h *Server) Deregister() error {
 	}

 	if config.Logger.V(logger.InfoLevel) {
-		config.Logger.Info(config.Context, "Deregistering node: "+service.Nodes[0].ID)
+		config.Logger.Info(config.Context, fmt.Sprintf("Deregistering node: %s", service.Nodes[0].ID))
 	}

 	if err := server.DefaultDeregisterFunc(service, config); err != nil {
@@ -368,7 +366,6 @@ func (h *Server) Deregister() error {
 	}

 	h.registered = false
-
 	h.Unlock()
 	return nil
 }
@@ -403,7 +400,7 @@ func (h *Server) Start() error {
 	}

 	if config.Logger.V(logger.InfoLevel) {
-		config.Logger.Info(config.Context, "Listening on "+ts.Addr().String())
+		config.Logger.Info(config.Context, fmt.Sprintf("Listening on %s", ts.Addr().String()))
 	}

 	h.Lock()
@@ -416,7 +413,7 @@ func (h *Server) Start() error {
 	if h.opts.Context != nil {
 		if hs, ok := h.opts.Context.Value(serverKey{}).(*http.Server); ok && hs != nil {
 			if hs.Handler == nil && h.hd != nil {
-				if hdlr, ok := h.hd.Handler().(http.Handler); ok {
+				if hdlr, ok := h.hd.(http.Handler); ok {
 					hs.Handler = hdlr
 					handler = hs.Handler
 				}
@@ -432,7 +429,7 @@ func (h *Server) Start() error {
 	case len(h.handlers) > 0 && h.hd != nil:
 		handler = h
 	case handler == nil && h.hd != nil:
-		if hdlr, ok := h.hd.Handler().(http.Handler); ok {
+		if hdlr, ok := h.hd.(http.Handler); ok {
 			handler = hdlr
 		}
 	}
@@ -441,13 +438,9 @@ func (h *Server) Start() error {
 		return fmt.Errorf("cant process with nil handler")
 	}

-	if err := config.Broker.Connect(h.opts.Context); err != nil {
-		return err
-	}
-
 	if err := config.RegisterCheck(h.opts.Context); err != nil {
 		if config.Logger.V(logger.ErrorLevel) {
-			config.Logger.Error(config.Context, fmt.Sprintf("Server %s-%s register check error", config.Name, config.ID), err)
+			config.Logger.Error(config.Context, fmt.Sprintf("Server %s-%s register check error: %s", config.Name, config.ID, err))
 		}
 	} else {
 		if err = h.Register(); err != nil {
@@ -474,12 +467,9 @@ func (h *Server) Start() error {
 	}

 	go func() {
-		if cerr := hs.Serve(ts); cerr != nil && !errors.Is(cerr, http.ErrServerClosed) {
-			h.opts.Logger.Error(h.opts.Context, "serve error", cerr)
+		if cerr := hs.Serve(ts); cerr != nil && !errors.Is(cerr, net.ErrClosed) {
+			h.opts.Logger.Error(h.opts.Context, cerr.Error())
 		}
-		h.stateLive.Store(0)
-		h.stateReady.Store(0)
-		h.stateHealth.Store(0)
 	}()

 	go func() {
@@ -506,28 +496,28 @@ func (h *Server) Start() error {
 				// nolint: nestif
 				if rerr != nil && registered {
 					if config.Logger.V(logger.ErrorLevel) {
-						config.Logger.Error(config.Context, fmt.Sprintf("Server %s-%s register check error, deregister it", config.Name, config.ID), rerr)
+						config.Logger.Error(config.Context, fmt.Sprintf("Server %s-%s register check error: %s, deregister it", config.Name, config.ID, rerr))
 					}
 					// deregister self in case of error
 					if err := h.Deregister(); err != nil {
 						if config.Logger.V(logger.ErrorLevel) {
-							config.Logger.Error(config.Context, fmt.Sprintf("Server %s-%s deregister error", config.Name, config.ID), err)
+							config.Logger.Error(config.Context, fmt.Sprintf("Server %s-%s deregister error: %s", config.Name, config.ID, err))
 						}
 					}
 				} else if rerr != nil && !registered {
 					if config.Logger.V(logger.ErrorLevel) {
-						config.Logger.Error(config.Context, fmt.Sprintf("Server %s-%s register check error", config.Name, config.ID), rerr)
+						config.Logger.Error(config.Context, fmt.Sprintf("Server %s-%s register check error: %s", config.Name, config.ID, rerr))
 					}
 					continue
 				}
 				if err := h.Register(); err != nil {
 					if config.Logger.V(logger.ErrorLevel) {
-						config.Logger.Error(config.Context, fmt.Sprintf("Server %s-%s register error", config.Name, config.ID), err)
+						config.Logger.Error(config.Context, fmt.Sprintf("Server %s-%s register error: %s", config.Name, config.ID, err))
 					}
 				}

 				if err := h.Register(); err != nil {
-					config.Logger.Error(config.Context, "Server register error", err)
+					config.Logger.Error(config.Context, fmt.Sprintf("Server register error: %s", err))
 				}
 			// wait for exit
 			case ch = <-h.exit:
@@ -537,11 +527,7 @@ func (h *Server) Start() error {

 		// deregister
 		if err := h.Deregister(); err != nil {
-			config.Logger.Error(config.Context, "Server deregister error", err)
-		}
-
-		if err := config.Broker.Disconnect(config.Context); err != nil {
-			config.Logger.Error(config.Context, "Broker disconnect error", err)
+			config.Logger.Error(config.Context, fmt.Sprintf("Server deregister error: %s", err))
 		}

 		ctx, cancel := context.WithTimeout(context.Background(), h.opts.GracefulTimeout)
@@ -555,10 +541,6 @@ func (h *Server) Start() error {
 		ch <- err
 	}()

-	h.stateLive.Store(1)
-	h.stateReady.Store(1)
-	h.stateHealth.Store(1)
-
 	return nil
 }

@@ -576,28 +558,13 @@ func (h *Server) Name() string {
 	return h.opts.Name
 }

-func (h *Server) Live() bool {
-	return h.stateLive.Load() == 1
-}
-
-func (h *Server) Ready() bool {
-	return h.stateReady.Load() == 1
-}
-
-func (h *Server) Health() bool {
-	return h.stateHealth.Load() == 1
-}
-
-func NewServer(opts ...server.Option) *Server {
+func NewServer(opts ...options.Option) *Server {
 	options := server.NewOptions(opts...)
 	eh := DefaultErrorHandler
 	if v, ok := options.Context.Value(errorHandlerKey{}).(errorHandler); ok && v != nil {
 		eh = v
 	}
 	return &Server{
-		stateLive:    &atomic.Uint32{},
-		stateReady:   &atomic.Uint32{},
-		stateHealth:  &atomic.Uint32{},
 		opts:         options,
 		exit:         make(chan chan error),
 		errorHandler: eh,
--- a/message.go
+++ b/message.go
@@ -0,0 +1,35 @@
+package http
+
+import (
+	"go.unistack.org/micro/v4/codec"
+	"go.unistack.org/micro/v4/metadata"
+)
+
+type httpMessage struct {
+	payload     interface{}
+	codec       codec.Codec
+	header      metadata.Metadata
+	topic       string
+	contentType string
+	body        []byte
+}
+
+func (r *httpMessage) Topic() string {
+	return r.topic
+}
+
+func (r *httpMessage) ContentType() string {
+	return r.contentType
+}
+
+func (r *httpMessage) Header() metadata.Metadata {
+	return r.header
+}
+
+func (r *httpMessage) Body() interface{} {
+	return r.payload
+}
+
+func (r *httpMessage) Codec() codec.Codec {
+	return r.codec
+}
--- a/options.go
+++ b/options.go
@@ -5,7 +5,7 @@ import (
 	"fmt"
 	"net/http"

-	"go.unistack.org/micro/v4/server"
+	"go.unistack.org/micro/v4/options"
 )

 // SetError pass error to caller
@@ -69,7 +69,7 @@ func getRspHeader(ctx context.Context) http.Header {

 // GetRspCode used internally by generated http server handler
 func GetRspCode(ctx context.Context) int {
-	code := int(200)
+	var code int
 	if rsp, ok := ctx.Value(rspCodeKey{}).(*rspCodeVal); ok {
 		code = rsp.code
 	}
@@ -79,24 +79,24 @@ func GetRspCode(ctx context.Context) int {
 type middlewareKey struct{}

 // Middleware passes http middlewares
-func Middleware(mw ...func(http.Handler) http.Handler) server.Option {
-	return server.SetOption(middlewareKey{}, mw)
+func Middleware(mw ...func(http.Handler) http.Handler) options.Option {
+	return options.ContextOption(middlewareKey{}, mw)
 }

 type serverKey struct{}

 // HTTPServer provide ability to pass *http.Server
-func HTTPServer(hs *http.Server) server.Option {
-	return server.SetOption(serverKey{}, hs)
+func HTTPServer(hs *http.Server) options.Option {
+	return options.ContextOption(serverKey{}, hs)
 }

-type errorHandler func(ctx context.Context, s server.Handler, w http.ResponseWriter, r *http.Request, err error, status int)
+type errorHandler func(ctx context.Context, s interface{}, w http.ResponseWriter, r *http.Request, err error, status int)

 type errorHandlerKey struct{}

 // ErrorHandler specifies handler for errors
-func ErrorHandler(fn errorHandler) server.Option {
-	return server.SetOption(errorHandlerKey{}, fn)
+func ErrorHandler(fn errorHandler) options.Option {
+	return options.ContextOption(errorHandlerKey{}, fn)
 }

 type (
@@ -107,12 +107,18 @@ type (
 )

 // PathHandler specifies http handler for path regexp
-func PathHandler(method, path string, handler http.HandlerFunc) server.Option {
-	return func(o *server.Options) {
-		if o.Context == nil {
-			o.Context = context.Background()
+func PathHandler(method, path string, handler http.HandlerFunc) options.Option {
+	return func(src interface{}) error {
+		vctx, err := options.Get(src, ".Context")
+		if err != nil {
+			return err
 		}
-		v, ok := o.Context.Value(pathHandlerKey{}).(*pathHandlerVal)
+		ctx, ok := vctx.(context.Context)
+		if !ok {
+			return fmt.Errorf("invalid option")
+		}
+
+		v, ok := ctx.Value(pathHandlerKey{}).(*pathHandlerVal)
 		if !ok {
 			v = &pathHandlerVal{h: make(map[string]map[string]http.HandlerFunc)}
 		}
@@ -121,23 +127,17 @@ func PathHandler(method, path string, handler http.HandlerFunc) server.Option {
 			m = make(map[string]http.HandlerFunc)
 			v.h[method] = m
 		}
+		ctx = context.WithValue(ctx, pathHandlerKey{}, v)
 		m[path] = handler
-		o.Context = context.WithValue(o.Context, pathHandlerKey{}, v)
+		return options.Set(src, ctx, ".Context")
 	}
 }

 type registerRPCHandlerKey struct{}

 // RegisterRPCHandler registers compatibility endpoints with /ServiceName.ServiceEndpoint method POST
-func RegisterRPCHandler(b bool) server.Option {
-	return server.SetOption(registerRPCHandlerKey{}, b)
-}
-
-type registerCORSHandlerKey struct{}
-
-// RegisterCORSHandler registers cors endpoints with /ServiceName.ServiceEndpoint method POPTIONSOST
-func RegisterCORSHandler(b bool) server.HandlerOption {
-	return server.SetHandlerOption(registerCORSHandlerKey{}, b)
+func RegisterRPCHandler(b bool) options.Option {
+	return options.ContextOption(registerRPCHandlerKey{}, b)
 }

 type handlerEndpointsKey struct{}
@@ -150,8 +150,8 @@ type EndpointMetadata struct {
 	Stream bool
 }

-func HandlerEndpoints(md []EndpointMetadata) server.HandlerOption {
-	return server.SetHandlerOption(handlerEndpointsKey{}, md)
+func HandlerEndpoints(md []EndpointMetadata) options.Option {
+	return options.ContextOption(handlerEndpointsKey{}, md)
 }

 type handlerOptions struct {
--- a/request.go
+++ b/request.go
@@ -1,6 +1,8 @@
 package http

 import (
+	"io"
+
 	"go.unistack.org/micro/v4/codec"
 	"go.unistack.org/micro/v4/metadata"
 	"go.unistack.org/micro/v4/server"
@@ -9,7 +11,7 @@ import (
 var _ server.Request = &rpcRequest{}

 type rpcRequest struct {
-	// rw          io.ReadWriter
+	rw          io.ReadWriter
 	payload     interface{}
 	codec       codec.Codec
 	header      metadata.Metadata
@@ -45,7 +47,11 @@ func (r *rpcRequest) Header() metadata.Metadata {
 }

 func (r *rpcRequest) Read() ([]byte, error) {
-	return nil, nil
+	f := &codec.Frame{}
+	if err := r.codec.ReadBody(r.rw, f); err != nil {
+		return nil, err
+	}
+	return f.Data, nil
 }

 func (r *rpcRequest) Stream() bool {
--- a/tools.go
+++ b/tools.go
@@ -0,0 +1,8 @@
+//go:build tools
+
+package http
+
+import (
+	_ "go.unistack.org/micro-proto/v4"
+	_ "go.unistack.org/protoc-gen-go-micro/v4"
+)
--- a/util.go
+++ b/util.go
@@ -15,52 +15,37 @@ func FillRequest(ctx context.Context, req interface{}, opts ...FillRequestOption
 	for _, o := range opts {
 		o(&options)
 	}
-
 	md, ok := metadata.FromIncomingContext(ctx)
 	if !ok {
 		return nil
 	}

 	for idx := 0; idx < len(options.headers)/2; idx += 2 {
-		k := options.headers[idx]
-		v, ok := md.Get(k)
+		k := http.CanonicalHeaderKey(options.headers[idx])
+		v, ok := md[k]
 		if !ok {
 			continue
 		}
-
-		if len(v) == 1 {
-			err = rutil.SetFieldByPath(req, v[0], k)
-		} else {
-			err = rutil.SetFieldByPath(req, v, k)
-		}
-		if err != nil {
+		if err = rutil.SetFieldByPath(req, v, k); err != nil {
 			return err
 		}
 	}

-	cookieVals, _ := md.Get("Cookie")
-	for i := range cookieVals {
-		cookies := strings.Split(cookieVals[i], ";")
-		cmd := make(map[string]string, len(cookies))
-		for _, cookie := range cookies {
-			kv := strings.Split(cookie, "=")
-			if len(kv) != 2 {
-				continue
-			}
-			cmd[strings.TrimSpace(kv[0])] = strings.TrimSpace(kv[1])
+	cookies := md["Cookie"]
+	cmd := make(map[string]string, len(cookies))
+	kv := strings.Split(cookies, "=")
+	if len(kv) != 2 {
+		return nil
+	}
+	cmd[strings.TrimSpace(kv[0])] = strings.TrimSpace(kv[1])
+	for idx := 0; idx < len(options.cookies)/2; idx += 2 {
+		k := http.CanonicalHeaderKey(options.cookies[idx])
+		v, ok := cmd[k]
+		if !ok {
+			continue
 		}
-		for idx := 0; idx < len(options.cookies)/2; idx += 2 {
-			k := http.CanonicalHeaderKey(options.cookies[idx])
-			v, ok := cmd[k]
-
-			if !ok {
-				continue
-			}
-
-			err = rutil.SetFieldByPath(req, v, k)
-			if err != nil {
-				return err
-			}
+		if err = rutil.SetFieldByPath(req, v, k); err != nil {
+			return err
 		}
 	}

--- a/util_test.go
+++ b/util_test.go
@@ -8,52 +8,8 @@ import (
 	"testing"

 	"go.unistack.org/micro/v4/metadata"
-	"go.unistack.org/micro/v4/options"
-	"go.unistack.org/micro/v4/server"
 )

-func Test_Hook(t *testing.T) {
-	opts := server.Options{}
-
-	var fn server.HandlerFunc = func(fctx context.Context, req server.Request, rsp interface{}) (err error) {
-		// fmt.Println("1")
-		return nil
-	}
-
-	var fn2 server.HandlerWrapper = func(next server.HandlerFunc) server.HandlerFunc {
-		return func(ctx context.Context, req server.Request, rsp interface{}) error {
-			//	fmt.Println("2")
-			return next(ctx, req, rsp)
-		}
-	}
-	var fn3 server.HandlerWrapper = func(next server.HandlerFunc) server.HandlerFunc {
-		return func(ctx context.Context, req server.Request, rsp interface{}) error {
-			// fmt.Println("3")
-			return next(ctx, req, rsp)
-		}
-	}
-	var fn4 server.HandlerWrapper = func(next server.HandlerFunc) server.HandlerFunc {
-		return func(ctx context.Context, req server.Request, rsp interface{}) error {
-			// fmt.Println("4")
-			return next(ctx, req, rsp)
-		}
-	}
-
-	opts.Hooks = append(opts.Hooks, fn2, fn3, fn4)
-
-	opts.Hooks.EachNext(func(hook options.Hook) {
-		if h, ok := hook.(server.HandlerWrapper); ok {
-			// fmt.Printf("h %#+v\n", h)
-			fn = h(fn)
-		}
-	})
-
-	err := fn(nil, nil, nil)
-	if err != nil {
-		t.Fatal(err)
-	}
-}
-
 func TestFillrequest(t *testing.T) {
 	md := metadata.New(1)
 	md.Set("ClientID", "xxx")
Author	SHA1	Message	Date
Александр Толстихин	8c22eb5034	Update workflows (#195 ) All checks were successful test / test (push) Successful in 3m35s Details Update workflows Co-authored-by: Aleksandr Tolstikhin <atolstikhin@mtsbank.ru> Reviewed-on: #195 Co-authored-by: Александр Толстихин <tolstihin1996@mail.ru> Co-committed-by: Александр Толстихин <tolstihin1996@mail.ru>	2024-12-11 00:36:27 +03:00
Кирилл Горбунов	12e26d0018	hotfix (#186 ) ## Pull Request template Please, go through these steps before clicking submit on this PR. 1. Give a descriptive title to your PR. 2. Provide a description of your changes. 3. Make sure you have some relevant tests. 4. Put `closes #XXXX` in your comment to auto-close the issue that your PR fixes (if applicable). PLEASE REMOVE THIS TEMPLATE BEFORE SUBMITTING Co-authored-by: Gorbunov Kirill Andreevich <kgorbunov@mtsbank.ru> Reviewed-on: #186 Co-authored-by: Кирилл Горбунов <kirya_gorbunov_2015@mail.ru> Co-committed-by: Кирилл Горбунов <kirya_gorbunov_2015@mail.ru>	2024-03-26 14:53:14 +03:00
Василий Толстов	aab779b406	Merge pull request 'update http.Server run for v4' (#185 ) from devstigneev/micro-server-http:master into master Reviewed-on: #185	2024-03-13 11:06:10 +03:00
Evstigneev Denis	3514bb9626	update http.Server run	2024-03-13 10:05:29 +03:00
Vasiliy Tolstov	c7dc998670	fixup panic Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>	2024-03-12 00:52:14 +03:00
Vasiliy Tolstov	954101f887	fixup handlers Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>	2024-03-12 00:02:48 +03:00
Vasiliy Tolstov	4c3d26c39b	fixup headers Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>	2024-03-11 23:37:54 +03:00
Кирилл Горбунов	a483e08ffa	add gzip rsp #153 (#182 ) ## Pull Request template Please, go through these steps before clicking submit on this PR. 1. Give a descriptive title to your PR. 2. Provide a description of your changes. 3. Make sure you have some relevant tests. 4. Put `closes #XXXX` in your comment to auto-close the issue that your PR fixes (if applicable). PLEASE REMOVE THIS TEMPLATE BEFORE SUBMITTING Co-authored-by: Gorbunov Kirill Andreevich <kgorbunov@mtsbank.ru> Reviewed-on: #182 Co-authored-by: Кирилл Горбунов <kirya_gorbunov_2015@mail.ru> Co-committed-by: Кирилл Горбунов <kirya_gorbunov_2015@mail.ru>	2024-03-11 12:31:19 +03:00
Василий Толстов	28eeca30c0	Merge pull request 'issue_179' (#180 ) from devstigneev/micro-server-http:issue_179 into master Reviewed-on: #180 Reviewed-by: Василий Толстов <v.tolstov@unistack.org>	2024-03-08 23:05:31 +03:00
Evstigneev Denis	2e8462a0f1	fix logmessages	2024-03-08 18:03:50 +03:00
Evstigneev Denis	1432587369	sent err to channel	2024-03-08 18:00:02 +03:00
Evstigneev Denis	ea8c9dd22e	update micro version and add gracefulTimeout && update log msg	2024-03-08 17:58:18 +03:00
Evstigneev Denis	49608197d0	removed comments code	2024-03-07 18:17:07 +03:00
Evstigneev Denis	41d7d145ce	removed Listener.Stop	2024-03-07 18:16:02 +03:00
Evstigneev Denis	1d5142d619	removed using http.Serve and add using *http.Server + Shutdown	2024-03-07 18:13:46 +03:00
Vasiliy Tolstov	41f7bdf182	Merge pull request 'handler: add single page application handler' (#176 ) from spa-handler into master Reviewed-on: #176	2023-08-19 23:22:00 +03:00
Vasiliy Tolstov	ed907c7076	handler: add single page application handler Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>	2023-08-19 23:19:54 +03:00
Vasiliy Tolstov	5c2cba3ecc	Merge pull request 'micro v4 fix' (#175 ) from micro4 into master Reviewed-on: #175	2023-08-16 15:27:32 +03:00
Vasiliy Tolstov	966bc31eb2	micro v4 fix Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>	2023-08-16 15:27:07 +03:00
Vasiliy Tolstov	259e1d275e	Merge pull request 'handler: fix for latest micro' (#174 ) from microv4 into master Reviewed-on: #174	2023-08-16 10:19:02 +03:00
Vasiliy Tolstov	fdbcff2ba0	handler: fix for latest micro Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>	2023-08-16 10:18:38 +03:00
Vasiliy Tolstov	3e814bf229	Merge pull request 'fix swagger handler' (#173 ) from handler-swagger into master Reviewed-on: #173	2023-08-14 13:45:13 +03:00
Vasiliy Tolstov	13cdeb9397	fix swagger handler Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>	2023-08-14 13:44:57 +03:00
Vasiliy Tolstov	0e19afef86	Merge pull request 'options' (#171 ) from options into master Reviewed-on: #171	2023-08-12 13:53:42 +03:00
Vasiliy Tolstov	7e850f75e0	update for latest micro changes Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>	2023-08-12 13:53:04 +03:00
Vasiliy Tolstov	4c3d3058f6	handler/swagger: initial import Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>	2023-06-18 20:49:29 +03:00
Vasiliy Tolstov	bcd27b833a	Merge pull request 'fix query param struct filling' (#168 ) from matchesfix into master Reviewed-on: #168	2023-05-29 12:29:39 +03:00
Vasiliy Tolstov	090b5e3c07	fix query param struct filling Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>	2023-05-29 12:29:04 +03:00
Vasiliy Tolstov	95109c9dc2	Merge pull request 'add scheme to metadata' (#166 ) from scheme into master Reviewed-on: #166	2023-05-19 23:28:22 +03:00
Vasiliy Tolstov	69dcf71d3f	add scheme to metadata Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>	2023-05-19 23:24:53 +03:00
Vasiliy Tolstov	0a0a986a70	Merge pull request 'move down path handler after specific handler' (#164 ) from path-handler into master Reviewed-on: #164	2023-05-19 23:04:01 +03:00
Vasiliy Tolstov	76fe748e4a	move down path handler after specific handler Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>	2023-05-19 23:02:42 +03:00
Vasiliy Tolstov	9926d52f78	Merge pull request 'fix build' (#161 ) from fixup into master Reviewed-on: #161	2023-05-09 18:48:11 +03:00
Vasiliy Tolstov	2ed04e3e24	fix build Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>	2023-05-09 18:47:56 +03:00
Vasiliy Tolstov	4a9cc0f03f	Merge pull request 'cleanup message stuf from server' (#160 ) from cleanup into master Reviewed-on: #160	2023-05-09 18:39:08 +03:00
Vasiliy Tolstov	99af727138	cleanup message stuf from server Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>	2023-05-09 18:38:49 +03:00
Vasiliy Tolstov	89fe1dd6bc	Merge pull request 'export Server to allow to cast' (#159 ) from exportServer into master Reviewed-on: #159	2023-05-09 18:34:39 +03:00
Vasiliy Tolstov	8b591f7fd4	export Server to allow to cast Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>	2023-05-09 18:34:24 +03:00
Vasiliy Tolstov	bec1705d09	Merge pull request 'allow to expose some method via http.HandlerFunc' (#158 ) from httphandler into master Reviewed-on: #158	2023-05-08 22:23:58 +03:00
Vasiliy Tolstov	316f644090	allow to expose some method via http.HandlerFunc Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>	2023-05-08 22:23:34 +03:00
Vasiliy Tolstov	3fdff4312c	Merge pull request 'issue-155: add swagger-ui handler' (#156 ) from issue-155 into master Reviewed-on: #156	2023-05-04 02:20:49 +03:00
Vasiliy Tolstov	09657b4b67	issue-155: add swagger-ui handler Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>	2023-05-04 02:20:25 +03:00
Vasiliy Tolstov	741a6f181b	Merge pull request 'move to micro v4' (#154 ) from v4 into master Reviewed-on: #154	2023-04-28 22:00:02 +03:00
Vasiliy Tolstov	7f971ee6c3	move to micro v4 Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>	2023-04-28 21:59:31 +03:00