Merge branch 'main' of ssh://github.com/mongodb/docs-code-examples into docsp-46221

Author: cbullinger

config.json

@@ -1,23 +1,79 @@
 [
     {
-        "notes": "Copy Go project files to Arch Center artifact repo",
-        "source_directory" : "generated-usage-examples/go/atlas-sdk-go/full-example",
+        "notes": "Copy atlas-sdk-go project files to user-facing Atlas Architecture Center artifact repo root",
+        "source_directory" : "generated-usage-examples/go/atlas-sdk-go/copied-project/",
         "target_repo" : "atlas-architecture-go-sdk",
         "target_branch" : "main",
-        "target_directory" : ""
+        "target_directory" : "."
     },
     {
-        "notes": "This is a test config. It can be safely deleted.",
-        "source_directory" : "generated-examples/go",
-        "target_repo" : "docs-code-examples-test-target",
+        "notes": "atlas-sdk-go/copied-project/cmd subdirectory",
+        "source_directory" : "generated-usage-examples/go/atlas-sdk-go/copied-project/cmd",
+        "target_repo" : "atlas-architecture-go-sdk",
+        "target_branch" : "main",
+        "target_directory" : "cmd"
+    },
+    {
+        "notes": "atlas-sdk-go/copied-project/cmd/get_logs subdirectory",
+        "source_directory" : "generated-usage-examples/go/atlas-sdk-go/copied-project/cmd/get_logs",
+        "target_repo" : "atlas-architecture-go-sdk",
+        "target_branch" : "main",
+        "target_directory" : "cmd/get_logs"
+    },
+    {
+        "notes": "atlas-sdk-go/copied-project/cmd/get_metrics_process subdirectory",
+        "source_directory" : "generated-usage-examples/go/atlas-sdk-go/copied-project/cmd/get_metrics_process",
+        "target_repo" : "atlas-architecture-go-sdk",
+        "target_branch" : "main",
+        "target_directory" : "cmd/get_metrics_process"
+    },
+    {
+        "notes": "atlas-sdk-go/copied-project/cmd/get_metrics_disk subdirectory",
+        "source_directory" : "generated-usage-examples/go/atlas-sdk-go/copied-project/cmd/get_metrics_disk",
+        "target_repo" : "atlas-architecture-go-sdk",
+        "target_branch" : "main",
+        "target_directory" : "cmd/get_metrics_disk"
+    },
+    {
+        "notes": "atlas-sdk-go/copied-project/configs",
+        "source_directory" : "generated-usage-examples/go/atlas-sdk-go/copied-project/configs",
+        "target_repo" : "atlas-architecture-go-sdk",
+        "target_branch" : "main",
+        "target_directory" : "configs"
+    },
+    {
+        "notes": "atlas-sdk-go/copied-project/internal subdirectory",
+        "source_directory" : "generated-usage-examples/go/atlas-sdk-go/copied-project/internal",
+        "target_repo" : "atlas-architecture-go-sdk",
+        "target_branch" : "main",
+        "target_directory" : "internal"
+    },
+    {
+        "notes": "atlas-sdk-go/copied-project/internal/auth subdirectory",
+        "source_directory" : "generated-usage-examples/go/atlas-sdk-go/copied-project/internal/auth",
+        "target_repo" : "atlas-architecture-go-sdk",
+        "target_branch" : "main",
+        "target_directory" : "internal/auth"
+    },
+    {
+        "notes": "Copy atlas-sdk-go project files to user-facing Atlas Architecture Center artifact repo root",
+        "source_directory" : "generated-usage-examples/go/atlas-sdk-go/copied-project/",
+        "target_repo" : "atlas-architecture-go-sdk",
+        "target_branch" : "copy-test-2",
+        "target_directory" : "."
+    },
+    {
+        "notes": "Example config for copying files from a directory to another repo",
+        "source_directory" : "generated-examples",
+        "target_repo" : "my-target-repo-name",
         "target_branch" : "main",
-        "target_directory" : "go"
+        "target_directory" : "examples"
     },
     {
-        "notes":"This is a test config that copies fake v2 code examples to the v2.2 driver branch.",
-        "source_directory" : "generated-examples/go/v2",
-        "target_repo" : "docs-code-examples-test-target",
+        "notes":"Example config for copying a subset of files to another repo and branch",
+        "source_directory" : "generated-examples/v2",
+        "target_repo" : "my-target-repo-name",
         "target_branch" : "v2.2",
-        "target_directory" : "go"
+        "target_directory" : "v2-examples"
     }
 ]

deprecated_examples.json

@@ -1,98 +1,14 @@
 [
   {
-    "filename": "go/delete_me.go",
-    "repo": "",
-    "branch": "",
-    "deleted_on": "2025-03-07T21:53:21Z"
-  },
-  {
-    "filename": "go/newgotestfile.go",
-    "repo": "docs-code-examples-test-target",
-    "branch": "v2.2",
-    "deleted_on": "2025-03-19T16:11:53-07:00"
-  },
-  {
-    "filename": "go/ohhai_detete_me",
-    "repo": "docs-code-examples-test-target",
-    "branch": "v2.2",
-    "deleted_on": "2025-03-19T16:11:54-07:00"
-  },
-  {
-    "filename": "go/v22testfile2.go",
-    "repo": "docs-code-examples-test-target",
-    "branch": "v2.2",
-    "deleted_on": "2025-03-19T16:11:55-07:00"
-  },
-  {
-    "filename": "go/newgotestfile.go",
+    "filename": "go/gcloud24march.go",
     "repo": "docs-code-examples-test-target",
-    "branch": "v2.2",
-    "deleted_on": "2025-03-19T16:33:15-07:00"
-  },
-  {
-    "filename": "go/ohhai_detete_me",
-    "repo": "docs-code-examples-test-target",
-    "branch": "v2.2",
-    "deleted_on": "2025-03-19T16:33:15-07:00"
-  },
-  {
-    "filename": "go/v22testfile2.go",
-    "repo": "docs-code-examples-test-target",
-    "branch": "v2.2",
-    "deleted_on": "2025-03-19T16:33:16-07:00"
-  },
-  {
-    "filename": "go/newgotestfile.go",
-    "repo": "docs-code-examples-test-target",
-    "branch": "v2.2",
-    "deleted_on": "2025-03-19T16:37:04-07:00"
-  },
-  {
-    "filename": "go/ohhai_detete_me",
-    "repo": "docs-code-examples-test-target",
-    "branch": "v2.2",
-    "deleted_on": "2025-03-19T16:37:05-07:00"
-  },
-  {
-    "filename": "go/v22testfile2.go",
-    "repo": "docs-code-examples-test-target",
-    "branch": "v2.2",
-    "deleted_on": "2025-03-19T16:37:06-07:00"
-  },
-  {
-    "filename": "go/ohhai_detete_me",
-    "repo": "docs-code-examples-test-target",
-    "branch": "v2.2",
-    "deleted_on": "2025-03-19T16:43:04-07:00"
-  },
-  {
-    "filename": "go/v22testfile2.go",
-    "repo": "docs-code-examples-test-target",
-    "branch": "v2.2",
-    "deleted_on": "2025-03-19T16:43:04-07:00"
-  },
-  {
-    "filename": "go/newgotestfile.go",
-    "repo": "docs-code-examples-test-target",
-    "branch": "v2.2",
-    "deleted_on": "2025-03-19T16:43:04-07:00"
-  },
-  {
-    "filename": "go/newgotestfile.go",
-    "repo": "docs-code-examples-test-target",
-    "branch": "v2.2",
-    "deleted_on": "2025-03-19T16:43:46-07:00"
-  },
-  {
-    "filename": "go/ohhai_detete_me",
-    "repo": "docs-code-examples-test-target",
-    "branch": "v2.2",
-    "deleted_on": "2025-03-19T16:43:46-07:00"
+    "branch": "main",
+    "deleted_on": "2025-03-24T18:16:30Z"
   },
   {
-    "filename": "go/v22testfile2.go",
+    "filename": "go/gcloud24march_v2.go",
     "repo": "docs-code-examples-test-target",
     "branch": "v2.2",
-    "deleted_on": "2025-03-19T16:43:46-07:00"
+    "deleted_on": "2025-03-24T18:16:30Z"
   }
 ]

generated-usage-examples/go/atlas-sdk-go/copied-project/cmd/get_logs/main.go

@@ -0,0 +1,110 @@
+package main
+
+import (
+	"atlas-sdk-go/internal/auth"
+	"compress/gzip"
+	"context"
+	"fmt"
+	"go.mongodb.org/atlas-sdk/v20250219001/admin"
+	"io"
+	"log"
+	"os"
+	"strings"
+)
+
+// getHostLogs downloads a compressed .gz file that contains the MongoDB logs for
+// the specified host in your project.
+func getHostLogs(ctx context.Context, atlasClient admin.APIClient, params *admin.GetHostLogsApiParams) (string, error) {
+	logFileName := fmt.Sprintf("logs_%s_%s.gz", params.GroupId, params.HostName)
+	fmt.Printf("Fetching %s log for host %s in project %s\n", params.LogName, params.HostName, params.GroupId)
+
+	if err := downloadLogs(ctx, atlasClient, params, logFileName); err != nil {
+		return "", err
+	}
+
+	fmt.Printf("Logs saved to %s\n", logFileName)
+	return logFileName, nil
+}
+
+func SafeClose(c io.Closer) {
+	if c != nil {
+		if err := c.Close(); err != nil {
+			log.Printf("Warning: failed to close resource: %v", err)
+		}
+	}
+}
+
+func downloadLogs(ctx context.Context, atlasClient admin.APIClient, params *admin.GetHostLogsApiParams, filePath string) error {
+	resp, _, err := atlasClient.MonitoringAndLogsApi.GetHostLogsWithParams(ctx, params).Execute()
+	if err != nil {
+		return fmt.Errorf("fetch logs: %w", err)
+	}
+	defer SafeClose(resp)
+
+	file, err := os.Create(filePath)
+	if err != nil {
+		return fmt.Errorf("create %q: %w", filePath, err)
+	}
+	defer SafeClose(file)
+
+	if _, err := io.Copy(file, resp); err != nil {
+		return fmt.Errorf("write to %q: %w", filePath, err)
+	}
+
+	return nil
+}
+
+func unzipGzFile(srcPath, destPath string) error {
+	srcFile, err := os.Open(srcPath)
+	if err != nil {
+		return fmt.Errorf("open gz file: %w", err)
+	}
+	defer SafeClose(srcFile)
+
+	gzReader, err := gzip.NewReader(srcFile)
+	if err != nil {
+		return fmt.Errorf("create gzip reader: %w", err)
+	}
+	defer SafeClose(gzReader)
+
+	destFile, err := os.Create(destPath)
+	if err != nil {
+		return fmt.Errorf("create destination file: %w", err)
+	}
+	defer SafeClose(destFile)
+
+	if _, err := io.Copy(destFile, gzReader); err != nil {
+		return fmt.Errorf("unzip copy error: %w", err)
+	}
+
+	fmt.Printf("Unzipped logs to %s\n", destPath)
+	return nil
+}
+
+func main() {
+	ctx := context.Background()
+
+	// Create an Atlas client authenticated using OAuth2 with service account credentials
+	client, _, config, err := auth.CreateAtlasClient()
+	if err != nil {
+		log.Fatalf("Failed to create Atlas client: %v", err)
+	}
+
+	params := &admin.GetHostLogsApiParams{
+		GroupId:  config.ProjectID,
+		HostName: config.HostName,
+		LogName:  "mongodb", // Type of log ("mongodb" or "mongos")
+	}
+
+	logFileName, err := getHostLogs(ctx, *client, params)
+	if err != nil {
+		log.Fatalf("Failed to download logs: %v", err)
+	}
+
+	plainTextLog := strings.TrimSuffix(logFileName, ".gz") + ".log"
+	if err := unzipGzFile(logFileName, plainTextLog); err != nil {
+		log.Fatalf("Failed to unzip log file: %v", err)
+	}
+
+}
+

generated-usage-examples/go/atlas-sdk-go/copied-project/cmd/get_metrics_disk/main.go

@@ -0,0 +1,63 @@
+package main
+
+import (
+	"atlas-sdk-go/internal/auth"
+	"context"
+	"encoding/json"
+	"fmt"
+	"go.mongodb.org/atlas-sdk/v20250219001/admin"
+	"log"
+)
+
+// getDiskMetrics fetches metrics for a specified disk partition in a project and prints results to the console
+func getDiskMetrics(ctx context.Context, atlasClient admin.APIClient, params *admin.GetDiskMeasurementsApiParams) (*admin.ApiMeasurementsGeneralViewAtlas, error) {
+
+	resp, _, err := atlasClient.MonitoringAndLogsApi.GetDiskMeasurementsWithParams(ctx, params).Execute()
+	if err != nil {
+		if apiError, ok := admin.AsError(err); ok {
+			return nil, fmt.Errorf("failed to get metrics for partition: %s (API error: %v)", err, apiError.GetDetail())
+		}
+		return nil, fmt.Errorf("failed to get metrics: %w", err)
+	}
+	if resp == nil || resp.HasMeasurements() == false {
+		return nil, fmt.Errorf("no metrics found for partition %s in project %s", params.PartitionName, params.GroupId)
+	}
+	jsonData, err := json.MarshalIndent(resp, "", "  ")
+	if err != nil {
+		return nil, fmt.Errorf("failed to marshal response: %w", err)
+	}
+	fmt.Println(string(jsonData))
+	return resp, nil
+}
+
+func main() {
+	ctx := context.Background()
+
+	// Create an Atlas client authenticated using OAuth2 with service account credentials
+	atlasClient, _, config, err := auth.CreateAtlasClient()
+	if err != nil {
+		log.Fatalf("Failed to create Atlas client: %v", err)
+	}
+
+	// Fetch disk metrics using the following parameters:
+	partitionName := "data"
+	diskMetricsGranularity := admin.PtrString("P1D")
+	diskMetricsPeriod := admin.PtrString("P1D")
+	diskMetrics := []string{
+		"DISK_PARTITION_SPACE_FREE", "DISK_PARTITION_SPACE_USED",
+	}
+
+	diskMeasurementsParams := &admin.GetDiskMeasurementsApiParams{
+		GroupId:       config.ProjectID,
+		ProcessId:     config.ProcessID,
+		PartitionName: partitionName,
+		M:             &diskMetrics,
+		Granularity:   diskMetricsGranularity,
+		Period:        diskMetricsPeriod,
+	}
+	_, err = getDiskMetrics(ctx, *atlasClient, diskMeasurementsParams)
+	if err != nil {
+		fmt.Printf("Error fetching disk metrics: %v", err)
+	}
+}
+