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