unistack-org/micro-server-grpc
4
0
Fork 2
Code Issues 3 Pull Requests Actions Packages Projects Releases 48 Wiki Activity
188 Commits 5 Branches 49 Tags 1.5 MiB
41fbaf40ea
Commit Graph

188 Commits

This Branch
This Branch
All Branches
Author SHA1 Message Date
ben-toogood
f815eed7fd util/wrapper: Add Static Client wrapper (#1685) 
* util/wrapper: Add Static Client wrapper

* util/wrapper/static: pass address to stream too

* add static client wrapper tests

* server: fix error message spaces between words

* server/{rpc,grpc}: replace log.Error with log.Errorf

* server/grpc: fix log typo

* server/rpc: fix log typo

Co-authored-by: Vasiliy Tolstov <v.tolstov@unistack.org>
 2020-09-20 15:11:09 +03:00
Asim Aslam
8c937eabb9 Registration Retry / Interval (#1651) 
* Change the default ttl to 90 seconds

* add retries to registration

* Add retry to web register
 2020-09-20 15:11:09 +03:00
Ben Toogood
95ffd9ca4a Auth Options 2020-09-20 15:11:09 +03:00
Socket
eac461041a unsubscribe can async (#1596) 
Co-authored-by: huangshaojie <huangshaojie@corp.netease.com>
Co-authored-by: Asim Aslam <asim@aslam.me>
 2020-09-20 15:11:09 +03:00
Vasiliy Tolstov
19a313ac4e api/router: avoid unneeded loops and fix path match (#1594) 
* api/router: avoid unneeded loops and fix path match

* if match found in google api path syntax, not try pcre loop
* if path is not ending via $ sign, append it to pcre to avoid matching other strings like
  /api/account/register can be matched to /api/account
* api: add tests and validations

Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
 2020-09-20 15:11:09 +03:00
Asim Aslam
ac3ce1ec16 change logging for service startup 2020-09-20 15:11:09 +03:00
Vasiliy Tolstov
655bf08aca server: set registered only after configuring subscribers (#1557) 
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
 2020-09-20 15:11:09 +03:00
Vasiliy Tolstov
213359baed vendor proto files from google (#1536) 
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
 2020-09-20 15:11:09 +03:00
Vasiliy Tolstov
33e3df9bdb regenerate all proto based files (#1531) 
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
 2020-09-20 15:11:09 +03:00
Asim Aslam
25c4c7f7c4 fix typo 2020-09-20 15:11:09 +03:00
Vasiliy Tolstov
f349c7723f minimize allocations (#1472) 
* server: minimize allocations on re-register

Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>

* server: stop old instance before Init()

Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>

* client/grpc: fix allocations in protobuf marshal

Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>

* codec/json: fix allocations in protobuf marshal

Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>

* remove stop from init

Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>

* codec/grpc: expose MaxMessageSize

Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>

* codec: use buffer pool

Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>

* metadata: minimize reallocations

Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>

* util/wrapper: use metadata helper

Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>

* registry/cache: move logs to debug level

Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>

* server: move logs to debug level

Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>

* server: cache service only when Advertise is ip addr

Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>

* server: use metadata.Copy

Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
 2020-09-20 15:11:09 +03:00
Ben Toogood
f874f4cc97 Fix nil grpc server auth bug 2020-09-20 15:11:09 +03:00
Vasiliy Tolstov
015d4d6d64 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-09-20 15:11:09 +03:00
Vasiliy Tolstov
b7887155ba api: add static router and improve path parser in rpc handler (#1437) 
* api: add static router and improve path parser in rpc handler

Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>

* expose metadata context key to be able to get unmodified map keys

Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>

* server/grpc: fix jsonpb codec for protobuf msg

Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>

* api/handler/rpc: write 204 status code when rsp is nil

Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>

* api/handler/rpc: add check for nil response for non javascript

Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
 2020-09-20 15:11:09 +03:00
Asim Aslam
bf7cb081f4 fix server logging (#1417) 2020-09-20 15:11:09 +03:00
Vasiliy Tolstov
422f951014 grpc client/server fixes (#1355) 
* grpc client/server fixes

Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
 2020-09-20 15:11:09 +03:00
Vasiliy Tolstov
b722b4338b Revert "server/grpc: fix ordering of register and check for registered (#1338)" (#1341) 
This reverts commit 62a644ddd898a75a19b89106312c1cf58f4acd70.

Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
 2020-09-20 15:11:09 +03:00
Vasiliy Tolstov
d83b49c634 server/grpc: fix ordering of register and check for registered (#1338) 
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
 2020-09-20 15:11:09 +03:00
Vasiliy Tolstov
05b18c03dc minimize allocations in logger and tunnel code (#1323) 
* logs alloc

Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>

* fix allocs

Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>

* fix allocs

Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>

* tunnel allocs

Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>

* try to fix tunnel

Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>

* cache cipher for send

Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>

* more logger

Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>

* more logger

Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>

* more logger

Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>

* more logger

Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>

* more logger

Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>

* more logger

Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>

* more logger

Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
 2020-09-20 15:11:09 +03:00
Jake Sanders
b0164dca94 Comment typo in gRPC subscriber (#1304) 2020-09-20 15:11:09 +03:00
Vasiliy Tolstov
b48f919b7b server/grpc: avoid panic in case of nil Header (#1303) 
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
 2020-09-20 15:11:09 +03:00
Vasiliy Tolstov
6ebe79538a 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-09-20 15:11:09 +03:00
Vasiliy Tolstov
78d2884ced 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-09-20 15:11:09 +03:00
Vasiliy Tolstov
f727b75b6f server/grpc: add MaxConn option to limit max inflight requests (#1247) 
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
 2020-09-20 15:11:08 +03:00
Vasiliy Tolstov
28ef20ef4a prune util/log and user logger (#1237) 
* prune util/log and user logger

Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>

* plaintext logger

Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>

* add newline

Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
 2020-09-20 15:11:08 +03:00
Lars Lehtonen
cf4b4aecda server/grpc: Prune Unused Code (#1220) 
* server/grpc: remove unused grpcServer.newCodec()

* server/grpc: remove unused defaultRPCCodecs
 2020-09-20 15:11:08 +03:00
Vasiliy Tolstov
70cc7c93ef 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-09-20 15:11:08 +03:00
Asim Aslam
d89db33c07 add tls config to server (#1202) 
* add tls config

* add TLSConfig to acme provider
 2020-09-20 15:11:08 +03:00
Asim Aslam
471d2205bd accept Listen option in grpc server (#1201) 2020-09-20 15:11:08 +03:00
Vasiliy Tolstov
816bfec4a0 various fixes for broker and messaging in server (#1187) 
* provide broker disconnect messages in server

Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>

* broker/eats: another fix

Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
 2020-09-20 15:11:08 +03:00
Vasiliy Tolstov
e56b65ecce 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-09-20 15:11:08 +03:00
Vasiliy Tolstov
704e7e3e94 fix map race condition in grpc server 
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
 2020-09-20 15:11:08 +03:00
Vasiliy Tolstov
6b5eb3555b fix import paths for v2 release 
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
 2020-09-20 15:11:08 +03:00
Asim Aslam
e45a20a7f3 strip sub comments 2020-09-20 15:11:08 +03:00
Asim Aslam
3a1515040f only connect broker if there are subscribers 2020-09-20 15:11:08 +03:00
Asim Aslam
ab6334fad1 Add broker comments on server subscribe 2020-09-20 15:11:08 +03:00
Asim Aslam
df710d9efc hard stop if graceful stop fails after 1 second 2020-09-20 15:11:08 +03:00
Asim Aslam
256d79a47f do not wait to stop 2020-09-20 15:11:08 +03:00
Vasiliy Tolstov
08fe30da46 pass additional context for broker subscribe (#1105) 
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
 2020-09-20 15:11:08 +03:00
Asim Aslam
74e52bdb3e fix grpc json streaming by setting content sub type (#1089) 2020-09-20 15:11:08 +03:00
Asim Aslam
aa7d6aada3 fix log streaming 2020-09-20 15:11:08 +03:00
Asim Aslam
7e8f3ef103 don't panic on nil 2020-09-20 15:11:08 +03:00
Asim Aslam
c61072ccb9 Moving to gRPC by default (#1069) 
* Step 1

* Fix the test panics
 2020-09-20 15:11:08 +03:00
Astone
c1382ac0b7 named return value for error defer modify. 2020-09-20 15:11:08 +03:00
Milos Gajdos
83d0560d23 Fixing dead code and go vet moaning 2020-09-20 15:11:08 +03:00
Vasiliy Tolstov
e2e6425e65 linting fixes 
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
 2020-09-20 15:11:08 +03:00
Astone
e13e329abc improve code quality 2020-09-20 15:11:08 +03:00
Astone
4cba1b3ec9 optimize: a better way for return error 2020-09-20 15:11:08 +03:00
Vasiliy Tolstov
b78060a571 subscriber recovery 
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
 2020-09-20 15:11:08 +03:00
Asim Aslam
15b405b1a9 The mega cruft proxy PR (#974) 
* the mega cruft proxy PR

* Rename broker id

* add protocol=grpc

* fix compilation breaks

* Add the tunnel broker to the network

* fix broker id

* continue to be backwards compatible in the protocol
 2020-09-20 15:11:08 +03:00