database

package
v0.0.0-...-bceca87 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Dec 28, 2019 License: BSD-2-Clause Imports: 6 Imported by: 4

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type MongoDB

type MongoDB struct {
	DBURI    string
	Database string
	// contains filtered or unexported fields
}

func New

func New(db_uri, database string) (mongodb *MongoDB)

func (*MongoDB) GetCollection

func (mdb *MongoDB) GetCollection(collectionName string) (session *mgo.Session, collection *mgo.Collection, err error)

func (*MongoDB) GetSession

func (mdb *MongoDB) GetSession() (session *mgo.Session, err error)

func (*MongoDB) GetUpdateTotalMessages

func (mdb *MongoDB) GetUpdateTotalMessages(step int64) (count int64)

type TorpedoStats

type TorpedoStats struct {
	ProcessedMessagesTotal int64
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL