storage

Documentation

Index

• Variables
• func CheckIP(ip *models.IP) bool
• func CheckProxy(ip *models.IP)
• func CheckProxyDB()
• func ProxyAdd(ip *models.IP)
• func ProxyDel(ip *models.IP)
• func ProxyFind(value string) (ip *models.IP)
• func ProxyRandom() (ip *models.IP)
• type Storage
  • func NewStorage() *Storage
  • func (s *Storage) Count() int
  • func (s *Storage) Create(item interface{}) error
  • func (s *Storage) Delete(ip *models.IP) error
  • func (s *Storage) FindAll(value string) ([]*models.IP, error)
  • func (s *Storage) GetAll() ([]*models.IP, error)
  • func (s *Storage) GetDBSession() *mgo.Session
  • func (s *Storage) GetOne(value string) (*models.IP, error)
  • func (s *Storage) Update(ip *models.IP) error

Variables

var Config = util.NewConfig()

Config 全局配置文件

var GlobalMgoSession, _ = mgo.Dial(string(Config.Mongo.Addr))

GlobalMgoSession 全局连接Session

Functions

func CheckIP

func CheckIP(ip *models.IP) bool

CheckIP is to check the ip work or not

func CheckProxy

func CheckProxy(ip *models.IP)

CheckProxy .

func CheckProxyDB

func CheckProxyDB()

CheckProxyDB to check the ip in DB

func ProxyAdd

func ProxyAdd(ip *models.IP)

ProxyAdd .

func ProxyDel

func ProxyDel(ip *models.IP)

ProxyDel .

func ProxyFind

func ProxyFind(value string) (ip *models.IP)

ProxyFind .

func ProxyRandom

func ProxyRandom() (ip *models.IP)

ProxyRandom .

Types

type Storage

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

Storage struct is used for storeing persistent data of alerts

func NewStorage

func NewStorage() *Storage

NewStorage creates and returns new Storage instance

func (*Storage) Count

func (s *Storage) Count() int

Count all collections

func (*Storage) Create

func (s *Storage) Create(item interface{}) error

Create insert new item

func (*Storage) Delete

func (s *Storage) Delete(ip *models.IP) error

Delete .

func (*Storage) FindAll

func (s *Storage) FindAll(value string) ([]*models.IP, error)

FindAll .

func (*Storage) GetAll

func (s *Storage) GetAll() ([]*models.IP, error)

GetAll .

func (*Storage) GetDBSession

func (s *Storage) GetDBSession() *mgo.Session

GetDBSession returns a new connection from the pool

func (*Storage) GetOne

func (s *Storage) GetOne(value string) (*models.IP, error)

GetOne Finds and returns one data from storage

func (*Storage) Update

func (s *Storage) Update(ip *models.IP) error

Update .