Snip and copy files

Author: cbullinger

generated-usage-examples/go/atlas-sdk-go/main.snippet.archive-collections.go

@@ -0,0 +1,81 @@
+// See entire project at https://github.com/mongodb/atlas-architecture-go-sdk
+package main
+
+import (
+	"context"
+	"fmt"
+	"time"
+
+	"atlas-sdk-go/internal/archive"
+	"atlas-sdk-go/internal/auth"
+	"atlas-sdk-go/internal/config"
+	"atlas-sdk-go/internal/errors"
+)
+
+func main() {
+	ctx, cancel := context.WithTimeout(context.Background(), 10*time.Minute)
+	defer cancel()
+
+	// Load application context with configuration and secrets for the environment
+	explicitEnv := "production"
+	appCtx, err := config.LoadAppContextWithContext(ctx, explicitEnv, false)
+	if err != nil {
+		errors.ExitWithError("Failed to load configuration", err)
+	}
+
+	client, err := auth.NewClient(appCtx.Config, appCtx.Secrets)
+	if err != nil {
+		errors.ExitWithError("Failed to initialize Atlas client", err)
+	}
+
+	projectID := appCtx.Config.ProjectID
+	if projectID == "" {
+		errors.ExitWithError("Project ID not found in configuration", nil)
+	}
+
+	fmt.Println("Starting archive analysis for project:", projectID)
+
+	// Step 1: List all clusters in the project
+	clusters, _, err := client.ClustersApi.ListClusters(ctx, projectID).Execute()
+	if err != nil {
+		errors.ExitWithError("Failed to list clusters", err)
+	}
+
+	fmt.Printf("Found %d clusters to analyze", len(clusters.GetResults()))
+
+	// Step 2: Process each cluster
+	failedArchives := 0
+	for _, cluster := range clusters.GetResults() {
+		clusterName := cluster.GetName()
+		fmt.Printf("Analyzing cluster: %s", clusterName)
+
+		// Step 3: Find collections suitable for archiving
+		// NOTE: In a real production scenario, you would customize the collection analysis logic to match your specific data patterns.
+		candidates := archive.CollectionsForArchiving(ctx, client, projectID, clusterName)
+		fmt.Printf("Found %d collections eligible for archiving in cluster %s",
+			len(candidates), clusterName)
+
+		// Step 4: Configure online archive for each candidate collection
+		for _, candidate := range candidates {
+			fmt.Printf("Configuring archive for %s.%s",
+				candidate.DatabaseName, candidate.CollectionName)
+
+			configureErr := archive.ConfigureOnlineArchive(ctx, client, projectID, clusterName, candidate)
+			if configureErr != nil {
+				fmt.Printf("Failed to configure archive: %v", configureErr)
+				failedArchives++
+				continue
+			}
+
+			fmt.Printf("Successfully configured online archive for %s.%s",
+				candidate.DatabaseName, candidate.CollectionName)
+		}
+	}
+
+	if failedArchives > 0 {
+		fmt.Printf("Warning: %d archive configurations failed", failedArchives)
+	}
+
+	fmt.Println("Archive analysis and configuration completed")
+}
+

generated-usage-examples/go/atlas-sdk-go/main.snippet.get-logs.go

@@ -12,16 +12,13 @@ import (
 	"atlas-sdk-go/internal/fileutils"
 	"atlas-sdk-go/internal/logs"
 
-	"github.com/joho/godotenv"
 	"go.mongodb.org/atlas-sdk/v20250219001/admin"
 )
 
 func main() {
-	if err := godotenv.Load(); err != nil {
-		log.Printf("Warning: .env file not loaded: %v", err)
-	}
-
-	secrets, cfg, err := config.LoadAll("configs/config.json")
+	configPath := ""  // Use default config path for environment
+	explicitEnv := "" // Use default environment
+	secrets, cfg, err := config.LoadAll(configPath, explicitEnv)
 	if err != nil {
 		errors.ExitWithError("Failed to load configuration", err)
 	}
@@ -39,13 +36,16 @@ func main() {
 		HostName: cfg.HostName,
 		LogName:  "mongodb",
 	}
+	fmt.Printf("Request parameters: GroupID=%s, HostName=%s, LogName=%s\n",
+		cfg.ProjectID, cfg.HostName, p.LogName)
 	rc, err := logs.FetchHostLogs(ctx, client.MonitoringAndLogsApi, p)
 	if err != nil {
 		errors.ExitWithError("Failed to fetch logs", err)
 	}
 	defer fileutils.SafeClose(rc)
 
 	// Prepare output paths
+	// If the ATLAS_DOWNLOADS_DIR env variable is set, it will be used as the base directory for output files
 	outDir := "logs"
 	prefix := fmt.Sprintf("%s_%s", p.HostName, p.LogName)
 	gzPath, err := fileutils.GenerateOutputPath(outDir, prefix, "gz")

generated-usage-examples/go/atlas-sdk-go/main.snippet.get-metrics-dev.go

@@ -5,23 +5,19 @@ import (
 	"context"
 	"encoding/json"
 	"fmt"
-	"log"
 
 	"atlas-sdk-go/internal/auth"
 	"atlas-sdk-go/internal/config"
 	"atlas-sdk-go/internal/errors"
 	"atlas-sdk-go/internal/metrics"
 
-	"github.com/joho/godotenv"
 	"go.mongodb.org/atlas-sdk/v20250219001/admin"
 )
 
 func main() {
-	if err := godotenv.Load(); err != nil {
-		log.Printf("Warning: .env file not loaded: %v", err)
-	}
-
-	secrets, cfg, err := config.LoadAll("configs/config.json")
+	configPath := "" // Use default config path for environment
+	explicitEnv := "development"
+	secrets, cfg, err := config.LoadAll(configPath, explicitEnv)
 	if err != nil {
 		errors.ExitWithError("Failed to load configuration", err)
 	}

generated-usage-examples/go/atlas-sdk-go/main.snippet.get-metrics-prod.go

@@ -5,25 +5,21 @@ import (
 	"context"
 	"encoding/json"
 	"fmt"
-	"log"
 
 	"atlas-sdk-go/internal/errors"
 
 	"atlas-sdk-go/internal/auth"
 	"atlas-sdk-go/internal/config"
 
-	"github.com/joho/godotenv"
 	"go.mongodb.org/atlas-sdk/v20250219001/admin"
 
 	"atlas-sdk-go/internal/metrics"
 )
 
 func main() {
-	if err := godotenv.Load(); err != nil {
-		log.Printf("Warning: .env file not loaded: %v", err)
-	}
-
-	secrets, cfg, err := config.LoadAll("configs/config.json")
+	configPath := "" // Use default config path for environment
+	explicitEnv := "production"
+	secrets, cfg, err := config.LoadAll(configPath, explicitEnv)
 	if err != nil {
 		errors.ExitWithError("Failed to load configuration", err)
 	}

generated-usage-examples/go/atlas-sdk-go/main.snippet.historical-billing.go

@@ -14,16 +14,13 @@ import (
 	"atlas-sdk-go/internal/errors"
 	"atlas-sdk-go/internal/fileutils"
 
-	"github.com/joho/godotenv"
 	"go.mongodb.org/atlas-sdk/v20250219001/admin"
 )
 
 func main() {
-	if err := godotenv.Load(); err != nil {
-		log.Printf("Warning: .env file not loaded: %v", err)
-	}
-
-	secrets, cfg, err := config.LoadAll("configs/config.json")
+	configPath := ""  // Use default config path for environment
+	explicitEnv := "" // Use default environment
+	secrets, cfg, err := config.LoadAll(configPath, explicitEnv)
 	if err != nil {
 		errors.ExitWithError("Failed to load configuration", err)
 	}

generated-usage-examples/go/atlas-sdk-go/main.snippet.line-items.go

@@ -5,6 +5,7 @@ import (
 	"context"
 	"fmt"
 	"log"
+	"time"
 
 	"go.mongodb.org/atlas-sdk/v20250219001/admin"
 
@@ -14,16 +15,12 @@ import (
 	"atlas-sdk-go/internal/data/export"
 	"atlas-sdk-go/internal/errors"
 	"atlas-sdk-go/internal/fileutils"
-
-	"github.com/joho/godotenv"
 )
 
 func main() {
-	if err := godotenv.Load(); err != nil {
-		log.Printf("Warning: .env file not loaded: %v", err)
-	}
-
-	secrets, cfg, err := config.LoadAll("configs/config.json")
+	configPath := ""  // Use default config path for environment
+	explicitEnv := "" // Use default environment
+	secrets, cfg, err := config.LoadAll(configPath, explicitEnv)
 	if err != nil {
 		errors.ExitWithError("Failed to load configuration", err)
 	}

generated-usage-examples/go/atlas-sdk-go/main.snippet.linked-billing.go

@@ -4,23 +4,19 @@ package main
 import (
 	"context"
 	"fmt"
-	"log"
 
 	"atlas-sdk-go/internal/auth"
 	"atlas-sdk-go/internal/billing"
 	"atlas-sdk-go/internal/config"
 	"atlas-sdk-go/internal/errors"
 
-	"github.com/joho/godotenv"
 	"go.mongodb.org/atlas-sdk/v20250219001/admin"
 )
 
 func main() {
-	if err := godotenv.Load(); err != nil {
-		log.Printf("Warning: .env file not loaded: %v", err)
-	}
-
-	secrets, cfg, err := config.LoadAll("configs/config.json")
+	configPath := ""  // Use default config path for environment
+	explicitEnv := "" // Use default environment
+	secrets, cfg, err := config.LoadAll(configPath, explicitEnv)
 	if err != nil {
 		errors.ExitWithError("Failed to load configuration", err)
 	}

generated-usage-examples/go/atlas-sdk-go/project-copy/.gitignore

@@ -1,5 +1,14 @@
 # Secrets
 .env
+!.env.example
+.env.development
+.env.production
+configs/config.example.json
+!configs/config.development.json
+!configs/config.production.json
+
+tmp
+
 
 # Logs
 *.log

generated-usage-examples/go/atlas-sdk-go/project-copy/CHANGELOG.md

@@ -5,7 +5,7 @@ Notable changes to the project.
 ## v1.1 (2025-06-17)
 ### Added
 - Example scripts for fetching cross-organization billing information.
- 
+
 ## v1.0 (2025-05-29)
 ### Added
 - Initial project structure with example scripts for fetching logs and metrics.

generated-usage-examples/go/atlas-sdk-go/project-copy/configs/config.development.json

@@ -0,0 +1,12 @@
+{
+  "ENVIRONMENT": "dev",
+  "MONGODB_ATLAS_BASE_URL": "https://cloud-dev.mongodb.com",
+  "ATLAS_ORG_ID": "32b6e34b3d91647abb20e7b8",
+  "ATLAS_PROJECT_ID": "5e2211c17a3e5a48f5497de3",
+  "ATLAS_PROJECT_NAME": "Customer Portal - Dev",
+  "ATLAS_PROCESS_ID": "CustomerPortalDev-shard-00-00.ajlj3.mongodb.net:27017",
+  "CLOUD_PROVIDER": "AWS",
+  "AUTO_SCALING_DISK_GB": true,
+  "AUTO_SCALING_COMPUTE": true,
+  "DISK_SIZE_GB": 10000
+}