db

Documentation

Index

• Variables
• func Each(i Iterator, fn func(interface{}) error) error
• type Backend
• type Iterator
• type MongoDB
  • func NewMongoDB(url string) *MongoDB
  • func (m *MongoDB) Close()
  • func (m *MongoDB) Find(objectType string, query map[string]interface{}) (Iterator, error)
  • func (m *MongoDB) IsValid() bool
  • func (m *MongoDB) Upsert(objectType string, id, object interface{}) error
• type Query

Variables

var (
	BackendNotInitializedError = errors.New("backend not initialized")
	BackendTypeError           = errors.New("object type is incorrect")
)

Functions

func Each

func Each(i Iterator, fn func(interface{}) error) error

Types

type Backend

type Backend interface {
	Find(objectType string, query map[string]interface{}) (Iterator, error)
	Upsert(objectType string, id, object interface{}) error
	Close() error
}

type Iterator

type Iterator interface {
	Next() (value interface{}, done bool, err error)
}

type MongoDB

type MongoDB struct {
	Session *mgo.Session
	DB      *mgo.Database
}

MongoDB encapsulates a mongo database and session

func NewMongoDB

func NewMongoDB(url string) *MongoDB

func (*MongoDB) Close

func (m *MongoDB) Close()

Close closes the mongodb session; must be called, else the session remains open

func (*MongoDB) Find

func (m *MongoDB) Find(objectType string, query map[string]interface{}) (Iterator, error)

Find finds from a collection using the query

func (*MongoDB) IsValid

func (m *MongoDB) IsValid() bool

IsValid returns true for a valid session, false otherwise

func (*MongoDB) Upsert

func (m *MongoDB) Upsert(objectType string, id, object interface{}) error

Upsert upserts a specific entity into the given collection

type Query

type Query map[interface{}]interface{}