Cockroach Store bugfix (#1401)
This commit is contained in:
parent
eb4d2ae6aa
commit
397a8638f4
@ -616,7 +616,7 @@ func (c *cmd) Before(ctx *cli.Context) error {
|
||||
}
|
||||
|
||||
if len(ctx.String("store_namespace")) > 0 {
|
||||
if err := (*c.opts.Store).Init(store.Namespace(ctx.String("store_address"))); err != nil {
|
||||
if err := (*c.opts.Store).Init(store.Namespace(ctx.String("store_namespace"))); err != nil {
|
||||
logger.Fatalf("Error configuring store: %v", err)
|
||||
}
|
||||
}
|
||||
|
@ -10,7 +10,6 @@ import (
|
||||
"time"
|
||||
|
||||
"github.com/lib/pq"
|
||||
"github.com/micro/go-micro/v2/logger"
|
||||
"github.com/micro/go-micro/v2/store"
|
||||
"github.com/pkg/errors"
|
||||
)
|
||||
@ -370,10 +369,8 @@ func NewStore(opts ...store.Option) store.Store {
|
||||
// set the options
|
||||
s.options = options
|
||||
|
||||
// configure the store
|
||||
if err := s.configure(); err != nil {
|
||||
logger.Fatal(err)
|
||||
}
|
||||
// best-effort configure the store
|
||||
s.configure()
|
||||
|
||||
// return store
|
||||
return s
|
||||
|
Loading…
Reference in New Issue
Block a user