postgres

Documentation

Index

• func DB(config *engine.PluginConfig) (*gorm.DB, error)
• func NewPostgresPlugin() *engine.Plugin
• type PostgresPlugin
  • func (p *PostgresPlugin) AddRow(config *engine.PluginConfig, schema string, storageUnit string, ...) (bool, error)
  • func (p *PostgresPlugin) AddStorageUnit(config *engine.PluginConfig, schema string, storageUnit string, ...) (bool, error)
  • func (p *PostgresPlugin) Chat(config *engine.PluginConfig, schema string, model string, ...) ([]*engine.ChatMessage, error)
  • func (p *PostgresPlugin) DeleteRow(config *engine.PluginConfig, schema string, storageUnit string, ...) (bool, error)
  • func (p *PostgresPlugin) GetDatabases(config *engine.PluginConfig) ([]string, error)
  • func (p *PostgresPlugin) GetGraph(config *engine.PluginConfig, schema string) ([]engine.GraphUnit, error)
  • func (p *PostgresPlugin) GetRows(config *engine.PluginConfig, schema string, storageUnit string, where string, ...) (*engine.GetRowsResult, error)
  • func (p *PostgresPlugin) GetSchema(config *engine.PluginConfig) ([]string, error)
  • func (p *PostgresPlugin) GetStorageUnits(config *engine.PluginConfig, schema string) ([]engine.StorageUnit, error)
  • func (p *PostgresPlugin) IsAvailable(config *engine.PluginConfig) bool
  • func (p *PostgresPlugin) RawExecute(config *engine.PluginConfig, query string) (*engine.GetRowsResult, error)
  • func (p *PostgresPlugin) UpdateStorageUnit(config *engine.PluginConfig, schema string, storageUnit string, ...) (bool, error)

Functions

func DB

func DB(config *engine.PluginConfig) (*gorm.DB, error)

func NewPostgresPlugin

func NewPostgresPlugin() *engine.Plugin

Types

type PostgresPlugin

type PostgresPlugin struct{}

func (*PostgresPlugin) AddRow

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

func (*PostgresPlugin) AddStorageUnit

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

func (*PostgresPlugin) Chat

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

func (*PostgresPlugin) DeleteRow

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

func (*PostgresPlugin) GetDatabases

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

func (*PostgresPlugin) GetGraph

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

func (*PostgresPlugin) GetRows

func (p *PostgresPlugin) GetRows(config *engine.PluginConfig, schema string, storageUnit string, where string, pageSize int, pageOffset int) (*engine.GetRowsResult, error)

func (*PostgresPlugin) GetSchema

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

func (*PostgresPlugin) GetStorageUnits

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

func (*PostgresPlugin) IsAvailable

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

func (*PostgresPlugin) RawExecute

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

func (*PostgresPlugin) UpdateStorageUnit

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