[core] Reduce integration plugin dial timeouts

Author: teo

core/integration/dcs/plugin.go

@@ -43,7 +43,7 @@ import (
 	"google.golang.org/grpc/connectivity"
 )
 
-const DCS_CALL_TIMEOUT = 10 * time.Second
+const DCS_DIAL_TIMEOUT = 2 * time.Second
 
 type Plugin struct {
 	dcsHost        string
@@ -76,7 +76,7 @@ func (p *Plugin) GetName() string {
 
 func (p *Plugin) Init(instanceId string) error {
 	if p.dcsClient == nil {
-		callTimeout := DCS_CALL_TIMEOUT
+		callTimeout := DCS_DIAL_TIMEOUT
 		cxt, cancel := context.WithTimeout(context.Background(), callTimeout)
 		p.dcsClient = NewClient(cxt, cancel, viper.GetString("dcsServiceEndpoint"))
 		if p.dcsClient == nil {

core/integration/ddsched/plugin.go

@@ -43,7 +43,7 @@ import (
 	"google.golang.org/grpc/connectivity"
 )
 
-const DDSCHED_CALL_TIMEOUT = 10 * time.Second
+const DDSCHED_DIAL_TIMEOUT = 2 * time.Second
 
 
 type Plugin struct {
@@ -82,7 +82,7 @@ func (p *Plugin) GetName() string {
 
 func (p *Plugin) Init(_ string) error {
 	if p.ddSchedClient == nil {
-		callTimeout := DDSCHED_CALL_TIMEOUT
+		callTimeout := DDSCHED_DIAL_TIMEOUT
 		cxt, cancel := context.WithTimeout(context.Background(), callTimeout)
 		p.ddSchedClient = NewClient(cxt, cancel, viper.GetString("ddSchedulerEndpoint"))
 		if p.ddSchedClient == nil {

core/integration/odc/plugin.go

@@ -39,7 +39,7 @@ import (
 	"github.com/spf13/viper"
 )
 
-const ODC_CALL_TIMEOUT = 10 * time.Second
+const ODC_DIAL_TIMEOUT = 2 * time.Second
 
 
 type Plugin struct {
@@ -73,7 +73,7 @@ func (p *Plugin) GetName() string {
 
 func (p *Plugin) Init(_ string) error {
 	if p.odcClient == nil {
-		callTimeout := ODC_CALL_TIMEOUT
+		callTimeout := ODC_DIAL_TIMEOUT
 		cxt, cancel := context.WithTimeout(context.Background(), callTimeout)
 		p.odcClient = NewClient(cxt, cancel, viper.GetString("odcEndpoint"))
 		if p.odcClient == nil {