From 42954c7cf12d4f501e72942079caa31bc46bb7c3 Mon Sep 17 00:00:00 2001 From: SoXX Date: Wed, 4 Sep 2024 13:41:29 +0200 Subject: [PATCH] feat(grpc): added ping added ping function --- pkg/plug/grpc.go | 18 ++++++++++++++++++ 1 file changed, 18 insertions(+) diff --git a/pkg/plug/grpc.go b/pkg/plug/grpc.go index 3a2b5f5..f769565 100644 --- a/pkg/plug/grpc.go +++ b/pkg/plug/grpc.go @@ -155,3 +155,21 @@ func (s *server) removeTask(taskID string) { fn() delete(s.ctx, taskID) } + +func (s *server) GetUserMessages(ctx context.Context, message *gRPC.GetMessagesRequest) (*gRPC.GetMessagesResponse, error) { + +} + +func (s *server) SendMessage(ctx context.Context, message *gRPC.SendMessageRequest) (*gRPC.SendMessageResponse, error) { +} + +func (s *server) Ping(ctx context.Context, ping *gRPC.PingRequest) (*gRPC.PongResponse, error) { + ctx, span := tracer.Start(ctx, "Ping") + defer span.End() + + var pong gRPC.PongResponse + pong.Message = ping.Message + pong.Timestamp = ping.Timestamp + + return &pong, nil +}