mongo_data_source

Documentation

Index

• Variables
• func ConfigureForEnv(env string, cb func(c *config.Configuration) *config.Configuration)
• func New(collection string) data_source.DataSource
• type MongoDataSource
  • func (m MongoDataSource) All() (map[string]map[string]interface{}, error)
  • func (m MongoDataSource) Count(search map[string]interface{}) (int64, error)
  • func (m MongoDataSource) Delete(id string) error
  • func (m MongoDataSource) Find(search map[string]interface{}) (map[string]map[string]interface{}, error)
  • func (m MongoDataSource) FindAndDelete(search map[string]interface{}) error
  • func (m MongoDataSource) FindOne(search map[string]interface{}) (string, map[string]interface{}, error)
  • func (m MongoDataSource) Name() string
  • func (m MongoDataSource) Save(entityId string, entity map[string]interface{}) error
  • func (m MongoDataSource) Start() error
  • func (m MongoDataSource) Stop() error

Variables

var Plugin = plugin.Plugin

Functions

func ConfigureForEnv

func ConfigureForEnv(env string, cb func(c *config.Configuration) *config.Configuration)

ConfigureForEnv sets the config for the plugin for the specified environment.

func New

func New(collection string) data_source.DataSource

Types

type MongoDataSource

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

func (MongoDataSource) All

func (m MongoDataSource) All() (map[string]map[string]interface{}, error)

func (MongoDataSource) Count

func (m MongoDataSource) Count(search map[string]interface{}) (int64, error)

func (MongoDataSource) Delete

func (m MongoDataSource) Delete(id string) error

func (MongoDataSource) Find

func (m MongoDataSource) Find(search map[string]interface{}) (map[string]map[string]interface{}, error)

func (MongoDataSource) FindAndDelete

func (m MongoDataSource) FindAndDelete(search map[string]interface{}) error

func (MongoDataSource) FindOne

func (m MongoDataSource) FindOne(search map[string]interface{}) (string, map[string]interface{}, error)

func (MongoDataSource) Name

func (m MongoDataSource) Name() string

func (MongoDataSource) Save

func (m MongoDataSource) Save(entityId string, entity map[string]interface{}) error

func (MongoDataSource) Start

func (m MongoDataSource) Start() error

func (MongoDataSource) Stop

func (m MongoDataSource) Stop() error