mongo

Documentation

Index

• func Count(session *mgo.Session, db string, collection string) int
• 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 ListAllCollections(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)

Functions

func Count

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

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 ListAllCollections

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

func SendDeadSignal

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

Types

type MinMax

type MinMax struct {
	Min bson.ObjectId
	Max bson.ObjectId
}

func BucketAuto

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