model

Documentation

Index

• type Item
• type Mgo
  • func InitMgoDB(ConnStr, DBName string) *Mgo
  • func (mgo *Mgo) Close()
  • func (mgo *Mgo) DeleteUrl(url Url) error
  • func (mgo *Mgo) InsertItems(items []Item) (err error)
  • func (mgo *Mgo) InsertUrls(urls []string) (err error)
  • func (mgo *Mgo) QueryUrls(topN int) ([]Url, error)
• type RedisMq
  • func InitRedisMq(redisHost string, redisDB int) (*RedisMq, error)
  • func (rmq *RedisMq) GetUrls(jobChan chan string)
  • func (rmq *RedisMq) LoadUrlsFromRedis(jobChan chan string)
  • func (rmq *RedisMq) PushUrl(url Url)
• type Url

Types

type Item

type Item struct {
	Id       bson.ObjectId `bson:"_id"`
	Votes    int           `bson:"votes"`
	Answers  int           `bson:"answers"`
	Views    int           `bson:"views"`
	Url      string        `bson:"url"`
	Question string        `bson:"question"`
}

type Mgo

type Mgo struct {
	Session *mgo.Session
	DB      *mgo.Database
	MgoHost string
	MgoDB   string
}

func InitMgoDB

func InitMgoDB(ConnStr, DBName string) *Mgo

func (*Mgo) Close

func (mgo *Mgo) Close()

func (*Mgo) DeleteUrl

func (mgo *Mgo) DeleteUrl(url Url) error

func (*Mgo) InsertItems

func (mgo *Mgo) InsertItems(items []Item) (err error)

func (*Mgo) InsertUrls

func (mgo *Mgo) InsertUrls(urls []string) (err error)

func (*Mgo) QueryUrls

func (mgo *Mgo) QueryUrls(topN int) ([]Url, error)

type RedisMq

type RedisMq struct {
	RedisClient *redis.Pool

	Mgo *Mgo
	C   redis.Conn
	// contains filtered or unexported fields
}

func InitRedisMq

func InitRedisMq(redisHost string, redisDB int) (*RedisMq, error)

func (*RedisMq) GetUrls

func (rmq *RedisMq) GetUrls(jobChan chan string)

func (*RedisMq) LoadUrlsFromRedis

func (rmq *RedisMq) LoadUrlsFromRedis(jobChan chan string)

* this function is likely a producter.

func (*RedisMq) PushUrl

func (rmq *RedisMq) PushUrl(url Url)

type Url

type Url struct {
	Id  bson.ObjectId `bson:"_id"`
	Url string        `json:"url"`
}