aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorAleksey Myasnikov <79263256394@ya.ru>2022-04-04 18:57:17 +0300
committerAleksey Myasnikov <79263256394@ya.ru>2022-04-04 18:57:17 +0300
commite8cd12dd772de3f6b4436f58182da60e177ae9be (patch)
treea4a86cb22935f4d037cf032de71e4a77d2575d8b
parent9c78102d1e1acf1d50bef8ed6189be487eed9521 (diff)
downloadydb-e8cd12dd772de3f6b4436f58182da60e177ae9be.tar.gz
Change "timeouts.md"
ref:fb9c6d1f35079135c22730b20f373c1553744201
-rw-r--r--ydb/docs/ru/core/best_practices/_includes/timeouts.md21
1 files changed, 11 insertions, 10 deletions
diff --git a/ydb/docs/ru/core/best_practices/_includes/timeouts.md b/ydb/docs/ru/core/best_practices/_includes/timeouts.md
index e75d2563687..14eb38453a7 100644
--- a/ydb/docs/ru/core/best_practices/_includes/timeouts.md
+++ b/ydb/docs/ru/core/best_practices/_includes/timeouts.md
@@ -82,18 +82,19 @@ description: 'Значение operation_timeout определяет время
```go
import (
- "context"
- "a.yandex-team.ru/kikimr/public/sdk/go/ydb"
- "a.yandex-team.ru/kikimr/public/sdk/go/ydb/table"
+ "context"
+
+ ydb "github.com/ydb-platform/ydb-go-sdk/v3"
+ "github.com/ydb-platform/ydb-go-sdk/v3/table"
)
- func executeInTx(ctx context.Context, s *table.Session, query string) {
- newCtx, close := context.WithTimeout(ctx, time.Millisecond*300) // client and by default operation timeout
- newCtx2 := ydb.WithOperationTimeout(newCtx, time.Millisecond*400) // operation timeout override
- newCtx3 := ydb.WithOperationCancelAfter(newCtx2, time.Millisecond*300) // cancel after timeout
- defer close()
- tx := table.TxControl(table.BeginTx(table.WithSerializableReadWrite()), table.CommitTx())
- _, res, err := session.Execute(newCtx3, tx, query)
+ func executeInTx(ctx context.Context, s table.Session, query string) {
+ ctx, cancel := context.WithTimeout(ctx, time.Millisecond*300) // client and by default operation timeout
+ defer cancel()
+ ctx = ydb.WithOperationTimeout(ctx, time.Millisecond*400) // operation timeout override
+ ctx = ydb.WithOperationCancelAfter(ctx, time.Millisecond*300) // cancel after timeout
+ tx := table.TxControl(table.BeginTx(table.WithSerializableReadWrite()), table.CommitTx())
+ _, res, err := s.Execute(ctx, tx, query, table.NewQueryParameters())
}
```