mongodb

Documentation

Index

• type Config
• type Mongodb
  • func New(c *Config) *Mongodb
  • func (m *Mongodb) Close() error
  • func (m *Mongodb) CreateRecords(q QueryInsert) (ok bool, err error)
  • func (m *Mongodb) GetRecords(q QueryGet) ([]map[string]interface{}, error)
  • func (m *Mongodb) Open() error
• type QueryGet
• type QueryInsert

Types

type Config

type Config struct {
	ConnectionURL string `json:"connectionUrl"`
	Database      string `json:"database"`
}

Config provides options to establish connection to mongo db

type Mongodb

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

Mongodb struct

func New

func New(c *Config) *Mongodb

New returns new *Mongodb struct with passed config

func (*Mongodb) Close

func (m *Mongodb) Close() error

Close calls func disconnect for mongo

func (*Mongodb) CreateRecords

func (m *Mongodb) CreateRecords(q QueryInsert) (ok bool, err error)

CreateRecords creates new records according to passed QueryInsert

func (*Mongodb) GetRecords

func (m *Mongodb) GetRecords(q QueryGet) ([]map[string]interface{}, error)

func (*Mongodb) Open

func (m *Mongodb) Open() error

Open initialises new mongodb client

type QueryGet

type QueryGet struct {
	Collection string                 `json:"collection"`
	Query      map[string]interface{} `json:"query"`
}

QueryGet describes to perform retrieving mongo records

type QueryInsert

type QueryInsert struct {
	Collection string                   `json:"collection"`
	Query      []map[string]interface{} `json:"query"`
}

QueryInsert describes interface to insert mongo records