xdb

Documentation

Index

• Constants
• func DB() *gorm.DB
• func GetAutoSliceDB(db *gorm.DB, userId int64, sf SP) *gorm.DB
• func InitQpsDB(limit int, interval time.Duration)
• func OpenMysqlDB(dbType string, dbUrl string, config *gorm.Config, ...) (instance *gorm.DB, err error)
• func QpsDB() *gorm.DB
• func SetMainDB(main *gorm.DB, DSN string)
• type Consistent
  • func NewConsistent() *Consistent
  • func (c *Consistent) Add(element string)
  • func (c *Consistent) Get(name string) (string, error)
  • func (c *Consistent) Remove(element string)
• type SP

Constants

const (
	EmptyVal    = ""
	PartOnlyOne = 1
)

const (
	// MYSQL dbType
	MYSQL = "mysql"
	// PG dbType
	PG = "postgres"
)

Functions

func DB

func DB() *gorm.DB

DB 获取数据库链接

func GetAutoSliceDB

func GetAutoSliceDB(db *gorm.DB, userId int64, sf SP) *gorm.DB

GetAutoSliceDB 获取自动分表

func InitQpsDB

func InitQpsDB(limit int, interval time.Duration)

InitQpsDB 初始化同步等待QPS DB

func OpenMysqlDB

func OpenMysqlDB(dbType string, dbUrl string, config *gorm.Config, maxIdleConns, maxOpenConns int, models ...interface{}) (instance *gorm.DB, err error)

OpenMysqlDB gorm v2 dbUrl = username:password@tcp(localhost:3306)/db_name?charset=utf8mb4&parseTime=True&loc=Local

func QpsDB

func QpsDB() *gorm.DB

QpsDB 获取DB对象，若超时则返回nil

func SetMainDB

func SetMainDB(main *gorm.DB, DSN string)

SetMainDB 设置主DB

Types

type Consistent

type Consistent struct {

	//虚拟节点个数，用来增加hash的平衡性
	VirtualNode int
	//map 读写锁
	sync.RWMutex
	// contains filtered or unexported fields
}

Consistent 创建结构体保存一致性hash信息

func NewConsistent

func NewConsistent() *Consistent

NewConsistent 创建一致性hash算法结构体，设置默认节点数量

func (*Consistent) Add

func (c *Consistent) Add(element string)

Add 向hash环中添加节点

func (*Consistent) Get

func (c *Consistent) Get(name string) (string, error)

Get 根据数据标示获取最近的服务器节点信息

func (*Consistent) Remove

func (c *Consistent) Remove(element string)

Remove 删除一个节点

type SP

type SP struct {
	Value  interface{}
	Part   int64  // 用户ID取余分表
	ByDate string // 通过日期2022-01-01分表，按月，按日
}