fixup sync map
This commit is contained in:
parent
57853b2849
commit
b9a5e9d610
10
sync/map.go
10
sync/map.go
@ -8,8 +8,6 @@ import (
|
|||||||
"sort"
|
"sort"
|
||||||
|
|
||||||
"github.com/micro/go-micro/v2/store"
|
"github.com/micro/go-micro/v2/store"
|
||||||
ckv "github.com/micro/go-micro/v2/store/etcd"
|
|
||||||
lock "github.com/micro/go-micro/v2/sync/lock/etcd"
|
|
||||||
)
|
)
|
||||||
|
|
||||||
type syncMap struct {
|
type syncMap struct {
|
||||||
@ -152,14 +150,6 @@ func NewMap(opts ...Option) Map {
|
|||||||
o(&options)
|
o(&options)
|
||||||
}
|
}
|
||||||
|
|
||||||
if options.Lock == nil {
|
|
||||||
options.Lock = lock.NewLock()
|
|
||||||
}
|
|
||||||
|
|
||||||
if options.Store == nil {
|
|
||||||
options.Store = ckv.NewStore()
|
|
||||||
}
|
|
||||||
|
|
||||||
return &syncMap{
|
return &syncMap{
|
||||||
opts: options,
|
opts: options,
|
||||||
}
|
}
|
||||||
|
Loading…
x
Reference in New Issue
Block a user