81d2259fac
transport memory: fix races
...
* fix race with rand.Intn for non default source
* increase random interval to avoid issues when many services
running on the host
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
2019-07-13 23:47:57 +03:00
Asim Aslam
2fecde1dbb
Merge pull request #583 from unistack-org/broker
...
broker memory: fix issue with publish/subscribe
2019-07-13 00:16:28 +01:00
008749b2b0
broker memory: fix issue with publish/subscribe
...
mutex locking have errors, so when two service (one pub, other sub)
try to use this broker it waits for mutex release and nothing works
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
2019-07-13 00:04:53 +03:00
Asim Aslam
3ccb900bca
Merge pull request #582 from unistack-org/memory2
...
memory transport: use write mutex lock when close
2019-07-12 10:29:46 +01:00
a72e1185da
memory transport: use write mutex lock when close
...
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
2019-07-12 12:11:08 +03:00
Asim Aslam
5157241c88
Merge branch 'master' of ssh://github.com/micro/go-micro
2019-07-11 21:46:33 +01:00
Asim Aslam
70d811c47a
don't use quic in the test
2019-07-11 21:46:27 +01:00
Asim Aslam
b371704444
Merge pull request #581 from milosgajdos83/proto-update
...
Added proto.Advert, proto.TableEvent is now proto.Event
2019-07-11 21:44:10 +01:00
Asim Aslam
a5f21e69ad
Merge branch 'master' of ssh://github.com/micro/go-micro
2019-07-11 21:41:00 +01:00
Asim Aslam
6b984136f7
update go mod
2019-07-11 21:40:52 +01:00
Milos Gajdos
9c851f297b
Added proto.Advert type to protobuf definitions
2019-07-11 21:14:34 +01:00
Asim Aslam
dac8a13a77
Merge pull request #580 from milosgajdos83/advertise-table
...
Advertise full table every minute.
2019-07-11 12:49:02 +01:00
Asim Aslam
360e193a01
update go mod
2019-07-11 12:47:50 +01:00
Milos Gajdos
35a1de91a9
Advertise full table every minute.
2019-07-11 12:39:20 +01:00
Asim Aslam
7631463b94
fix compilation errors
2019-07-11 10:47:02 +01:00
Asim Aslam
6581586226
Make tunnel test use quic
2019-07-11 10:34:01 +01:00
Asim Aslam
06c29302d7
Merge branch 'master' of ssh://github.com/micro/go-micro
2019-07-11 09:38:27 +01:00
Asim Aslam
dab0e9e9bc
Set next protos in quic
2019-07-11 09:38:20 +01:00
Asim Aslam
47d91a1f64
Merge pull request #579 from magodo/magodo/store_get_reset_expiry
...
`memoryStore.Read()` returns honor `Record.Expiry`
2019-07-11 08:39:46 +01:00
magodo
bdeae91063
condense code
2019-07-11 14:13:58 +08:00
magodo
c8d57032bc
update expiry only if it is non-zero
2019-07-11 12:58:20 +08:00
magodo
3abe3aa28b
store.Read() returns honor Record.Expiry
2019-07-11 12:51:55 +08:00
Asim Aslam
9b1cb4ef0e
functioning tunnel with test
2019-07-11 00:55:50 +01:00
Asim Aslam
b4796724d9
Merge branch 'master' of ssh://github.com/micro/go-micro
2019-07-11 00:14:43 +01:00
Asim Aslam
ae5376cc0e
functioning tunnel/link code
2019-07-11 00:14:36 +01:00
Asim Aslam
7bee0629c2
Merge pull request #578 from unistack-org/memory
...
memory transport: fix race cond on channel close
2019-07-10 23:30:46 +01:00
29fa8de98e
memory transport: fix race cond on channel close
...
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
2019-07-11 01:21:03 +03:00
Asim Aslam
382fbecd40
Merge pull request #577 from milosgajdos83/update-events
...
Added update action to handle update registry events. Table.Update inserts when no route found.
2019-07-10 21:54:48 +01:00
Milos Gajdos
a0ee7d2092
Added update action to manageServiceRoutes. Table is embedded; skip opts
2019-07-10 21:28:32 +01:00
Asim Aslam
1f744b31a4
Return the dead node when deleting the service
2019-07-10 21:03:53 +01:00
Asim Aslam
998a23c963
Functional code for link
2019-07-10 20:04:01 +01:00
Asim Aslam
e17ecf66b1
Fix breaking code
2019-07-10 20:03:55 +01:00
Asim Aslam
c5dd737568
Add back in broker address
2019-07-10 19:58:30 +01:00
Asim Aslam
7c29be288b
Update a tunnel top level comment
2019-07-10 19:33:34 +01:00
Asim Aslam
217f540601
The listener has no session id
2019-07-10 19:17:36 +01:00
Asim Aslam
ffae0f0fab
Add a comment for tunnel processor
2019-07-10 19:13:50 +01:00
Asim Aslam
4cca2b43a3
Add further link comments
2019-07-10 19:11:32 +01:00
Asim Aslam
8c157c1d5f
update link comments
2019-07-10 19:09:22 +01:00
Asim Aslam
1f218f7b48
Allow the socket to be specified
2019-07-10 19:07:18 +01:00
Asim Aslam
7e0d4fe0cf
Merge branch 'master' of ssh://github.com/micro/go-micro
2019-07-10 19:01:38 +01:00
Asim Aslam
0a39fe39c3
Update tunnel to use id+session for the key
2019-07-10 19:01:24 +01:00
Milos Gajdos
163b917ec7
proto.EventType Insert is now Create to mirror table.Event
2019-07-10 18:37:46 +01:00
Asim Aslam
0f16eb2858
add further comments to tunnel
2019-07-10 18:35:10 +01:00
Asim Aslam
89231f701b
Add comments and session
2019-07-10 18:26:11 +01:00
Asim Aslam
196e76e350
Merge branch 'master' of ssh://github.com/micro/go-micro
2019-07-10 18:24:12 +01:00
Asim Aslam
f3d9177233
Add sessions to tunnel
2019-07-10 18:24:03 +01:00
Asim Aslam
8b7ac8a3f9
Merge pull request #576 from milosgajdos83/router-rpc
...
Added List and Watch rpc calls.
2019-07-10 17:55:23 +01:00
Milos Gajdos
8f5aed707e
Table.Add is now Table.Create. Insesrt event is now Create event.
2019-07-10 17:46:22 +01:00
Asim Aslam
c71576a538
Update link Id comment
2019-07-10 17:43:36 +01:00
Asim Aslam
27cfc06828
Cleanup and move around the link code
2019-07-10 17:42:41 +01:00
