mongodb

Documentation

Index

• func CollectionFilter(collections []string, collectionsExclude []string) bson.D
• type MongoDB
  • func NewMongoDB(username string, password string, host string, port uint, dbName string, ...) *MongoDB
  • func (m *MongoDB) Close()
  • func (m *MongoDB) Connect() error
  • func (m *MongoDB) CreateCollection(collection string) error
  • func (m *MongoDB) DropCollection(collection string) error
  • func (m *MongoDB) DumpDocumentsBatch(collection string, batchSize int64) error
  • func (m *MongoDB) FetchAllDocuments(collection string) ([]bson.D, error)
  • func (m *MongoDB) FetchCollections(filter interface{}) ([]string, error)
  • func (m *MongoDB) FetchTotalDocumentsCount(collection string, filter interface{}) (int64, error)
  • func (m *MongoDB) GetURI() string
  • func (m *MongoDB) InsertDocuments(collection string, documents []interface{}) error
  • func (m *MongoDB) Ping() error

Functions

func CollectionFilter

func CollectionFilter(collections []string, collectionsExclude []string) bson.D

Types

type MongoDB

type MongoDB struct {
	// contains filtered or unexported fields
}

func NewMongoDB

func NewMongoDB(username string, password string, host string, port uint, dbName string, isSRV bool) *MongoDB

func (*MongoDB) Close

func (m *MongoDB) Close()

func (*MongoDB) Connect

func (m *MongoDB) Connect() error

func (*MongoDB) CreateCollection

func (m *MongoDB) CreateCollection(collection string) error

func (*MongoDB) DropCollection

func (m *MongoDB) DropCollection(collection string) error

func (*MongoDB) DumpDocumentsBatch

func (m *MongoDB) DumpDocumentsBatch(collection string, batchSize int64) error

func (*MongoDB) FetchAllDocuments

func (m *MongoDB) FetchAllDocuments(collection string) ([]bson.D, error)

func (*MongoDB) FetchCollections

func (m *MongoDB) FetchCollections(filter interface{}) ([]string, error)

func (*MongoDB) FetchTotalDocumentsCount

func (m *MongoDB) FetchTotalDocumentsCount(collection string, filter interface{}) (int64, error)

func (*MongoDB) GetURI

func (m *MongoDB) GetURI() string

func (*MongoDB) InsertDocuments

func (m *MongoDB) InsertDocuments(collection string, documents []interface{}) error

func (*MongoDB) Ping

func (m *MongoDB) Ping() error