ssdb

Documentation

Index

• func GetSSdbPool(config map[string]string) (*pool.Connectors, error)
• type GoSSDBContent
  • func DataBaseMapping(config map[string]string) (*GoSSDBContent, error)
  • func (s *GoSSDBContent) GetGoSSDBRepository(entity interface{}) ISSdbRepository
• type ISSdbRepository
• type SSdbRepository
  • func (s *SSdbRepository) CreateKey(prefix, key string) string
  • func (s *SSdbRepository) Get(key string, result interface{}) error
  • func (s *SSdbRepository) GetClient() *pool.Client
  • func (s *SSdbRepository) GetIncr(key string, res map[string]int64) (err error)
  • func (s *SSdbRepository) GetMany(keys []string, result interface{}) error
  • func (s *SSdbRepository) Incr(key, field string, num int64) (int64, error)
  • func (s *SSdbRepository) Remove(keys ...string) (int64, error)
  • func (s *SSdbRepository) RemoveIncr(key string) error
  • func (s *SSdbRepository) Set(key string, entity interface{}, ttl int64) (int64, error)
  • func (s *SSdbRepository) SetMany(entityMap map[string]interface{}) (int64, error)

Functions

func GetSSdbPool

func GetSSdbPool(config map[string]string) (*pool.Connectors, error)

获取ssdb连接池

Types

type GoSSDBContent

type GoSSDBContent struct {
	// contains filtered or unexported fields
}

集合上下文

func DataBaseMapping

func DataBaseMapping(config map[string]string) (*GoSSDBContent, error)

添加映射 @client 连接对象 @dataName 数据库名

func (*GoSSDBContent) GetGoSSDBRepository

func (s *GoSSDBContent) GetGoSSDBRepository(entity interface{}) ISSdbRepository

获取集合仓储 entity 结构体

type ISSdbRepository

type ISSdbRepository interface {

	// 插入单个
	// entity  结构体
	// ttl     单位秒 ，0为永不到期
	Set(key string, entity interface{}, ttl int64) (int64, error)

	// 插入多个【单次20000个以下】
	// entityMap 结构体字典
	SetMany(entityMap map[string]interface{}) (int64, error)

	//递增字段值
	//key hashid
	//fieid 字段名称
	Incr(key, field string, num int64) (int64, error)

	//获取递增字段值
	//key hashid
	//res 要获取的字段值
	GetIncr(key string, res map[string]int64) (err error)

	//移除递增
	//key hashid
	RemoveIncr(key string) error

	// 删除单个
	// key key值
	Remove(key ...string) (int64, error)

	//查询单个
	// key         key值
	// result      查询的结果
	Get(key string, result interface{}) error

	//查询多个[只支持string类型]
	// keys        key值切片
	// result      查询的结果切片
	GetMany(keys []string, result interface{}) error

	// 创建内部key（配合直接使用数据库连接（GetClient）使用,其它方法不需要使用内部已调用）
	// prefix 前缀
	// key
	CreateKey(prefix, key string) string

	//获取客户端
	GetClient() *pool.Client
}

SSDB 仓储接口(只支持string类型)

type SSdbRepository

type SSdbRepository struct {
	// contains filtered or unexported fields
}

SSDB 仓储(string)

func (*SSdbRepository) CreateKey

func (s *SSdbRepository) CreateKey(prefix, key string) string

创建内部key

func (*SSdbRepository) Get

func (s *SSdbRepository) Get(key string, result interface{}) error

查询单个 key key值 result 查询的结果

func (*SSdbRepository) GetClient

func (s *SSdbRepository) GetClient() *pool.Client

获取客户端

func (*SSdbRepository) GetIncr

func (s *SSdbRepository) GetIncr(key string, res map[string]int64) (err error)

获取递增值

func (*SSdbRepository) GetMany

func (s *SSdbRepository) GetMany(keys []string, result interface{}) error

查询多个 keys key值切片 result 查询的结果切片

func (*SSdbRepository) Incr

func (s *SSdbRepository) Incr(key, field string, num int64) (int64, error)

递增

func (*SSdbRepository) Remove

func (s *SSdbRepository) Remove(keys ...string) (int64, error)

移除 keys key值切片

func (*SSdbRepository) RemoveIncr

func (s *SSdbRepository) RemoveIncr(key string) error

清理递增字段

func (*SSdbRepository) Set

func (s *SSdbRepository) Set(key string, entity interface{}, ttl int64) (int64, error)

插入单个[key数据存在会更新] entity 结构体 ttl 单位秒 ，0为永不到期

func (*SSdbRepository) SetMany

func (s *SSdbRepository) SetMany(entityMap map[string]interface{}) (int64, error)

插入多个 [key数据存在会更新] entityMap 结构体字典