diff --git a/cluster/router/local/factory.go b/cluster/router/local/factory.go index 73864c8dacbd8e029e471856cd50505aae931ad4..42e03e25abdfa4c04851bddd7f57434d4c03a112 100644 --- a/cluster/router/local/factory.go +++ b/cluster/router/local/factory.go @@ -38,6 +38,6 @@ func newLocalPriorityRouteFactory() router.PriorityRouterFactory { } // NewPriorityRouter construct a new NewLocalDiscRouter via url -func (f *LocalPriorityRouteFactory) NewPriorityRouter(url *common.URL) (router.PriorityRouter, error) { +func (f *LocalPriorityRouteFactory) NewPriorityRouter(url *common.URL, notify chan struct{}) (router.PriorityRouter, error) { return NewLocalPriorityRouter(url) } diff --git a/config/graceful_shutdown_config_test.go b/config/graceful_shutdown_config_test.go index 80eb5317386f4e9d966f7a9f07635a810727d77c..43d2fc3c1bfdabf618ca07c696a0bc1d1018aa42 100644 --- a/config/graceful_shutdown_config_test.go +++ b/config/graceful_shutdown_config_test.go @@ -32,8 +32,8 @@ func TestShutdownConfigGetTimeout(t *testing.T) { assert.False(t, config.RequestsFinished) config = ShutdownConfig{ - Timeout: "12x", - StepTimeout: "34a", + Timeout: "60s", + StepTimeout: "10s", } assert.Equal(t, 60*time.Second, config.GetTimeout())