go/crud_generator
1
0
Fork 0
mirror of https://github.com/ManyakRus/crud_generator.git synced 2025-01-03 01:22:21 +02:00
Code Issues Releases Activity

сделал timeout_seconds

Browse Source
This commit is contained in:
Nikitin Aleksandr 2024-01-25 11:38:45 +03:00
parent 67ca0be64c
commit 52d54a1ddb
3 changed files with 59 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

25
bin/templates/pkg/network/grpc/constants/constants.go
View File

@ -1,5 +1,28 @@
package constants
var TIMEOUT_SECONDS = 30
import "sync"
// timeout_seconds - время ожидания ответа
var timeout_seconds int = 30
// TEXT_ERROR_MODEL_VERSION - текст ошибки версии модели
const TEXT_ERROR_MODEL_VERSION = "Error: wrong version object model"
// mutex_TIMEOUT_SECONDS - защита от многопоточности GetTimeoutSeconds()
var mutex_TIMEOUT_SECONDS sync.RWMutex
// GetTimeoutSeconds - возвращает время ожидания ответа
func GetTimeoutSeconds() int {
mutex_TIMEOUT_SECONDS.RLock()
defer mutex_TIMEOUT_SECONDS.RUnlock()
return timeout_seconds
}
// SetTimeoutSeconds - устанавливает время ожидания ответа
func SetTimeoutSeconds(seconds int) {
mutex_TIMEOUT_SECONDS.Lock()
defer mutex_TIMEOUT_SECONDS.Unlock()
timeout_seconds = seconds
}

14
bin/templates/pkg/network/grpc/grpc_client/grpc_client_table.go_
View File

@ -53,7 +53,7 @@ func (crud Crud_GRPC) Read(m *lawsuit_status_types.LawsuitStatusType) error {
Request.VersionModel = versionModel
ctxMain := context.Background()
ctx, ctxCancelFunc := context.WithTimeout(ctxMain, time.Second*time.Duration(constants.TIMEOUT_SECONDS))
ctx, ctxCancelFunc := context.WithTimeout(ctxMain, time.Second*time.Duration(constants.GetTimeoutSeconds()))
defer ctxCancelFunc()
// запрос
@ -97,7 +97,7 @@ func (crud Crud_GRPC) Create(m *lawsuit_status_types.LawsuitStatusType) error {
Request.VersionModel = VersionModel
ctxMain := context.Background()
ctx, ctxCancelFunc := context.WithTimeout(ctxMain, time.Second*time.Duration(constants.TIMEOUT_SECONDS))
ctx, ctxCancelFunc := context.WithTimeout(ctxMain, time.Second*time.Duration(constants.GetTimeoutSeconds()))
defer ctxCancelFunc()
// запрос
@ -141,7 +141,7 @@ func (crud Crud_GRPC) Update(m *lawsuit_status_types.LawsuitStatusType) error {
Request.VersionModel = VersionModel
ctxMain := context.Background()
ctx, ctxCancelFunc := context.WithTimeout(ctxMain, time.Second*time.Duration(constants.TIMEOUT_SECONDS))
ctx, ctxCancelFunc := context.WithTimeout(ctxMain, time.Second*time.Duration(constants.GetTimeoutSeconds()))
defer ctxCancelFunc()
// запрос
@ -185,7 +185,7 @@ func (crud Crud_GRPC) Save(m *lawsuit_status_types.LawsuitStatusType) error {
Request.VersionModel = VersionModel
ctxMain := context.Background()
ctx, ctxCancelFunc := context.WithTimeout(ctxMain, time.Second*time.Duration(constants.TIMEOUT_SECONDS))
ctx, ctxCancelFunc := context.WithTimeout(ctxMain, time.Second*time.Duration(constants.GetTimeoutSeconds()))
defer ctxCancelFunc()
// запрос
@ -225,7 +225,7 @@ func (crud Crud_GRPC) Delete(m *lawsuit_status_types.LawsuitStatusType) error {
Request.VersionModel = VersionModel
ctxMain := context.Background()
ctx, ctxCancelFunc := context.WithTimeout(ctxMain, time.Second*time.Duration(constants.TIMEOUT_SECONDS))
ctx, ctxCancelFunc := context.WithTimeout(ctxMain, time.Second*time.Duration(constants.GetTimeoutSeconds()))
defer ctxCancelFunc()
// запрос
@ -265,7 +265,7 @@ func (crud Crud_GRPC) Restore(m *lawsuit_status_types.LawsuitStatusType) error {
Request.VersionModel = VersionModel
ctxMain := context.Background()
ctx, ctxCancelFunc := context.WithTimeout(ctxMain, time.Second*time.Duration(constants.TIMEOUT_SECONDS))
ctx, ctxCancelFunc := context.WithTimeout(ctxMain, time.Second*time.Duration(constants.GetTimeoutSeconds()))
defer ctxCancelFunc()
// запрос
@ -304,7 +304,7 @@ func (crud Crud_GRPC) Find_ByExtID(m *lawsuit_status_types.LawsuitStatusType) er
Request.VersionModel = VersionModel
ctxMain := context.Background()
ctx, ctxCancelFunc := context.WithTimeout(ctxMain, time.Second*time.Duration(constants.TIMEOUT_SECONDS))
ctx, ctxCancelFunc := context.WithTimeout(ctxMain, time.Second*time.Duration(constants.GetTimeoutSeconds()))
defer ctxCancelFunc()
//запрос

28
bin/templates/pkg/network/nrpc/nrpc_client/constants/constants.go Normal file
View File

@ -0,0 +1,28 @@
package constants
import "sync"
// timeout_seconds - время ожидания ответа
var timeout_seconds int = 30
// TEXT_ERROR_MODEL_VERSION - текст ошибки версии модели
const TEXT_ERROR_MODEL_VERSION = "Error: wrong version object model"
// mutex_TIMEOUT_SECONDS - защита от многопоточности GetTimeoutSeconds()
var mutex_TIMEOUT_SECONDS sync.RWMutex
// GetTimeoutSeconds - возвращает время ожидания ответа
func GetTimeoutSeconds() int {
mutex_TIMEOUT_SECONDS.RLock()
defer mutex_TIMEOUT_SECONDS.RUnlock()
return timeout_seconds
}
// SetTimeoutSeconds - устанавливает время ожидания ответа
func SetTimeoutSeconds(seconds int) {
mutex_TIMEOUT_SECONDS.Lock()
defer mutex_TIMEOUT_SECONDS.Unlock()
timeout_seconds = seconds
}