redis

package

v0.0.0-...-e67e6ae Latest Latest Go to latest Published: Jul 22, 2022 License: Apache-2.0 Imports: 15 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/tkeel-io/rule-rulex

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func NewEventDB(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
type PropertyDB
- func (p *PropertyDB) BatchCreate(ctx context.Context, sqlCreate string, values interface{}) (err error)
- func (p *PropertyDB) Close() error
type Server

Constants ¶

View Source

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 */

)

Variables ¶

This section is empty.

Functions ¶

func NewEventDB ¶

func NewEventDB(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 []*redis.Client) *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 []*redis.Client) *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     *redis.Client
	Name   string
	Weight int
}

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL