[Issue kubernetes#28] Add timeout to the BackendConfig

This commits adds a new Connection section to the BackendConfig that
enables setting the timeout.

pkg/apis/backendconfig/v1beta1/types.go

@@ -39,6 +39,7 @@ type BackendConfigSpec struct {
 	Iap            *IAPConfig            `json:"iap,omitempty"`
 	Cdn            *CDNConfig            `json:"cdn,omitempty"`
 	SecurityPolicy *SecurityPolicyConfig `json:"securityPolicy,omitempty"`
+	Connection     *ConnectionConfig     `json:"connection,omitempty"`
 }
 
 // BackendConfigStatus is the status for a BackendConfig resource
@@ -107,3 +108,8 @@ type SecurityPolicyConfig struct {
 	// Name of the security policy that should be associated.
 	Name string `json:"name"`
 }
+
+// ConnectionConfig contains configuration the timeout for the backends.
+type ConnectionConfig struct {
+	Timeout int64 `json:"timeout,omitempty"`
+}

pkg/backends/syncer.go

@@ -107,6 +107,7 @@ func (s *backendSyncer) ensureBackendService(sp utils.ServicePort) error {
 	}
 
 	needUpdate := ensureProtocol(be, sp)
+	needUpdate = ensureTimeout(be, sp)
 	needUpdate = ensureHealthCheckLink(be, hcLink) || needUpdate
 	needUpdate = ensureDescription(be, &sp) || needUpdate
 	if s.backendConfigEnabled && sp.BackendConfig != nil {
@@ -203,6 +204,18 @@ func ensureProtocol(be *composite.BackendService, p utils.ServicePort) (needsUpd
 	return true
 }
 
+// ensureProtocol updates the BackendService Timeout with the expected value
+func ensureTimeout(be *composite.BackendService, p utils.ServicePort) (needsUpdate bool) {
+	if p.BackendConfig.Spec.Connection == nil {
+		return false
+	}
+	if be.TimeoutSec == p.BackendConfig.Spec.Connection.Timeout {
+		return false
+	}
+	be.TimeoutSec = p.BackendConfig.Spec.Connection.Timeout
+	return true
+}
+
 // ensureHealthCheckLink updates the BackendService HealthCheck with the expected value
 func ensureHealthCheckLink(be *composite.BackendService, hcLink string) (needsUpdate bool) {
 	existingHCLink := getHealthCheckLink(be)