mongodb

Documentation

Index

• func DB(config *engine.PluginConfig) (*mongo.Client, error)
• func NewMongoDBPlugin() *engine.Plugin
• type MongoDBPlugin
  • func (p *MongoDBPlugin) AddRow(config *engine.PluginConfig, schema string, storageUnit string, ...) (bool, error)
  • func (p *MongoDBPlugin) AddStorageUnit(config *engine.PluginConfig, schema string, storageUnit string, ...) (bool, error)
  • func (p *MongoDBPlugin) Chat(config *engine.PluginConfig, schema string, model string, ...) ([]*engine.ChatMessage, error)
  • func (p *MongoDBPlugin) DeleteRow(config *engine.PluginConfig, database string, storageUnit string, ...) (bool, error)
  • func (p *MongoDBPlugin) GetDatabases(config *engine.PluginConfig) ([]string, error)
  • func (p *MongoDBPlugin) GetGraph(config *engine.PluginConfig, database string) ([]engine.GraphUnit, error)
  • func (p *MongoDBPlugin) GetRows(config *engine.PluginConfig, database, collection, filter string, ...) (*engine.GetRowsResult, error)
  • func (p *MongoDBPlugin) GetSchema(config *engine.PluginConfig) ([]string, error)
  • func (p *MongoDBPlugin) GetStorageUnits(config *engine.PluginConfig, database string) ([]engine.StorageUnit, error)
  • func (p *MongoDBPlugin) IsAvailable(config *engine.PluginConfig) bool
  • func (p *MongoDBPlugin) RawExecute(config *engine.PluginConfig, query string) (*engine.GetRowsResult, error)
  • func (p *MongoDBPlugin) UpdateStorageUnit(config *engine.PluginConfig, database string, storageUnit string, ...) (bool, error)

Functions

func DB

func DB(config *engine.PluginConfig) (*mongo.Client, error)

func NewMongoDBPlugin

func NewMongoDBPlugin() *engine.Plugin

Types

type MongoDBPlugin

type MongoDBPlugin struct{}

func (*MongoDBPlugin) AddRow

func (p *MongoDBPlugin) AddRow(config *engine.PluginConfig, schema string, storageUnit string, values []engine.Record) (bool, error)

func (*MongoDBPlugin) AddStorageUnit

func (p *MongoDBPlugin) AddStorageUnit(config *engine.PluginConfig, schema string, storageUnit string, fields map[string]string) (bool, error)

func (*MongoDBPlugin) Chat

func (p *MongoDBPlugin) Chat(config *engine.PluginConfig, schema string, model string, previousConversation string, query string) ([]*engine.ChatMessage, error)

func (*MongoDBPlugin) DeleteRow

func (p *MongoDBPlugin) DeleteRow(config *engine.PluginConfig, database string, storageUnit string, values map[string]string) (bool, error)

func (*MongoDBPlugin) GetDatabases

func (p *MongoDBPlugin) GetDatabases(config *engine.PluginConfig) ([]string, error)

func (*MongoDBPlugin) GetGraph

func (p *MongoDBPlugin) GetGraph(config *engine.PluginConfig, database string) ([]engine.GraphUnit, error)

func (*MongoDBPlugin) GetRows

func (p *MongoDBPlugin) GetRows(config *engine.PluginConfig, database, collection, filter string, pageSize, pageOffset int) (*engine.GetRowsResult, error)

func (*MongoDBPlugin) GetSchema

func (p *MongoDBPlugin) GetSchema(config *engine.PluginConfig) ([]string, error)

func (*MongoDBPlugin) GetStorageUnits

func (p *MongoDBPlugin) GetStorageUnits(config *engine.PluginConfig, database string) ([]engine.StorageUnit, error)

func (*MongoDBPlugin) IsAvailable

func (p *MongoDBPlugin) IsAvailable(config *engine.PluginConfig) bool

func (*MongoDBPlugin) RawExecute

func (p *MongoDBPlugin) RawExecute(config *engine.PluginConfig, query string) (*engine.GetRowsResult, error)

func (*MongoDBPlugin) UpdateStorageUnit

func (p *MongoDBPlugin) UpdateStorageUnit(config *engine.PluginConfig, database string, storageUnit string, values map[string]string) (bool, error)