Skip to content

Commit a5958ae

Browse files
HJianBoHJianBo
authored
Merge pull request #42 from emqx/update_to_exhook_v3
Update to exhook v3 for 5.9.0
2 parents 6954033 + f8890e9 commit a5958ae

File tree

18 files changed

+1441
-1569
lines changed

18 files changed

+1441
-1569
lines changed

‎exhook-svr-erlang/.gitignore

+2
Original file line numberDiff line numberDiff line change
@@ -5,3 +5,5 @@ apps/exhook_svr/src/emqx_exhook_v_1_hook_provider_client.erl
55
apps/exhook_svr/src/emqx_exhook_v_1_hook_provider_bhvr.erl
66
apps/exhook_svr/src/emqx_exhook_v_2_hook_provider_client.erl
77
apps/exhook_svr/src/emqx_exhook_v_2_hook_provider_bhvr.erl
8+
apps/exhook_svr/src/emqx_exhook_v_3_hook_provider_client.erl
9+
apps/exhook_svr/src/emqx_exhook_v_3_hook_provider_bhvr.erl

‎exhook-svr-erlang/apps/exhook_svr/priv/exhook.proto

+48-8
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
11
//------------------------------------------------------------------------------
2-
// Copyright (c) 2020-2022 EMQ Technologies Co., Ltd. All Rights Reserved.
2+
// Copyright (c) 2020-2025 EMQ Technologies Co., Ltd. All Rights Reserved.
33
//
44
// Licensed under the Apache License, Version 2.0 (the "License");
55
// you may not use this file except in compliance with the License.
@@ -16,15 +16,17 @@
1616

1717
syntax = "proto3";
1818

19-
option csharp_namespace = "Emqx.Exhook.V2";
19+
option csharp_namespace = "Emqx.Exhook.V3";
2020
option go_package = "emqx.io/grpc/exhook";
2121
option java_multiple_files = true;
2222
option java_package = "io.emqx.exhook";
2323
option java_outer_classname = "EmqxExHookProto";
2424

25-
// The exhook proto version should be fixed as `v2` in EMQX v5.x
26-
// to make sure the exhook proto version is compatible
27-
package emqx.exhook.v2;
25+
// Please make sure the exhook proto version is compatible
26+
// with the EMQX version
27+
// v3: EMQX 5.9.0+
28+
// v2: EMQX 5.0-5.8.x
29+
package emqx.exhook.v3;
2830

2931
service HookProvider {
3032

@@ -97,6 +99,8 @@ message ClientConnectRequest {
9799
repeated Property props = 2;
98100

99101
RequestMeta meta = 3;
102+
103+
repeated Property user_props = 4;
100104
}
101105

102106
message ClientConnackRequest {
@@ -108,6 +112,8 @@ message ClientConnackRequest {
108112
repeated Property props = 3;
109113

110114
RequestMeta meta = 4;
115+
116+
repeated Property user_props = 5;
111117
}
112118

113119
message ClientConnectedRequest {
@@ -148,6 +154,9 @@ message ClientAuthorizeRequest {
148154

149155
AuthorizeReqType type = 2;
150156

157+
// In ClientAuthorizeRequest.
158+
// Only "real-topic" will be serialized in gRPC request when shared-sub.
159+
// For example, when client subscribes to `$share/group/t/1`, the real topic is `t/1`.
151160
string topic = 3;
152161

153162
bool result = 4;
@@ -164,6 +173,8 @@ message ClientSubscribeRequest {
164173
repeated TopicFilter topic_filters = 3;
165174

166175
RequestMeta meta = 4;
176+
177+
repeated Property user_props = 5;
167178
}
168179

169180
message ClientUnsubscribeRequest {
@@ -175,6 +186,8 @@ message ClientUnsubscribeRequest {
175186
repeated TopicFilter topic_filters = 3;
176187

177188
RequestMeta meta = 4;
189+
190+
repeated Property user_props = 5;
178191
}
179192

180193
message SessionCreatedRequest {
@@ -239,6 +252,10 @@ message MessagePublishRequest {
239252
Message message = 1;
240253

241254
RequestMeta meta = 2;
255+
256+
repeated Property props = 3;
257+
258+
repeated Property user_props = 4;
242259
}
243260

244261
message MessageDeliveredRequest {
@@ -368,6 +385,8 @@ message ConnInfo {
368385
string proto_ver = 7;
369386

370387
uint32 keepalive = 8;
388+
389+
uint32 peerport = 9;
371390
}
372391

373392
message ClientInfo {
@@ -397,6 +416,8 @@ message ClientInfo {
397416

398417
// subject of client TLS cert
399418
string dn = 12;
419+
420+
uint32 peerport = 13;
400421
}
401422

402423
message Message {
@@ -452,16 +473,35 @@ message TopicFilter {
452473

453474
string name = 1;
454475

455-
uint32 qos = 2;
476+
// Deprecated
477+
// Since EMQX 5.4.0, we have deprecated the 'qos' field in the `TopicFilter` structure.
478+
// A new field named 'subopts,' has been added to encompass all subscription options.
479+
// Please see the `SubOpts` structure for details.
480+
reserved 2;
481+
reserved "qos";
482+
483+
SubOpts subopts = 3;
456484
}
457485

458486
message SubOpts {
459487

460488
// The QoS level
461489
uint32 qos = 1;
462490

463-
// The group name for shared subscription
464-
string share = 2;
491+
// Deprecated
492+
reserved 2;
493+
reserved "share";
494+
// Since EMQX 5.4.0, we have deprecated the 'share' field in the `SubOpts` structure.
495+
// The group name of shared subscription will be serialized with topic.
496+
// hooks:
497+
// "client.subscribe":
498+
// ClientSubscribeRequest.TopicFilter.name = "$share/group/topic/1"
499+
// "client.unsubscribe":
500+
// ClientUnsubscribeRequest.TopicFilter.name = "$share/group/topic/1"
501+
// "session.subscribed":
502+
// SessionSubscribedRequest.topic = "$share/group/topic/1"
503+
// "session.unsubscribed":
504+
// SessionUnsubscribedRequest.topic = "$share/group/topic/1"
465505

466506
// The Retain Handling option (MQTT v5.0)
467507
//

‎exhook-svr-erlang/apps/exhook_svr/src/exhook_svr.erl

+3-2
Original file line numberDiff line numberDiff line change
@@ -16,7 +16,7 @@
1616

1717
-module(exhook_svr).
1818

19-
-behavior(emqx_exhook_v_1_hook_provider_bhvr).
19+
-behavior(emqx_exhook_v_3_hook_provider_bhvr).
2020

2121
%% gRPC server HookProvider callbacks
2222
-export([ on_provider_loaded/2
@@ -112,7 +112,8 @@ on_client_disconnected(_Req, Md) ->
112112
| {error, grpc_cowboy_h:error_response()}.
113113
on_client_authenticate(_Req, Md) ->
114114
ets:update_counter(exhook_stats, ?FUNCTION_NAME, {2, 1}, {?FUNCTION_NAME, 0}),
115-
{ok, #{type => 'STOP_AND_RETURN', value => {bool_result, true}}, Md}.
115+
%%{ok, #{type => 'STOP_AND_RETURN', value => {bool_result, true}}, Md}.
116+
{ok, #{type => 'IGNORE'}, Md}.
116117

117118
-spec on_client_authorize(emqx_exhook_pb:client_authorize_request(), grpc:metadata())
118119
-> {ok, emqx_exhook_pb:valued_response(), grpc:metadata()}

‎exhook-svr-erlang/apps/exhook_svr/src/exhook_svr_app.erl

+1-1
Original file line numberDiff line numberDiff line change
@@ -18,7 +18,7 @@ start(_StartType, _StartArgs) ->
1818
%% grpc server
1919
Services = #{protos => [emqx_exhook_pb],
2020
services => #{
21-
'emqx.exhook.v2.HookProvider' => exhook_svr
21+
'emqx.exhook.v3.HookProvider' => exhook_svr
2222
}
2323
},
2424
Options = [],

‎exhook-svr-erlang/rebar.config

+5-2
Original file line numberDiff line numberDiff line change
@@ -1,11 +1,14 @@
11
{erl_opts, [debug_info]}.
22

33
{plugins,
4-
[{grpc_plugin, {git, "https://github.com/HJianBo/grpcbox_plugin", {tag, "v0.10.1"}}}
4+
[{grpc_plugin, {git, "https://github.com/HJianBo/grpcbox_plugin", {tag, "v0.10.3"}}}
55
]}.
66

77
{deps,
8-
[{grpc, {git, "https://github.com/emqx/grpc-erl", {tag, "0.6.4"}}}
8+
[
9+
{cowlib, "2.13.0"},
10+
{cowboy, {git, "https://github.com/emqx/cowboy", {tag, "2.9.3"}}},
11+
{grpc, {git, "https://github.com/emqx/grpc-erl", {tag, "0.7.1"}}}
912
]}.
1013

1114
{grpc,

‎exhook-svr-erlang/rebar3

-15.8 KB
Binary file not shown.

‎exhook-svr-go/.gitignore

+1
Original file line numberDiff line numberDiff line change
@@ -0,0 +1 @@
1+
go

‎exhook-svr-go/go.mod

+11-5
Original file line numberDiff line numberDiff line change
@@ -1,12 +1,18 @@
11
module emqx.io/grpc/exhook
22

3-
go 1.11
3+
go 1.24
44

55
replace emqx.io/grpc/exhook => ./
66

77
require (
8-
github.com/golang/protobuf v1.5.0
9-
google.golang.org/grpc v1.36.0
10-
google.golang.org/grpc/cmd/protoc-gen-go-grpc v1.2.0 // indirect
11-
google.golang.org/protobuf v1.27.1
8+
google.golang.org/grpc v1.71.0
9+
google.golang.org/protobuf v1.36.5
10+
)
11+
12+
require (
13+
github.com/golang/protobuf v1.5.4 // indirect
14+
golang.org/x/net v0.34.0 // indirect
15+
golang.org/x/sys v0.29.0 // indirect
16+
golang.org/x/text v0.21.0 // indirect
17+
google.golang.org/genproto v0.0.0-20200526211855-cb27e3aa2013 // indirect
1218
)

‎exhook-svr-go/go.sum

+32-33
Original file line numberDiff line numberDiff line change
@@ -2,12 +2,12 @@ cloud.google.com/go v0.26.0/go.mod h1:aQUYkXzVsufM+DwF1aE+0xfcU+56JwCaLick0ClmMT
22
github.com/BurntSushi/toml v0.3.1/go.mod h1:xHWCNGjB5oqiDr8zfno3MHue2Ht5sIBksp03qcyfWMU=
33
github.com/census-instrumentation/opencensus-proto v0.2.1/go.mod h1:f6KPmirojxKA12rnyqOA5BBL4O983OfeGPqjHWSTneU=
44
github.com/client9/misspell v0.3.4/go.mod h1:qj6jICC3Q7zFZvVWo7KLAzC3yx5G7kyvSDkc90ppPyw=
5-
github.com/cncf/udpa/go v0.0.0-20201120205902-5459f2c99403/go.mod h1:WmhPx2Nbnhtbo57+VJT5O0JRkEi1Wbu0z5j0R8u5Hbk=
6-
github.com/davecgh/go-spew v1.1.0/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
7-
github.com/envoyproxy/go-control-plane v0.9.0/go.mod h1:YTl/9mNaCwkRvm6d1a2C3ymFceY/DCBVvsKhRF0iEA4=
85
github.com/envoyproxy/go-control-plane v0.9.1-0.20191026205805-5f8ba28d4473/go.mod h1:YTl/9mNaCwkRvm6d1a2C3ymFceY/DCBVvsKhRF0iEA4=
9-
github.com/envoyproxy/go-control-plane v0.9.9-0.20201210154907-fd9021fe5dad/go.mod h1:cXg6YxExXjJnVBQHBLXeUAgxn2UodCpnH306RInaBQk=
106
github.com/envoyproxy/protoc-gen-validate v0.1.0/go.mod h1:iSmxcyjqTsJpI2R4NaDN7+kN2VEUnK/pcBlmesArF7c=
7+
github.com/go-logr/logr v1.4.2 h1:6pFjapn8bFcIbiKo3XT4j/BhANplGihG6tvd+8rYgrY=
8+
github.com/go-logr/logr v1.4.2/go.mod h1:9T104GzyrTigFIr8wt5mBrctHMim0Nb2HLGrmQ40KvY=
9+
github.com/go-logr/stdr v1.2.2 h1:hSWxHoqTgW2S2qGc0LTAI563KZ5YKYRhT3MFKZMbjag=
10+
github.com/go-logr/stdr v1.2.2/go.mod h1:mMo/vtBO5dYbehREoey6XUKy/eSumjCCveDpRre4VKE=
1111
github.com/golang/glog v0.0.0-20160126235308-23def4e6c14b/go.mod h1:SBH7ygxi8pfUlaOkMMuAQtPIUF8ecWP5IEl/CR7VP2Q=
1212
github.com/golang/mock v1.1.1/go.mod h1:oTYuIxOrZwtPieC+H1uAHpcLFnEyAGVDL/k47Jfbm0A=
1313
github.com/golang/protobuf v1.2.0/go.mod h1:6lQm79b+lXiMfvg/cZm0SGofjICqVBUtrP5yJMmIC1U=
@@ -18,23 +18,29 @@ github.com/golang/protobuf v1.4.0-rc.2/go.mod h1:LlEzMj4AhA7rCAGe4KMBDvJI+AwstrU
1818
github.com/golang/protobuf v1.4.0-rc.4.0.20200313231945-b860323f09d0/go.mod h1:WU3c8KckQ9AFe+yFwt9sWVRKCVIyN9cPHBJSNnbL67w=
1919
github.com/golang/protobuf v1.4.0/go.mod h1:jodUvKwWbYaEsadDk5Fwe5c77LiNKVO9IDvqG2KuDX0=
2020
github.com/golang/protobuf v1.4.1/go.mod h1:U8fpvMrcmy5pZrNK1lt4xCsGvpyWQ/VVv6QDs8UjoX8=
21-
github.com/golang/protobuf v1.4.2/go.mod h1:oDoupMAO8OvCJWAcko0GGGIgR6R6ocIYbsSw735rRwI=
22-
github.com/golang/protobuf v1.4.3 h1:JjCZWpVbqXDqFVmTfYWEVTMIYrL/NPdPSCHPJ0T/raM=
23-
github.com/golang/protobuf v1.4.3/go.mod h1:oDoupMAO8OvCJWAcko0GGGIgR6R6ocIYbsSw735rRwI=
24-
github.com/golang/protobuf v1.5.0 h1:LUVKkCeviFUMKqHa4tXIIij/lbhnMbP7Fn5wKdKkRh4=
25-
github.com/golang/protobuf v1.5.0/go.mod h1:FsONVRAS9T7sI+LIUmWTfcYkHO4aIWwzhcaSAoJOfIk=
21+
github.com/golang/protobuf v1.5.4 h1:i7eJL8qZTpSEXOPTxNKhASYpMn+8e5Q6AdndVa1dWek=
22+
github.com/golang/protobuf v1.5.4/go.mod h1:lnTiLA8Wa4RWRcIUkrtSVa5nRhsEGBg48fD6rSs7xps=
2623
github.com/google/go-cmp v0.2.0/go.mod h1:oXzfMopK8JAjlY9xF4vHSVASa0yLyX7SntLO5aqRK0M=
2724
github.com/google/go-cmp v0.3.0/go.mod h1:8QqcDgzrUqlUb/G2PQTWiueGozuR1884gddMywk6iLU=
2825
github.com/google/go-cmp v0.3.1/go.mod h1:8QqcDgzrUqlUb/G2PQTWiueGozuR1884gddMywk6iLU=
2926
github.com/google/go-cmp v0.4.0/go.mod h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/gNBxE=
30-
github.com/google/go-cmp v0.5.0 h1:/QaMHBdZ26BB3SSst0Iwl10Epc+xhTquomWX0oZEB6w=
31-
github.com/google/go-cmp v0.5.0/go.mod h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/gNBxE=
32-
github.com/google/go-cmp v0.5.5/go.mod h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/gNBxE=
33-
github.com/google/uuid v1.1.2/go.mod h1:TIyPZe4MgqvfeYDBFedMoGGpEw/LqOeaOT+nhxU+yHo=
34-
github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4=
27+
github.com/google/go-cmp v0.6.0 h1:ofyhxvXcZhMsU5ulbFiLKl/XBFqE1GSq7atu8tAmTRI=
28+
github.com/google/go-cmp v0.6.0/go.mod h1:17dUlkBOakJ0+DkrSSNjCkIjxS6bF9zb3elmeNGIjoY=
29+
github.com/google/uuid v1.6.0 h1:NIvaJDMOsjHA8n1jAhLSgzrAzy1Hgr+hNrb57e+94F0=
30+
github.com/google/uuid v1.6.0/go.mod h1:TIyPZe4MgqvfeYDBFedMoGGpEw/LqOeaOT+nhxU+yHo=
3531
github.com/prometheus/client_model v0.0.0-20190812154241-14fe0d1b01d4/go.mod h1:xMI15A0UPsDsEKsMN9yxemIoYk6Tm2C1GtYGdfGttqA=
36-
github.com/stretchr/objx v0.1.0/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME=
37-
github.com/stretchr/testify v1.5.1/go.mod h1:5W2xD1RspED5o8YsWQXVCued0rvSQ+mT+I5cxcmMvtA=
32+
go.opentelemetry.io/auto/sdk v1.1.0 h1:cH53jehLUN6UFLY71z+NDOiNJqDdPRaXzTel0sJySYA=
33+
go.opentelemetry.io/auto/sdk v1.1.0/go.mod h1:3wSPjt5PWp2RhlCcmmOial7AvC4DQqZb7a7wCow3W8A=
34+
go.opentelemetry.io/otel v1.34.0 h1:zRLXxLCgL1WyKsPVrgbSdMN4c0FMkDAskSTQP+0hdUY=
35+
go.opentelemetry.io/otel v1.34.0/go.mod h1:OWFPOQ+h4G8xpyjgqo4SxJYdDQ/qmRH+wivy7zzx9oI=
36+
go.opentelemetry.io/otel/metric v1.34.0 h1:+eTR3U0MyfWjRDhmFMxe2SsW64QrZ84AOhvqS7Y+PoQ=
37+
go.opentelemetry.io/otel/metric v1.34.0/go.mod h1:CEDrp0fy2D0MvkXE+dPV7cMi8tWZwX3dmaIhwPOaqHE=
38+
go.opentelemetry.io/otel/sdk v1.34.0 h1:95zS4k/2GOy069d321O8jWgYsW3MzVV+KuSPKp7Wr1A=
39+
go.opentelemetry.io/otel/sdk v1.34.0/go.mod h1:0e/pNiaMAqaykJGKbi+tSjWfNNHMTxoC9qANsCzbyxU=
40+
go.opentelemetry.io/otel/sdk/metric v1.34.0 h1:5CeK9ujjbFVL5c1PhLuStg1wxA7vQv7ce1EK0Gyvahk=
41+
go.opentelemetry.io/otel/sdk/metric v1.34.0/go.mod h1:jQ/r8Ze28zRKoNRdkjCZxfs6YvBTG1+YIqyFVFYec5w=
42+
go.opentelemetry.io/otel/trace v1.34.0 h1:+ouXS2V8Rd4hp4580a8q23bg0azF2nI8cqLYnC8mh/k=
43+
go.opentelemetry.io/otel/trace v1.34.0/go.mod h1:Svm7lSjQD7kG7KJ/MUHPVXSDGz2OX4h0M2jHBhmSfRE=
3844
golang.org/x/crypto v0.0.0-20190308221718-c2843e01d9a2/go.mod h1:djNgcEr1/C05ACkg1iLfiJU5Ep61QUkGW8qpdssI0+w=
3945
golang.org/x/exp v0.0.0-20190121172915-509febef88a4/go.mod h1:CJ0aWSM057203Lf6IL+f9T1iT9GByDxfZKAQTCR3kQA=
4046
golang.org/x/lint v0.0.0-20181026193005-c67002cb31c3/go.mod h1:UVdnD1Gm6xHRNCYTkRU2/jEulfH38KcIWyp/GAMgvoE=
@@ -43,22 +49,24 @@ golang.org/x/lint v0.0.0-20190313153728-d0100b6bd8b3/go.mod h1:6SW0HCj/g11FgYtHl
4349
golang.org/x/net v0.0.0-20180724234803-3673e40ba225/go.mod h1:mL1N/T3taQHkDXs73rZJwtUhF3w3ftmwwsq0BUmARs4=
4450
golang.org/x/net v0.0.0-20180826012351-8a410e7b638d/go.mod h1:mL1N/T3taQHkDXs73rZJwtUhF3w3ftmwwsq0BUmARs4=
4551
golang.org/x/net v0.0.0-20190213061140-3a22650c66bd/go.mod h1:mL1N/T3taQHkDXs73rZJwtUhF3w3ftmwwsq0BUmARs4=
46-
golang.org/x/net v0.0.0-20190311183353-d8887717615a h1:oWX7TPOiFAMXLq8o0ikBYfCJVlRHBcsciT5bXOrH628=
4752
golang.org/x/net v0.0.0-20190311183353-d8887717615a/go.mod h1:t9HGtf8HONx5eT2rtn7q6eTqICYqUVnKs3thJo3Qplg=
53+
golang.org/x/net v0.34.0 h1:Mb7Mrk043xzHgnRM88suvJFwzVrRfHEHJEl5/71CKw0=
54+
golang.org/x/net v0.34.0/go.mod h1:di0qlW3YNM5oh6GqDGQr92MyTozJPmybPK4Ev/Gm31k=
4855
golang.org/x/oauth2 v0.0.0-20180821212333-d2e6202438be/go.mod h1:N/0e6XlmueqKjAGxoOufVs8QHGRruUQn6yWY3a++T0U=
4956
golang.org/x/sync v0.0.0-20180314180146-1d60e4601c6f/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
5057
golang.org/x/sync v0.0.0-20181108010431-42b317875d0f/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
5158
golang.org/x/sync v0.0.0-20190423024810-112230192c58/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
5259
golang.org/x/sys v0.0.0-20180830151530-49385e6e1522/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY=
53-
golang.org/x/sys v0.0.0-20190215142949-d0b11bdaac8a h1:1BGLXjeY4akVXGgbC9HugT3Jv3hCI0z56oJR5vAMgBU=
5460
golang.org/x/sys v0.0.0-20190215142949-d0b11bdaac8a/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY=
55-
golang.org/x/text v0.3.0 h1:g61tztE5qeGQ89tm6NTjjM9VPIm088od1l6aSorWRWg=
61+
golang.org/x/sys v0.29.0 h1:TPYlXGxvx1MGTn2GiZDhnjPA9wZzZeGKHHmKhHYvgaU=
62+
golang.org/x/sys v0.29.0/go.mod h1:/VUhepiaJMQUp4+oa/7Zr1D23ma6VTLIYjOOTFZPUcA=
5663
golang.org/x/text v0.3.0/go.mod h1:NqM8EUOU14njkJ3fqMW+pc6Ldnwhi/IjpwHt7yyuwOQ=
64+
golang.org/x/text v0.21.0 h1:zyQAAkrwaneQ066sspRyJaG9VNi/YJ1NfzcGB3hZ/qo=
65+
golang.org/x/text v0.21.0/go.mod h1:4IBbMaMmOPCJ8SecivzSH54+73PCFmPWxNTLm+vZkEQ=
5766
golang.org/x/tools v0.0.0-20190114222345-bf090417da8b/go.mod h1:n7NCudcB/nEzxVGmLbDWY5pfWTLqBcC2KZ6jyYvM4mQ=
5867
golang.org/x/tools v0.0.0-20190226205152-f727befe758c/go.mod h1:9Yl7xja0Znq3iFh3HoIrodX9oNMXvdceNzlUR8zjMvY=
5968
golang.org/x/tools v0.0.0-20190311212946-11955173bddd/go.mod h1:LCzVGOaR6xXOjkQ3onu1FJEFr0SW1gC7cKk1uF8kGRs=
6069
golang.org/x/tools v0.0.0-20190524140312-2c0ae7006135/go.mod h1:RgjU9mgBXZiqYHBnxXauZ1Gv1EHHAz9KjViQ78xBX0Q=
61-
golang.org/x/xerrors v0.0.0-20191204190536-9bdfabe68543 h1:E7g+9GITq07hpfrRu66IVDexMakfv52eLZ2CXBWiKr4=
6270
golang.org/x/xerrors v0.0.0-20191204190536-9bdfabe68543/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0=
6371
google.golang.org/appengine v1.1.0/go.mod h1:EbEs0AVv82hx2wNQdGPgUI5lhzA/G0D9YwlJXL52JkM=
6472
google.golang.org/appengine v1.4.0/go.mod h1:xpcJRLb0r/rnEns0DIKYYv+WjYCduHsrkT7/EB5XEv4=
@@ -68,26 +76,17 @@ google.golang.org/genproto v0.0.0-20200526211855-cb27e3aa2013 h1:+kGHl1aib/qcwaR
6876
google.golang.org/genproto v0.0.0-20200526211855-cb27e3aa2013/go.mod h1:NbSheEEYHJ7i3ixzK3sjbqSGDJWnxyFXZblF3eUsNvo=
6977
google.golang.org/grpc v1.19.0/go.mod h1:mqu4LbDTu4XGKhr4mRzUsmM4RtVoemTSY81AxZiDr8c=
7078
google.golang.org/grpc v1.23.0/go.mod h1:Y5yQAOtifL1yxbo5wqy6BxZv8vAUGQwXBOALyacEbxg=
71-
google.golang.org/grpc v1.25.1/go.mod h1:c3i+UQWmh7LiEpx4sFZnkU36qjEYZ0imhYfXVyQciAY=
7279
google.golang.org/grpc v1.27.0/go.mod h1:qbnxyOmOxrQa7FizSgH+ReBfzJrCY1pSN7KXBS8abTk=
73-
google.golang.org/grpc v1.36.0 h1:o1bcQ6imQMIOpdrO3SWf2z5RV72WbDwdXuK0MDlc8As=
74-
google.golang.org/grpc v1.36.0/go.mod h1:qjiiYl8FncCW8feJPdyg3v6XW24KsRHe+dy9BAGRRjU=
75-
google.golang.org/grpc/cmd/protoc-gen-go-grpc v1.2.0 h1:TLkBREm4nIsEcexnCjgQd5GQWaHcqMzwQV0TX9pq8S0=
76-
google.golang.org/grpc/cmd/protoc-gen-go-grpc v1.2.0/go.mod h1:DNq5QpG7LJqD2AamLZ7zvKE0DEpVl2BSEVjFycAAjRY=
80+
google.golang.org/grpc v1.71.0 h1:kF77BGdPTQ4/JZWMlb9VpJ5pa25aqvVqogsxNHHdeBg=
81+
google.golang.org/grpc v1.71.0/go.mod h1:H0GRtasmQOh9LkFoCPDu3ZrwUtD1YGE+b2vYBYd/8Ec=
7782
google.golang.org/protobuf v0.0.0-20200109180630-ec00e32a8dfd/go.mod h1:DFci5gLYBciE7Vtevhsrf46CRTquxDuWsQurQQe4oz8=
7883
google.golang.org/protobuf v0.0.0-20200221191635-4d8936d0db64/go.mod h1:kwYJMbMJ01Woi6D6+Kah6886xMZcty6N08ah7+eCXa0=
7984
google.golang.org/protobuf v0.0.0-20200228230310-ab0ca4ff8a60/go.mod h1:cfTl7dwQJ+fmap5saPgwCLgHXTUD7jkjRqWcaiX5VyM=
8085
google.golang.org/protobuf v1.20.1-0.20200309200217-e05f789c0967/go.mod h1:A+miEFZTKqfCUM6K7xSMQL9OKL/b6hQv+e19PK+JZNE=
8186
google.golang.org/protobuf v1.21.0/go.mod h1:47Nbq4nVaFHyn7ilMalzfO3qCViNmqZ2kzikPIcrTAo=
8287
google.golang.org/protobuf v1.22.0/go.mod h1:EGpADcykh3NcUnDUJcl1+ZksZNG86OlYog2l/sGQquU=
83-
google.golang.org/protobuf v1.23.0/go.mod h1:EGpADcykh3NcUnDUJcl1+ZksZNG86OlYog2l/sGQquU=
8488
google.golang.org/protobuf v1.23.1-0.20200526195155-81db48ad09cc/go.mod h1:EGpADcykh3NcUnDUJcl1+ZksZNG86OlYog2l/sGQquU=
85-
google.golang.org/protobuf v1.25.0 h1:Ejskq+SyPohKW+1uil0JJMtmHCgJPJ/qWTxr8qp+R4c=
86-
google.golang.org/protobuf v1.25.0/go.mod h1:9JNX74DMeImyA3h4bdi1ymwjUzf21/xIlbajtzgsN7c=
87-
google.golang.org/protobuf v1.26.0-rc.1/go.mod h1:jlhhOSvTdKEhbULTjvd4ARK9grFBp09yW+WbY/TyQbw=
88-
google.golang.org/protobuf v1.27.1 h1:SnqbnDw1V7RiZcXPx5MEeqPv2s79L9i7BJUlG/+RurQ=
89-
google.golang.org/protobuf v1.27.1/go.mod h1:9q0QmTI4eRPtz6boOQmLYwt+qCgq0jsYwAQnmE0givc=
90-
gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
91-
gopkg.in/yaml.v2 v2.2.2/go.mod h1:hI93XBmqTisBFMUTm0b8Fm+jr3Dg1NNxqwp+5A1VGuI=
89+
google.golang.org/protobuf v1.36.5 h1:tPhr+woSbjfYvY6/GPufUoYizxw1cF/yFoxJ2fmpwlM=
90+
google.golang.org/protobuf v1.36.5/go.mod h1:9fA7Ob0pmnwhb644+1+CVWFRbNajQ6iRojtC/QF5bRE=
9291
honnef.co/go/tools v0.0.0-20190102054323-c2f93a96b099/go.mod h1:rf3lG4BRIbNafJWhAfAdb/ePZxsR/4RtNHQocxwk9r4=
9392
honnef.co/go/tools v0.0.0-20190523083050-ea95bdfd59fc/go.mod h1:rf3lG4BRIbNafJWhAfAdb/ePZxsR/4RtNHQocxwk9r4=

‎exhook-svr-go/main.go

+1-1
Original file line numberDiff line numberDiff line change
@@ -16,7 +16,7 @@ const (
1616

1717
var cnter *utils.Counter = utils.NewCounter(0, 100)
1818

19-
// server is used to implement emqx_exhook_v1.s *server
19+
// server is used to implement emqx_exhook_v3.s *server
2020
type server struct {
2121
pb.UnimplementedHookProviderServer
2222
}

0 commit comments

Comments
 (0)