diff options
author | Aleksey Myasnikov <79263256394@ya.ru> | 2022-04-04 18:57:17 +0300 |
---|---|---|
committer | Aleksey Myasnikov <79263256394@ya.ru> | 2022-04-04 18:57:17 +0300 |
commit | e8cd12dd772de3f6b4436f58182da60e177ae9be (patch) | |
tree | a4a86cb22935f4d037cf032de71e4a77d2575d8b | |
parent | 9c78102d1e1acf1d50bef8ed6189be487eed9521 (diff) | |
download | ydb-e8cd12dd772de3f6b4436f58182da60e177ae9be.tar.gz |
Change "timeouts.md"
ref:fb9c6d1f35079135c22730b20f373c1553744201
-rw-r--r-- | ydb/docs/ru/core/best_practices/_includes/timeouts.md | 21 |
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()) } ``` |