mongodb

Documentation

Index

• Constants
• func CloseMongoConnection(collection string)
• func InitMongoConnection()
• func ListCollections() []string
• func ReadAll(SearchElement string, collection string) *mongo.Cursor
• func WriteToMongo(v []byte, collection string)
• type DbWriteCache_t

Constants

const DB_WRITE_THRESHOLD = 100 // the threshold at which the cache is written to Mongo.

Functions

func CloseMongoConnection

func CloseMongoConnection(collection string)

func InitMongoConnection

func InitMongoConnection()

func ListCollections

func ListCollections() []string

func ReadAll

func ReadAll(SearchElement string, collection string) *mongo.Cursor

Reads all of though data points of a particular type. E.g magheading or boatspeed etc

func WriteToMongo

func WriteToMongo(v []byte, collection string)

Types

type DbWriteCache_t

type DbWriteCache_t struct {
	Count int                         //number of documents waiting to be written
	Mem   *[DB_WRITE_THRESHOLD][]byte //pomter to array of []byte where the bson documents are cached before they are written
}