fac75866d9
Move pool to util
2020-01-19 17:30:49 +00:00
c145f355dd
Moving to gRPC by default ( #1069 )
...
* Step 1
* Fix the test panics
2019-12-29 21:07:55 +00:00
c445aed6b1
Cleanup and speedup network convergence along with direct messaging for connect and solicit
2019-12-07 19:54:29 +00:00
29fb58db39
improve code quality
2019-12-03 20:59:02 +08:00
00bbb3ac61
revert some protocol changes for now
2019-11-30 21:20: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
afa1f50435
Revert to creating new connections for stream
2019-09-25 15:21:21 +01:00
52d9d75dfa
use with stream for client connection
2019-08-31 18:26:48 +01:00
4495ca3839
Use client.Call for non streaming requests
2019-08-16 17:24:17 +01:00
0b0eee41d0
functioning proxy code
2019-08-16 16:46:29 +01:00
58bc4c103f
go fmt
2019-08-15 20:54:09 +01:00
ef04331b86
multiplexing cruft
2019-08-15 20:08:49 +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
1db98ee0f0
move all the buffer references to util/buf
2019-07-28 19:33:24 +01:00
f2669e7b1e
Move connection pool to own package
2019-07-28 18:56:18 +01: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
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
e0bf1c2283
Remove Port from registry
2019-07-08 08:01:42 +01:00
4b4ad68eb9
Change Publication to Event
2019-07-07 12:44:09 +01:00
777a203f96
gofmt
2019-07-07 12:33:54 +01:00
d2d6841f02
Move transport to network/transport
2019-07-07 10:37:34 +01:00
0da8256426
Accept a range of addresses
2019-06-26 20:51:13 +01:00
1b4005e9a5
Go fmt everything
2019-06-21 17:20:41 +01:00
ca5acba0c6
Move selector to client/selector
2019-06-21 15:13:54 +01:00
ed4bce3285
check in this cruft
2019-06-08 19:40:44 +01:00
9e23855c37
Fixup the proxy, strip down go.mod. Win bigly
2019-06-07 13:42:39 +01:00
a86c26d485
fix bug need pass the variable as a parameter to the anonymous function
2019-05-31 14:24:37 +08:00
f824ba0779
non-blocking call chan when retries are 0
2019-04-18 09:05:22 +00:00
b8f20924cc
proxy publish
2019-02-23 17:06:17 +00:00
58adaef339
Add Exchange option
2019-02-23 10:50:53 +00:00
b1a31134bd
Support micro proxy
2019-01-30 18:42:11 +00:00
8090f9968d
Update headers to remove X- prefix
2019-01-24 10:11:02 +00:00
6468733d98
Use protocol from node metadata
2019-01-18 12:30:39 +00:00
c1d0237370
Add client response
2019-01-14 21:30:43 +00:00
9adebfcf1e
rename method to endpoint
2019-01-10 21:25:31 +00:00
40ff5b749b
Set topic header
2019-01-10 20:35:10 +00:00
648da5494f
Change a few things
2019-01-10 11:39:39 +00:00
4cb41721f1
further codec changes
2019-01-08 15:38:25 +00:00
d179c971af
Switch default codec and add default codec for server
2019-01-07 13:48:38 +00:00
b3b4bc6059
remove Plus
2018-12-31 20:51:22 +00:00
45c05c4e2b
Add timeout error
2018-11-25 09:41:28 +00:00
ef8b5e28b0
fix rpc client call WARNING: DATA RACE
2018-09-20 10:08:00 +08:00
446d3fc72e
fix bug: loop variable i captured by func literal
2018-09-19 21:58:20 +08:00
88505388c1
Add verbosity to errors
2018-07-26 09:33:50 +01:00
ac2106ced7
strip deadline from stream
2018-07-17 16:39:07 -07:00
1b4f7d8a68
a stream should not timeout
2018-07-17 16:32:35 -07:00
ba8582a47a
change retries to actually mean retries
2018-05-28 16:01:04 +01:00
541e894507
just update the pool configuration if the options changed, because recreating the pool,existed idleconnection, if any, will be dropped without closing
2018-05-26 15:38:41 +08:00
c3c0543733
add message options
2018-05-10 17:33:54 +01:00
