29fb58db39
improve code quality
2019-12-03 20:59:02 +08:00
f9b900b2ca
optimize: a better way for return error
2019-12-03 12:47:29 +08:00
b8e96f45d4
add recovery in case of panics
...
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org >
2019-12-03 02:25:40 +03:00
af94899b54
Fix rpc go routine leak
2019-11-27 17:12:07 +00:00
5932dd753c
Merge pull request #981 from unistack-org/subscriber
...
subscriber recovery
2019-11-27 10:28:51 +00:00
86a6328254
subscriber recovery
...
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org >
2019-11-27 13:21:20 +03:00
8b63df7a98
regenerate the protos
2019-11-26 13:53:33 +00:00
080363e8c4
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
2019-11-25 16:31:43 +00:00
49d73faa5f
return error to caller on grpc server request processing ( #962 )
...
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org >
2019-11-20 10:28:30 +00:00
da6c1be607
dont panic on missing headers in broker event ( #963 )
...
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org >
2019-11-20 07:55:47 +00:00
9f481542f3
Fix a codec race by locking the buffers. Include a buffer pool for perf. ( #941 )
...
* Fix a codec race by locking the buffers. Include a buffer pool for perf.
* Read Lock on buffer Read
2019-11-13 11:05:53 +00:00
72522a869a
fix endpoint extractor panic
2019-11-11 17:37:48 +00:00
5ae3e179b9
preallocated slices ( #934 )
2019-11-11 00:03:51 +00:00
c696a859be
fix data race for server Wait option ( #931 )
...
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org >
2019-11-09 21:52:41 +00:00
a9e8fc6039
Don't set stream unless its true
2019-11-09 10:32:52 +00:00
f67c5e779f
preallocated slices ( #917 )
2019-11-05 17:43:12 +00:00
c14bf5dc4e
improve the log of panic recovering ( #906 )
2019-11-02 23:08:54 +00:00
f88518d994
used gofmt with -s flag on whole project
2019-11-01 15:07:53 +00:00
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
Astone