bd70820b6b
ServicePrivileges => ServiceToken
2020-03-31 13:48:28 +01:00
956029ae3d
Fixes for CLI login
2020-03-31 13:30:14 +01:00
e0c7f48d20
WithServicePrivileges => ServicePrivileges
2020-03-31 12:57:38 +01:00
d659e435c6
Service => Service Auth
2020-03-31 12:44:34 +01:00
9e6db79860
regenerate all proto ( #1440 )
...
* regenerate all proto
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org >
* regenerate from proto
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org >
* regenerate from proto
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org >
2020-03-30 21:58:32 +01:00
8282e781e4
grpc pool should check state ( #1435 )
...
Co-authored-by: huangshaojie <huangshaojie@corp.netease.com >
2020-03-28 08:48:25 +00:00
1057ef6acb
Add ContextWithToken ( #1407 )
...
* Add ContextWithToken
* Tidying up BearerScheme
Co-authored-by: Ben Toogood <ben@micro.mu >
2020-03-25 11:20:53 +00:00
d559587807
client/grpc: remove json-iterator usage ( #1387 )
...
* minimize external deps and binary size
* if user wants json-iterator codec it must be used in server and
client code. so best to use it via go-plugins
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org >
2020-03-21 09:40:58 +00:00
ab73127063
grpc client/server fixes ( #1355 )
...
Run tests / Test repo (push) Has been cancelled
* grpc client/server fixes
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org >
2020-03-17 14:27:20 +03:00
ac333d9d47
client/grpc: unwrap error after call ( #1352 )
...
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org >
2020-03-16 13:33:38 +03:00
d91c14eb30
grpc client error fix ( #1351 )
...
Co-authored-by: Ben Toogood <ben@micro.mu >
2020-03-16 12:53:15 +03:00
48b2a5c37c
Fix Auth Headers ( #1324 )
...
Co-authored-by: Ben Toogood <ben@micro.mu >
2020-03-10 16:47:01 +00:00
ed83c27f0e
add websocket streaming to api rpc handler ( #1326 )
2020-03-10 15:21:43 +00:00
962567ef42
Implement config singleton ( #1268 )
...
* Implement config singleton
* Pass token in grpc request headers
* Refactor BearerScheme
* Fix typo
2020-02-28 12:58:27 +00:00
64a5ce9607
various fixes ( #1267 )
...
* logger: remove Panic log level
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org >
* server/grpc: add missing Unlock in Subscribe error
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org >
* server: minor code change
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org >
* server/grpc: extend test suite with pub/sub testing
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org >
* server/grpc: fix invalid check and allow subscriber error to be returned
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org >
* server/grpc: add pubsub tests
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org >
* client/grpc: check for nil req/rsp
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org >
2020-02-26 18:34:40 +00:00
6aaaf54275
add MICRO_AUTH_TOKEN, parse token in wrapper, preload config and othe… ( #1261 )
...
* add MICRO_AUTH_TOKEN, parse token in wrapper, preload config and other things
* fix wrapper panic
2020-02-25 22:15:44 +00:00
ffdf986aac
Refactor auth: add token and store implementations ( #1230 )
...
* Refactor auth: add token and memory implementations
* Fix typo
* Remove memory auth (implemented already by the store implementation), revert default to noop
* Add grpc header
* Global Config
* config/global => util/config
* Rename package to remove confict
* Tweak
* Improve Error Handling
2020-02-24 15:07:27 +00:00
5b0175c2e5
allocations improvements and tunnel fixes ( #1248 )
...
* reduce allocations in tunnel code
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org >
* another allocation fix
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org >
* allocate maps with len if it known
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org >
* allocate key for send once
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org >
2020-02-24 14:15:20 +00:00
f4118dc357
secure the grpc client ( #1215 )
...
* secure the grpc client
* make compile
* Add system cert pool
* Revert manually adding ca certs
* Tweak comment
Co-authored-by: ben-toogood <bentoogood@gmail.com >
2020-02-19 08:44:35 +00:00
58598d0fe0
fixes for safe conversation and avoid panics ( #1213 )
...
* fixes for safe convertation
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org >
* fix client publish panic
If broker connect returns error we dont check it status and use
it later to publish message, mostly this is unexpected because
broker connection failed and we cant use it.
Also proposed solution have benefit - we flag connection status
only when we have succeseful broker connection
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org >
* api/handler/broker: fix possible broker publish panic
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org >
2020-02-18 23:05:38 +00:00
6248f05f74
add missing option to client.NewMessage ( #1212 )
...
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org >
2020-02-18 14:18:59 +03:00
1e40c86dfe
Ignore gRPC Proxy ( #1205 )
2020-02-17 08:14:45 +00:00
b3fc8be24e
normalise proxy name ( #1203 )
2020-02-15 21:57:30 +00:00
c691d116ab
when the stream errors cleanup the connection ( #1199 )
2020-02-15 11:35:08 +00:00
d9b3b17582
set dial timeout in stream
2020-02-13 18:51:32 +00:00
6dc942bc19
client/grpc: fix panic on invalid message ( #1191 )
...
* client/grpc: fix panic on invalid message
* travis: disable lint and race for now
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org >
2020-02-13 14:57:21 +03:00
99807a680c
strip Micro-Topic header from incoming context in client.Call ( #1177 )
...
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org >
2020-02-07 22:09:52 +00:00
7105e4099c
pass micro errors from grpc server to grpc client ( #1167 )
...
* pass micro errors from grpc server to grpc client
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org >
* wrap micro errors.Error to grpc status
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org >
2020-02-06 10:18:33 +00:00
a44dc90d45
fix ctx.Done issue #720 ( #1166 )
...
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org >
2020-02-05 21:13:14 +00:00
449bcb46fe
New backoff ( #1153 )
...
* new backoff function
* use backoff from util/backoff
* remove reset atemts
* change comment
* fmt
2020-02-02 20:32:55 +00:00
87753ad289
format results in TestBacloff
2020-01-30 20:08:03 +03:00
ffb9da0230
fix test and description
2020-01-30 19:43:03 +03:00
f6fcfcb8fc
exponentialBackoff was changed from power function to exponential function
2020-01-30 17:25:07 +03:00
f23638c036
fix import paths for v2 release
...
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org >
2020-01-30 14:44:40 +03:00
2b1844971c
go fmt
2020-01-24 21:31:57 +00:00
9df19e826e
cancel stream
2020-01-19 22:53:56 +00:00
54fb61bba4
Move proto to service/
2020-01-19 17:31:24 +00:00
fac75866d9
Move pool to util
2020-01-19 17:30:49 +00:00
a47ff65529
remove mock client
2020-01-19 17:24:22 +00:00
0a37767127
Fix service registration with registry service
2020-01-18 19:53:51 +00:00
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
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
0b8ff3a8bb
fix grpc json streaming by setting content sub type ( #1089 )
2020-01-07 18:37:34 +00:00
45c986c5f1
don't marshal frame values
2019-12-31 21:36:22 +00:00
c145f355dd
Moving to gRPC by default ( #1069 )
...
* Step 1
* Fix the test panics
2019-12-29 21:07:55 +00:00
22aa7d14b3
support streams pool for grpc ( #1062 )
...
* Update grpc_pool.go
* Update options.go
* Update grpc.go
* Update grpc_pool_test.go
* streams pool for grpc
* use busy list to speed up allocate while pool is very busy
* fix idle bug
2019-12-27 12:25:58 +00:00
d5951f1d7c
Merge pull request #1042 from ZGeomantic/feat-client-mock
...
support ctx as input params, error as output for MockClient.Call
2019-12-15 15:12:17 +00:00
572fe58314
comment
2019-12-15 15:05:19 +08:00
5602b93d7a
support ctx as input params, error as output for MockClient.Call
2019-12-14 10:36:12 +08:00
d50f30d743
strip handlers
2019-12-10 11:46:13 +00:00
Ben Toogood