mongodb

Documentation

Index

• type Mongodb
  • func NewMongo() (mongo *Mongodb, err error)
  • func (mongo *Mongodb) AddSub(sub *Sub) error
  • func (mongo *Mongodb) AddUser(u *User) error
  • func (mongo *Mongodb) AddUserToSub(sm *Sub_map, id string) error
  • func (mongo *Mongodb) ChanSubUsers(sub_id string) <-chan string
  • func (mongo *Mongodb) ChanUserID(own string) <-chan string
  • func (mongo *Mongodb) Client_login(id, psw string) bool
  • func (mongo *Mongodb) Ctrl_login(id, auth string) (bool, string)
  • func (mongo *Mongodb) DelOfflineMsg(id string) error
  • func (mongo *Mongodb) DelSub(sub_id, id string) error
  • func (mongo *Mongodb) DelUser(id string, own string) error
  • func (mongo *Mongodb) DelUserFromSub(sm *Sub_map, id string) error
  • func (mongo *Mongodb) GetOfflineMsg(id string, fin <-chan byte) (<-chan *Msg, <-chan byte)
  • func (mongo *Mongodb) InsertOfflineMsg(msg *Msg, ip string, etcds []string) error
  • func (mongo *Mongodb) IsSubExist(sub_id, id string) bool
  • func (mongo *Mongodb) IsUserExist(uid, oid string) bool

Types

type Mongodb

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

func NewMongo

func NewMongo() (mongo *Mongodb, err error)

func (*Mongodb) AddSub

func (mongo *Mongodb) AddSub(sub *Sub) error

func (*Mongodb) AddUser

func (mongo *Mongodb) AddUser(u *User) error

Add or del user

func (*Mongodb) AddUserToSub

func (mongo *Mongodb) AddUserToSub(sm *Sub_map, id string) error

func (*Mongodb) ChanSubUsers

func (mongo *Mongodb) ChanSubUsers(sub_id string) <-chan string

func (*Mongodb) ChanUserID

func (mongo *Mongodb) ChanUserID(own string) <-chan string

Get the All use's id.

func (*Mongodb) Client_login

func (mongo *Mongodb) Client_login(id, psw string) bool

func (*Mongodb) Ctrl_login

func (mongo *Mongodb) Ctrl_login(id, auth string) (bool, string)

func (*Mongodb) DelOfflineMsg

func (mongo *Mongodb) DelOfflineMsg(id string) error

Del the offile msg

func (*Mongodb) DelSub

func (mongo *Mongodb) DelSub(sub_id, id string) error

func (*Mongodb) DelUser

func (mongo *Mongodb) DelUser(id string, own string) error

func (*Mongodb) DelUserFromSub

func (mongo *Mongodb) DelUserFromSub(sm *Sub_map, id string) error

func (*Mongodb) GetOfflineMsg

func (mongo *Mongodb) GetOfflineMsg(id string, fin <-chan byte) (<-chan *Msg, <-chan byte)

id is to_id (client id)

func (*Mongodb) InsertOfflineMsg

func (mongo *Mongodb) InsertOfflineMsg(msg *Msg, ip string, etcds []string) error

Intert a new offilne msg Before should check the to_id belong the user

func (*Mongodb) IsSubExist

func (mongo *Mongodb) IsSubExist(sub_id, id string) bool

func (*Mongodb) IsUserExist

func (mongo *Mongodb) IsUserExist(uid, oid string) bool