llmongodb/dbs.go

// dbs
package main

import (
	"github.com/garyburd/redigo/redis"
	//	"github.com/fzzy/radix/redis"
	"fmt"
	"log"
	"os"
	"time"

	"gopkg.in/mgo.v2"
)

var (
	dbs = Dbs{
		MongoURI: "mongodb://127.0.0.1:27018",
		RedisURI: "127.0.0.1:6379",
		Database: "lastlogin",
	}
)

// Dbs structure
type Dbs struct {
	MongoURI string
	Database string
	RedisURI string
	rdb      *redis.Pool //*redis.Client
	mdb      *mgo.Session
	ll       *mgo.Collection
	//	us       *mgo.Collection
}

// MongoLogin structure
type MongoLogin struct {
	ID       string    `json:"_id" bson:"_id"`
	User     string    `json:"user"`
	Protocol string    `json:"protocol"`
	IP       string    `json:"ip"`
	Date     time.Time `json:"date"`
	Insert   time.Time `json:"insert"`
}

// Ips structure
type Ips struct {
	IP string `json:"ip"`
}

// UserLogin structure
type UserLogin struct {
	User string    `json:"user"`
	Date time.Time `json:"date"`
	Lock bool      `json:"lock"`
}

// Index structure
type Index struct {
	User string    `json:"user"`
	Date time.Time `json:"date"`
}

func (db *Dbs) poolRedis() {

	dbs.rdb = &redis.Pool{
		MaxIdle:     128,
		MaxActive:   1000,
		Wait:        true,
		IdleTimeout: 1 * time.Second,
		Dial: func() (redis.Conn, error) {
			c, err := redis.Dial("tcp", db.RedisURI)
			if err != nil {
				return nil, err
			}
			return c, err
		},
		TestOnBorrow: func(c redis.Conn, t time.Time) error {
			_, err := c.Do("PING")
			return err
		},
	}

}

func (db *Dbs) connectMongo() {
	var err error
	db.mdb, err = mgo.Dial(db.MongoURI)
	if err != nil {
		log.Println("Mongodb connect Error: ", err.Error())
		os.Exit(-3)
	}

	db.ll = db.mdb.DB(db.Database).C(fmt.Sprintf("lastlogin_%s", opts.Month))
}