a725998c0a
Update rpc_server.go
2019-09-27 16:01:16 +02:00
f3b723ca44
Do nog log error when EOS is being written on an EOF socket
2019-09-27 15:02:21 +02:00
fa0d020556
Set register ttl and interval by default
2019-09-23 17:59:34 +01:00
ac5eb5da47
Remove fmt
2019-09-22 15:31:07 +01:00
2434c7b2a7
replace version format
2019-09-22 15:21:22 +01:00
c1c173dfe5
recover handler if panic
2019-09-11 00:40:40 +08:00
6daf4fda72
Full support for grpc server side
2019-08-26 12:33:59 +01:00
36623bfe50
Improve stream processing
2019-08-25 19:30:22 +01:00
6128d18ee0
checkpoint fixing data race to process h2 and grpc requests
2019-08-24 20:12:04 +01:00
ba99f037fb
Lock started flag when changing it.
2019-08-23 15:07:08 +01:00
80dc0b97a9
Make server starts and stops idempotent
2019-08-23 15:00:57 +01:00
c6e15ef2d1
rename server, set version to timestamp
2019-08-21 15:43:46 +01:00
f1d08f251f
fix panic: negative WaitGroup counter
...
avoid double wait group Done()
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org >
2019-08-19 13:58:57 +03:00
c44fd63301
Force grpc client/server to use grpc codec for broker
2019-08-18 11:28:21 +01:00
991142cd57
No need to set request in the buffer
2019-08-16 14:42:45 +01:00
88817dc53f
Strip some dead code
2019-08-15 20:54:00 +01:00
ef04331b86
multiplexing cruft
2019-08-15 20:08:49 +01:00
f6b8045dd5
send client error if it exists
2019-08-15 15:22:53 +01:00
a42de29f67
Do same for host port on deregister
2019-08-15 08:59:50 +01:00
bf0e46dc0d
fix registry addr error for mq-rpc
2019-08-14 21:32:28 +08:00
d0d729a789
fix the tunnel execution
2019-08-11 18:11:33 +01:00
de34f259ba
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(`
---
a: 1234
`)
func main() {
memorySource := memory.NewSource(
memory.WithYAML(configData),
)
// Create new config
conf := config.NewConfig()
// Load file source
conf.Load(memorySource)
fmt.Println(string(conf.Bytes()))
}
2019-08-11 19:31:22 +08:00
3adce58eb2
Add monitor/debug packages
2019-08-06 17:53:14 +01:00
bb01b3ed78
Don't extract repeated value
2019-08-06 14:52:15 +01:00
c3ea25225c
Don't check value name on extraction
2019-08-06 14:49:42 +01:00
beffa625f8
fix broker log line
2019-08-06 12:25:51 +01:00
7884e889f4
Don't publish the process rpc call and embed the router handler in the network
2019-07-31 16:36:53 +01:00
a63dcda003
Strip the verbosity of the debug handler
2019-07-28 19:43:50 +01:00
1db98ee0f0
move all the buffer references to util/buf
2019-07-28 19:33:24 +01:00
1217ca94b1
bunch of other ipv6 fixes
...
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org >
2019-07-18 08:59:53 +03:00
e688ab0a45
fix ipv6 addr parsing and using
...
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org >
2019-07-17 12:20:29 +03:00
a3bddf5839
changes to minimize allocations and provide useful info
...
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org >
2019-07-17 00:21:03 +03:00
c5dd737568
Add back in broker address
2019-07-10 19:58:30 +01:00
64ec0633a3
Fix breaks and go fmt
2019-07-10 07:47:17 +01:00
0bf54c122f
move transport back
2019-07-09 18:41:26 +01:00
5cd1e81ba9
Merge pull request #570 from sunfuze/grpc-json-marshal
...
grpc: using jsonpb.Marshaler to do Marshal, map to jsonpb.Unmarsh
2019-07-08 08:44:51 +01:00
e0bf1c2283
Remove Port from registry
2019-07-08 08:01:42 +01:00
b655f7f55a
grpc: using jsonpb.Marshaler to do Marshal, map to jsonpb.Unmarsh
2019-07-08 10:32:10 +08:00
4b4ad68eb9
Change Publication to Event
2019-07-07 12:44:09 +01:00
777a203f96
gofmt
2019-07-07 12:33:54 +01:00
c1097a4509
strip broker address
2019-07-07 12:33:47 +01:00
d2d6841f02
Move transport to network/transport
2019-07-07 10:37:34 +01:00
e40307c567
codec grpc: fix extra allocations on message unmarshal
...
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org >
2019-07-04 14:06:29 +03:00
e88041dc26
if unmarshal target is proto.Message, using jsonpb
2019-07-04 16:43:36 +08:00
d8e998ad85
add peer in context
2019-06-27 14:53:01 +01:00
9630e153a5
fix grpc proto wrapper
2019-06-27 13:08:06 +01:00
8d5d812e32
Fix a streaming bug
2019-06-20 12:44:51 +01:00
d3a6297b17
Add working grpc proxy config
2019-06-18 18:51:52 +01:00
f65694670e
add cruft
2019-06-17 20:05:58 +01:00
baaa386e27
a. add default context type when header not found
...
b. return subscribe error after handler finished
2019-06-17 17:54:37 +08:00
