store

Documentation

Index

• Constants
• func DBReplSetGetConfig() (bson.M, error)
• func DBReplSetGetStatus() (bson.M, error)
• func DBServerStatus() (bson.M, error)
• func DBStats() (bson.M, error)
• func DBStatsCollection(colName string) (bson.M, error)
• func EnsureIndexes()
• func EnsureIndexesMessages(collection string)
• func GetCMessages(collection string) *mgo.Collection
• func GetCollectionNames() ([]string, error)
• func GetSlowestQueries() ([]map[string]interface{}, error)
• func NewStore() error
• func RefreshStore()
• type MongoStore
  • func Tat() *MongoStore

Constants

const (
	// DatabaseName is DatabaseName on mongoBD
	DatabaseName = "tat"

	// CollectionDefaultMessages is default names for collections message, if
	// topic doesn't have "collection" attribute setted
	CollectionDefaultMessages = "messages"
)

Functions

func DBReplSetGetConfig

func DBReplSetGetConfig() (bson.M, error)

DBReplSetGetConfig returns replSetGetConfig cmd

func DBReplSetGetStatus

func DBReplSetGetStatus() (bson.M, error)

DBReplSetGetStatus returns replSetGetStatus cmd

func DBServerStatus

func DBServerStatus() (bson.M, error)

DBServerStatus returns serverStatus cmd

func DBStats

func DBStats() (bson.M, error)

DBStats returns dbstats cmd

func DBStatsCollection

func DBStatsCollection(colName string) (bson.M, error)

DBStatsCollection returns stats for given collection

func EnsureIndexes

func EnsureIndexes()

EnsureIndexes fixes index at startup

func EnsureIndexesMessages

func EnsureIndexesMessages(collection string)

EnsureIndexesMessages set indexes on a message collection

func GetCMessages

func GetCMessages(collection string) *mgo.Collection

GetCMessages return mgo collection

func GetCollectionNames

func GetCollectionNames() ([]string, error)

GetCollectionNames returns collection names

func GetSlowestQueries

func GetSlowestQueries() ([]map[string]interface{}, error)

GetSlowestQueries returns the slowest queries

func NewStore

func NewStore() error

NewStore initializes a new MongoDB Store

func RefreshStore

func RefreshStore()

RefreshStore calls Refresh on mongoDB Store, in order to avoid lost connection

Types

type MongoStore

type MongoStore struct {
	Session          *mgo.Session
	CGroups          *mgo.Collection
	CDefaultMessages *mgo.Collection
	CPresences       *mgo.Collection
	CTopics          *mgo.Collection
	CUsers           *mgo.Collection
	CSockets         *mgo.Collection
}

MongoStore stores MongoDB Session and collections

func Tat

func Tat() *MongoStore

Tat returns mongoDB instance for Tat