diff options
author | asmyasnikov <asmyasnikov@ydb.tech> | 2022-08-09 04:31:00 +0300 |
---|---|---|
committer | asmyasnikov <asmyasnikov@ydb.tech> | 2022-08-09 04:31:00 +0300 |
commit | aaf121f19f34bb7ed026b627f75a09e68723f89d (patch) | |
tree | adb7195a1ecaa9c663d37108bb2063e6ae80619a | |
parent | dfd20cd437d550c61ce3d52b54aa4a88fbb904b1 (diff) | |
download | ydb-aaf121f19f34bb7ed026b627f75a09e68723f89d.tar.gz |
fix imports in go upsert recipes + simplify ydb.Open code snippets
fix imports in go upsert recipes
32 files changed, 53 insertions, 84 deletions
diff --git a/ydb/docs/en/core/reference/ydb-sdk/example/go/index.md b/ydb/docs/en/core/reference/ydb-sdk/example/go/index.md index aa17623990..b9f4a97e2e 100644 --- a/ydb/docs/en/core/reference/ydb-sdk/example/go/index.md +++ b/ydb/docs/en/core/reference/ydb-sdk/example/go/index.md @@ -46,8 +46,7 @@ dsn := "grpcs://ydb.serverless.yandexcloud.net:2135/?database=/ru-central1/b1g8s // IAM token token := "t1.9euelZrOy8aVmZKJm5HGjceMkMeVj-..." // creating a DB connection object, which is the input point for YDB services -db, err := ydb.Open( - ctx, +db, err := ydb.Open(ctx, dsn, // yc.WithInternalCA(), // using Yandex.Cloud certificates ydb.WithAccessTokenCredentials(token), // token-based authentication diff --git a/ydb/docs/en/core/reference/ydb-sdk/recipes/auth/_includes/access_token/go.md b/ydb/docs/en/core/reference/ydb-sdk/recipes/auth/_includes/access_token/go.md index 3d6d086eec..dacd18352a 100644 --- a/ydb/docs/en/core/reference/ydb-sdk/recipes/auth/_includes/access_token/go.md +++ b/ydb/docs/en/core/reference/ydb-sdk/recipes/auth/_includes/access_token/go.md @@ -11,8 +11,7 @@ import ( func main() { ctx, cancel := context.WithCancel(context.Background()) defer cancel() - db, err := ydb.Open( - ctx, + db, err := ydb.Open(ctx, os.Getenv("YDB_CONNECTION_STRING"), ydb.WithAccessTokenCredentials(os.Getenv("YDB_TOKEN")), ) diff --git a/ydb/docs/en/core/reference/ydb-sdk/recipes/auth/_includes/anonymous/go.md b/ydb/docs/en/core/reference/ydb-sdk/recipes/auth/_includes/anonymous/go.md index 75b09e7898..dcb95d4a3c 100644 --- a/ydb/docs/en/core/reference/ydb-sdk/recipes/auth/_includes/anonymous/go.md +++ b/ydb/docs/en/core/reference/ydb-sdk/recipes/auth/_includes/anonymous/go.md @@ -10,8 +10,7 @@ import ( func main() { ctx, cancel := context.WithCancel(context.Background()) defer cancel() - db, err := ydb.Open( - ctx, + db, err := ydb.Open(ctx, os.Getenv("YDB_CONNECTION_STRING"), ydb.WithAnonymousCredentials(), ) diff --git a/ydb/docs/en/core/reference/ydb-sdk/recipes/auth/_includes/env/go.md b/ydb/docs/en/core/reference/ydb-sdk/recipes/auth/_includes/env/go.md index e1a156b013..3d5ab05993 100644 --- a/ydb/docs/en/core/reference/ydb-sdk/recipes/auth/_includes/env/go.md +++ b/ydb/docs/en/core/reference/ydb-sdk/recipes/auth/_includes/env/go.md @@ -12,8 +12,7 @@ import ( func main() { ctx, cancel := context.WithCancel(context.Background()) defer cancel() - db, err := ydb.Open( - ctx, + db, err := ydb.Open(ctx, os.Getenv("YDB_CONNECTION_STRING"), environ.WithEnvironCredentials(ctx), ) diff --git a/ydb/docs/en/core/reference/ydb-sdk/recipes/auth/_includes/metadata/go.md b/ydb/docs/en/core/reference/ydb-sdk/recipes/auth/_includes/metadata/go.md index d9831a735c..ac77d35c62 100644 --- a/ydb/docs/en/core/reference/ydb-sdk/recipes/auth/_includes/metadata/go.md +++ b/ydb/docs/en/core/reference/ydb-sdk/recipes/auth/_includes/metadata/go.md @@ -12,8 +12,7 @@ import ( func main() { ctx, cancel := context.WithCancel(context.Background()) defer cancel() - db, err := ydb.Open( - ctx, + db, err := ydb.Open(ctx, os.Getenv("YDB_CONNECTION_STRING"), yc.WithMetadataCredentials(ctx), yc.WithInternalCA(), // append Yandex Cloud certificates diff --git a/ydb/docs/en/core/reference/ydb-sdk/recipes/auth/_includes/service_account/go.md b/ydb/docs/en/core/reference/ydb-sdk/recipes/auth/_includes/service_account/go.md index 6c97769975..1a5d26021a 100644 --- a/ydb/docs/en/core/reference/ydb-sdk/recipes/auth/_includes/service_account/go.md +++ b/ydb/docs/en/core/reference/ydb-sdk/recipes/auth/_includes/service_account/go.md @@ -12,8 +12,7 @@ import ( func main() { ctx, cancel := context.WithCancel(context.Background()) defer cancel() - db, err := ydb.Open( - ctx, + db, err := ydb.Open(ctx, os.Getenv("YDB_CONNECTION_STRING"), yc.WithServiceAccountKeyFileCredentials( os.Getenv("YDB_SERVICE_ACCOUNT_KEY_FILE_CREDENTIALS"), diff --git a/ydb/docs/en/core/reference/ydb-sdk/recipes/balancing/_includes/prefer_local/go.md b/ydb/docs/en/core/reference/ydb-sdk/recipes/balancing/_includes/prefer_local/go.md index 04e48ec199..fc43c67df8 100644 --- a/ydb/docs/en/core/reference/ydb-sdk/recipes/balancing/_includes/prefer_local/go.md +++ b/ydb/docs/en/core/reference/ydb-sdk/recipes/balancing/_includes/prefer_local/go.md @@ -12,8 +12,7 @@ import ( func main() { ctx, cancel := context.WithCancel(context.Background()) defer cancel() - db, err := ydb.Open( - ctx, + db, err := ydb.Open(ctx, os.Getenv("YDB_CONNECTION_STRING"), ydb.WithBalancer( balancers.PreferLocalDC( diff --git a/ydb/docs/en/core/reference/ydb-sdk/recipes/balancing/_includes/prefer_location/go.md b/ydb/docs/en/core/reference/ydb-sdk/recipes/balancing/_includes/prefer_location/go.md index 500d2974a1..7d360849b9 100644 --- a/ydb/docs/en/core/reference/ydb-sdk/recipes/balancing/_includes/prefer_location/go.md +++ b/ydb/docs/en/core/reference/ydb-sdk/recipes/balancing/_includes/prefer_location/go.md @@ -12,8 +12,7 @@ import ( func main() { ctx, cancel := context.WithCancel(context.Background()) defer cancel() - db, err := ydb.Open( - ctx, + db, err := ydb.Open(ctx, os.Getenv("YDB_CONNECTION_STRING"), ydb.WithBalancer( balancers.PreferLocations( diff --git a/ydb/docs/en/core/reference/ydb-sdk/recipes/balancing/_includes/random_choice/go.md b/ydb/docs/en/core/reference/ydb-sdk/recipes/balancing/_includes/random_choice/go.md index 4206736823..a52aaa7827 100644 --- a/ydb/docs/en/core/reference/ydb-sdk/recipes/balancing/_includes/random_choice/go.md +++ b/ydb/docs/en/core/reference/ydb-sdk/recipes/balancing/_includes/random_choice/go.md @@ -12,8 +12,7 @@ import ( func main() { ctx, cancel := context.WithCancel(context.Background()) defer cancel() - db, err := ydb.Open( - ctx, + db, err := ydb.Open(ctx, os.Getenv("YDB_CONNECTION_STRING"), ydb.WithBalancer( balancers.RandomChoice(), diff --git a/ydb/docs/en/core/reference/ydb-sdk/recipes/bulk_upsert/_includes/go.md b/ydb/docs/en/core/reference/ydb-sdk/recipes/bulk_upsert/_includes/go.md index 0908a1a2d8..4f7e25ffa6 100644 --- a/ydb/docs/en/core/reference/ydb-sdk/recipes/bulk_upsert/_includes/go.md +++ b/ydb/docs/en/core/reference/ydb-sdk/recipes/bulk_upsert/_includes/go.md @@ -6,13 +6,14 @@ import ( "os" "github.com/ydb-platform/ydb-go-sdk/v3" + "github.com/ydb-platform/ydb-go-sdk/v3/table" + "github.com/ydb-platform/ydb-go-sdk/v3/table/types" ) func main() { ctx, cancel := context.WithCancel(context.Background()) defer cancel() - db, err := ydb.Open( - ctx, + db, err := ydb.Open(ctx, os.Getenv("YDB_CONNECTION_STRING"), ydb.WithAccessTokenCredentials(os.Getenv("YDB_TOKEN")), ) diff --git a/ydb/docs/en/core/reference/ydb-sdk/recipes/debug/_includes/jaeger/go.md b/ydb/docs/en/core/reference/ydb-sdk/recipes/debug/_includes/jaeger/go.md index 668ba6ba04..a99be9ede9 100644 --- a/ydb/docs/en/core/reference/ydb-sdk/recipes/debug/_includes/jaeger/go.md +++ b/ydb/docs/en/core/reference/ydb-sdk/recipes/debug/_includes/jaeger/go.md @@ -44,12 +44,11 @@ func main() { span, ctx := opentracing.StartSpanFromContext(context.Background(), "client") defer span.Finish() - db, err := ydb.Open( - ctx, + db, err := ydb.Open(ctx, os.Getenv("YDB_CONNECTION_STRING"), tracing.WithTraces( tracing.WithDetails(trace.DetailsAll), - )), + ), ) if err != nil { panic(err) diff --git a/ydb/docs/en/core/reference/ydb-sdk/recipes/debug/_includes/logs/go.md b/ydb/docs/en/core/reference/ydb-sdk/recipes/debug/_includes/logs/go.md index db6328ff12..a34b657302 100644 --- a/ydb/docs/en/core/reference/ydb-sdk/recipes/debug/_includes/logs/go.md +++ b/ydb/docs/en/core/reference/ydb-sdk/recipes/debug/_includes/logs/go.md @@ -21,8 +21,7 @@ There are several ways to enable logs in an application that uses `ydb-go-sdk`: ctx, cancel := context.WithCancel(context.Background()) defer cancel() var log *zap.Logger // zap-logger with init out of this scope - db, err := ydb.Open( - ctx, + db, err := ydb.Open(ctx, os.Getenv("YDB_CONNECTION_STRING"), ydbZap.WithTraces( log, @@ -59,8 +58,7 @@ There are several ways to enable logs in an application that uses `ydb-go-sdk`: ctx, cancel := context.WithCancel(context.Background()) defer cancel() var log zerolog.Logger // zap-logger with init out of this scope - db, err := ydb.Open( - ctx, + db, err := ydb.Open(ctx, os.Getenv("YDB_CONNECTION_STRING"), ydbZerolog.WithTraces( log, @@ -95,13 +93,12 @@ There are several ways to enable logs in an application that uses `ydb-go-sdk`: ctx, cancel := context.WithCancel(context.Background()) defer cancel() var logger log.Logger // logger implementation with init out of this scope - db, err := ydb.Open( - ctx, + db, err := ydb.Open(ctx, os.Getenv("YDB_CONNECTION_STRING"), ydb.WithLogger( trace.DetailsAll, - ydb.WithExternalLogger(logger), - ), + ydb.WithExternalLogger(logger), + ), ) if err != nil { panic(err) diff --git a/ydb/docs/en/core/reference/ydb-sdk/recipes/debug/_includes/prometheus/go.md b/ydb/docs/en/core/reference/ydb-sdk/recipes/debug/_includes/prometheus/go.md index b5521453d7..466bb1b838 100644 --- a/ydb/docs/en/core/reference/ydb-sdk/recipes/debug/_includes/prometheus/go.md +++ b/ydb/docs/en/core/reference/ydb-sdk/recipes/debug/_includes/prometheus/go.md @@ -13,8 +13,7 @@ import ( func main() { ctx := context.Background() registry := prometheus.NewRegistry() - db, err := ydb.Open( - ctx, + db, err := ydb.Open(ctx, os.Getenv("YDB_CONNECTION_STRING"), metrics.WithTraces( registry, diff --git a/ydb/docs/en/core/reference/ydb-sdk/recipes/retry/_includes/go.md b/ydb/docs/en/core/reference/ydb-sdk/recipes/retry/_includes/go.md index a0ea32db03..6218b03dba 100644 --- a/ydb/docs/en/core/reference/ydb-sdk/recipes/retry/_includes/go.md +++ b/ydb/docs/en/core/reference/ydb-sdk/recipes/retry/_includes/go.md @@ -24,8 +24,7 @@ If the custom function returns an error, the {{ ydb-short-name }} Go SDK tries t ) func main() { - db, err := ydb.Open( - ctx, + db, err := ydb.Open(ctx, os.Getenv("YDB_CONNECTION_STRING"), ) if err != nil { @@ -37,8 +36,7 @@ If the custom function returns an error, the {{ ydb-short-name }} Go SDK tries t var cancel context.CancelFunc // fix deadline for retries ctx, cancel := context.WithTimeout(ctx, time.Second) - err = retry.Retry( - ctx, + err = retry.Retry(ctx, func(ctx context.Context) error { whoAmI, err := db.Discovery().WhoAmI(ctx) if err != nil { diff --git a/ydb/docs/en/core/reference/ydb-sdk/recipes/session_pool_limit/_includes/go.md b/ydb/docs/en/core/reference/ydb-sdk/recipes/session_pool_limit/_includes/go.md index 32fccc1141..653b08c103 100644 --- a/ydb/docs/en/core/reference/ydb-sdk/recipes/session_pool_limit/_includes/go.md +++ b/ydb/docs/en/core/reference/ydb-sdk/recipes/session_pool_limit/_includes/go.md @@ -8,8 +8,7 @@ import ( ) func main() { - db, err := ydb.Open( - ctx, + db, err := ydb.Open(ctx, os.Getenv("YDB_CONNECTION_STRING"), ydb.WithSessionPoolSizeLimit(500), ) diff --git a/ydb/docs/en/core/reference/ydb-sdk/recipes/upsert/_includes/go.md b/ydb/docs/en/core/reference/ydb-sdk/recipes/upsert/_includes/go.md index 82b74ed301..d8c158cb4a 100644 --- a/ydb/docs/en/core/reference/ydb-sdk/recipes/upsert/_includes/go.md +++ b/ydb/docs/en/core/reference/ydb-sdk/recipes/upsert/_includes/go.md @@ -6,13 +6,14 @@ import ( "os" "github.com/ydb-platform/ydb-go-sdk/v3" + "github.com/ydb-platform/ydb-go-sdk/v3/table" + "github.com/ydb-platform/ydb-go-sdk/v3/table/types" ) func main() { ctx, cancel := context.WithCancel(context.Background()) defer cancel() - db, err := ydb.Open( - ctx, + db, err := ydb.Open(ctx, os.Getenv("YDB_CONNECTION_STRING"), ydb.WithAccessTokenCredentials(os.Getenv("YDB_TOKEN")), ) @@ -26,8 +27,7 @@ func main() { err = db.Table().DoTx( // Do retry operation on errors with best effort ctx, // context manages exiting from Do func(ctx context.Context, tx table.TransactionActor) (err error) { // retry operation - res, err = tx.Execute( - ctx,` + res, err = tx.Execute(ctx, ` PRAGMA TablePathPrefix("/path/to/table"); DECLARE $seriesID AS Uint64; DECLARE $seasonID AS Uint64; diff --git a/ydb/docs/ru/core/reference/ydb-sdk/example/go/index.md b/ydb/docs/ru/core/reference/ydb-sdk/example/go/index.md index 4b355ad3d5..46b132c588 100644 --- a/ydb/docs/ru/core/reference/ydb-sdk/example/go/index.md +++ b/ydb/docs/ru/core/reference/ydb-sdk/example/go/index.md @@ -48,8 +48,7 @@ dsn := "grpcs://ydb.serverless.yandexcloud.net:2135/?database=/ru-central1/b1g8s // IAM-токен token := "t1.9euelZrOy8aVmZKJm5HGjceMkMeVj-..." // создаем объект подключения db, является входной точкой для сервисов YDB -db, err := ydb.Open( - ctx, +db, err := ydb.Open(ctx, dsn, // yc.WithInternalCA(), // используем сертификаты Яндекс Облака ydb.WithAccessTokenCredentials(token), // аутентификация с помощью токена diff --git a/ydb/docs/ru/core/reference/ydb-sdk/recipes/auth/_includes/access_token/go.md b/ydb/docs/ru/core/reference/ydb-sdk/recipes/auth/_includes/access_token/go.md index 3d6d086eec..dacd18352a 100644 --- a/ydb/docs/ru/core/reference/ydb-sdk/recipes/auth/_includes/access_token/go.md +++ b/ydb/docs/ru/core/reference/ydb-sdk/recipes/auth/_includes/access_token/go.md @@ -11,8 +11,7 @@ import ( func main() { ctx, cancel := context.WithCancel(context.Background()) defer cancel() - db, err := ydb.Open( - ctx, + db, err := ydb.Open(ctx, os.Getenv("YDB_CONNECTION_STRING"), ydb.WithAccessTokenCredentials(os.Getenv("YDB_TOKEN")), ) diff --git a/ydb/docs/ru/core/reference/ydb-sdk/recipes/auth/_includes/anonymous/go.md b/ydb/docs/ru/core/reference/ydb-sdk/recipes/auth/_includes/anonymous/go.md index 75b09e7898..dcb95d4a3c 100644 --- a/ydb/docs/ru/core/reference/ydb-sdk/recipes/auth/_includes/anonymous/go.md +++ b/ydb/docs/ru/core/reference/ydb-sdk/recipes/auth/_includes/anonymous/go.md @@ -10,8 +10,7 @@ import ( func main() { ctx, cancel := context.WithCancel(context.Background()) defer cancel() - db, err := ydb.Open( - ctx, + db, err := ydb.Open(ctx, os.Getenv("YDB_CONNECTION_STRING"), ydb.WithAnonymousCredentials(), ) diff --git a/ydb/docs/ru/core/reference/ydb-sdk/recipes/auth/_includes/env/go.md b/ydb/docs/ru/core/reference/ydb-sdk/recipes/auth/_includes/env/go.md index e1a156b013..3d5ab05993 100644 --- a/ydb/docs/ru/core/reference/ydb-sdk/recipes/auth/_includes/env/go.md +++ b/ydb/docs/ru/core/reference/ydb-sdk/recipes/auth/_includes/env/go.md @@ -12,8 +12,7 @@ import ( func main() { ctx, cancel := context.WithCancel(context.Background()) defer cancel() - db, err := ydb.Open( - ctx, + db, err := ydb.Open(ctx, os.Getenv("YDB_CONNECTION_STRING"), environ.WithEnvironCredentials(ctx), ) diff --git a/ydb/docs/ru/core/reference/ydb-sdk/recipes/auth/_includes/metadata/go.md b/ydb/docs/ru/core/reference/ydb-sdk/recipes/auth/_includes/metadata/go.md index d9831a735c..ac77d35c62 100644 --- a/ydb/docs/ru/core/reference/ydb-sdk/recipes/auth/_includes/metadata/go.md +++ b/ydb/docs/ru/core/reference/ydb-sdk/recipes/auth/_includes/metadata/go.md @@ -12,8 +12,7 @@ import ( func main() { ctx, cancel := context.WithCancel(context.Background()) defer cancel() - db, err := ydb.Open( - ctx, + db, err := ydb.Open(ctx, os.Getenv("YDB_CONNECTION_STRING"), yc.WithMetadataCredentials(ctx), yc.WithInternalCA(), // append Yandex Cloud certificates diff --git a/ydb/docs/ru/core/reference/ydb-sdk/recipes/auth/_includes/service_account/go.md b/ydb/docs/ru/core/reference/ydb-sdk/recipes/auth/_includes/service_account/go.md index 6c97769975..1a5d26021a 100644 --- a/ydb/docs/ru/core/reference/ydb-sdk/recipes/auth/_includes/service_account/go.md +++ b/ydb/docs/ru/core/reference/ydb-sdk/recipes/auth/_includes/service_account/go.md @@ -12,8 +12,7 @@ import ( func main() { ctx, cancel := context.WithCancel(context.Background()) defer cancel() - db, err := ydb.Open( - ctx, + db, err := ydb.Open(ctx, os.Getenv("YDB_CONNECTION_STRING"), yc.WithServiceAccountKeyFileCredentials( os.Getenv("YDB_SERVICE_ACCOUNT_KEY_FILE_CREDENTIALS"), diff --git a/ydb/docs/ru/core/reference/ydb-sdk/recipes/balancing/_includes/prefer_local/go.md b/ydb/docs/ru/core/reference/ydb-sdk/recipes/balancing/_includes/prefer_local/go.md index 04e48ec199..fc43c67df8 100644 --- a/ydb/docs/ru/core/reference/ydb-sdk/recipes/balancing/_includes/prefer_local/go.md +++ b/ydb/docs/ru/core/reference/ydb-sdk/recipes/balancing/_includes/prefer_local/go.md @@ -12,8 +12,7 @@ import ( func main() { ctx, cancel := context.WithCancel(context.Background()) defer cancel() - db, err := ydb.Open( - ctx, + db, err := ydb.Open(ctx, os.Getenv("YDB_CONNECTION_STRING"), ydb.WithBalancer( balancers.PreferLocalDC( diff --git a/ydb/docs/ru/core/reference/ydb-sdk/recipes/balancing/_includes/prefer_location/go.md b/ydb/docs/ru/core/reference/ydb-sdk/recipes/balancing/_includes/prefer_location/go.md index 500d2974a1..7d360849b9 100644 --- a/ydb/docs/ru/core/reference/ydb-sdk/recipes/balancing/_includes/prefer_location/go.md +++ b/ydb/docs/ru/core/reference/ydb-sdk/recipes/balancing/_includes/prefer_location/go.md @@ -12,8 +12,7 @@ import ( func main() { ctx, cancel := context.WithCancel(context.Background()) defer cancel() - db, err := ydb.Open( - ctx, + db, err := ydb.Open(ctx, os.Getenv("YDB_CONNECTION_STRING"), ydb.WithBalancer( balancers.PreferLocations( diff --git a/ydb/docs/ru/core/reference/ydb-sdk/recipes/balancing/_includes/random_choice/go.md b/ydb/docs/ru/core/reference/ydb-sdk/recipes/balancing/_includes/random_choice/go.md index 4206736823..a52aaa7827 100644 --- a/ydb/docs/ru/core/reference/ydb-sdk/recipes/balancing/_includes/random_choice/go.md +++ b/ydb/docs/ru/core/reference/ydb-sdk/recipes/balancing/_includes/random_choice/go.md @@ -12,8 +12,7 @@ import ( func main() { ctx, cancel := context.WithCancel(context.Background()) defer cancel() - db, err := ydb.Open( - ctx, + db, err := ydb.Open(ctx, os.Getenv("YDB_CONNECTION_STRING"), ydb.WithBalancer( balancers.RandomChoice(), diff --git a/ydb/docs/ru/core/reference/ydb-sdk/recipes/bulk_upsert/_includes/go.md b/ydb/docs/ru/core/reference/ydb-sdk/recipes/bulk_upsert/_includes/go.md index 2c8d8246f3..3876c0d522 100644 --- a/ydb/docs/ru/core/reference/ydb-sdk/recipes/bulk_upsert/_includes/go.md +++ b/ydb/docs/ru/core/reference/ydb-sdk/recipes/bulk_upsert/_includes/go.md @@ -6,13 +6,14 @@ import ( "os" "github.com/ydb-platform/ydb-go-sdk/v3" + "github.com/ydb-platform/ydb-go-sdk/v3/table" + "github.com/ydb-platform/ydb-go-sdk/v3/table/types" ) func main() { ctx, cancel := context.WithCancel(context.Background()) defer cancel() - db, err := ydb.Open( - ctx, + db, err := ydb.Open(ctx, os.Getenv("YDB_CONNECTION_STRING"), ydb.WithAccessTokenCredentials(os.Getenv("YDB_TOKEN")), ) diff --git a/ydb/docs/ru/core/reference/ydb-sdk/recipes/debug/_includes/jaeger/go.md b/ydb/docs/ru/core/reference/ydb-sdk/recipes/debug/_includes/jaeger/go.md index 668ba6ba04..a99be9ede9 100644 --- a/ydb/docs/ru/core/reference/ydb-sdk/recipes/debug/_includes/jaeger/go.md +++ b/ydb/docs/ru/core/reference/ydb-sdk/recipes/debug/_includes/jaeger/go.md @@ -44,12 +44,11 @@ func main() { span, ctx := opentracing.StartSpanFromContext(context.Background(), "client") defer span.Finish() - db, err := ydb.Open( - ctx, + db, err := ydb.Open(ctx, os.Getenv("YDB_CONNECTION_STRING"), tracing.WithTraces( tracing.WithDetails(trace.DetailsAll), - )), + ), ) if err != nil { panic(err) diff --git a/ydb/docs/ru/core/reference/ydb-sdk/recipes/debug/_includes/logs/go.md b/ydb/docs/ru/core/reference/ydb-sdk/recipes/debug/_includes/logs/go.md index fd792fdccc..00da506429 100644 --- a/ydb/docs/ru/core/reference/ydb-sdk/recipes/debug/_includes/logs/go.md +++ b/ydb/docs/ru/core/reference/ydb-sdk/recipes/debug/_includes/logs/go.md @@ -19,8 +19,7 @@ ctx, cancel := context.WithCancel(context.Background()) defer cancel() var log *zap.Logger // zap-logger with init out of this scope - db, err := ydb.Open( - ctx, + db, err := ydb.Open(ctx, os.Getenv("YDB_CONNECTION_STRING"), ydbZap.WithTraces( log, @@ -55,8 +54,7 @@ ctx, cancel := context.WithCancel(context.Background()) defer cancel() var log zerolog.Logger // zap-logger with init out of this scope - db, err := ydb.Open( - ctx, + db, err := ydb.Open(ctx, os.Getenv("YDB_CONNECTION_STRING"), ydbZerolog.WithTraces( log, @@ -89,13 +87,12 @@ ctx, cancel := context.WithCancel(context.Background()) defer cancel() var logger log.Logger // logger implementation with init out of this scope - db, err := ydb.Open( - ctx, + db, err := ydb.Open(ctx, os.Getenv("YDB_CONNECTION_STRING"), ydb.WithLogger( trace.DetailsAll, - ydb.WithExternalLogger(logger), - ), + ydb.WithExternalLogger(logger), + ), ) if err != nil { panic(err) diff --git a/ydb/docs/ru/core/reference/ydb-sdk/recipes/debug/_includes/prometheus/go.md b/ydb/docs/ru/core/reference/ydb-sdk/recipes/debug/_includes/prometheus/go.md index b5521453d7..466bb1b838 100644 --- a/ydb/docs/ru/core/reference/ydb-sdk/recipes/debug/_includes/prometheus/go.md +++ b/ydb/docs/ru/core/reference/ydb-sdk/recipes/debug/_includes/prometheus/go.md @@ -13,8 +13,7 @@ import ( func main() { ctx := context.Background() registry := prometheus.NewRegistry() - db, err := ydb.Open( - ctx, + db, err := ydb.Open(ctx, os.Getenv("YDB_CONNECTION_STRING"), metrics.WithTraces( registry, diff --git a/ydb/docs/ru/core/reference/ydb-sdk/recipes/retry/_includes/go.md b/ydb/docs/ru/core/reference/ydb-sdk/recipes/retry/_includes/go.md index 2a815c70ee..68558a1a1f 100644 --- a/ydb/docs/ru/core/reference/ydb-sdk/recipes/retry/_includes/go.md +++ b/ydb/docs/ru/core/reference/ydb-sdk/recipes/retry/_includes/go.md @@ -24,8 +24,7 @@ ) func main() { - db, err := ydb.Open( - ctx, + db, err := ydb.Open(ctx, os.Getenv("YDB_CONNECTION_STRING"), ) if err != nil { diff --git a/ydb/docs/ru/core/reference/ydb-sdk/recipes/session_pool_limit/_includes/go.md b/ydb/docs/ru/core/reference/ydb-sdk/recipes/session_pool_limit/_includes/go.md index 32fccc1141..653b08c103 100644 --- a/ydb/docs/ru/core/reference/ydb-sdk/recipes/session_pool_limit/_includes/go.md +++ b/ydb/docs/ru/core/reference/ydb-sdk/recipes/session_pool_limit/_includes/go.md @@ -8,8 +8,7 @@ import ( ) func main() { - db, err := ydb.Open( - ctx, + db, err := ydb.Open(ctx, os.Getenv("YDB_CONNECTION_STRING"), ydb.WithSessionPoolSizeLimit(500), ) diff --git a/ydb/docs/ru/core/reference/ydb-sdk/recipes/upsert/_includes/go.md b/ydb/docs/ru/core/reference/ydb-sdk/recipes/upsert/_includes/go.md index 82b74ed301..d8c158cb4a 100644 --- a/ydb/docs/ru/core/reference/ydb-sdk/recipes/upsert/_includes/go.md +++ b/ydb/docs/ru/core/reference/ydb-sdk/recipes/upsert/_includes/go.md @@ -6,13 +6,14 @@ import ( "os" "github.com/ydb-platform/ydb-go-sdk/v3" + "github.com/ydb-platform/ydb-go-sdk/v3/table" + "github.com/ydb-platform/ydb-go-sdk/v3/table/types" ) func main() { ctx, cancel := context.WithCancel(context.Background()) defer cancel() - db, err := ydb.Open( - ctx, + db, err := ydb.Open(ctx, os.Getenv("YDB_CONNECTION_STRING"), ydb.WithAccessTokenCredentials(os.Getenv("YDB_TOKEN")), ) @@ -26,8 +27,7 @@ func main() { err = db.Table().DoTx( // Do retry operation on errors with best effort ctx, // context manages exiting from Do func(ctx context.Context, tx table.TransactionActor) (err error) { // retry operation - res, err = tx.Execute( - ctx,` + res, err = tx.Execute(ctx, ` PRAGMA TablePathPrefix("/path/to/table"); DECLARE $seriesID AS Uint64; DECLARE $seasonID AS Uint64; |