mysql

Documentation

Index

• Constants
• func NewEventDB(dbName, table string, urls []string) (event types.DBImpl, err error)
• func NewPropertyDB(dbName, table string, urls []string, log *zap.Logger) (property types.DBImpl, err error)
• type EventDB
  • func (e *EventDB) BatchCreate(ctx context.Context, sqlCreate string, values interface{}) (err error)
  • func (e *EventDB) Close() error
• type LoadBalance
• type LoadBalanceRandom
  • func NewLoadBalanceRandom(servers []*Server) *LoadBalanceRandom
  • func (l *LoadBalanceRandom) Close()
  • func (l *LoadBalanceRandom) Select(remove []*sqlx.DB) *Server
  • func (l *LoadBalanceRandom) String() string
  • func (l *LoadBalanceRandom) UpdateServers(servers []*Server)
• type PropertyDB
  • func (p *PropertyDB) BatchCreate(ctx context.Context, sqlCreate string, values interface{}) (err error)
  • func (p *PropertyDB) Close() error
• type Server

Constants

const (
	MYSQL_DB               = `CREATE DATABASE IF NOT EXISTS iot_manage`
	MYSQL_IOT_THING_CREATE = `` /* 975-byte string literal not displayed */

	MYSQL_IOT_DEVICE_EVENT_DATA = `` /* 477-byte string literal not displayed */

)

Functions

func NewEventDB

func NewEventDB(dbName, table string, urls []string) (event types.DBImpl, err error)

func NewPropertyDB

func NewPropertyDB(dbName, table string, urls []string, log *zap.Logger) (property types.DBImpl, err error)

Types

type EventDB

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

property model

func (*EventDB) BatchCreate

func (e *EventDB) BatchCreate(ctx context.Context, sqlCreate string, values interface{}) (err error)

func (*EventDB) Close

func (e *EventDB) Close() error

type LoadBalance

type LoadBalance interface {
	//选择一个后端Server
	//参数remove是需要排除选择的后端Server
	Select(remove []*sqlx.DB) *Server
	//更新可用Server列表
	UpdateServers(servers []*Server)
	Close()
}

type LoadBalanceRandom

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

func NewLoadBalanceRandom

func NewLoadBalanceRandom(servers []*Server) *LoadBalanceRandom

func (*LoadBalanceRandom) Close

func (l *LoadBalanceRandom) Close()

func (*LoadBalanceRandom) Select

func (l *LoadBalanceRandom) Select(remove []*sqlx.DB) *Server

选择一个后端Server

func (*LoadBalanceRandom) String

func (l *LoadBalanceRandom) String() string

func (*LoadBalanceRandom) UpdateServers

func (l *LoadBalanceRandom) UpdateServers(servers []*Server)

系统运行过程中，后端可用Server会更新

type PropertyDB

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

property model

func (*PropertyDB) BatchCreate

func (p *PropertyDB) BatchCreate(ctx context.Context, sqlCreate string, values interface{}) (err error)

func (*PropertyDB) Close

func (p *PropertyDB) Close() error

type Server

type Server struct {
	DB     *sqlx.DB
	Name   string
	Weight int
}