From 7e586aef90212da05800f1f01266e1f8b85c3c19 Mon Sep 17 00:00:00 2001 From: Leonard Lyubich Date: Mon, 1 Feb 2021 15:31:40 +0300 Subject: [PATCH] [#328] container/grpc: Implement AnnounceUsedSpace method Add AnnounceUsedSpace method that converts gRPC request to v2 request and passes it to v2 client. Signed-off-by: Leonard Lyubich --- pkg/network/transport/container/grpc/service.go | 11 +++++++++++ 1 file changed, 11 insertions(+) diff --git a/pkg/network/transport/container/grpc/service.go b/pkg/network/transport/container/grpc/service.go index d4583111..1323331b 100644 --- a/pkg/network/transport/container/grpc/service.go +++ b/pkg/network/transport/container/grpc/service.go @@ -85,3 +85,14 @@ func (s *Server) GetExtendedACL(ctx context.Context, req *containerGRPC.GetExten return container.GetExtendedACLResponseToGRPCMessage(resp), nil } + +// AnnounceUsedSpace converts gRPC AnnounceUsedSpaceRequest message and passes it to internal Container service. +func (s *Server) AnnounceUsedSpace(ctx context.Context, req *containerGRPC.AnnounceUsedSpaceRequest) (*containerGRPC.AnnounceUsedSpaceResponse, error) { + resp, err := s.srv.AnnounceUsedSpace(ctx, container.AnnounceUsedSpaceRequestFromGRPCMessage(req)) + if err != nil { + // TODO: think about how we transport errors through gRPC + return nil, err + } + + return container.AnnounceUsedSpaceResponseToGRPCMessage(resp), nil +}