 liyingxin
|
b3c4a26188
|
Merge branch 'websocket' into merge_websocket
|
2022-04-08 16:54:06 +08:00 |
|
|
wzl12356
|
bd3d0e141b
|
Merge branch 'master' of https://github.com/wzl12356/workflow
|
2022-04-07 11:49:03 +08:00 |
|
|
wzl12356
|
10100bee14
|
kafka: fix coredump when no meta
|
2022-04-07 11:48:52 +08:00 |
|
|
XieHan
|
de9be9a344
|
remove ComplexDnsTask::message_in()
|
2022-04-05 00:18:17 +08:00 |
|
|
XieHan
|
e7b754e855
|
Fix JSON parser memleak on invalid unicode
|
2022-04-02 01:43:21 +08:00 |
|
|
XieHan
|
5f112d8284
|
update class ConsulConfig
|
2022-04-01 02:15:36 +08:00 |
|
|
wzl12356
|
a6930d05ab
|
kafka: fix meta_callback set uninit state
|
2022-03-31 21:21:30 +08:00 |
|
|
wzl12356
|
e3812907a8
|
kafka: fix zstd decompress bug
|
2022-03-25 06:00:59 +08:00 |
|
|
xiehan
|
170a15aef5
|
Merge pull request #813 from wzl12356/master
kafka: fix endless loop when fetch message from empty topic partition
|
2022-03-18 19:38:07 +08:00 |
|
|
wzl12356
|
fc28fddba8
|
kafka: fix endless loop when fetch message from empty topic partition
|
2022-03-18 19:32:29 +08:00 |
|
|
xiehan
|
b2fa6df47c
|
Merge pull request #809 from wzl12356/master
kafka: fix offset not continuous when fetch
|
2022-03-18 15:59:06 +08:00 |
|
|
XieHan
|
107c14d614
|
update WFMySQLConnection::init(). Add errno when url invalid
|
2022-03-18 15:55:44 +08:00 |
|
|
XieHan
|
9586b5530a
|
update WFConsulClient. Fix url bug
|
2022-03-18 15:19:08 +08:00 |
|
|
wzl12356
|
3b3d9ae073
|
Merge branch 'master' of https://github.com/wzl12356/workflow
|
2022-03-18 13:33:53 +08:00 |
|
|
wzl12356
|
5197a1f906
|
kafka: fix offset not continuous when fetch
|
2022-03-18 13:32:50 +08:00 |
|
|
dapengwang
|
9c2b8f1f6f
|
fix get http resp for consul
|
2022-03-17 19:42:23 +08:00 |
|
|
XieHan
|
6e9c6b18c1
|
optimize Consul client
|
2022-03-17 17:33:03 +08:00 |
|
|
xiehan
|
d242f2cd30
|
Merge pull request #799 from flaprocwang/master
add consul client
|
2022-03-17 16:02:46 +08:00 |
|
|
dapengwang
|
8bb2bb0e6a
|
fix copy right
|
2022-03-17 09:11:55 +08:00 |
|
|
dapengwang
|
dec10e9100
|
fix code style
|
2022-03-16 19:13:35 +08:00 |
|
|
dapengwang
|
a3a9101d7e
|
remove init func and code optimization
|
2022-03-16 11:17:37 +08:00 |
|
|
wangzhulei
|
b696b18321
|
kafka: filter smaller offset when fetch api
|
2022-03-16 10:20:18 +08:00 |
|
|
wzl12356
|
a54756bcfc
|
kafka: fix operator=
|
2022-03-15 18:34:50 +08:00 |
|
|
dapengwang
|
41aa4c804d
|
fix ConsulConfig operator=
|
2022-03-15 10:06:21 +08:00 |
|
|
dapengwang
|
48358287f1
|
change consul to default compiler
|
2022-03-15 09:50:26 +08:00 |
|
|
dapengwang
|
c51dbd5070
|
add consul client
|
2022-03-14 16:25:23 +08:00 |
|
|
XieHan
|
1f911d684c
|
add json parser and update library version
|
2022-03-10 19:44:39 +08:00 |
|
|
XieHan
|
5f18077560
|
add protocol namespace to DnsUtil
|
2022-03-09 22:16:40 +08:00 |
|
|
wzl12356
|
c40e395cf1
|
kafka: delete useless sasl_buf
|
2022-03-07 16:14:52 +08:00 |
|
|
wzl12356
|
e68c36ddbd
|
kafka: fix bug(when broker toggles the leader, the produce freezes)
|
2022-03-07 16:02:03 +08:00 |
|
|
XieHan
|
886217568f
|
add HttpMessage::is_header_complete()
|
2022-03-06 15:51:07 +08:00 |
|
|
XieHan
|
0db42d9344
|
update code for http proxy task
|
2022-03-04 02:03:43 +08:00 |
|
|
XieHan
|
e50868a8b6
|
Make it more compatible to some non-standard http responses
|
2022-03-03 19:30:11 +08:00 |
|
|
XieHan
|
e33f0cc89c
|
add const to some http parser interfaces
|
2022-03-03 19:04:50 +08:00 |
|
|
xiehan
|
cd5ddb24ed
|
Merge pull request #777 from holmes1412/master
remove comparison in WFServiceGorvernance::copy_host_port()
|
2022-03-03 15:40:51 +08:00 |
|
|
liyingxin
|
31b16ab95a
|
remove comparison in WFServiceGorvernance::copy_host_port()
|
2022-03-03 14:58:46 +08:00 |
|
|
xiehan
|
4564d54665
|
Merge pull request #776 from holmes1412/master
Fix WFServiceGorvernance::copy_host_port()
|
2022-03-02 21:23:49 +08:00 |
|
|
liyingxin
|
894b8e9699
|
Fix WFServiceGorvernance::copy_host_port()
|
2022-03-02 20:49:45 +08:00 |
|
|
xiehan
|
5977d8667b
|
Update HttpUtil.cc
|
2022-03-02 17:25:55 +08:00 |
|
|
xiehan
|
ff0bd91cdb
|
Merge pull request #772 from Barenboim/master
Do not cleanup unfinished named counter on exit.
|
2022-02-26 18:16:08 +08:00 |
|
|
XieHan
|
dea4efe9ec
|
Do not cleanup unfinished named counter on exit.
|
2022-02-26 17:38:48 +08:00 |
|
|
liyingxin
|
63fd9c1d58
|
Upstream : make AddressParams.weight as the multiple of consistent_hash value nodes.
|
2022-02-25 18:32:23 +08:00 |
|
|
liyingxin
|
add8feee64
|
simplify hash_map_add/remove_addr()
|
2022-02-25 17:11:50 +08:00 |
|
|
liyingxin
|
3d707dd63a
|
Upstream: Change rand() back to std::hash(). Same ip can be added multiple times.
|
2022-02-25 15:26:59 +08:00 |
|
|
xiehan
|
6004c654b6
|
Merge pull request #760 from holmes1412/master
optimize consistent_hash with map
|
2022-02-21 19:23:34 +08:00 |
|
|
liyingxin
|
37a1009677
|
optimize consistent_hash with map
|
2022-02-18 22:45:57 +08:00 |
|
|
XieHan
|
6b6120c85b
|
Optimize SSL sync writing.
|
2022-02-18 20:48:40 +08:00 |
|
|
xiehan
|
fb021b57aa
|
Merge pull request #756 from holmes1412/master
ConsistentHashPolicy: change std_hash to rand.
|
2022-02-17 19:22:36 +08:00 |
|
|
liyingxin
|
cf4f26fa3f
|
ConsistentHashPolicy: change std_hash to rand.
|
2022-02-17 17:59:25 +08:00 |
|
|
XieHan
|
48b81cc79e
|
fix style
|
2022-02-14 02:27:54 +08:00 |
|