chore(workers): provide HTTP invoke timeout through env

Author: TimVosch

services/fission-rmq-connector/main.go

@@ -61,6 +61,7 @@ var (
 	HTTP_ENDPOINT = env.Must("HTTP_ENDPOINT")
 	MAX_RETRIES   = env.CouldInt("MAX_RETRIES", 3)
 	METRICS_ADDR  = env.Could("METRICS_ADDR", ":2112")
+	HTTP_TIMEOUT  = time.Duration(env.CouldInt("HTTP_TIMEOUT", 120)) * time.Second
 )
 
 func Run(cleanup cleanupper.Cleanupper) error {
@@ -119,7 +120,7 @@ func setupMetrics(cleanup cleanupper.Cleanupper) error {
 func buildProcessor(publish chan<- mq.PublishMessage) mq.ProcessorFuncBuilder {
 	return func() mq.ProcessorFunc {
 		client := &http.Client{
-			Timeout: 10 * time.Second,
+			Timeout: HTTP_TIMEOUT,
 		}
 		return func(incoming amqp091.Delivery) error {
 			opsReceived.Inc()

services/fission-user-workers/service/ctrl_k8s.go

@@ -310,6 +310,10 @@ func (ctrl *KubernetesController) workerToMessageQueueTrigger(worker UserWorker)
 									Name:  "EXCHANGE",
 									Value: ctrl.mqtExchange,
 								},
+								{
+									Name:  "HTTP_TIMEOUT",
+									Value: env.Could("CTRL_K8S_MQT_HTTP_TIMEOUT", ""),
+								},
 							},
 						},
 					},