removed mutex from redisDB struct and moved Execute method to shards.go file

2 files changed, 8 insertions, 10 deletions

diff --git a/redisDB.go b/redisDB.go
index 939fbbe..cde14d0 100644
--- a/redisDB.go
+++ b/redisDB.go
@@ -2,7 +2,6 @@ package main
 
 import (
 	"fmt"
-	"sync"
 	"time"
 )
 type Item struct {
@@ -11,19 +10,11 @@ type Item struct {
 }
 
 type RedisDB struct {
-	mu   sync.Mutex
 	shards []*Shard
 }
 
 type SimpleString string
 
-func (db *RedisDB) Execute(key string, fn func(*Shard) interface{}) interface{} {
-    shard := db.getShard(key)
-    shard.mu.Lock()
-    defer shard.mu.Unlock()
-    return fn(shard)
-}
-
 func serializeRESP(v any) []byte {
     switch val := v.(type) {
     case string:
diff --git a/shards.go b/shards.go
index bd19751..cba4dd4 100644
--- a/shards.go
+++ b/shards.go
@@ -16,4 +16,11 @@ func (db *RedisDB) getShard(key string)*Shard{
 	val := hash.Sum64()
 
 	return db.shards[val%16]
-}
\ No newline at end of file
+}
+
+func (db *RedisDB) Execute(key string, fn func(*Shard) interface{}) interface{} {
+    shard := db.getShard(key)
+    shard.mu.Lock()
+    defer shard.mu.Unlock()
+    return fn(shard)
+}