Commit Graph

95 Commits

Author SHA1 Message Date
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
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
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
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
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
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
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
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
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
c61072ccb9 Moving to gRPC by default (#1069)
* Step 1

* Fix the test panics
2020-09-20 15:11:08 +03:00
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
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
d0222ee239 return error to caller on grpc server request processing (#962)
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
2020-09-20 15:11:08 +03:00
Till Knuesting
592f1fb218 preallocated slices (#934) 2020-09-20 15:11:08 +03:00
Yang Shi
5cc92860a6 improve the log of panic recovering (#906) 2020-09-20 15:11:08 +03:00
tegk
a5978b5470 used gofmt with -s flag on whole project 2020-09-20 15:11:08 +03:00
Shu Xian
94f5ccf378 recover handler if panic 2020-09-20 15:11:08 +03:00
Milos Gajdos
a037094a31 Lock started flag when changing it. 2020-09-20 15:11:08 +03:00
Milos Gajdos
65733b8268 Make server starts and stops idempotent 2020-09-20 15:11:08 +03:00
johnson
f9dcbb71be update service not found error tooltip
fixing test failed issue

change back error type
change registry.ErrNotFound back to selector.ErrNotFound

change back error type
change registry.ErrNotFound back to selector.ErrNotFound

remove the single node tunnel test

Fix read yaml config from memory

package main

import (
	"fmt"

	"github.com/micro/go-micro/config"
	"github.com/micro/go-micro/config/source/memory"
)

var configData = []byte(`
2020-09-20 15:11:08 +03:00
Asim Aslam
b7ee22d993 Add monitor/debug packages 2020-09-20 15:11:08 +03:00
Asim Aslam
35364b037b fix broker log line 2020-09-20 15:11:08 +03:00
c0e32da83e bunch of other ipv6 fixes
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
2020-09-20 15:11:08 +03:00
5aad839816 fix ipv6 addr parsing and using
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
2020-09-20 15:11:08 +03:00
Asim Aslam
df9fa0c938 Remove Port from registry 2020-09-20 15:11:08 +03:00
Asim Aslam
b3f501e789 strip broker address 2020-09-20 15:11:08 +03:00
Asim Aslam
5a7113b669 add peer in context 2020-09-20 15:11:08 +03:00
Asim Aslam
d09a33b43c fix grpc proto wrapper 2020-09-20 15:11:08 +03:00
Asim Aslam
4651f11492 Add working grpc proxy config 2020-09-20 15:11:08 +03:00
Asim Aslam
ac860f37e2 add cruft 2020-09-20 15:11:08 +03:00
Asim Aslam
0635d2c2ca check in this cruft 2020-09-20 15:11:08 +03:00
Asim Aslam
eaae419939 strip use of cmd 2020-09-20 15:11:08 +03:00
Asim Aslam
8a3538eb77 Further consolidate the libraries 2020-09-20 15:11:08 +03:00