module

package

Go to main page

Versions in this module

v0

v0.1.5

Dec 18, 2024

Changes in this version

type SQLiteModule

+ Table *SQLiteTable

type SQLiteTable

+ func (t *SQLiteTable) ClearBuffers()

+ func (t *SQLiteTable) FlushBuffers() error

v0.1.4

Nov 24, 2024

Changes in this version

+ type MySQLCursor struct

+ func (t *MySQLCursor) Close() error

+ func (t *MySQLCursor) Column(context *sqlite3.SQLiteContext, col int) error

+ func (t *MySQLCursor) EOF() bool

+ func (t *MySQLCursor) Filter(idxNum int, idxStr string, vals []interface{}) error

+ func (t *MySQLCursor) Next() error

+ func (t *MySQLCursor) Rowid() (int64, error)

+ type MySQLModule struct

+ func (m *MySQLModule) Connect(c *sqlite3.SQLiteConn, args []string) (sqlite3.VTab, error)

+ func (m *MySQLModule) Create(c *sqlite3.SQLiteConn, args []string) (sqlite3.VTab, error)

+ func (m *MySQLModule) GetDBConnection(connectionString string) (*sql.Conn, error)

+ func (m *MySQLModule) TransactionModule()

+ func (v *MySQLModule) DestroyModule()

+ type MySQLPlan struct

+ QueryBlock struct{ ... }

+ type MySQLTable struct

+ func (t *MySQLTable) Begin() error

+ func (t *MySQLTable) BestIndex(cst []sqlite3.InfoConstraint, ob []sqlite3.InfoOrderBy) (*sqlite3.IndexResult, error)

+ func (t *MySQLTable) Commit() error

+ func (t *MySQLTable) Delete(id any) error

+ func (t *MySQLTable) Destroy() error

+ func (t *MySQLTable) Disconnect() error

+ func (t *MySQLTable) Insert(id any, vals []any) (int64, error)

+ func (t *MySQLTable) Open() (sqlite3.VTabCursor, error)

+ func (t *MySQLTable) PartialUpdate() bool

+ func (t *MySQLTable) Rollback() error

+ func (t *MySQLTable) Update(id any, vals []any) error

+ type PostgresCursor struct

+ func (t *PostgresCursor) Close() error

+ func (t *PostgresCursor) Column(context *sqlite3.SQLiteContext, col int) error

+ func (t *PostgresCursor) EOF() bool

+ func (t *PostgresCursor) Filter(idxNum int, idxStr string, vals []interface{}) error

+ func (t *PostgresCursor) Next() error

+ func (t *PostgresCursor) Rowid() (int64, error)

+ type PostgresModule struct

+ func (m *PostgresModule) Connect(c *sqlite3.SQLiteConn, args []string) (sqlite3.VTab, error)

+ func (m *PostgresModule) Create(c *sqlite3.SQLiteConn, args []string) (sqlite3.VTab, error)

+ func (m *PostgresModule) GetDBConnection(connectionString string) (*pgxpool.Conn, error)

+ func (m *PostgresModule) TransactionModule()

+ func (v *PostgresModule) DestroyModule()

+ type PostgresPlan []struct

+ type PostgresTable struct

+ func (t *PostgresTable) Begin() error

+ func (t *PostgresTable) BestIndex(cst []sqlite3.InfoConstraint, ob []sqlite3.InfoOrderBy) (*sqlite3.IndexResult, error)

+ func (t *PostgresTable) Commit() error

+ func (t *PostgresTable) Delete(id any) error

+ func (t *PostgresTable) Destroy() error

+ func (t *PostgresTable) Disconnect() error

+ func (t *PostgresTable) Insert(id any, vals []any) (int64, error)

+ func (t *PostgresTable) Open() (sqlite3.VTabCursor, error)

+ func (t *PostgresTable) PartialUpdate() bool

+ func (t *PostgresTable) Rollback() error

+ func (t *PostgresTable) Update(id any, vals []any) error

+ type SQLQueryToExecute struct

+ Args []interface{}

+ LimitIndex int

+ OffsetIndex int

+ Query string

type SQLiteTable

+ func (t *SQLiteTable) PartialUpdate() bool

+ type Valuable interface

+ Value func() (driver.Value, error)

v0.1.3

Sep 14, 2024

v0.1.2

Sep 11, 2024

Changes in this version

+ type LogCursor struct

+ func (t *LogCursor) Close() error

+ func (t *LogCursor) Column(context *sqlite3.SQLiteContext, col int) error

+ func (t *LogCursor) EOF() bool

+ func (t *LogCursor) Filter(idxNum int, idxStr string, vals []interface{}) error

+ func (t *LogCursor) Next() error

+ func (t *LogCursor) Rowid() (int64, error)

+ type LogModule struct

+ func (m *LogModule) Connect(c *sqlite3.SQLiteConn, args []string) (sqlite3.VTab, error)

+ func (m *LogModule) Create(c *sqlite3.SQLiteConn, args []string) (sqlite3.VTab, error)

+ func (v *LogModule) DestroyModule()

+ type LogTable struct

+ func (t *LogTable) BestIndex(cst []sqlite3.InfoConstraint, ob []sqlite3.InfoOrderBy) (*sqlite3.IndexResult, error)

+ func (t *LogTable) Destroy() error

+ func (t *LogTable) Disconnect() error

+ func (t *LogTable) Open() (sqlite3.VTabCursor, error)

v0.1.1

Aug 6, 2024

Changes in this version

+ type CsvCursor struct

+ func (t *CsvCursor) Close() error

+ func (t *CsvCursor) Column(context *sqlite3.SQLiteContext, col int) error

+ func (t *CsvCursor) EOF() bool

+ func (t *CsvCursor) Filter(idxNum int, idxStr string, vals []interface{}) error

+ func (t *CsvCursor) Next() error

+ func (t *CsvCursor) Rowid() (int64, error)

+ type CsvModule struct

+ func (m *CsvModule) Connect(c *sqlite3.SQLiteConn, args []string) (sqlite3.VTab, error)

+ func (m *CsvModule) Create(c *sqlite3.SQLiteConn, args []string) (sqlite3.VTab, error)

+ func (v *CsvModule) DestroyModule()

+ type CsvTable struct

+ func (t *CsvTable) BestIndex(cst []sqlite3.InfoConstraint, ob []sqlite3.InfoOrderBy) (*sqlite3.IndexResult, error)

+ func (t *CsvTable) Destroy() error

+ func (t *CsvTable) Disconnect() error

+ func (t *CsvTable) Open() (sqlite3.VTabCursor, error)

+ type HtmlCursor struct

+ func (t *HtmlCursor) Close() error

+ func (t *HtmlCursor) Column(context *sqlite3.SQLiteContext, col int) error

+ func (t *HtmlCursor) EOF() bool

+ func (t *HtmlCursor) Filter(idxNum int, idxStr string, vals []interface{}) error

+ func (t *HtmlCursor) Next() error

+ func (t *HtmlCursor) Rowid() (int64, error)

+ type HtmlModule struct

+ func (m *HtmlModule) Connect(c *sqlite3.SQLiteConn, args []string) (sqlite3.VTab, error)

+ func (m *HtmlModule) Create(c *sqlite3.SQLiteConn, args []string) (sqlite3.VTab, error)

+ func (v *HtmlModule) DestroyModule()

+ type HtmlTable struct

+ func (t *HtmlTable) BestIndex(cst []sqlite3.InfoConstraint, ob []sqlite3.InfoOrderBy) (*sqlite3.IndexResult, error)

+ func (t *HtmlTable) Destroy() error

+ func (t *HtmlTable) Disconnect() error

+ func (t *HtmlTable) Open() (sqlite3.VTabCursor, error)

+ type JSONCursor struct

+ func (t *JSONCursor) Close() error

+ func (t *JSONCursor) Column(context *sqlite3.SQLiteContext, col int) error

+ func (t *JSONCursor) EOF() bool

+ func (t *JSONCursor) Filter(idxNum int, idxStr string, vals []interface{}) error

+ func (t *JSONCursor) Next() error

+ func (t *JSONCursor) Rowid() (int64, error)

+ type JSONCursorColShape struct

+ type JSONModule struct

+ func (m *JSONModule) Connect(c *sqlite3.SQLiteConn, args []string) (sqlite3.VTab, error)

+ func (m *JSONModule) Create(c *sqlite3.SQLiteConn, args []string) (sqlite3.VTab, error)

+ func (v *JSONModule) DestroyModule()

+ type JSONTable struct

+ func (t *JSONTable) BestIndex(cst []sqlite3.InfoConstraint, ob []sqlite3.InfoOrderBy) (*sqlite3.IndexResult, error)

+ func (t *JSONTable) Destroy() error

+ func (t *JSONTable) Disconnect() error

+ func (t *JSONTable) Open() (sqlite3.VTabCursor, error)

+ type JSONlCursor struct

+ func (t *JSONlCursor) Close() error

+ func (t *JSONlCursor) Column(context *sqlite3.SQLiteContext, col int) error

+ func (t *JSONlCursor) EOF() bool

+ func (t *JSONlCursor) Filter(idxNum int, idxStr string, vals []interface{}) error

+ func (t *JSONlCursor) Next() error

+ func (t *JSONlCursor) Rowid() (int64, error)

+ type JSONlModule struct

+ func (m *JSONlModule) Connect(c *sqlite3.SQLiteConn, args []string) (sqlite3.VTab, error)

+ func (m *JSONlModule) Create(c *sqlite3.SQLiteConn, args []string) (sqlite3.VTab, error)

+ func (v *JSONlModule) DestroyModule()

+ type JSONlTable struct

+ func (t *JSONlTable) BestIndex(cst []sqlite3.InfoConstraint, ob []sqlite3.InfoOrderBy) (*sqlite3.IndexResult, error)

+ func (t *JSONlTable) Destroy() error

+ func (t *JSONlTable) Disconnect() error

+ func (t *JSONlTable) Open() (sqlite3.VTabCursor, error)

+ type ParquetCursor struct

+ func (t *ParquetCursor) Close() error

+ func (t *ParquetCursor) Column(context *sqlite3.SQLiteContext, col int) error

+ func (t *ParquetCursor) EOF() bool

+ func (t *ParquetCursor) Filter(idxNum int, idxStr string, vals []interface{}) error

+ func (t *ParquetCursor) Next() error

+ func (t *ParquetCursor) Rowid() (int64, error)

+ type ParquetModule struct

+ func (m *ParquetModule) Connect(c *sqlite3.SQLiteConn, args []string) (sqlite3.VTab, error)

+ func (m *ParquetModule) Create(c *sqlite3.SQLiteConn, args []string) (sqlite3.VTab, error)

+ func (v *ParquetModule) DestroyModule()

+ type ParquetTable struct

+ func (t *ParquetTable) BestIndex(cst []sqlite3.InfoConstraint, ob []sqlite3.InfoOrderBy) (*sqlite3.IndexResult, error)

+ func (t *ParquetTable) Destroy() error

+ func (t *ParquetTable) Disconnect() error

+ func (t *ParquetTable) Open() (sqlite3.VTabCursor, error)

+ type SQLiteCursor struct

+ func (c *SQLiteCursor) Close() error

+ func (c *SQLiteCursor) Column(context *sqlite3.SQLiteContext, col int) error

+ func (c *SQLiteCursor) EOF() bool

+ func (c *SQLiteCursor) Filter(idxNum int, idxStr string, vals []interface{}) error

+ func (c *SQLiteCursor) Next() error

+ func (c *SQLiteCursor) Rowid() (int64, error)

+ type SQLiteModule struct

+ ConnectionIndex int

+ ConnectionPool *rpc.ConnectionPool

+ Logger hclog.Logger

+ PluginArgs []string

+ PluginManifest rpc.PluginManifest

+ PluginPath string

+ Stderr io.Writer

+ TableIndex int

+ UserConfig rpc.PluginConfig

+ func (m *SQLiteModule) Connect(c *sqlite3.SQLiteConn, args []string) (sqlite3.VTab, error)

+ func (m *SQLiteModule) Create(c *sqlite3.SQLiteConn, args []string) (sqlite3.VTab, error)

+ func (m *SQLiteModule) EponymousOnlyModule()

+ func (v *SQLiteModule) DestroyModule()

+ type SQLiteTable struct

+ ConnectionPool *rpc.ConnectionPool

+ PluginPath string

+ func (t *SQLiteTable) BestIndex(cst []sqlite3.InfoConstraint, ob []sqlite3.InfoOrderBy) (*sqlite3.IndexResult, error)

+ func (t *SQLiteTable) Delete(id any) error

+ func (t *SQLiteTable) Insert(id any, vals []any) (int64, error)

+ func (t *SQLiteTable) Open() (sqlite3.VTabCursor, error)

+ func (t *SQLiteTable) Update(id any, vals []any) error

+ func (v *SQLiteTable) Destroy() error

+ func (v *SQLiteTable) Disconnect() error

+ type TomlCursor struct

+ func (t *TomlCursor) Close() error

+ func (t *TomlCursor) Column(context *sqlite3.SQLiteContext, col int) error

+ func (t *TomlCursor) EOF() bool

+ func (t *TomlCursor) Filter(idxNum int, idxStr string, vals []interface{}) error

+ func (t *TomlCursor) Next() error

+ func (t *TomlCursor) Rowid() (int64, error)

+ type TomlModule struct

+ func (m *TomlModule) Connect(c *sqlite3.SQLiteConn, args []string) (sqlite3.VTab, error)

+ func (m *TomlModule) Create(c *sqlite3.SQLiteConn, args []string) (sqlite3.VTab, error)

+ func (v *TomlModule) DestroyModule()

+ type TomlTable struct

+ func (t *TomlTable) BestIndex(cst []sqlite3.InfoConstraint, ob []sqlite3.InfoOrderBy) (*sqlite3.IndexResult, error)

+ func (t *TomlTable) Destroy() error

+ func (t *TomlTable) Disconnect() error

+ func (t *TomlTable) Open() (sqlite3.VTabCursor, error)

+ type YamlCursor struct

+ func (t *YamlCursor) Close() error

+ func (t *YamlCursor) Column(context *sqlite3.SQLiteContext, col int) error

+ func (t *YamlCursor) EOF() bool

+ func (t *YamlCursor) Filter(idxNum int, idxStr string, vals []interface{}) error

+ func (t *YamlCursor) Next() error

+ func (t *YamlCursor) Rowid() (int64, error)

+ type YamlModule struct

+ func (m *YamlModule) Connect(c *sqlite3.SQLiteConn, args []string) (sqlite3.VTab, error)

+ func (m *YamlModule) Create(c *sqlite3.SQLiteConn, args []string) (sqlite3.VTab, error)

+ func (v *YamlModule) DestroyModule()

+ type YamlTable struct

+ func (t *YamlTable) BestIndex(cst []sqlite3.InfoConstraint, ob []sqlite3.InfoOrderBy) (*sqlite3.IndexResult, error)

+ func (t *YamlTable) Destroy() error

+ func (t *YamlTable) Disconnect() error

+ func (t *YamlTable) Open() (sqlite3.VTabCursor, error)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL