mongodb

Documentation

Index

• Constants
• type Datastore
  • func NewDatastore(config datalayer.DBConfig) (*Datastore, error)
  • func (ds *Datastore) Connect(config datalayer.DBConfig) (datalayer.DataStore, error)
  • func (ds *Datastore) CreateCollection(ctx context.Context, name string, schema, metadata map[string]interface{}) error
  • func (ds *Datastore) GetCollections(ctx context.Context) (collections []datalayer.CollectionVM, err error)
  • func (ds *Datastore) GetItem(ctx context.Context, collectionName, itemID string) (item map[string]interface{}, err error)
  • func (ds *Datastore) GetItems(ctx context.Context, collectionName string, queryData datalayer.QueryMeta) (items []map[string]interface{}, respInfo datalayer.ItemsResponseInfo, ...)
  • func (ds *Datastore) GetSchema(ctx context.Context, collectionName string) (map[string]interface{}, error)
  • func (ds *Datastore) SaveItem(ctx context.Context, collectionName, itemID string, ...) error

Constants

const DriverName = "mongodb"

Types

type Datastore

type Datastore struct {
	DB               *mgo.Database
	SchemaCollection string
}

func NewDatastore

func NewDatastore(config datalayer.DBConfig) (*Datastore, error)

func (*Datastore) Connect

func (ds *Datastore) Connect(config datalayer.DBConfig) (datalayer.DataStore, error)

func (*Datastore) CreateCollection

func (ds *Datastore) CreateCollection(ctx context.Context, name string, schema, metadata map[string]interface{}) error

func (*Datastore) GetCollections

func (ds *Datastore) GetCollections(ctx context.Context) (collections []datalayer.CollectionVM, err error)

func (*Datastore) GetItem

func (ds *Datastore) GetItem(ctx context.Context, collectionName, itemID string) (item map[string]interface{}, err error)

func (*Datastore) GetItems

func (ds *Datastore) GetItems(ctx context.Context, collectionName string, queryData datalayer.QueryMeta) (items []map[string]interface{}, respInfo datalayer.ItemsResponseInfo, err error)

func (*Datastore) GetSchema

func (ds *Datastore) GetSchema(ctx context.Context, collectionName string) (map[string]interface{}, error)

func (*Datastore) SaveItem

func (ds *Datastore) SaveItem(ctx context.Context, collectionName, itemID string, item map[string]interface{}) error