bf0e46dc0d
fix registry addr error for mq-rpc
2019-08-14 21:32:28 +08: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
edb0fe4b16
fix the consul setup code
2019-08-06 19:43:46 +01:00
e16420fdbd
Consul config fix https://github.com/micro/go-micro/pull/641
2019-08-06 09:15:38 +01:00
b806e7bdf5
Stop a goroutine leak in registy
2019-08-01 23:03:11 +01:00
c108188d65
Preallocate nodes slice in addNodes before populating it
2019-07-15 14:47:33 +01:00
609934ce99
Preallocate slices; avoide append() reallocations when copying data
2019-07-15 11:13:58 +01:00
1f744b31a4
Return the dead node when deleting the service
2019-07-10 21:03:53 +01:00
e0bf1c2283
Remove Port from registry
2019-07-08 08:01:42 +01:00
a412486c39
Update registry util semantics
2019-07-04 11:36:49 +01:00
0e34c572b4
export registry util function to safe copy registry data
...
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org >
2019-07-04 11:39:43 +03:00
f6e064cdbd
Fixed router idempotency. Return registry.ErrWatchStopped from mdns reg
2019-07-01 15:46:26 +01:00
c3d2043caf
Reverts c0a628d65b
...
Fixes #540
2019-06-22 19:01:03 +01:00
c0a628d65b
Simplified delService code; properly delete service nodes
2019-06-18 21:39:00 +01:00
7266c62d09
remove comment
2019-06-18 15:33:31 +01:00
6459cdfc21
propagate updates to local watchers
2019-06-18 14:42:56 +01:00
ab692ff590
remove mock data from memory registry
...
memory registry can be used as fast inprocess registry,
so mock data needs to be in tests only
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org >
2019-06-13 00:51:56 +03:00
73b0a0ed0e
Return registry.ErrWatcherStopped when consul watcher stops.
...
The original code returns "result chan closed" errors.Error which does
not carry higher semantics signal to downstream despite go-micro having
a clearly defined Error for this behaviour. This commit fixes that and
lets the downstream i.e. consumer of this code to act based on different
errors.
2019-06-09 15:51:27 +01:00
4035ab5c7b
Change go-log links
2019-05-31 00:38:05 +01:00
a353c83f47
Add rcache => cache
2019-05-31 00:22:43 +01:00
389d141c5a
Use existing consul client for watcher
2019-05-16 12:37:48 +10:00
58775249c5
fix race with rcache
...
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org >
2019-05-09 23:02:32 +03:00
1a151a3348
fix data races in gossip registry
...
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org >
2019-05-09 22:32:21 +03:00
afd1f9f50f
Update consul/watch import
...
The watch package was moved from github.com/hashicorp/consul/watch to github.com/hashicorp/consul/api/watch to live in the API module.
Per: https://github.com/hashicorp/consul/commit/6c885d383a7f303cc6c625108d3e7fc1a35d715d
2019-04-26 10:40:10 -07:00
df6561165a
gofmt
2019-04-23 07:13:21 +00:00
d3f447a732
solve NewRegistry httpclient 'nil pointer dereference' bug
2019-02-28 09:56:57 +08:00
f4be7d018d
delete context file
2019-02-13 14:39:38 +00:00
7cb466359f
rework gossip registry
2019-02-13 14:39:20 +00:00
f961c571bd
registry: [gossip] fix panic
...
panic: runtime error: invalid memory address or nil pointer dereference
[signal SIGSEGV: segmentation violation code=0x1 addr=0x88 pc=0xd1b215]
goroutine 8 [running]:
sync.(*RWMutex).RLock(...)
/var/home/vtolstov/sdk/go1.12beta2/src/sync/rwmutex.go:48
github.com/hashicorp/memberlist.(*Memberlist).LocalNode(0x0, 0x0)
/home/vtolstov/devel/projects/centralv2/vendor/github.com/hashicorp/memberlist/memberlist.go:417 +0x35
github.com/micro/go-micro/registry/gossip.(*gossipRegistry).run.func3(0xc000155880)
/home/vtolstov/devel/projects/centralv2/vendor/github.com/micro/go-micro/registry/gossip/gossip.go:565 +0xf5
created by github.com/micro/go-micro/registry/gossip.(*gossipRegistry).run
/home/vtolstov/devel/projects/centralv2/vendor/github.com/micro/go-micro/registry/gossip/gossip.go:553 +0xa25
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org >
2019-02-13 16:36:38 +03:00
36532c94b2
registry: [gossip] add ConnectRetry and ConnectTimeout
...
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org >
2019-02-12 17:16:35 +03:00
422e2002a0
registry: gossip unify registry option passing, optimize
...
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org >
2019-02-02 01:12:39 +03:00
cead99ac44
fix nil pointer
2019-02-01 16:01:51 +00:00
88e12347d0
update mdns to remove race condition
2019-02-01 13:41:11 +00:00
652b1067f5
fix data race
2019-02-01 09:05:03 +00:00
48b80dd051
replace memory registry
2019-01-18 17:29:17 +00:00
7314af347b
Set MDNS as default registry
2019-01-15 16:50:37 +00:00
39c24baca9
rename mock things to memory
2019-01-14 15:27:25 +00:00
bb31480f1a
downgrade code generated stuff
2019-01-10 10:57:04 +00:00
eec1726f1d
add package comment
2019-01-09 16:31:23 +08:00
453ce2fcbe
add locker
2019-01-09 14:24:12 +08:00
5cae330732
Update selector race, rename cache selector
2018-12-29 15:44:51 +00:00
8b54a850f7
run gossip updater first
2018-12-19 19:04:44 +00:00
fae8c5eb4c
fix context
2018-12-19 09:27:53 +00:00
5bcdf189de
implement some gossip options
...
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org >
2018-12-19 12:25:16 +03:00
b02e1e04fc
Add gossip readme
2018-12-06 18:26:51 +00:00
cf8c059711
Merge pull request #345 from micro/gossip
...
Gossip
2018-12-06 18:22:52 +00:00
b343420af6
update the gossiper
2018-12-06 18:19:05 +00:00
1ed2b589a2
log to dev null
2018-12-04 17:33:11 +00:00
72d8dc89fb
add cmd and bug fix
2018-12-04 17:22:20 +00:00
8706aa4a46
Remove file
2018-12-04 16:43:05 +00:00
Shu Xian