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

154 Commits

This Branch
This Branch
All Branches
Author SHA1 Message Date
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
Vasiliy Tolstov
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
Asim Aslam
f34326e4d7 fix endpoint extractor panic 2020-09-20 15:11:08 +03:00
Till Knuesting
592f1fb218 preallocated slices (#934) 2020-09-20 15:11:08 +03:00
Asim Aslam
f867969aa3 Don't set stream unless its true 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
Asim Aslam
4a4159a9f6 Force grpc client/server to use grpc codec for broker 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
846593c2c3 Don't extract repeated value 2020-09-20 15:11:08 +03:00
Asim Aslam
35364b037b fix broker log line 2020-09-20 15:11:08 +03:00
Asim Aslam
a1154590f2 Strip the verbosity of the debug handler 2020-09-20 15:11:08 +03:00
Asim Aslam
7d6efd8a74 move all the buffer references to util/buf 2020-09-20 15:11:08 +03:00
Vasiliy Tolstov
c0e32da83e bunch of other ipv6 fixes 
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
 2020-09-20 15:11:08 +03:00
Vasiliy Tolstov
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
596c435086 Fix breaks and go fmt 2020-09-20 15:11:08 +03:00
Asim Aslam
b6dd5a84c7 move transport back 2020-09-20 15:11:08 +03:00
Asim Aslam
df9fa0c938 Remove Port from registry 2020-09-20 15:11:08 +03:00
Joe
dfffa16590 grpc: using jsonpb.Marshaler to do Marshal, map to jsonpb.Unmarsh 2020-09-20 15:11:08 +03:00
Asim Aslam
5cedaef171 Change Publication to Event 2020-09-20 15:11:08 +03:00
Asim Aslam
d631074eff gofmt 2020-09-20 15:11:08 +03:00
Asim Aslam
b3f501e789 strip broker address 2020-09-20 15:11:08 +03:00
Asim Aslam
246f5c3dd5 Move transport to network/transport 2020-09-20 15:11:08 +03:00
Vasiliy Tolstov
f60b239b67 codec grpc: fix extra allocations on message unmarshal 
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
 2020-09-20 15:11:08 +03:00
Joe
d4d579bd5a if unmarshal target is proto.Message, using jsonpb 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
johnson
6f50ba3575 a. add default context type when header not found 
b. return subscribe error after handler finished
 2020-09-20 15:11:08 +03:00
johnson
6d0872a1df missing nil check for grpc WaitGroup 2020-09-20 15:11:08 +03:00