interface => any

Reviewed-on: #2

abstruct.go

@@ -13,25 +13,38 @@ package easymap
 //
 // Date : 9:56 下午 2021/2/23
 type EasyMap interface {
-	Get(key interface{}) (interface{}, error)
+	Get(key any) (any, bool)
-	GetWithReceiver(key interface{}, dest interface{}) error
+	GetWithReceiver(key any, dest any) error
-	GetUint(key interface{}) (uint, error)
+	GetUint(key any) (uint, error)
-	GetUint8(key interface{}) (uint8, error)
+	GetUint8(key any) (uint8, error)
-	GetUint16(key interface{}) (uint16, error)
+	GetUint16(key any) (uint16, error)
-	GetUint32(key interface{}) (uint32, error)
+	GetUint32(key any) (uint32, error)
-	GetUint64(key interface{}) (uint64, error)
+	GetUint64(key any) (uint64, error)
-	GetInt(key interface{}) (int, error)
+	GetInt(key any) (int, error)
-	GetInt8(key interface{}) (int8, error)
+	GetInt8(key any) (int8, error)
-	GetInt16(key interface{}) (int16, error)
+	GetInt16(key any) (int16, error)
-	GetInt32(key interface{}) (int32, error)
+	GetInt32(key any) (int32, error)
-	GetInt64(key interface{}) (int64, error)
+	GetInt64(key any) (int64, error)
-	GetFloat32(key interface{}) (float32, error)
+	GetFloat32(key any) (float32, error)
-	GetFloat64(key interface{}) (float64, error)
+	GetFloat64(key any) (float64, error)
-	GetBool(key interface{}) (bool, error)
+	GetBool(key any) (bool, error)
-	GetString(key interface{}) (string, error)
+	GetString(key any) (string, error)
-	Set(key interface{}, value interface{})
+	Set(key any, value any)
-	Del(key interface{})
+	Del(key any)
-	Exist(key interface{}) bool
+	Exist(key any) bool
-	GetAll() map[interface{}]interface{}
+	Count() int
-	GetAllForMapKeyString() map[string]interface{}
+	GetAll() map[any]any
+	GetAllForMapKeyString() map[string]any
+	// Merge 合并数据
+	Merge(mergeData ...EasyMap)
+	// MergeWithReceiver 合并数据并转换
+	MergeWithReceiver(receiver any, mergeData ...EasyMap) error
+	// Iterator 对数据的迭代
+	Iterator(IteratorFunc)
+	// ToStruct 转换成结构体
+	ToStruct(receiver any) error
+	// ToString 转为字符串
+	ToString() string
+	// Filter 过滤数据
+	Filter(ignoreFieldList []string, rewriteFieldTable map[string]string) map[string]any
 }

common.go

@@ -0,0 +1,434 @@
+// Package easymap ...
+//
+// Description : easymap ...
+//
+// Author : go_developer@163.com<白茶清欢>
+//
+// Date : 2023-12-14 15:51
+package easymap
+
+import (
+	"encoding/json"
+	"errors"
+	"fmt"
+	"git.zhangdeman.cn/zhangdeman/serialize"
+	"git.zhangdeman.cn/zhangdeman/util"
+	"sync"
+)
+
+// common 公共基础结构
+//
+// Author : go_developer@163.com<白茶清欢>
+//
+// Date : 15:52 2023/12/14
+type common struct {
+	normalDataTable  []map[any]any // 普通数组
+	syncMapDataTable []sync.Map    // sync_map类型
+	dataTableType    string        // 数据表类型
+	segment          int           // 分片熟练
+	lock             *sync.RWMutex // 数据锁
+}
+
+// initLock ...
+//
+// Author : go_developer@163.com<白茶清欢>
+//
+// Date : 21:25 2023/12/24
+func (c *common) initLock() {
+	if c.dataTableType == normalDataTableType {
+		c.lock = &sync.RWMutex{}
+	}
+}
+
+// Lock ...
+//
+// Author : go_developer@163.com<白茶清欢>
+//
+// Date : 21:27 2023/12/24
+func (c *common) Lock() {
+	if nil == c.lock {
+		return
+	}
+	c.lock.Lock()
+}
+
+// Unlock ...
+//
+// Author : go_developer@163.com<白茶清欢>
+//
+// Date : 21:27 2023/12/24
+func (c *common) Unlock() {
+	if nil == c.lock {
+		return
+	}
+	c.lock.Unlock()
+}
+
+// RLock ...
+//
+// Author : go_developer@163.com<白茶清欢>
+//
+// Date : 21:43 2023/12/24
+func (c *common) RLock() {
+	if nil == c.lock {
+		return
+	}
+	c.lock.RLock()
+}
+
+// RUnlock ...
+//
+// Author : go_developer@163.com<白茶清欢>
+//
+// Date : 21:43 2023/12/24
+func (c *common) RUnlock() {
+	if nil == c.lock {
+		return
+	}
+	c.lock.RUnlock()
+}
+
+func (c *common) Get(key any) (any, bool) {
+	segmentIndex := util.Hash.GetHashIDMod(key, c.segment)
+	c.RLock()
+	defer c.RUnlock()
+	if c.dataTableType == normalDataTableType {
+		data, exist := c.normalDataTable[segmentIndex][key]
+		return data, exist
+	} else {
+		// sync map
+		return c.syncMapDataTable[segmentIndex].Load(key)
+	}
+}
+
+func (c *common) GetWithReceiver(key any, dest any) error {
+	if nil == dest {
+		return errors.New("dest is nil")
+	}
+	val, exist := c.Get(key)
+	if !exist {
+		return fmt.Errorf("key %v not exist", key)
+	}
+	if nil == val {
+		return errors.New("value is nil")
+	}
+	return util.ConvertAssign(dest, val)
+}
+
+func (c *common) GetUint(key any) (uint, error) {
+	var (
+		val uint
+		err error
+	)
+	err = c.GetWithReceiver(key, &val)
+	return val, err
+}
+
+func (c *common) GetUint8(key any) (uint8, error) {
+	var (
+		val uint8
+		err error
+	)
+	err = c.GetWithReceiver(key, &val)
+	return val, err
+}
+
+func (c *common) GetUint16(key any) (uint16, error) {
+	var (
+		val uint16
+		err error
+	)
+	err = c.GetWithReceiver(key, &val)
+	return val, err
+}
+
+func (c *common) GetUint32(key any) (uint32, error) {
+	var (
+		val uint32
+		err error
+	)
+	err = c.GetWithReceiver(key, &val)
+	return val, err
+}
+
+func (c *common) GetUint64(key any) (uint64, error) {
+	var (
+		val uint64
+		err error
+	)
+	err = c.GetWithReceiver(key, &val)
+	return val, err
+}
+
+func (c *common) GetInt(key any) (int, error) {
+	var (
+		val int
+		err error
+	)
+	err = c.GetWithReceiver(key, &val)
+	return val, err
+}
+
+func (c *common) GetInt8(key any) (int8, error) {
+	var (
+		val int8
+		err error
+	)
+	err = c.GetWithReceiver(key, &val)
+	return val, err
+}
+
+func (c *common) GetInt16(key any) (int16, error) {
+	var (
+		val int16
+		err error
+	)
+	err = c.GetWithReceiver(key, &val)
+	return val, err
+}
+
+func (c *common) GetInt32(key any) (int32, error) {
+	var (
+		val int32
+		err error
+	)
+	err = c.GetWithReceiver(key, &val)
+	return val, err
+}
+
+func (c *common) GetInt64(key any) (int64, error) {
+	var (
+		val int64
+		err error
+	)
+	err = c.GetWithReceiver(key, &val)
+	return val, err
+}
+
+func (c *common) GetFloat32(key any) (float32, error) {
+	var (
+		val float32
+		err error
+	)
+	err = c.GetWithReceiver(key, &val)
+	return val, err
+}
+
+func (c *common) GetFloat64(key any) (float64, error) {
+	var (
+		val float64
+		err error
+	)
+	err = c.GetWithReceiver(key, &val)
+	return val, err
+}
+
+func (c *common) GetBool(key any) (bool, error) {
+	var (
+		val bool
+		err error
+	)
+	err = c.GetWithReceiver(key, &val)
+	return val, err
+}
+
+func (c *common) GetString(key any) (string, error) {
+	var (
+		val string
+		err error
+	)
+	err = c.GetWithReceiver(key, &val)
+	return val, err
+}
+
+func (c *common) Set(key any, value any) {
+	segmentIndex := util.Hash.GetHashIDMod(key, c.segment)
+	c.Lock()
+	defer c.Unlock()
+	if c.dataTableType == normalDataTableType {
+		c.normalDataTable[segmentIndex][key] = value
+	} else {
+		// sync map
+		c.syncMapDataTable[segmentIndex].Store(key, value)
+	}
+}
+
+func (c *common) Del(key any) {
+	segmentIndex := util.Hash.GetHashIDMod(key, c.segment)
+	c.Lock()
+	defer c.Unlock()
+	if c.dataTableType == normalDataTableType {
+		delete(c.normalDataTable[segmentIndex], key)
+	} else {
+		c.syncMapDataTable[segmentIndex].Delete(key)
+	}
+}
+
+func (c *common) Exist(key any) bool {
+	_, exist := c.Get(key)
+	return exist
+}
+
+// Count 计算元素数量
+//
+// Author : go_developer@163.com<白茶清欢>
+//
+// Date : 14:21 2024/1/30
+func (c *common) Count() int {
+	cnt := 0
+	c.RLock()
+	defer c.RUnlock()
+	for i := 0; i < c.segment; i++ {
+		cnt = cnt + len(c.normalDataTable[i])
+	}
+	return cnt
+}
+
+func (c *common) GetAll() map[any]any {
+	result := make(map[any]any)
+	c.RLock()
+	defer c.RUnlock()
+	for i := 0; i < c.segment; i++ {
+		if c.dataTableType == normalDataTableType {
+			for k, v := range c.normalDataTable[i] {
+				result[k] = v
+			}
+		} else {
+			c.syncMapDataTable[i].Range(func(key, value any) bool {
+				result[key] = value
+				return true
+			})
+		}
+	}
+	return result
+}
+
+// GetAllForMapKeyString ...
+//
+// Author : go_developer@163.com<白茶清欢>
+//
+// Date : 9:48 下午 2021/9/15
+func (c *common) GetAllForMapKeyString() map[string]any {
+	fullData := c.GetAll()
+	finalData := make(map[string]any)
+	for k, v := range fullData {
+		finalData[fmt.Sprintf("%v", k)] = v
+	}
+	return finalData
+}
+
+// Iterator ...
+//
+// Author : go_developer@163.com<白茶清欢>
+//
+// Date : 17:32 2023/3/7
+func (c *common) Iterator(handleFunc IteratorFunc) {
+	if nil == handleFunc {
+		return
+	}
+	c.Lock()
+	c.Unlock()
+	isBreak := false
+	for i := 0; i < c.segment; i++ {
+		if c.dataTableType == normalDataTableType {
+			for k, v := range c.normalDataTable[i] {
+				if !handleFunc(k, v) {
+					isBreak = true
+					break
+				}
+			}
+			if isBreak {
+				break
+			}
+		} else {
+			c.syncMapDataTable[i].Range(func(key, value any) bool {
+				return handleFunc(key, value)
+			})
+		}
+	}
+}
+
+// ToStruct ...
+//
+// Author : go_developer@163.com<白茶清欢>
+//
+// Date : 15:42 2023/8/10
+func (c *common) ToStruct(receiver any) error {
+	if nil == receiver {
+		return errors.New("receiver is nil")
+	}
+	mapData := c.GetAll()
+	byteData, err := json.Marshal(mapData)
+	if nil != err {
+		return err
+	}
+	return serialize.JSON.UnmarshalWithNumber(byteData, receiver)
+}
+
+// ToString 转字符串
+//
+// Author : go_developer@163.com<白茶清欢>
+//
+// Date : 20:44 2023/8/15
+func (c *common) ToString() string {
+	mapData := c.GetAllForMapKeyString()
+	return serialize.JSON.MarshalForStringIgnoreError(mapData)
+}
+
+// Filter 对数据进行过滤
+//
+// Author : go_developer@163.com<白茶清欢>
+//
+// Date : 16:25 2024/3/8
+func (c *common) Filter(ignoreFieldList []string, rewriteFieldTable map[string]string) map[string]any {
+	if nil == ignoreFieldList {
+		ignoreFieldList = make([]string, 0)
+	}
+	if nil == rewriteFieldTable {
+		rewriteFieldTable = make(map[string]string)
+	}
+	result := make(map[string]any)
+	ignoreFieldTable := make(map[string]bool)
+	for _, item := range ignoreFieldList {
+		ignoreFieldTable[item] = true
+	}
+	data := c.GetAllForMapKeyString()
+	for field, val := range data {
+		if _, exist := ignoreFieldTable[field]; exist {
+			// 忽略当前字段
+			continue
+		}
+		if rewriteField, exist := rewriteFieldTable[field]; exist && len(rewriteField) > 0 {
+			field = rewriteField
+		}
+		result[field] = val
+	}
+	return result
+}
+
+// Merge 合并数据
+//
+// Author : go_developer@163.com<白茶清欢>
+//
+// Date : 11:01 2024/3/11
+func (c *common) Merge(mergeData ...EasyMap) {
+	for _, itemData := range mergeData {
+		allData := itemData.GetAll()
+		for k, v := range allData {
+			c.Set(k, v)
+		}
+	}
+}
+
+// MergeWithReceiver 合并并转换
+//
+// Author : go_developer@163.com<白茶清欢>
+//
+// Date : 11:06 2024/3/11
+func (c *common) MergeWithReceiver(receiver any, mergeData ...EasyMap) error {
+	c.Merge(mergeData...)
+	if nil == receiver {
+		return nil
+	}
+	return c.ToStruct(receiver)
+}

define.go

@@ -0,0 +1,16 @@
+// Package easymap ...
+//
+// Description : easymap ...
+//
+// Author : go_developer@163.com<白茶清欢>
+//
+// Date : 2023-03-07 17:27
+package easymap
+
+// IteratorFunc 迭代函数， 返回值为是否继续迭代，true 继续迭代 false 终止后续迭代
+type IteratorFunc func(key any, value any) bool
+
+const (
+	normalDataTableType  = "NORMAL"
+	syncMapDataTableType = "SYNC_MAP"
+)

error.go

@@ -7,15 +7,18 @@
 // Date : 2021-02-23 10:15 下午
 package easymap
 
-import "github.com/pkg/errors"
+import (
+	"errors"
+	"fmt"
+)
 
 // keyNotFound key 不存在
 //
 // Author : go_developer@163.com<白茶清欢>
 //
 // Date : 10:17 下午 2021/2/23
-func keyNotFound(key interface{}) error {
+func keyNotFound(key any) error {
-	return errors.Errorf("%v 未找到", key)
+	return fmt.Errorf("%v 未找到", key)
 }
 
 // convertFail 数据类型妆换失败
@@ -24,7 +27,10 @@ func keyNotFound(key interface{}) error {
 //
 // Date : 10:28 下午 2021/2/23
 func convertFail(err error) error {
-	return errors.Wrapf(err, "数据类型转换失败")
+	if nil == err {
+		return nil
+	}
+	return fmt.Errorf("数据类型转换失败 : %v", err.Error())
 }
 
 // segmentError ...

go.mod

@@ -1,21 +1,26 @@
 module git.zhangdeman.cn/zhangdeman/easymap
 
-go 1.17
+go 1.21
+
+toolchain go1.21.5
 
 require (
-	git.zhangdeman.cn/zhangdeman/util v0.0.0-20230211164227-256094968151
+	git.zhangdeman.cn/zhangdeman/serialize v0.0.0-20241023104258-2e0a298aa558
-	github.com/pkg/errors v0.9.1
+	git.zhangdeman.cn/zhangdeman/util v0.0.0-20240618042405-6ee2c904644e
 )
 
 require (
+	git.zhangdeman.cn/zhangdeman/consts v0.0.0-20241023090605-10cff9173059 // indirect
+	github.com/BurntSushi/toml v1.4.0 // indirect
 	github.com/Jeffail/gabs v1.4.0 // indirect
 	github.com/axgle/mahonia v0.0.0-20180208002826-3358181d7394 // indirect
-	github.com/davecgh/go-spew v1.1.1 // indirect
+	github.com/dgrijalva/jwt-go/v4 v4.0.0-preview1 // indirect
-	github.com/dgrijalva/jwt-go v3.2.0+incompatible // indirect
 	github.com/go-ini/ini v1.67.0 // indirect
-	github.com/pmezard/go-difflib v1.0.0 // indirect
+	github.com/mitchellh/go-homedir v1.1.0 // indirect
+	github.com/mozillazg/go-pinyin v0.20.0 // indirect
+	github.com/pkg/errors v0.9.1 // indirect
 	github.com/spaolacci/murmur3 v1.1.0 // indirect
-	github.com/tidwall/gjson v1.14.4 // indirect
+	github.com/tidwall/gjson v1.16.0 // indirect
 	github.com/tidwall/match v1.1.1 // indirect
 	github.com/tidwall/pretty v1.2.1 // indirect
 	gopkg.in/yaml.v3 v3.0.1 // indirect

go.sum

@@ -1,36 +1,52 @@
-git.zhangdeman.cn/zhangdeman/util v0.0.0-20230211164227-256094968151 h1:j537bRLQL1FlkdXTIaT9Ecjx5eogkPsGiTOWIEFQlc8=
+git.zhangdeman.cn/zhangdeman/consts v0.0.0-20230815040024-2b12dd51d19b h1:C7KftnLh7dOqzNRs5dn/9yqMDvuqMn5RCglvV6bY758=
-git.zhangdeman.cn/zhangdeman/util v0.0.0-20230211164227-256094968151/go.mod h1:SyRTkOz6gxUVn3S/Qtkf+rhKV0I1ym8lwsT8YjggYFs=
+git.zhangdeman.cn/zhangdeman/consts v0.0.0-20230815040024-2b12dd51d19b/go.mod h1:IXXaZkb7vGzGnGM5RRWrASAuwrVSNxuoe0DmeXx5g6k=
+git.zhangdeman.cn/zhangdeman/consts v0.0.0-20241023090605-10cff9173059 h1:TPAYdTKKUjgxtCnK38d1Tb4teyQp1C7wYHPdR32yZtM=
+git.zhangdeman.cn/zhangdeman/consts v0.0.0-20241023090605-10cff9173059/go.mod h1:IXXaZkb7vGzGnGM5RRWrASAuwrVSNxuoe0DmeXx5g6k=
+git.zhangdeman.cn/zhangdeman/serialize v0.0.0-20231224125439-01f39b6ea08d h1:TV0BCQQewBEtLsv3i9gXkxLFd5A5bWBTiNd3D/I5o4Q=
+git.zhangdeman.cn/zhangdeman/serialize v0.0.0-20231224125439-01f39b6ea08d/go.mod h1:w7kG4zyTJ1uPFaTWhze+OQuaUBINT2XnDxpyiM6ctc0=
+git.zhangdeman.cn/zhangdeman/serialize v0.0.0-20241023104258-2e0a298aa558 h1:ZVJyyDKfYeA3TsN8UOi4IprkouK4wIIfCKe+F9byLWA=
+git.zhangdeman.cn/zhangdeman/serialize v0.0.0-20241023104258-2e0a298aa558/go.mod h1:/9eicss/Dt9tp2jwZ/4cXDqDKo/Dez+HuT5/NGdqW+s=
+git.zhangdeman.cn/zhangdeman/util v0.0.0-20230810063945-842592611562 h1:wo0r4mexqkPzQ1SZOw5z8A7FJ3ne1G6A/qWR3iaqlhw=
+git.zhangdeman.cn/zhangdeman/util v0.0.0-20230810063945-842592611562/go.mod h1:trYFOShINaQBvinQrH4A0G2kfL22Y2lygEcAiGDt/sc=
+git.zhangdeman.cn/zhangdeman/util v0.0.0-20230811070456-d6a489d5860b h1:vnmxYrNdX6f5sEVjjkM1fIR+i32kHJ4g9DJqug9KKek=
+git.zhangdeman.cn/zhangdeman/util v0.0.0-20230811070456-d6a489d5860b/go.mod h1:Yum5+tgP+Wf1GWUAyQz1Qh8Ab9m5+90GYkYdzqVs0lA=
+git.zhangdeman.cn/zhangdeman/util v0.0.0-20231014142840-445c6407db92 h1:p1GVRYJc3NNoZeLs4CukitAbM3O/ALNq3l31cnbBQDM=
+git.zhangdeman.cn/zhangdeman/util v0.0.0-20231014142840-445c6407db92/go.mod h1:6OBeuwKy2J1TjdAwStEyC6aYC3kStmJiCg1eFC7g0fk=
+git.zhangdeman.cn/zhangdeman/util v0.0.0-20240618042405-6ee2c904644e h1:Q973S6CcWr1ICZhFI1STFOJ+KUImCl2BaIXm6YppBqI=
+git.zhangdeman.cn/zhangdeman/util v0.0.0-20240618042405-6ee2c904644e/go.mod h1:VpPjBlwz8U+OxZuxzHQBv1aEEZ3pStH6bZvT21ADEbI=
+github.com/BurntSushi/toml v1.3.2 h1:o7IhLm0Msx3BaB+n3Ag7L8EVlByGnpq14C4YWiu/gL8=
+github.com/BurntSushi/toml v1.3.2/go.mod h1:CxXYINrC8qIiEnFrOxCa7Jy5BFHlXnUU2pbicEuybxQ=
+github.com/BurntSushi/toml v1.4.0 h1:kuoIxZQy2WRRk1pttg9asf+WVv6tWQuBNVmK8+nqPr0=
+github.com/BurntSushi/toml v1.4.0/go.mod h1:ukJfTF/6rtPPRCnwkur4qwRxa8vTRFBF0uk2lLoLwho=
 github.com/Jeffail/gabs v1.4.0 h1://5fYRRTq1edjfIrQGvdkcd22pkYUrHZ5YC/H2GJVAo=
 github.com/Jeffail/gabs v1.4.0/go.mod h1:6xMvQMK4k33lb7GUUpaAPh6nKMmemQeg5d4gn7/bOXc=
 github.com/axgle/mahonia v0.0.0-20180208002826-3358181d7394 h1:OYA+5W64v3OgClL+IrOD63t4i/RW7RqrAVl9LTZ9UqQ=
 github.com/axgle/mahonia v0.0.0-20180208002826-3358181d7394/go.mod h1:Q8n74mJTIgjX4RBBcHnJ05h//6/k6foqmgE45jTQtxg=
-github.com/davecgh/go-spew v1.1.0/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
 github.com/davecgh/go-spew v1.1.1 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c=
-github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
+github.com/dgrijalva/jwt-go/v4 v4.0.0-preview1 h1:CaO/zOnF8VvUfEbhRatPcwKVWamvbYd8tQGRWacE9kU=
-github.com/dgrijalva/jwt-go v3.2.0+incompatible h1:7qlOGliEKZXTDg6OTjfoBKDXWrumCAMpl/TFQ4/5kLM=
+github.com/dgrijalva/jwt-go/v4 v4.0.0-preview1/go.mod h1:+hnT3ywWDTAFrW5aE+u2Sa/wT555ZqwoCS+pk3p6ry4=
-github.com/dgrijalva/jwt-go v3.2.0+incompatible/go.mod h1:E3ru+11k8xSBh+hMPgOLZmtrrCbhqsmaPHjLKYnJCaQ=
 github.com/go-ini/ini v1.67.0 h1:z6ZrTEZqSWOTyH2FlglNbNgARyHG8oLW9gMELqKr06A=
 github.com/go-ini/ini v1.67.0/go.mod h1:ByCAeIL28uOIIG0E3PJtZPDL8WnHpFKFOtgjp+3Ies8=
+github.com/mitchellh/go-homedir v1.1.0 h1:lukF9ziXFxDFPkA1vsr5zpc1XuPDn/wFntq5mG+4E0Y=
+github.com/mitchellh/go-homedir v1.1.0/go.mod h1:SfyaCUpYCn1Vlf4IUYiD9fPX4A5wJrkLzIz1N1q0pr0=
+github.com/mozillazg/go-pinyin v0.20.0 h1:BtR3DsxpApHfKReaPO1fCqF4pThRwH9uwvXzm+GnMFQ=
+github.com/mozillazg/go-pinyin v0.20.0/go.mod h1:iR4EnMMRXkfpFVV5FMi4FNB6wGq9NV6uDWbUuPhP4Yc=
 github.com/pkg/errors v0.9.1 h1:FEBLx1zS214owpjy7qsBeixbURkuhQAwrK5UwLGTwt4=
 github.com/pkg/errors v0.9.1/go.mod h1:bwawxfHBFNV+L2hUp1rHADufV3IMtnDRdf1r5NINEl0=
 github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM=
-github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4=
 github.com/spaolacci/murmur3 v1.1.0 h1:7c1g84S4BPRrfL5Xrdp6fOJ206sU9y293DDHaoy0bLI=
 github.com/spaolacci/murmur3 v1.1.0/go.mod h1:JwIasOWyU6f++ZhiEuf87xNszmSA2myDM2Kzu9HwQUA=
-github.com/stretchr/objx v0.1.0/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME=
+github.com/stretchr/testify v1.8.2 h1:+h33VjcLVPDHtOdpUCuF+7gSuG3yGIftsP1YvFihtJ8=
-github.com/stretchr/objx v0.4.0/go.mod h1:YvHI0jy2hoMjB+UWwv71VJQ9isScKT/TqJzVSSt89Yw=
+github.com/tidwall/gjson v1.16.0 h1:SyXa+dsSPpUlcwEDuKuEBJEz5vzTvOea+9rjyYodQFg=
-github.com/stretchr/testify v1.7.1/go.mod h1:6Fq8oRcR53rry900zMqJjRRixrwX3KX962/h/Wwjteg=
+github.com/tidwall/gjson v1.16.0/go.mod h1:/wbyibRr2FHMks5tjHJ5F8dMZh3AcwJEMf5vlfC0lxk=
-github.com/stretchr/testify v1.8.0 h1:pSgiaMZlXftHpm5L7V1+rVB+AZJydKsMxsQBIJw4PKk=
-github.com/stretchr/testify v1.8.0/go.mod h1:yNjHg4UonilssWZ8iaSj1OCr/vHnekPRkoO+kdMU+MU=
-github.com/tidwall/gjson v1.14.4 h1:uo0p8EbA09J7RQaflQ1aBRffTR7xedD2bcIVSYxLnkM=
-github.com/tidwall/gjson v1.14.4/go.mod h1:/wbyibRr2FHMks5tjHJ5F8dMZh3AcwJEMf5vlfC0lxk=
 github.com/tidwall/match v1.1.1 h1:+Ho715JplO36QYgwN9PGYNhgZvoUSc9X2c80KVTi+GA=
 github.com/tidwall/match v1.1.1/go.mod h1:eRSPERbgtNPcGhD8UCthc6PmLEQXEWd3PRB5JTxsfmM=
 github.com/tidwall/pretty v1.2.0/go.mod h1:ITEVvHYasfjBbM0u2Pg8T2nJnzm8xPwvNhhsoaGGjNU=
 github.com/tidwall/pretty v1.2.1 h1:qjsOFOWWQl+N3RsoF5/ssm1pHmJJwhjlSbZ51I6wMl4=
 github.com/tidwall/pretty v1.2.1/go.mod h1:ITEVvHYasfjBbM0u2Pg8T2nJnzm8xPwvNhhsoaGGjNU=
+golang.org/x/xerrors v0.0.0-20191204190536-9bdfabe68543 h1:E7g+9GITq07hpfrRu66IVDexMakfv52eLZ2CXBWiKr4=
+golang.org/x/xerrors v0.0.0-20191204190536-9bdfabe68543/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0=
 gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405 h1:yhCVgyC4o1eVCa2tZl7eS0r+SDo693bJlVdllGtEeKM=
 gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
-gopkg.in/yaml.v3 v3.0.0-20200313102051-9f266ea9e77c/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=
 gopkg.in/yaml.v3 v3.0.1 h1:fxVm/GzAzEWqLHuvctI91KS9hhNmmWOoWu0XTYJS7CA=
 gopkg.in/yaml.v3 v3.0.1/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=

normal.go

@@ -7,282 +7,12 @@
 // Date : 2021-02-23 10:03 下午
 package easymap
 
-import (
-	"fmt"
-	"sync"
-
-	"git.zhangdeman.cn/zhangdeman/util"
-)
-
 // NewNormal 获取map实例
 //
 // Author : go_developer@163.com<白茶清欢>
 //
 // Date : 10:07 下午 2021/2/23
-func NewNormal(withLock bool) EasyMap {
+func NewNormal() EasyMap {
-	em := &normal{
+	em, _ := NewSegment(1)
-		data:     make(map[interface{}]interface{}),
-		withLock: withLock,
-	}
-	if withLock {
-		em.lock = &sync.RWMutex{}
-	}
 	return em
 }
-
-// normal 普通map,内部可以加锁
-//
-// Author : go_developer@163.com<白茶清欢>
-//
-// Date : 10:03 下午 2021/2/23
-type normal struct {
-	data     map[interface{}]interface{}
-	withLock bool
-	lock     *sync.RWMutex
-}
-
-func (n *normal) Get(key interface{}) (interface{}, error) {
-	if !n.Exist(key) {
-		return nil, keyNotFound(key)
-	}
-	n.RLock()
-	defer n.RUnlock()
-	return n.data[key], nil
-}
-
-func (n *normal) GetWithReceiver(key interface{}, dest interface{}) error {
-	var (
-		val interface{}
-		err error
-	)
-	if val, err = n.Get(key); nil != err {
-		return err
-	}
-	return convertFail(util.ConvertAssign(dest, val))
-}
-
-func (n *normal) GetUint(key interface{}) (uint, error) {
-	var (
-		result uint
-		err    error
-	)
-	if err = n.GetWithReceiver(key, &result); nil != err {
-		return 0, err
-	}
-	return result, nil
-}
-
-func (n *normal) GetUint8(key interface{}) (uint8, error) {
-	var (
-		result uint8
-		err    error
-	)
-	if err = n.GetWithReceiver(key, &result); nil != err {
-		return 0, err
-	}
-	return result, nil
-}
-
-func (n *normal) GetUint16(key interface{}) (uint16, error) {
-	var (
-		result uint16
-		err    error
-	)
-	if err = n.GetWithReceiver(key, &result); nil != err {
-		return 0, err
-	}
-	return result, nil
-}
-
-func (n *normal) GetUint32(key interface{}) (uint32, error) {
-	var (
-		result uint32
-		err    error
-	)
-	if err = n.GetWithReceiver(key, &result); nil != err {
-		return 0, err
-	}
-	return result, nil
-}
-
-func (n *normal) GetUint64(key interface{}) (uint64, error) {
-	var (
-		result uint64
-		err    error
-	)
-	if err = n.GetWithReceiver(key, &result); nil != err {
-		return 0, err
-	}
-	return result, nil
-}
-
-func (n *normal) GetInt(key interface{}) (int, error) {
-	var (
-		result int
-		err    error
-	)
-	if err = n.GetWithReceiver(key, &result); nil != err {
-		return 0, err
-	}
-	return result, nil
-}
-
-func (n *normal) GetInt8(key interface{}) (int8, error) {
-	var (
-		result int8
-		err    error
-	)
-	if err = n.GetWithReceiver(key, &result); nil != err {
-		return 0, err
-	}
-	return result, nil
-}
-
-func (n *normal) GetInt16(key interface{}) (int16, error) {
-	var (
-		result int16
-		err    error
-	)
-	if err = n.GetWithReceiver(key, &result); nil != err {
-		return 0, err
-	}
-	return result, nil
-}
-
-func (n *normal) GetInt32(key interface{}) (int32, error) {
-	var (
-		result int32
-		err    error
-	)
-	if err = n.GetWithReceiver(key, &result); nil != err {
-		return 0, err
-	}
-	return result, nil
-}
-
-func (n *normal) GetInt64(key interface{}) (int64, error) {
-	var (
-		result int64
-		err    error
-	)
-	if err = n.GetWithReceiver(key, &result); nil != err {
-		return 0, err
-	}
-	return result, nil
-}
-
-func (n *normal) GetFloat32(key interface{}) (float32, error) {
-	var (
-		result float32
-		err    error
-	)
-	if err = n.GetWithReceiver(key, &result); nil != err {
-		return 0, err
-	}
-	return result, nil
-}
-
-func (n *normal) GetFloat64(key interface{}) (float64, error) {
-	var (
-		result float64
-		err    error
-	)
-	if err = n.GetWithReceiver(key, &result); nil != err {
-		return 0, err
-	}
-	return result, nil
-}
-
-func (n *normal) GetBool(key interface{}) (bool, error) {
-	var (
-		result bool
-		err    error
-	)
-	if err = n.GetWithReceiver(key, &result); nil != err {
-		return false, err
-	}
-	return result, nil
-}
-
-func (n *normal) GetString(key interface{}) (string, error) {
-	var (
-		result string
-		err    error
-	)
-	if err = n.GetWithReceiver(key, &result); nil != err {
-		return "", err
-	}
-	return result, nil
-}
-
-func (n *normal) Set(key interface{}, value interface{}) {
-	n.Lock()
-	defer n.Unlock()
-	n.data[key] = value
-}
-
-func (n *normal) Del(key interface{}) {
-	n.Lock()
-	defer n.Unlock()
-	delete(n.data, key)
-}
-
-func (n *normal) Exist(key interface{}) bool {
-	n.RLock()
-	defer n.RUnlock()
-	_, exist := n.data[key]
-	return exist
-}
-
-// GetAll 读取全部数据使用的是原始数据深拷贝
-//
-// Author : go_developer@163.com<白茶清欢>
-//
-// Date : 10:36 下午 2021/2/23
-func (n *normal) GetAll() map[interface{}]interface{} {
-	result := make(map[interface{}]interface{})
-	n.RLock()
-	defer n.RUnlock()
-	for key, val := range n.data {
-		result[key] = val
-	}
-	return result
-}
-
-func (n *normal) RLock() {
-	if n.withLock {
-		n.lock.RLock()
-	}
-}
-
-func (n *normal) RUnlock() {
-	if n.withLock {
-		n.lock.RUnlock()
-	}
-}
-
-func (n *normal) Lock() {
-	if n.withLock {
-		n.lock.Lock()
-	}
-}
-
-func (n *normal) Unlock() {
-	if n.withLock {
-		n.lock.Unlock()
-	}
-}
-
-// GetAllForMapKeyString ...
-//
-// Author : go_developer@163.com<白茶清欢>
-//
-// Date : 9:48 下午 2021/9/15
-func (n *normal) GetAllForMapKeyString() map[string]interface{} {
-	fullData := n.GetAll()
-	finalData := make(map[string]interface{})
-	for k, v := range fullData {
-		finalData[fmt.Sprintf("%v", k)] = v
-	}
-	return finalData
-}

segment.go

@@ -7,151 +7,32 @@
 // Date : 2021-02-23 10:47 下午
 package easymap
 
-import (
-	"fmt"
-
-	"git.zhangdeman.cn/zhangdeman/util"
-)
-
 // NewSegment 获取分段map实例
 //
 // Author : go_developer@163.com<白茶清欢>
 //
 // Date : 11:05 下午 2021/2/24
-func NewSegment(segmentCnt int, withLock bool) (EasyMap, error) {
+func NewSegment(segmentCnt int) (EasyMap, error) {
 	if segmentCnt <= 0 {
 		return nil, segmentError()
 	}
 	em := &segment{
+		&common{
+			normalDataTable:  nil,
+			syncMapDataTable: nil,
+			dataTableType:    normalDataTableType,
 			segment:          segmentCnt,
+			lock:             nil,
+		},
 	}
-	em.dataTable = make([]EasyMap, segmentCnt)
+	em.normalDataTable = make([]map[any]any, segmentCnt)
 	for i := 0; i < segmentCnt; i++ {
-		em.dataTable[i] = NewNormal(withLock)
+		em.normalDataTable[i] = make(map[any]any)
 	}
+	em.common.initLock()
 	return em, nil
 }
 
 type segment struct {
-	dataTable []EasyMap
+	*common
-	segment   int
-}
-
-func (s *segment) Get(key interface{}) (interface{}, error) {
-	segmentIndex := util.Hash.GetHashIDMod(key, s.segment)
-	return s.dataTable[segmentIndex].Get(key)
-}
-
-func (s *segment) GetWithReceiver(key interface{}, dest interface{}) error {
-	segmentIndex := util.Hash.GetHashIDMod(key, s.segment)
-	return s.dataTable[segmentIndex].GetWithReceiver(key, dest)
-}
-
-func (s *segment) GetUint(key interface{}) (uint, error) {
-	segmentIndex := util.Hash.GetHashIDMod(key, s.segment)
-	return s.dataTable[segmentIndex].GetUint(key)
-}
-
-func (s *segment) GetUint8(key interface{}) (uint8, error) {
-	segmentIndex := util.Hash.GetHashIDMod(key, s.segment)
-	return s.dataTable[segmentIndex].GetUint8(key)
-}
-
-func (s *segment) GetUint16(key interface{}) (uint16, error) {
-	segmentIndex := util.Hash.GetHashIDMod(key, s.segment)
-	return s.dataTable[segmentIndex].GetUint16(key)
-}
-
-func (s *segment) GetUint32(key interface{}) (uint32, error) {
-	segmentIndex := util.Hash.GetHashIDMod(key, s.segment)
-	return s.dataTable[segmentIndex].GetUint32(key)
-}
-
-func (s *segment) GetUint64(key interface{}) (uint64, error) {
-	segmentIndex := util.Hash.GetHashIDMod(key, s.segment)
-	return s.dataTable[segmentIndex].GetUint64(key)
-}
-
-func (s *segment) GetInt(key interface{}) (int, error) {
-	segmentIndex := util.Hash.GetHashIDMod(key, s.segment)
-	return s.dataTable[segmentIndex].GetInt(key)
-}
-
-func (s *segment) GetInt8(key interface{}) (int8, error) {
-	segmentIndex := util.Hash.GetHashIDMod(key, s.segment)
-	return s.dataTable[segmentIndex].GetInt8(key)
-}
-
-func (s *segment) GetInt16(key interface{}) (int16, error) {
-	segmentIndex := util.Hash.GetHashIDMod(key, s.segment)
-	return s.dataTable[segmentIndex].GetInt16(key)
-}
-
-func (s *segment) GetInt32(key interface{}) (int32, error) {
-	segmentIndex := util.Hash.GetHashIDMod(key, s.segment)
-	return s.dataTable[segmentIndex].GetInt32(key)
-}
-
-func (s *segment) GetInt64(key interface{}) (int64, error) {
-	segmentIndex := util.Hash.GetHashIDMod(key, s.segment)
-	return s.dataTable[segmentIndex].GetInt64(key)
-}
-
-func (s *segment) GetFloat32(key interface{}) (float32, error) {
-	segmentIndex := util.Hash.GetHashIDMod(key, s.segment)
-	return s.dataTable[segmentIndex].GetFloat32(key)
-}
-
-func (s *segment) GetFloat64(key interface{}) (float64, error) {
-	segmentIndex := util.Hash.GetHashIDMod(key, s.segment)
-	return s.dataTable[segmentIndex].GetFloat64(key)
-}
-
-func (s *segment) GetBool(key interface{}) (bool, error) {
-	segmentIndex := util.Hash.GetHashIDMod(key, s.segment)
-	return s.dataTable[segmentIndex].GetBool(key)
-}
-
-func (s *segment) GetString(key interface{}) (string, error) {
-	segmentIndex := util.Hash.GetHashIDMod(key, s.segment)
-	return s.dataTable[segmentIndex].GetString(key)
-}
-
-func (s *segment) Set(key interface{}, value interface{}) {
-	segmentIndex := util.Hash.GetHashIDMod(key, s.segment)
-	s.dataTable[segmentIndex].Set(key, value)
-}
-
-func (s *segment) Del(key interface{}) {
-	segmentIndex := util.Hash.GetHashIDMod(key, s.segment)
-	s.dataTable[segmentIndex].Del(key)
-}
-
-func (s *segment) Exist(key interface{}) bool {
-	segmentIndex := util.Hash.GetHashIDMod(key, s.segment)
-	return s.dataTable[segmentIndex].Exist(key)
-}
-
-func (s *segment) GetAll() map[interface{}]interface{} {
-	result := make(map[interface{}]interface{})
-	for i := 0; i < s.segment; i++ {
-		for k, v := range s.dataTable[i].GetAll() {
-			result[k] = v
-		}
-	}
-	return result
-}
-
-// GetAllForMapKeyString ...
-//
-// Author : go_developer@163.com<白茶清欢>
-//
-// Date : 9:48 下午 2021/9/15
-func (s *segment) GetAllForMapKeyString() map[string]interface{} {
-	fullData := s.GetAll()
-	finalData := make(map[string]interface{})
-	for k, v := range fullData {
-		finalData[fmt.Sprintf("%v", k)] = v
-	}
-	return finalData
 }

sync_normal.go

@@ -7,229 +7,7 @@
 // Date : 2021-02-24 2:08 下午
 package easymap
 
-import (
-	"fmt"
-	"sync"
-
-	"git.zhangdeman.cn/zhangdeman/util"
-)
-
 func NewSync() EasyMap {
-	return &syncMap{}
+	em, _ := NewSegmentSync(1)
-}
+	return em
-
-type syncMap struct {
-	data sync.Map
-}
-
-func (s *syncMap) Get(key interface{}) (interface{}, error) {
-	val, exist := s.data.Load(key)
-	if !exist {
-		return nil, keyNotFound(key)
-	}
-	return val, nil
-}
-
-func (s *syncMap) GetWithReceiver(key interface{}, dest interface{}) error {
-	var (
-		val interface{}
-		err error
-	)
-	if val, err = s.Get(key); nil != err {
-		return err
-	}
-	if err = util.ConvertAssign(dest, val); nil != err {
-		return convertFail(err)
-	}
-	return nil
-}
-
-func (s *syncMap) GetUint(key interface{}) (uint, error) {
-	var (
-		result uint
-		err    error
-	)
-	if err = s.GetWithReceiver(key, &result); nil != err {
-		return 0, err
-	}
-	return result, nil
-}
-
-func (s *syncMap) GetUint8(key interface{}) (uint8, error) {
-	var (
-		result uint8
-		err    error
-	)
-	if err = s.GetWithReceiver(key, &result); nil != err {
-		return 0, err
-	}
-	return result, nil
-}
-
-func (s *syncMap) GetUint16(key interface{}) (uint16, error) {
-	var (
-		result uint16
-		err    error
-	)
-	if err = s.GetWithReceiver(key, &result); nil != err {
-		return 0, err
-	}
-	return result, nil
-}
-
-func (s *syncMap) GetUint32(key interface{}) (uint32, error) {
-	var (
-		result uint32
-		err    error
-	)
-	if err = s.GetWithReceiver(key, &result); nil != err {
-		return 0, err
-	}
-	return result, nil
-}
-
-func (s *syncMap) GetUint64(key interface{}) (uint64, error) {
-	var (
-		result uint64
-		err    error
-	)
-	if err = s.GetWithReceiver(key, &result); nil != err {
-		return 0, err
-	}
-	return result, nil
-}
-
-func (s *syncMap) GetInt(key interface{}) (int, error) {
-	var (
-		result int
-		err    error
-	)
-	if err = s.GetWithReceiver(key, &result); nil != err {
-		return 0, err
-	}
-	return result, nil
-}
-
-func (s *syncMap) GetInt8(key interface{}) (int8, error) {
-	var (
-		result int8
-		err    error
-	)
-	if err = s.GetWithReceiver(key, &result); nil != err {
-		return 0, err
-	}
-	return result, nil
-}
-
-func (s *syncMap) GetInt16(key interface{}) (int16, error) {
-	var (
-		result int16
-		err    error
-	)
-	if err = s.GetWithReceiver(key, &result); nil != err {
-		return 0, err
-	}
-	return result, nil
-}
-
-func (s *syncMap) GetInt32(key interface{}) (int32, error) {
-	var (
-		result int32
-		err    error
-	)
-	if err = s.GetWithReceiver(key, &result); nil != err {
-		return 0, err
-	}
-	return result, nil
-}
-
-func (s *syncMap) GetInt64(key interface{}) (int64, error) {
-	var (
-		result int64
-		err    error
-	)
-	if err = s.GetWithReceiver(key, &result); nil != err {
-		return 0, err
-	}
-	return result, nil
-}
-
-func (s *syncMap) GetFloat32(key interface{}) (float32, error) {
-	var (
-		result float32
-		err    error
-	)
-	if err = s.GetWithReceiver(key, &result); nil != err {
-		return 0, err
-	}
-	return result, nil
-}
-
-func (s *syncMap) GetFloat64(key interface{}) (float64, error) {
-	var (
-		result float64
-		err    error
-	)
-	if err = s.GetWithReceiver(key, &result); nil != err {
-		return 0, err
-	}
-	return result, nil
-}
-
-func (s *syncMap) GetBool(key interface{}) (bool, error) {
-	var (
-		result bool
-		err    error
-	)
-	if err = s.GetWithReceiver(key, &result); nil != err {
-		return false, err
-	}
-	return result, nil
-}
-
-func (s *syncMap) GetString(key interface{}) (string, error) {
-	var (
-		result string
-		err    error
-	)
-	if err = s.GetWithReceiver(key, &result); nil != err {
-		return "", err
-	}
-	return result, nil
-}
-
-func (s *syncMap) Set(key interface{}, value interface{}) {
-	s.data.Store(key, value)
-}
-
-func (s *syncMap) Del(key interface{}) {
-	s.data.Delete(key)
-}
-
-func (s *syncMap) Exist(key interface{}) bool {
-	_, exist := s.data.Load(key)
-	return exist
-}
-
-func (s *syncMap) GetAll() map[interface{}]interface{} {
-	result := make(map[interface{}]interface{})
-	s.data.Range(func(key, value interface{}) bool {
-		result[key] = value
-		return true
-	})
-	return result
-}
-
-// GetAllForMapKeyString ...
-//
-// Author : go_developer@163.com<白茶清欢>
-//
-// Date : 9:48 下午 2021/9/15
-func (s *syncMap) GetAllForMapKeyString() map[string]interface{} {
-	fullData := s.GetAll()
-	finalData := make(map[string]interface{})
-	for k, v := range fullData {
-		finalData[fmt.Sprintf("%v", k)] = v
-	}
-	return finalData
 }

sync_normal_test.go

@@ -1,6 +1,6 @@
-// Package easymap...
+// Package easymap ...
 //
-// Description : easymap...
+// Description : easymap ...
 //
 // Author : go_developer@163.com<白茶清欢>
 //

sync_segment.go

@@ -8,9 +8,7 @@
 package easymap
 
 import (
-	"fmt"
+	"sync"
-
-	"git.zhangdeman.cn/zhangdeman/util"
 )
 
 // NewSegmentSync 获取SegmentSync实例
@@ -23,116 +21,22 @@ func NewSegmentSync(segment int) (EasyMap, error) {
 		return nil, segmentError()
 	}
 	ss := &segmentSync{
+		&common{
+			normalDataTable:  nil,
+			syncMapDataTable: nil,
+			dataTableType:    syncMapDataTableType,
 			segment:          segment,
+			lock:             nil,
+		},
 	}
-	ss.dataTable = make([]EasyMap, segment)
+	ss.syncMapDataTable = make([]sync.Map, segment)
 	for i := 0; i < segment; i++ {
-		ss.dataTable[i] = NewSync()
+		ss.syncMapDataTable[i] = sync.Map{}
 	}
+	ss.initLock()
 	return ss, nil
 }
 
 type segmentSync struct {
-	dataTable []EasyMap
+	*common
-	segment   int
-}
-
-func (s *segmentSync) Get(key interface{}) (interface{}, error) {
-	return s.dataTable[util.Hash.GetHashIDMod(key, s.segment)].Get(key)
-}
-
-func (s *segmentSync) GetWithReceiver(key interface{}, dest interface{}) error {
-	return s.dataTable[util.Hash.GetHashIDMod(key, s.segment)].GetWithReceiver(key, dest)
-}
-
-func (s *segmentSync) GetUint(key interface{}) (uint, error) {
-	return s.dataTable[util.Hash.GetHashIDMod(key, s.segment)].GetUint(key)
-}
-
-func (s *segmentSync) GetUint8(key interface{}) (uint8, error) {
-	return s.dataTable[util.Hash.GetHashIDMod(key, s.segment)].GetUint8(key)
-}
-
-func (s *segmentSync) GetUint16(key interface{}) (uint16, error) {
-	return s.dataTable[util.Hash.GetHashIDMod(key, s.segment)].GetUint16(key)
-}
-
-func (s *segmentSync) GetUint32(key interface{}) (uint32, error) {
-	return s.dataTable[util.Hash.GetHashIDMod(key, s.segment)].GetUint32(key)
-}
-
-func (s *segmentSync) GetUint64(key interface{}) (uint64, error) {
-	return s.dataTable[util.Hash.GetHashIDMod(key, s.segment)].GetUint64(key)
-}
-
-func (s *segmentSync) GetInt(key interface{}) (int, error) {
-	return s.dataTable[util.Hash.GetHashIDMod(key, s.segment)].GetInt(key)
-}
-
-func (s *segmentSync) GetInt8(key interface{}) (int8, error) {
-	return s.dataTable[util.Hash.GetHashIDMod(key, s.segment)].GetInt8(key)
-}
-
-func (s *segmentSync) GetInt16(key interface{}) (int16, error) {
-	return s.dataTable[util.Hash.GetHashIDMod(key, s.segment)].GetInt16(key)
-}
-
-func (s *segmentSync) GetInt32(key interface{}) (int32, error) {
-	return s.dataTable[util.Hash.GetHashIDMod(key, s.segment)].GetInt32(key)
-}
-
-func (s *segmentSync) GetInt64(key interface{}) (int64, error) {
-	return s.dataTable[util.Hash.GetHashIDMod(key, s.segment)].GetInt64(key)
-}
-
-func (s *segmentSync) GetFloat32(key interface{}) (float32, error) {
-	return s.dataTable[util.Hash.GetHashIDMod(key, s.segment)].GetFloat32(key)
-}
-
-func (s *segmentSync) GetFloat64(key interface{}) (float64, error) {
-	return s.dataTable[util.Hash.GetHashIDMod(key, s.segment)].GetFloat64(key)
-}
-
-func (s *segmentSync) GetBool(key interface{}) (bool, error) {
-	return s.dataTable[util.Hash.GetHashIDMod(key, s.segment)].GetBool(key)
-}
-
-func (s *segmentSync) GetString(key interface{}) (string, error) {
-	return s.dataTable[util.Hash.GetHashIDMod(key, s.segment)].GetString(key)
-}
-
-func (s *segmentSync) Set(key interface{}, value interface{}) {
-	s.dataTable[util.Hash.GetHashIDMod(key, s.segment)].Set(key, value)
-}
-
-func (s *segmentSync) Del(key interface{}) {
-	s.dataTable[util.Hash.GetHashIDMod(key, s.segment)].Del(key)
-}
-
-func (s *segmentSync) Exist(key interface{}) bool {
-	return s.dataTable[util.Hash.GetHashIDMod(key, s.segment)].Exist(key)
-}
-
-func (s *segmentSync) GetAll() map[interface{}]interface{} {
-	result := make(map[interface{}]interface{})
-	for i := 0; i < s.segment; i++ {
-		for k, v := range s.dataTable[i].GetAll() {
-			result[k] = v
-		}
-	}
-	return result
-}
-
-// GetAllForMapKeyString ...
-//
-// Author : go_developer@163.com<白茶清欢>
-//
-// Date : 9:48 下午 2021/9/15
-func (s *segmentSync) GetAllForMapKeyString() map[string]interface{} {
-	fullData := s.GetAll()
-	finalData := make(map[string]interface{})
-	for k, v := range fullData {
-		finalData[fmt.Sprintf("%v", k)] = v
-	}
-	return finalData
 }