|
@@ -369,7 +369,7 @@ func NewServer(cfg ServerConfig) (srv *EtcdServer, err error) {
|
|
|
}
|
|
}
|
|
|
if cfg.ShouldDiscover() {
|
|
if cfg.ShouldDiscover() {
|
|
|
var str string
|
|
var str string
|
|
|
- str, err = discovery.JoinCluster(cfg.DiscoveryURL, cfg.DiscoveryProxy, m.ID, cfg.InitialPeerURLsMap.String())
|
|
|
|
|
|
|
+ str, err = discovery.JoinCluster(cfg.Logger, cfg.DiscoveryURL, cfg.DiscoveryProxy, m.ID, cfg.InitialPeerURLsMap.String())
|
|
|
if err != nil {
|
|
if err != nil {
|
|
|
return nil, &DiscoveryError{Op: "join", Err: err}
|
|
return nil, &DiscoveryError{Op: "join", Err: err}
|
|
|
}
|
|
}
|
|
@@ -562,7 +562,7 @@ func NewServer(cfg ServerConfig) (srv *EtcdServer, err error) {
|
|
|
}
|
|
}
|
|
|
srv.authStore = auth.NewAuthStore(srv.be, tp)
|
|
srv.authStore = auth.NewAuthStore(srv.be, tp)
|
|
|
if num := cfg.AutoCompactionRetention; num != 0 {
|
|
if num := cfg.AutoCompactionRetention; num != 0 {
|
|
|
- srv.compactor, err = compactor.New(cfg.AutoCompactionMode, num, srv.kv, srv)
|
|
|
|
|
|
|
+ srv.compactor, err = compactor.New(cfg.Logger, cfg.AutoCompactionMode, num, srv.kv, srv)
|
|
|
if err != nil {
|
|
if err != nil {
|
|
|
return nil, err
|
|
return nil, err
|
|
|
}
|
|
}
|