Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

db

package module

Go to main page

Versions in this module

v0

v0.6.0-beta.20220417.1300

Apr 17, 2022

v0.6.0-beta.20220417.1200

Apr 17, 2022

v0.6.0-1

Jul 10, 2022

v0.1.3

Dec 19, 2021

v0.1.2

Nov 25, 2021

v0.1.1

Jul 16, 2021

v0.1.0

Jul 15, 2021

Changes in this version

type RedisClient

+ AllKeys func() (values []string, err error)

+ BLPop func(collection string, timeout int) (value string, err error)

+ BRPop func(collection string, timeout int) (value string, err error)

+ BZPopMax func(collection string, timeout int) (value string, err error)

+ BZPopMin func(collection string, timeout int) (value string, err error)

+ Del func(collection string) (err error)

+ Get func(collection string) (value string, err error)

+ HDel func(collection string, key string) (err error)

+ HGet func(collection string, key string) (value string, err error)

+ HKeys func(collection string) (results []string, err error)

+ HScan func(collection string) (results map[string]string, err error)

+ HSet func(collection string, key string, value string) (err error)

+ Keys func(pattern string) (values []string, err error)

+ LLen func(collection string) (count int, err error)

+ LPop func(collection string) (value string, err error)

+ LPush func(collection string, value interface{}) (err error)

+ Lock func(lockKey string) (value int64, err error)

+ MemoryStats func() (stats map[string]int64, err error)

+ Ping func() (err error)

+ RPop func(collection string) (value string, err error)

+ RPush func(collection string, value interface{}) (err error)

+ Set func(collection string, value string) (err error)

+ SetBackoffMaxInterval func(interval time.Duration)

+ SetTimeout func(timeout int)

+ UnLock func(lockKey string, value int64)

+ ZAdd func(collection string, score float32, value interface{}) (err error)

+ ZCount func(collection string, min string, max string) (count int, err error)

+ ZCountAll func(collection string) (count int, err error)

+ ZPopMax func(collection string, count int) (results []string, err error)

+ ZPopMaxOne func(collection string) (value string, err error)

+ ZPopMin func(collection string, count int) (results []string, err error)

+ ZPopMinOne func(collection string) (value string, err error)

+ ZScan func(collection string, pattern string, count int) (results []string, err error)

v0.0.2

Dec 1, 2020

Changes in this version

+ var ESClient *elastic.Client

+ var MemoryStatsMetrics = []string

+ var Session *mgo.Session

+ func Close(c io.Closer)

+ func ContainsString(list []string, item string) bool

+ func GetCol(collectionName string) (*mgo.Session, *mgo.Collection)

+ func GetDataSourceCol(host string, port string, username string, password string, authSource string, ...) (*mgo.Session, *mgo.Collection, error)

+ func GetDb() (*mgo.Session, *mgo.Database)

+ func GetGridFs(prefix string) (*mgo.Session, *mgo.GridFS)

+ func GetSession() *mgo.Session

+ func GetSqlConn(dataSourceType string, host string, port string, username string, ...) (db *sqlx.DB, err error)

+ func GetSqlDatabaseConnectionString(dataSourceType string, host string, port string, username string, ...) (connStr string, err error)

+ func InitEsClient()

+ func InitMongo() error

+ func InitRedis() error

+ func NewRedisPool() *redis.Pool

+ func WriteMsgToES(when time.Time, msg chan string, index string)

+ type Mutex struct

+ Name string

+ type Redis struct

+ var RedisClient *Redis

+ func NewRedisClient() *Redis

+ func (r *Redis) BRPop(collection string, timeout int) (string, error)

+ func (r *Redis) HDel(collection string, key string) error

+ func (r *Redis) HGet(collection string, key string) (string, error)

+ func (r *Redis) HKeys(collection string) ([]string, error)

+ func (r *Redis) HScan(collection string) (results []string, err error)

+ func (r *Redis) HSet(collection string, key string, value string) error

+ func (r *Redis) LPop(collection string) (string, error)

+ func (r *Redis) LPush(collection string, value interface{}) error

+ func (r *Redis) Lock(lockKey string) (int64, error)

+ func (r *Redis) MemoryStats() (stats map[string]int64, err error)

+ func (r *Redis) Ping() error

+ func (r *Redis) RPush(collection string, value interface{}) error

+ func (r *Redis) UnLock(lockKey string, value int64)