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 +}