From a71faf43c50ffa2c91bd33773e6fea90e03aeee0 Mon Sep 17 00:00:00 2001
From: wilhelmagren <wilhelmagren98@gmail.com>
Date: Mon, 5 Feb 2024 20:55:02 +0100
Subject: [PATCH] feat(mock): multithreaded mocking start implement

---
 src/mock.rs | 23 +++++++++++++++++++----
 1 file changed, 19 insertions(+), 4 deletions(-)

diff --git a/src/mock.rs b/src/mock.rs
index 2dd976b..c30c2e1 100644
--- a/src/mock.rs
+++ b/src/mock.rs
@@ -1,7 +1,7 @@
 /*
 * MIT License
 *
-* Copyright (c) 2023 Firelink Data
+* Copyright (c) 2024 Firelink Data
 *
 * Permission is hereby granted, free of charge, to any person obtaining a copy
 * of this software and associated documentation files (the "Software"), to deal
@@ -21,8 +21,8 @@
 * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
 * SOFTWARE.
 *
-* File created: 2023-11-28
-* Last updated: 2023-12-22
+* File created: 2024-02-05
+* Last updated: 2024-02-05
 */
 
 use crate::schema::{self, FixedSchema};
@@ -34,12 +34,27 @@ use std::fs::OpenOptions;
 use std::io::Write;
 use std::path::PathBuf;
 use std::sync::Arc;
-use std::thread;
+use std::{thread, usize};
 use std::time::SystemTime;
 
 pub(crate) static DEFAULT_MOCKED_FILENAME_LEN: usize = 16;
 pub(crate) static DEFAULT_ROW_BUFFER_LEN: usize = 1024 * 1024;
 
+pub struct Mocker {
+    schema: schema::FixedSchema,
+    target_file: Option<PathBuf>,
+}
+
+impl Mocker {
+    pub fn new(schema: schema::FixedSchema, target_file: Option<PathBuf>) -> Self {
+        Self { schema, target_file }
+    }
+
+    pub fn generate(&self, n_rows: usize, multithreaded: bool) {
+        todo!()
+    }
+}
+
 ///
 pub struct FixedMocker {
     schema: schema::FixedSchema,