elevator timeout example

WEG-Technology · Mar 3, 2024 · 1fd29be · 1fd29be
1 parent f53a716
commit 1fd29be
Show file tree

Hide file tree

Showing 3 changed files with 7 additions and 2 deletions.
diff --git a/elevator/elevator.go b/elevator/elevator.go
@@ -7,6 +7,7 @@ import (
 	"gopkg.in/yaml.v3"
 	"os"
 	"sync"
+	"time"
 )
 
 func readYml(path string) ([]byte, error) {
@@ -115,6 +116,7 @@ func (e *ElevatorEngine) WarmUp() IElevatorEngine {
 		c, err := room.NewConnection(
 			room.WithBaseUrl(r.Connection.BaseURL),
 			room.WithDefaultHeader(room.NewHeader(room.NewMapStore(r.Connection.Headers))),
+			room.WithTimeout(time.Duration(r.Connection.Timeout)*time.Second),
 		)
 
 		if err != nil {

diff --git a/examples/yml_concurrent_example/integration.yml b/examples/yml_concurrent_example/integration.yml
@@ -15,15 +15,15 @@ flat:
     todo1Room:
       connection:
         baseUrl: ${BASE_URL}
-        timeout: 15
+        timeout: 1 # this request will timeout
         headers:
           Content-Type: "application/json"
           X-Type: "TODO - 2"
       requests:
         addTodo:
           concurrentKey: "add"
           method: "POST"
-          path: "todos/add"
+          path: "todos/add?delay=3000"
     todo2Room:
       connection:
         baseUrl: ${BASE_URL}

diff --git a/request.go b/request.go
@@ -214,6 +214,9 @@ func (r *BaseRequest) PreRequest() IRequest {
 
 func (r *BaseRequest) SetConnectionConfig(connectionConfig IConnectionConfig) IRequest {
 	r.connectionConfig = connectionConfig
+
+	//TODO make an observer for changes of few fields
+	r.contextBuilder = NewContextBuilder(r.connectionConfig.TimeoutDuration())
 	return r
 }