Merge pull request #571 from ydb-platform/ref-exanples

refactoring of exaamples

Author: asmyasnikov

connection_test.go

@@ -6,48 +6,16 @@ package ydb_test
 import (
 	"context"
 	"errors"
-	"fmt"
 	"testing"
 	"time"
 
 	"github.com/stretchr/testify/require"
 	grpcCodes "google.golang.org/grpc/codes"
 
 	"github.com/ydb-platform/ydb-go-sdk/v3"
-	"github.com/ydb-platform/ydb-go-sdk/v3/balancers"
 	"github.com/ydb-platform/ydb-go-sdk/v3/trace"
 )
 
-func ExampleOpen() {
-	ctx := context.TODO()
-	db, err := ydb.Open(ctx, "grpc://localhost:2135/local")
-	if err != nil {
-		fmt.Printf("connection failed: %v", err)
-	}
-	defer db.Close(ctx) // cleanup resources
-	fmt.Printf("connected to %s, database '%s'", db.Endpoint(), db.Name())
-}
-
-func ExampleOpen_advanced() {
-	ctx := context.TODO()
-	db, err := ydb.Open(
-		ctx,
-		"grpc://localhost:2135/local",
-		ydb.WithAnonymousCredentials(),
-		ydb.WithBalancer(
-			balancers.PreferLocationsWithFallback(
-				balancers.RandomChoice(), "a", "b",
-			),
-		),
-		ydb.WithSessionPoolSizeLimit(100),
-	)
-	if err != nil {
-		fmt.Printf("connection failed: %v", err)
-	}
-	defer db.Close(ctx) // cleanup resources
-	fmt.Printf("connected to %s, database '%s'", db.Endpoint(), db.Name())
-}
-
 func TestZeroDialTimeout(t *testing.T) {
 	ctx, cancel := context.WithTimeout(context.Background(), time.Second*10)
 	defer cancel()

example_test.go

@@ -8,6 +8,7 @@ import (
 	"log"
 
 	"github.com/ydb-platform/ydb-go-sdk/v3"
+	"github.com/ydb-platform/ydb-go-sdk/v3/balancers"
 	"github.com/ydb-platform/ydb-go-sdk/v3/retry"
 	"github.com/ydb-platform/ydb-go-sdk/v3/table"
 	"github.com/ydb-platform/ydb-go-sdk/v3/table/result/named"
@@ -173,3 +174,33 @@ func Example_discovery() {
 		fmt.Printf("%d) %s\n", i, e.String())
 	}
 }
+
+func ExampleOpen() {
+	ctx := context.TODO()
+	db, err := ydb.Open(ctx, "grpc://localhost:2135/local")
+	if err != nil {
+		fmt.Printf("connection failed: %v", err)
+	}
+	defer db.Close(ctx) // cleanup resources
+	fmt.Printf("connected to %s, database '%s'", db.Endpoint(), db.Name())
+}
+
+func ExampleOpen_advanced() {
+	ctx := context.TODO()
+	db, err := ydb.Open(
+		ctx,
+		"grpc://localhost:2135/local",
+		ydb.WithAnonymousCredentials(),
+		ydb.WithBalancer(
+			balancers.PreferLocationsWithFallback(
+				balancers.RandomChoice(), "a", "b",
+			),
+		),
+		ydb.WithSessionPoolSizeLimit(100),
+	)
+	if err != nil {
+		fmt.Printf("connection failed: %v", err)
+	}
+	defer db.Close(ctx) // cleanup resources
+	fmt.Printf("connected to %s, database '%s'", db.Endpoint(), db.Name())
+}