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

сделал if ctx.Err() != nil

Browse Source
This commit is contained in:
Nikitin Aleksandr 2024-06-03 13:23:29 +03:00
parent 4c90844815
commit 07e5a5e4a4
4 changed files with 20 additions and 23 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

29
bin/templates/internal/app/grpc/server_grpc/server_grpc.go_
View File

@ -2,7 +2,6 @@ package server_grpc
import (
"context"
"github.com/ManyakRus/starter/micro"
"github.com/ManyakRus/starter/postgres_gorm"
"gitlab.aescorp.ru/dsp_dev/claim/sync_service/pkg/network/grpc/grpc_proto"
"gitlab.aescorp.ru/dsp_dev/claim/sync_service/pkg/object_model/entities/lawsuit_status_types"
@ -15,8 +14,8 @@ func (s *ServerGRPC) LawsuitStatusType_Read(ctx context.Context, Request *grpc_p
var err error
//проверим контекст уже отменён
if micro.ContextDone(ctx) == true {
err = context.Canceled
if ctx.Err() != nil {
err = ctx.Err()
return &Otvet, err
}
@ -54,8 +53,8 @@ func (s *ServerGRPC) LawsuitStatusType_Delete(ctx context.Context, Request *grpc
var err error
//проверим контекст уже отменён
if micro.ContextDone(ctx) == true {
err = context.Canceled
if ctx.Err() != nil {
err = ctx.Err()
return &Otvet, err
}
@ -93,8 +92,8 @@ func (s *ServerGRPC) LawsuitStatusType_Restore(ctx context.Context, Request *grp
var err error
//проверим контекст уже отменён
if micro.ContextDone(ctx) == true {
err = context.Canceled
if ctx.Err() != nil {
err = ctx.Err()
return &Otvet, err
}
@ -132,8 +131,8 @@ func (s *ServerGRPC) LawsuitStatusType_Create(ctx context.Context, Request *grpc
var err error
//проверим контекст уже отменён
if micro.ContextDone(ctx) == true {
err = context.Canceled
if ctx.Err() != nil {
err = ctx.Err()
return &Otvet, err
}
@ -175,8 +174,8 @@ func (s *ServerGRPC) LawsuitStatusType_Update(ctx context.Context, Request *grpc
var err error
//проверим контекст уже отменён
if micro.ContextDone(ctx) == true {
err = context.Canceled
if ctx.Err() != nil {
err = ctx.Err()
return &Otvet, err
}
@ -218,8 +217,8 @@ func (s *ServerGRPC) LawsuitStatusType_Save(ctx context.Context, Request *grpc_p
var err error
//проверим контекст уже отменён
if micro.ContextDone(ctx) == true {
err = context.Canceled
if ctx.Err() != nil {
err = ctx.Err()
return &Otvet, err
}
@ -261,8 +260,8 @@ func (s *ServerGRPC) LawsuitStatusType_FindByExtID(ctx context.Context, Request
var err error
//проверим контекст уже отменён
if micro.ContextDone(ctx) == true {
err = context.Canceled
if ctx.Err() != nil {
err = ctx.Err()
return &Otvet, err
}

5
bin/templates/internal/app/grpc/server_grpc/server_grpc_table_cache.go_
View File

@ -3,7 +3,6 @@ package server_grpc
import (
"context"
"time"
"github.com/ManyakRus/starter/micro"
"github.com/ManyakRus/starter/contextmain"
"github.com/ManyakRus/starter/postgres_gorm"
"gitlab.aescorp.ru/dsp_dev/claim/sync_service/api/grpc_proto"
@ -17,8 +16,8 @@ func (s *ServerGRPC) LawsuitStatusType_ReadFromCache(ctx context.Context, Reques
var err error
//проверим контекст уже отменён
if micro.ContextDone(ctx) == true {
err = context.Canceled
if ctx.Err() != nil {
err = ctx.Err()
return &Otvet, err
}

5
bin/templates/internal/app/grpc/server_grpc/server_grpc_table_update.go_
View File

@ -2,7 +2,6 @@ package server_grpc
import (
"context"
"github.com/ManyakRus/starter/micro"
"github.com/ManyakRus/starter/contextmain"
"github.com/ManyakRus/starter/postgres_gorm"
"gitlab.aescorp.ru/dsp_dev/claim/sync_service/api/grpc_proto"
@ -18,8 +17,8 @@ func (s *ServerGRPC) LawsuitStatusType_UpdateManyFields(ctx context.Context, Req
var err error
//проверим контекст уже отменён
if micro.ContextDone(ctx) == true {
err = context.Canceled
if ctx.Err() != nil {
err = ctx.Err()
return &Otvet, err
}

4
bin/templates/internal/app/grpc/server_grpc/server_grpc_table_update_func.go_
View File

@ -4,8 +4,8 @@ func (s *ServerGRPC) LawsuitStatusType_Update(ctx context.Context, Request *grpc
var err error
//проверим контекст уже отменён
if micro.ContextDone(ctx) == true {
err = context.Canceled
if ctx.Err() != nil {
err = ctx.Err()
return &Otvet, err
}