Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Go/dev #2

Open
wants to merge 89 commits into
base: master
Choose a base branch
from
Open
Changes from 1 commit
Commits
Show all changes
89 commits
Select commit Hold shift + click to select a range
28b98b0
[ROCKETMQ-198] Go-Client's incomplete implement.
StyleTang Jul 7, 2017
2ebd1a0
use localhost test
StyleTang Aug 9, 2017
5ae0244
user only use
StyleTang Aug 9, 2017
b115a9c
consumer and producer can getConfig
StyleTang Aug 9, 2017
208f2a2
add .travis.yml
StyleTang Aug 10, 2017
3e8fc27
.travis.yml jdk
StyleTang Aug 10, 2017
c3a99db
.travis.yml jdk
StyleTang Aug 10, 2017
903a339
.travis.yml add go test
StyleTang Aug 10, 2017
d8ef4cb
.travis.yml remove java
StyleTang Aug 10, 2017
6ec7976
.travis.yml test java
StyleTang Aug 10, 2017
6cec9d4
.travis.yml test java
StyleTang Aug 10, 2017
82f7c87
openjdk7
StyleTang Aug 10, 2017
7139500
- os: linux
StyleTang Aug 10, 2017
7c4d36a
travis language: java
StyleTang Aug 10, 2017
9c43201
README.md
StyleTang Aug 10, 2017
119b6bc
update go client code of api
StyleTang Aug 10, 2017
664caa2
CurrentTimeMillisInt64
StyleTang Aug 12, 2017
34760b6
go api config
StyleTang Aug 12, 2017
3d01651
update rocketmq's example
StyleTang Aug 12, 2017
5bc4e16
update rocketmq's example
StyleTang Aug 12, 2017
5301148
package util unit test
Rock1994 Aug 12, 2017
ee9d420
Merge pull request #1 from Rock1994/go-client-refactor
StyleTang Aug 12, 2017
6165d4e
make SerializeType can be config
StyleTang Aug 12, 2017
925ab25
update api
StyleTang Aug 13, 2017
275ae2e
refactor code
StyleTang Aug 13, 2017
5863f41
add test case:
StyleTang Aug 13, 2017
57cef1e
test_delay_message_send_and_receive
StyleTang Aug 14, 2017
5cdad85
test_rocketmq_serialize_message_send_and_receive
StyleTang Aug 14, 2017
3e82748
test_rocketmq_serialize_message_send_and_receive
StyleTang Aug 15, 2017
669c3fe
LICENSE
StyleTang Aug 15, 2017
a7c5e5f
add go rocketmq client design
StyleTang Aug 15, 2017
8830e64
go fmt
StyleTang Aug 15, 2017
d96abe3
go report
StyleTang Aug 15, 2017
30a0e49
License format
StyleTang Aug 15, 2017
5531aeb
for golint
StyleTang Aug 17, 2017
97a475c
misspell
StyleTang Aug 17, 2017
46d95c9
change package name for golint
StyleTang Aug 17, 2017
5319eba
change package name for golint
StyleTang Aug 17, 2017
b9b0d60
make api easy to use
StyleTang Aug 17, 2017
6d509f2
make api easy to use
StyleTang Aug 17, 2017
77e9083
make api easy to use
StyleTang Aug 17, 2017
c3cd3d4
refactor
StyleTang Aug 20, 2017
cf3cd1a
change package
StyleTang Aug 20, 2017
4b14070
manage->kernel
StyleTang Aug 20, 2017
4f28277
manage->kernel
StyleTang Aug 20, 2017
4552662
change rebalance.go
StyleTang Aug 20, 2017
d3ece64
change rebalance.go
StyleTang Aug 20, 2017
fee140e
remove request_code and response_code
StyleTang Aug 20, 2017
9c4f2fe
send_message_request_header
StyleTang Aug 20, 2017
c33d39d
send_message_request_header
StyleTang Aug 20, 2017
739f442
range variable consumer captured by func literal
StyleTang Aug 20, 2017
f073f8a
go_vet
StyleTang Aug 20, 2017
31d5274
gofmt -s
StyleTang Aug 20, 2017
916b85b
gofmt -s
StyleTang Aug 20, 2017
ea38185
update design
StyleTang Aug 20, 2017
509f04d
update example
StyleTang Aug 20, 2017
3b6b82c
cyclomatic complexity 16 of function (*MqClientManager).initClientReq…
StyleTang Aug 22, 2017
3dda673
fix cyclomatic complexity 16 of function GetKvStringMap() is high (> …
StyleTang Aug 22, 2017
ea3f715
fix gocyclo problem
StyleTang Aug 22, 2017
48db053
pullMessage is very complicated, todo check
StyleTang Aug 22, 2017
2d4dffa
pullMessage is very complicated, todo check
StyleTang Aug 22, 2017
d55f2b4
go_vet pull_message_controller.go
StyleTang Aug 22, 2017
ce6602c
exported type Message should be of the form Message
StyleTang Aug 23, 2017
a0abe7a
comment on api
StyleTang Aug 23, 2017
dd2ecfc
allocate and header
StyleTang Aug 23, 2017
0d38422
comment on model
StyleTang Aug 23, 2017
6306f14
comment on kernel
StyleTang Aug 25, 2017
528bda1
comment on util
StyleTang Aug 25, 2017
1904e27
send result mq brokerName
StyleTang Aug 26, 2017
4e6f2a8
change api
StyleTang Aug 26, 2017
f2d450b
change api
StyleTang Aug 26, 2017
43db1c1
rocketmq send message result
StyleTang Aug 26, 2017
80665f3
golint
StyleTang Aug 26, 2017
e31c606
replace errors.New(fmt.Sprintf(...)) with fmt.Errorf(...) (golint)
StyleTang Aug 26, 2017
6eae380
golint
StyleTang Aug 26, 2017
36ccf5b
golint
StyleTang Aug 27, 2017
6da2037
golint
StyleTang Aug 27, 2017
efc87c6
go test
StyleTang Aug 27, 2017
82d2605
rocketmq api
StyleTang Aug 27, 2017
5218ab4
rocketmq console test
StyleTang Aug 27, 2017
bbbbf92
test examineProducerConnectionInfo exception
StyleTang Aug 27, 2017
b6af3f8
License
StyleTang Aug 27, 2017
c5aab32
go rocketmq api
StyleTang Aug 29, 2017
3cde1de
docs
StyleTang Aug 29, 2017
1708f8c
docs
StyleTang Aug 29, 2017
daa4462
update readme's svg
StyleTang Sep 7, 2017
ab37b78
format err %s --> %v
Jan 25, 2018
fbaef55
isInternetIpv4 add 172. ...
Jan 25, 2018
66bd9b8
update: util/isIntranetIpv4, add "10."
lily-lee May 2, 2018
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
docs
StyleTang committed Aug 29, 2017
commit 1708f8c782657e18c26756b530ed11826f457fb0
2 changes: 1 addition & 1 deletion rocketmq-go/README.md
Original file line number Diff line number Diff line change
@@ -8,7 +8,7 @@ examples:

# Go RocketMQ Client's Arch

![Go RocketMQ Client's Arch](http://www.plantuml.com/plantuml/svg/ZLNDRk8m4BxdANokL1w06qNzOTK4Dg7g4RdEGACcDjWE4jjotvNsaVfEVOKTsp7vPIa7bF5yy-MRySo4vLGf8WLx0rtiLXin2dVJF0EkGyhf1kHxe43kCmQ9fXg2Oy1w4OiopqDG2k5JmRKKUMxYJjYAO3J9Sy6GfCB-BA54LeadcyFx8BDJSaUP5X8XnGxvLLc0NDAN7D1UI96MpDlT5uOd_9aiQg0dwW39CI0zJYiAynjmkimUCwM16p83gJ0I2g4plXd5rOFd8OHaV2_U83bmLbiJrJBd79xf0UtJI_k4eYWeJmqZAvKMnGFG52IQ4dObA3qLALXBRR4kuCm1XKuPrcwTRQm-JWj8v7wIfeODuSO_MpXrIbFE84A8KpVC5Zi9M6U6HHBIyXej3B8zU8K4zLS94_qAf03zAjAHmzxVBbVJUPGyXRVnAbbEba_9wYwUXwlfu-msMWw0ugSecaNtgrbqDtVkqSYH7Ur_Hsa2CgDvzWla0-gmJKpSxuSIlFRwqzYsQhZhU8v149YAgIrbu7i3-oMuE3Jawlhw_02C6G8f5Zmu2x44TJT_Fy8FIXrHirX8j_z94-cZMqYJuMGnUvPqkqNNc5mAcA_N2dI2gk0Rw1XUQ6uwxnlOwh2gT-9Ect6u4OQkpDocJnXJ8S9Sp_0Sr-KmGSrKX2kmHLbdfp0z_wd4JGy6N0hsaBeoFUgsgw5omFk_TMtXmrKreGdmj3g-eUpDDr85kH3SLNKUsLctxKlqzqJCDRRlYjZcwApDFig0cgkmgb6VQNZ33S6lR74wMoRej5zZLjijM7sIRUw3--CikZNoWLrGGkEA5LiYrkTQceo_Fd-Rhz07FIZs8UmNwElpps0i6NFGNvz_bSyEdt4aE31pwjUx__Jy0m00)
![Go RocketMQ Client's Arch](http://www.plantuml.com/plantuml/svg/bLNDRk8m4Bxp53vNAW_0ZMNxGzM4Dg7Q8tATWKOuDiGE4ajxtvNsaVfEVOMT-8UGO6YR0s8ytum_VvuPvq93EQSC25tb_UZnePHPnQ3SzNfllRpZ74cXgkAKa-SWz5WeJGK3X13x8RGdQ05gvR0xu-a647bvIPPG2k3zQ6rz4HLq0QN3Usg7o9ymfnNNZTFdTap3s4gzUC3Ny9plyNWQngbI9xZkUdOzrLG3WblOEb44IY4Gy-bISkx4RC66d4k6uGxwM445gIvnPR7TTS5szslAj2pHMwmzqobzve2sLyRQdUYW9hipg4O9UurQacSWcHHdKkzBYhprI52ykbgEVFRqzxdI87oqWvHGI9sBHJznVtmQP9IBZLn2kXMiiOQgPKu4_A9RjFTx7YUKHK55LcTabTAok0MQcN8fOLs1qYEPWR7K2WK1QmOOMcOesZnV67vrBwJbPfXbflYOxO87oyxsGemGoowSBR4KK5Y68abt5OXYa6_0CoJ8tnsOw1SW1UWNcVKjzkPgEXjDulGfkafcwNGuVKfdryaacetknrVnD01Adk9u7D_Cnl7rnBhxVPlipVnscAPGvfJdlw6yHHxSrmj-TqgAnkjN4ycMeADrnuFjTZ0zR6bWjVJETHIvQ9gurHu3XXYAAjkkRtUkQVrWlfFeLdA32krgw0GRhStdAx5D-xLZW-aFTV3qoO1yBt0odolGAPA1RyScy4ov6UxVZNHhxYgm9ZRvSPOl2EP6JoDMPtl_f0ILQeBQRvYlmiEoCFLmOYorh-fGq3h8Pp3EHh5FN0TP0jvpBuY1X_MjGrCGcLl-GTdIAsJF_4bibzHfP6Uuj_NrCf9QuhQKnDnKPqWVeoxspMa7hvFeE5DudeRW5qQRpaopbO7SfSOPArT4payL0HbylF-fdw5NkbNiLPedwEFzRp2M30JeZ_T_oc-8_x681B1wrSzt__Ry1m00)

# Go RocketMQ Client's Roadmap
[Go RocketMQ Client's Roadmap](https://github.com/StyleTang/incubator-rocketmq-externals/blob/master/rocketmq-go/docs/roadmap.md)
2 changes: 0 additions & 2 deletions rocketmq-go/docs/package.puml
Original file line number Diff line number Diff line change
@@ -15,8 +15,6 @@ namespace api{
MQProducer o-- kernel.DefaultMQProducer
MQConsumer o-- kernel.DefaultMQPushConsumer
MQConsumer o-- kernel.DefaultMQPullConsumer
MQConsumer o-- kernel.MessageListener

}

class kernel.MqClientManager{