Asim Aslam
b32ebddf85
update nlopes/slack dep
2020-01-15 21:22:07 +00:00
Asim Aslam
b3e3dac975
Merge branch 'master' of ssh://github.com/micro/go-micro
2020-01-15 21:02:58 +00:00
Asim Aslam
f20e4daa60
fix rand panic
2020-01-15 21:02:53 +00:00
Asim Aslam
f67d87e99d
Merge pull request #1114 from milosgajdos83/network-backward-compatibility
...
Fixed bug:m network.proto backwards compatibility unmarshal
2020-01-15 19:57:57 +00:00
Milos Gajdos
36928b716c
Fixed bug:m network.proto backwards compatibility unmarshal
2020-01-15 19:45:43 +00:00
Asim Aslam
7c7b0ced5f
Merge pull request #1104 from milosgajdos83/network-hackery
...
[WIP] Network hackery
2020-01-14 20:28:32 +00:00
Milos Gajdos
c67ef7e017
Bug fix: skip sending sync message if the peer is not in our graph
2020-01-14 19:37:50 +00:00
Milos Gajdos
dcd925f1e5
Code cleanup; Indentation.
2020-01-14 18:48:42 +00:00
Milos Gajdos
0ea56a5ffe
Fixed tests
2020-01-14 18:22:58 +00:00
Milos Gajdos
821fda41ae
Added Status method to network.Node fixed random segfaults.
2020-01-14 18:12:36 +00:00
Asim Aslam
1d311ab457
Embedded NATS Broker ( #1110 )
...
* if the address is produced by a default route don't hash it
* embedded nats
* fix url parsing
* don't override help
* add ready flag
2020-01-14 13:23:16 +00:00
Asim Aslam
b699d969e4
if the address is produced by a default route don't hash it ( #1108 )
2020-01-14 11:20:13 +00:00
Milos Gajdos
994d371ff1
Removed redundant comments. Add proper PruneStalePeers test.
2020-01-14 10:49:34 +00:00
Milos Gajdos
a91dad04ee
Increment node error count and prune when Max limit is hit
2020-01-13 22:22:12 +00:00
Milos Gajdos
b4261e8cf9
Updated log and comments
2020-01-13 20:14:30 +00:00
Milos Gajdos
efcac3d009
Define tunnel errors
2020-01-13 20:14:30 +00:00
Milos Gajdos
770c7686ba
Fix nasty bug when graph action may not have been executed in some
...
branches
2020-01-13 20:14:30 +00:00
Milos Gajdos
11904e1137
Regular sync with network every 5 minutes. Apply routes before peering.
2020-01-13 20:14:29 +00:00
Milos Gajdos
1e009e52dd
Avoid having the same log statements in initNodes and resolveNodes
2020-01-13 20:14:29 +00:00
Milos Gajdos
bf42c028fb
Added sync message. Refactored connect flow. Adverts are gossipped.
...
This commit adds a Sync message which is sent as a reply to Connect
message. This should in theory speed up convergence of a (re)connecting
node.
We respond to Sync message by sending a peer message back to the peer
origin of the Sync message. We consequently update our routing table and
peer graph with the data sent in via Sync message.
We now gossip advertse to up to 3 randomly selected peers instead of
sending a multicast message to the network.
Equally, Solicitation i.e. full table adverts are gossipped to a
randomly selected peer. If that fails we send a multicast message to the
network.
2020-01-13 20:14:29 +00:00
Milos Gajdos
0a4bd02503
Add RefreshSync method for Sync bookkeeping
2020-01-13 20:14:29 +00:00
Milos Gajdos
63edfaa852
Added Sync message
...
Sync message will be sent between peers when a new node connects/joins
the network
2020-01-13 20:14:29 +00:00
Milos Gajdos
802cc8239a
Send solicit message properly. Updated comments.
2020-01-13 20:14:29 +00:00
Matthew Costa
75b1a62af3
Replace service prefix with FQDN style prefix ( #1107 )
...
* Replace service prefix with FQDN style prefix
According to the k8s documentation, the label and annotation prefixes should be in the format of a FQDN, with dot separated labels of no more than 63 characters. The current label and annotation paramteres are rejected by the k8s api, most likely because they have two forward slashes in them.
* Use go.micro as service and annotation prefix
2020-01-12 14:37:12 +00:00
Maarten Bezemer
50b20413d3
RPC stream client/server mutex fix ( #884 )
...
* Unlock RPC client while actually receiving a message
As receiving a message might block for a long time, unblocking the client allows to let it send messages in the meanwhile without using 'tricks'
* Unlock RPC server while actually receiving a message
As receiving a message might block for a long time, unblocking the client allows to let it send messages in the meanwhile without using 'tricks'
* Protect Close() against race conditions
* Concurrency and Sequence tests
2020-01-12 09:13:14 +00:00
Shu xian
fa5b3ee9d9
config/reader.Values add Set for specific path merge ( #1099 )
...
* add Set for specific path merge
* add Set
* add Del
2020-01-11 20:50:09 +00:00
Asim Aslam
f50a50eeb3
go fmt
2020-01-10 21:54:36 +00:00
Asim Aslam
e1e6199743
normalise runtime service status
2020-01-10 21:54:28 +00:00
Asim Aslam
61dd2b8489
Merge branch 'master' of ssh://github.com/micro/go-micro
2020-01-10 19:13:59 +00:00
Asim Aslam
6ca298c61d
set default store, fix store options bug, add String method
2020-01-10 19:13:55 +00:00
Vasiliy Tolstov
f4fb923fb2
pass additional context for broker subscribe ( #1105 )
...
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
2020-01-10 15:04:15 +00:00
shikbupt
32a2005f6d
add option for web service signal handler ( #1091 )
2020-01-10 14:25:28 +00:00
Asim Aslam
37d1139a57
ensure we close the grpc stream ( #1098 )
...
* ensure we close the grpc stream
* use g.Close
* use closed bool flag for checking connection close
2020-01-09 17:00:14 +00:00
Asim Aslam
a90a74c9e2
Change the store interface to remove variadic args ( #1095 )
2020-01-08 22:23:14 +00:00
Milos Gajdos
78aed5beed
Fixed tunnel race conditions. ( #1094 )
2020-01-08 14:48:38 +00:00
Milos Gajdos
59fccb82ec
Updated comments. Tiny cleanup changes. ( #1093 )
2020-01-08 13:18:11 +00:00
Asim Aslam
048065fe96
support ability to set store, address and namespace via flags and env vars ( #1092 )
2020-01-08 12:11:31 +00:00
Asim Aslam
0b8ff3a8bb
fix grpc json streaming by setting content sub type ( #1089 )
2020-01-07 18:37:34 +00:00
Asim Aslam
1892bd05a5
only add api endpoint metadata if it exists ( #1087 )
2020-01-06 22:22:36 +00:00
Asim Aslam
be6e8a7c78
add store to defaults ( #1086 )
2020-01-06 17:44:32 +00:00
Asim Aslam
df9055f69c
continue to process messages even after the connection is closed
2020-01-03 20:43:53 +00:00
Asim Aslam
649dd235c3
Merge branch 'master' of ssh://github.com/micro/go-micro
2020-01-03 19:46:24 +00:00
Asim Aslam
1af82df8b1
Check link is grpc
2020-01-03 19:46:14 +00:00
Eagle Wu
7098e59b5c
remove ignore error in method publish ( #1075 )
2020-01-03 17:24:19 +00:00
Shu xian
31362bc331
prevent resource leak ( #1080 )
2020-01-03 13:31:47 +00:00
Asim Aslam
4e2339749c
Merge branch 'master' of ssh://github.com/micro/go-micro
2020-01-02 21:19:50 +00:00
Asim Aslam
9cecf2e097
make grpc proxy streaming work
2020-01-02 21:11:25 +00:00
Lars Lehtonen
fe9c68238f
runtime/kubernetes: remove unused name variable ( #1078 )
2020-01-02 20:42:46 +00:00
Asim Aslam
225b17559b
fix log streaming
2020-01-02 18:23:43 +00:00
Asim Aslam
e697912ee5
don't panic on nil
2020-01-01 21:56:29 +00:00
