ITQ/Datarush
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

chore(api)!: updated grpc files

Browse Source
This commit is contained in:
ITQ
2025-12-16 17:21:30 +03:00
parent 7f267f61f4
commit c9bdc488d7
12 changed files with 587 additions and 113 deletions
Download Patch File Download Diff File Expand all files Collapse all files
pkg/api/task/task_grpc.pb.go
+114
View File
@@ -19,7 +19,10 @@ import (
const _ = grpc.SupportPackageIsVersion9
const (
TaskService_CreateTask_FullMethodName = "/task.TaskService/CreateTask"
TaskService_GetTask_FullMethodName = "/task.TaskService/GetTask"
TaskService_EditTask_FullMethodName = "/task.TaskService/EditTask"
TaskService_DeleteTask_FullMethodName = "/task.TaskService/DeleteTask"
TaskService_ListCompetitionTasks_FullMethodName = "/task.TaskService/ListCompetitionTasks"
TaskService_GetTaskAttachments_FullMethodName = "/task.TaskService/GetTaskAttachments"
)
@@ -28,7 +31,10 @@ const (
//
// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
type TaskServiceClient interface {
CreateTask(ctx context.Context, in *Task, opts ...grpc.CallOption) (*Task, error)
GetTask(ctx context.Context, in *GetTaskRequest, opts ...grpc.CallOption) (*Task, error)
EditTask(ctx context.Context, in *Task, opts ...grpc.CallOption) (*Task, error)
DeleteTask(ctx context.Context, in *DeleteTaskRequest, opts ...grpc.CallOption) (*DeleteTaskResponse, error)
ListCompetitionTasks(ctx context.Context, in *ListCompetitionTasksRequest, opts ...grpc.CallOption) (*ListCompetitionTasksResponse, error)
GetTaskAttachments(ctx context.Context, in *GetTaskAttachmentsRequest, opts ...grpc.CallOption) (*GetTaskAttachmentsResponse, error)
}
@@ -41,6 +47,16 @@ func NewTaskServiceClient(cc grpc.ClientConnInterface) TaskServiceClient {
return &taskServiceClient{cc}
}
func (c *taskServiceClient) CreateTask(ctx context.Context, in *Task, opts ...grpc.CallOption) (*Task, error) {
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
out := new(Task)
err := c.cc.Invoke(ctx, TaskService_CreateTask_FullMethodName, in, out, cOpts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *taskServiceClient) GetTask(ctx context.Context, in *GetTaskRequest, opts ...grpc.CallOption) (*Task, error) {
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
out := new(Task)
@@ -51,6 +67,26 @@ func (c *taskServiceClient) GetTask(ctx context.Context, in *GetTaskRequest, opt
return out, nil
}
func (c *taskServiceClient) EditTask(ctx context.Context, in *Task, opts ...grpc.CallOption) (*Task, error) {
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
out := new(Task)
err := c.cc.Invoke(ctx, TaskService_EditTask_FullMethodName, in, out, cOpts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *taskServiceClient) DeleteTask(ctx context.Context, in *DeleteTaskRequest, opts ...grpc.CallOption) (*DeleteTaskResponse, error) {
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
out := new(DeleteTaskResponse)
err := c.cc.Invoke(ctx, TaskService_DeleteTask_FullMethodName, in, out, cOpts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *taskServiceClient) ListCompetitionTasks(ctx context.Context, in *ListCompetitionTasksRequest, opts ...grpc.CallOption) (*ListCompetitionTasksResponse, error) {
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
out := new(ListCompetitionTasksResponse)
@@ -75,7 +111,10 @@ func (c *taskServiceClient) GetTaskAttachments(ctx context.Context, in *GetTaskA
// All implementations must embed UnimplementedTaskServiceServer
// for forward compatibility.
type TaskServiceServer interface {
CreateTask(context.Context, *Task) (*Task, error)
GetTask(context.Context, *GetTaskRequest) (*Task, error)
EditTask(context.Context, *Task) (*Task, error)
DeleteTask(context.Context, *DeleteTaskRequest) (*DeleteTaskResponse, error)
ListCompetitionTasks(context.Context, *ListCompetitionTasksRequest) (*ListCompetitionTasksResponse, error)
GetTaskAttachments(context.Context, *GetTaskAttachmentsRequest) (*GetTaskAttachmentsResponse, error)
mustEmbedUnimplementedTaskServiceServer()
@@ -88,9 +127,18 @@ type TaskServiceServer interface {
// pointer dereference when methods are called.
type UnimplementedTaskServiceServer struct{}
func (UnimplementedTaskServiceServer) CreateTask(context.Context, *Task) (*Task, error) {
return nil, status.Error(codes.Unimplemented, "method CreateTask not implemented")
}
func (UnimplementedTaskServiceServer) GetTask(context.Context, *GetTaskRequest) (*Task, error) {
return nil, status.Error(codes.Unimplemented, "method GetTask not implemented")
}
func (UnimplementedTaskServiceServer) EditTask(context.Context, *Task) (*Task, error) {
return nil, status.Error(codes.Unimplemented, "method EditTask not implemented")
}
func (UnimplementedTaskServiceServer) DeleteTask(context.Context, *DeleteTaskRequest) (*DeleteTaskResponse, error) {
return nil, status.Error(codes.Unimplemented, "method DeleteTask not implemented")
}
func (UnimplementedTaskServiceServer) ListCompetitionTasks(context.Context, *ListCompetitionTasksRequest) (*ListCompetitionTasksResponse, error) {
return nil, status.Error(codes.Unimplemented, "method ListCompetitionTasks not implemented")
}
@@ -118,6 +166,24 @@ func RegisterTaskServiceServer(s grpc.ServiceRegistrar, srv TaskServiceServer) {
s.RegisterService(&TaskService_ServiceDesc, srv)
}
func _TaskService_CreateTask_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(Task)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(TaskServiceServer).CreateTask(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: TaskService_CreateTask_FullMethodName,
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(TaskServiceServer).CreateTask(ctx, req.(*Task))
}
return interceptor(ctx, in, info, handler)
}
func _TaskService_GetTask_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(GetTaskRequest)
if err := dec(in); err != nil {
@@ -136,6 +202,42 @@ func _TaskService_GetTask_Handler(srv interface{}, ctx context.Context, dec func
return interceptor(ctx, in, info, handler)
}
func _TaskService_EditTask_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(Task)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(TaskServiceServer).EditTask(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: TaskService_EditTask_FullMethodName,
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(TaskServiceServer).EditTask(ctx, req.(*Task))
}
return interceptor(ctx, in, info, handler)
}
func _TaskService_DeleteTask_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(DeleteTaskRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(TaskServiceServer).DeleteTask(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: TaskService_DeleteTask_FullMethodName,
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(TaskServiceServer).DeleteTask(ctx, req.(*DeleteTaskRequest))
}
return interceptor(ctx, in, info, handler)
}
func _TaskService_ListCompetitionTasks_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(ListCompetitionTasksRequest)
if err := dec(in); err != nil {
@@ -179,10 +281,22 @@ var TaskService_ServiceDesc = grpc.ServiceDesc{
ServiceName: "task.TaskService",
HandlerType: (*TaskServiceServer)(nil),
Methods: []grpc.MethodDesc{
{
MethodName: "CreateTask",
Handler: _TaskService_CreateTask_Handler,
},
{
MethodName: "GetTask",
Handler: _TaskService_GetTask_Handler,
},
{
MethodName: "EditTask",
Handler: _TaskService_EditTask_Handler,
},
{
MethodName: "DeleteTask",
Handler: _TaskService_DeleteTask_Handler,
},
{
MethodName: "ListCompetitionTasks",
Handler: _TaskService_ListCompetitionTasks_Handler,