mongo

Documentation

Index

• func Count(session *mgo.Session, db string, collection string) int64
• func CreateMongoSession(cfg *config.MongoConnConfig) (*mgo.Session, error)
• func IsDeadSignal(op *gtm.Op, pipeline string) bool
• func IsEmpty(session *mgo.Session, db string, collection string) bool
• func ListAllUserCollections(session *mgo.Session) map[string][]string
• func SendDeadSignal(session *mgo.Session, pipeline string) error
• type MinMax
  • func BucketAuto(session *mgo.Session, db string, collection string, sampleCnt int, ...) ([]MinMax, error)
  • func GetMinMax(session *mgo.Session, db string, collection string) (MinMax, error)

Functions

func Count

func Count(session *mgo.Session, db string, collection string) int64

func CreateMongoSession

func CreateMongoSession(cfg *config.MongoConnConfig) (*mgo.Session, error)

func IsDeadSignal

func IsDeadSignal(op *gtm.Op, pipeline string) bool

func IsEmpty

func IsEmpty(session *mgo.Session, db string, collection string) bool

func ListAllUserCollections

func ListAllUserCollections(session *mgo.Session) map[string][]string

func SendDeadSignal

func SendDeadSignal(session *mgo.Session, pipeline string) error

Types

type MinMax

type MinMax struct {
	Min interface{}
	Max interface{}
}

func BucketAuto

func BucketAuto(session *mgo.Session, db string, collection string, sampleCnt int, bucketCnt int) ([]MinMax, error)

func GetMinMax

func GetMinMax(session *mgo.Session, db string, collection string) (MinMax, error)