INTMDB-874: Support transactionLifetimeLimitSeconds parameter in Clus…

…ter and Advanced Cluser (#501)
mongodb · Jun 19, 2023 · f7cb3b1 · f7cb3b1
1 parent d69ad1a
commit f7cb3b1
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 2 deletions.
diff --git a/mongodbatlas/clusters.go b/mongodbatlas/clusters.go
@@ -186,6 +186,7 @@ type ProcessArgs struct {
 	OplogSizeMB                      *int64   `json:"oplogSizeMB,omitempty"`
 	SampleSizeBIConnector            *int64   `json:"sampleSizeBIConnector,omitempty"`
 	SampleRefreshIntervalBIConnector *int64   `json:"sampleRefreshIntervalBIConnector,omitempty"`
+	TransactionLifetimeLimitSeconds  *int64   `json:"transactionLifetimeLimitSeconds,omitempty"`
 	OplogMinRetentionHours           *float64 `json:"oplogMinRetentionHours,omitempty"`
 }
 

diff --git a/mongodbatlas/clusters_test.go b/mongodbatlas/clusters_test.go
@@ -774,6 +774,7 @@ func TestClusters_UpdateProcessArgs(t *testing.T) {
 		OplogMinRetentionHours:           pointer(100.0),
 		SampleSizeBIConnector:            pointer(int64(5000)),
 		SampleRefreshIntervalBIConnector: pointer(int64(300)),
+		TransactionLifetimeLimitSeconds:  pointer(int64(30)),
 	}
 
 	mux.HandleFunc(fmt.Sprintf("/api/atlas/v1.0/groups/%s/clusters/%s/processArgs", groupID, clusterName), func(w http.ResponseWriter, r *http.Request) {
@@ -788,6 +789,7 @@ func TestClusters_UpdateProcessArgs(t *testing.T) {
 			"oplogMinRetentionHours":           float64(100),
 			"sampleSizeBIConnector":            float64(5000),
 			"sampleRefreshIntervalBIConnector": float64(300),
+			"transactionLifetimeLimitSeconds":  float64(30),
 		}
 
 		jsonBlob := `
@@ -801,7 +803,8 @@ func TestClusters_UpdateProcessArgs(t *testing.T) {
 			"oplogSizeMB": 2000,
             "oplogMinRetentionHours": 100,
 			"sampleSizeBIConnector": 5000,
-			"sampleRefreshIntervalBIConnector": 300
+			"sampleRefreshIntervalBIConnector": 300,
+			"transactionLifetimeLimitSeconds": 30
 		}
 		`
 
@@ -849,7 +852,8 @@ func TestClusters_GetProcessArgs(t *testing.T) {
 			"noTableScan": true,
 			"oplogSizeMB": 2000,
 			"sampleSizeBIConnector": 5000,
-			"sampleRefreshIntervalBIConnector": 300
+			"sampleRefreshIntervalBIConnector": 300,
+			"transactionLifetimeLimitSeconds": 30
 		}`)
 	})
 
@@ -868,6 +872,7 @@ func TestClusters_GetProcessArgs(t *testing.T) {
 		OplogSizeMB:                      pointer(int64(2000)),
 		SampleSizeBIConnector:            pointer(int64(5000)),
 		SampleRefreshIntervalBIConnector: pointer(int64(300)),
+		TransactionLifetimeLimitSeconds:  pointer(int64(30)),
 	}
 
 	if diff := deep.Equal(processArgs, expected); diff != nil {