plugins

package

Go to main page

Versions in this module

v0

v0.27.0

Apr 9, 2026

v0.26.0

Mar 22, 2026

Changes in this version

type ClickHouseDriver

+ func (d *ClickHouseDriver) IsNamespaceSupported() bool

type MySQLDriver

+ func (d *MySQLDriver) IsNamespaceSupported() bool

type NullDriver

+ func (d *NullDriver) IsNamespaceSupported() bool

type PostgreSQLDriver

+ func (d *PostgreSQLDriver) IsNamespaceSupported() bool

type SQLiteDriver

+ func (d *SQLiteDriver) IsNamespaceSupported() bool

v0.25.0

Mar 7, 2026

Changes in this version

+ type ClickHouseBrowser struct

+ func NewClickHouseBrowser(driver *ClickHouseDriver) *ClickHouseBrowser

+ func (b *ClickHouseBrowser) Connect(ctx context.Context, dsn string) error

+ func (b *ClickHouseBrowser) Disconnect(ctx context.Context) error

+ func (b *ClickHouseBrowser) List(ctx context.Context, ids []string) ([]plugin.BrowserItem, error)

+ func (b *ClickHouseBrowser) ParseExplain(data plugin.BrowserQueryResult) (plugin.BrowserExplainResult, error)

+ func (b *ClickHouseBrowser) Query(ctx context.Context, query string) (plugin.BrowserQueryResult, error)

+ func (b *ClickHouseBrowser) Show(ctx context.Context, ids []string) (string, error)

+ type ClickHouseDriver struct

+ func NewClickHouseDriver() *ClickHouseDriver

+ func (d *ClickHouseDriver) Connect(ctx context.Context, config config.DriverConfig) (plugin.DriverConnection, error)

+ func (d *ClickHouseDriver) Disconnect(ctx context.Context, conn plugin.DriverConnection) error

+ type ClickHouseDriverConnection struct

+ DB *sql.DB

+ func (c *ClickHouseDriverConnection) AppendAuditLog(ctx context.Context, execCtx plugin.DriverExecutionContext, ...) error

+ func (c *ClickHouseDriverConnection) LockAuditLog(ctx context.Context, execCtx plugin.DriverExecutionContext, ...) error

+ func (c *ClickHouseDriverConnection) Query(execCtx plugin.DriverExecutionContext) plugin.DriverQuery

+ func (c *ClickHouseDriverConnection) ReadAuditLogs(ctx context.Context, execCtx plugin.DriverExecutionContext) ([]plugin.DriverAuditLog, error)

+ func (c *ClickHouseDriverConnection) UnlockAuditLog(ctx context.Context, execCtx plugin.DriverExecutionContext, ...) error

+ func (c *ClickHouseDriverConnection) UpsertAuditLockTable(ctx context.Context, execCtx plugin.DriverExecutionContext) error

+ func (c *ClickHouseDriverConnection) UpsertAuditLogTable(ctx context.Context, execCtx plugin.DriverExecutionContext) error

+ type ClickHouseQuery struct

+ func (q *ClickHouseQuery) Begin(ctx context.Context) (plugin.DriverQuery, error)

+ func (q *ClickHouseQuery) Commit(ctx context.Context) error

+ func (q *ClickHouseQuery) Exec(ctx context.Context, query string, args ...any) error

+ func (q *ClickHouseQuery) Query(ctx context.Context, query string, args ...any) (*plugin.DriverQueryResult, error)

+ func (q *ClickHouseQuery) Rollback(ctx context.Context) error

v0.24.0

Mar 7, 2026

v0.23.0

Mar 7, 2026

v0.22.0

Mar 2, 2026

Changes in this version

+ type MySQLBrowser struct

+ func NewMySQLBrowser(driver *MySQLDriver) *MySQLBrowser

+ func (b *MySQLBrowser) Connect(ctx context.Context, dsn string) error

+ func (b *MySQLBrowser) Disconnect(ctx context.Context) error

+ func (b *MySQLBrowser) List(ctx context.Context, ids []string) ([]plugin.BrowserItem, error)

+ func (b *MySQLBrowser) ParseExplain(data plugin.BrowserQueryResult) (plugin.BrowserExplainResult, error)

+ func (b *MySQLBrowser) Query(ctx context.Context, query string) (plugin.BrowserQueryResult, error)

+ func (b *MySQLBrowser) Show(ctx context.Context, ids []string) (string, error)

+ type MySQLDriver struct

+ func NewMySQLDriver() *MySQLDriver

+ func (d *MySQLDriver) Connect(ctx context.Context, config config.DriverConfig) (plugin.DriverConnection, error)

+ func (d *MySQLDriver) Disconnect(ctx context.Context, conn plugin.DriverConnection) error

+ type MySQLDriverConnection struct

+ DB *sql.DB

+ func (c *MySQLDriverConnection) AppendAuditLog(ctx context.Context, execCtx plugin.DriverExecutionContext, ...) error

+ func (c *MySQLDriverConnection) LockAuditLog(ctx context.Context, execCtx plugin.DriverExecutionContext, ...) error

+ func (c *MySQLDriverConnection) Query(execCtx plugin.DriverExecutionContext) plugin.DriverQuery

+ func (c *MySQLDriverConnection) ReadAuditLogs(ctx context.Context, execCtx plugin.DriverExecutionContext) ([]plugin.DriverAuditLog, error)

+ func (c *MySQLDriverConnection) UnlockAuditLog(ctx context.Context, execCtx plugin.DriverExecutionContext, ...) error

+ func (c *MySQLDriverConnection) UpsertAuditLockTable(ctx context.Context, execCtx plugin.DriverExecutionContext) error

+ func (c *MySQLDriverConnection) UpsertAuditLogTable(ctx context.Context, execCtx plugin.DriverExecutionContext) error

+ type MySQLQuery struct

+ func (q *MySQLQuery) Begin(ctx context.Context) (plugin.DriverQuery, error)

+ func (q *MySQLQuery) Commit(ctx context.Context) error

+ func (q *MySQLQuery) Exec(ctx context.Context, query string, args ...any) error

+ func (q *MySQLQuery) Query(ctx context.Context, query string, args ...any) (*plugin.DriverQueryResult, error)

+ func (q *MySQLQuery) Rollback(ctx context.Context) error

+ type SQLiteBrowser struct

+ func NewSQLiteBrowser(driver *SQLiteDriver) *SQLiteBrowser

+ func (b *SQLiteBrowser) Connect(ctx context.Context, dsn string) error

+ func (b *SQLiteBrowser) Disconnect(ctx context.Context) error

+ func (b *SQLiteBrowser) List(ctx context.Context, ids []string) ([]plugin.BrowserItem, error)

+ func (b *SQLiteBrowser) ParseExplain(data plugin.BrowserQueryResult) (plugin.BrowserExplainResult, error)

+ func (b *SQLiteBrowser) Query(ctx context.Context, query string) (plugin.BrowserQueryResult, error)

+ func (b *SQLiteBrowser) Show(ctx context.Context, ids []string) (string, error)

type SQLiteDriver

+ Path string

+ func (d *SQLiteDriver) CreateDatabase(ctx context.Context, path string) error

+ func (d *SQLiteDriver) Initialize(ctx context.Context) error

type SQLiteDriverConnection

+ Read *sql.DB

+ Write *sql.DB

v0.21.0

Feb 22, 2026

Changes in this version

+ var ErrDriverNotSelected = errors.New("driver not selected")

+ type NullDriver struct

+ func NewNullDriver() *NullDriver

+ func (d *NullDriver) Connect(ctx context.Context, config config.DriverConfig) (plugin.DriverConnection, error)

+ func (d *NullDriver) Disconnect(ctx context.Context, conn plugin.DriverConnection) error

+ type NullDriverConnection struct

+ func (c *NullDriverConnection) AppendAuditLog(ctx context.Context, execCtx plugin.DriverExecutionContext, ...) error

+ func (c *NullDriverConnection) LockAuditLog(ctx context.Context, execCtx plugin.DriverExecutionContext, ...) error

+ func (c *NullDriverConnection) Query(execCtx plugin.DriverExecutionContext) plugin.DriverQuery

+ func (c *NullDriverConnection) ReadAuditLogs(ctx context.Context, execCtx plugin.DriverExecutionContext) ([]plugin.DriverAuditLog, error)

+ func (c *NullDriverConnection) UnlockAuditLog(ctx context.Context, execCtx plugin.DriverExecutionContext, ...) error

+ func (c *NullDriverConnection) UpsertAuditLockTable(ctx context.Context, execCtx plugin.DriverExecutionContext) error

+ func (c *NullDriverConnection) UpsertAuditLogTable(ctx context.Context, execCtx plugin.DriverExecutionContext) error

+ type NullDriverQuery struct

+ func (q *NullDriverQuery) Begin(ctx context.Context) (plugin.DriverQuery, error)

+ func (q *NullDriverQuery) Commit(ctx context.Context) error

+ func (q *NullDriverQuery) Exec(ctx context.Context, query string, args ...any) error

+ func (q *NullDriverQuery) Query(ctx context.Context, query string, args ...any) (*plugin.DriverQueryResult, error)

+ func (q *NullDriverQuery) Rollback(ctx context.Context) error

+ type PostgreSQLBrowser struct

+ func NewPostgreSQLBrowser(driver *PostgreSQLDriver) *PostgreSQLBrowser

+ func (b *PostgreSQLBrowser) Connect(ctx context.Context, dsn string) error

+ func (b *PostgreSQLBrowser) Disconnect(ctx context.Context) error

+ func (b *PostgreSQLBrowser) List(ctx context.Context, ids []string) ([]plugin.BrowserItem, error)

+ func (b *PostgreSQLBrowser) ParseExplain(data plugin.BrowserQueryResult) (plugin.BrowserExplainResult, error)

+ func (b *PostgreSQLBrowser) Query(ctx context.Context, sql string) (plugin.BrowserQueryResult, error)

+ func (b *PostgreSQLBrowser) Show(ctx context.Context, ids []string) (string, error)

+ type PostgreSQLDriver struct

+ func NewPostgreSQLDriver() *PostgreSQLDriver

+ func (d *PostgreSQLDriver) Connect(ctx context.Context, config config.DriverConfig) (plugin.DriverConnection, error)

+ func (d *PostgreSQLDriver) Disconnect(ctx context.Context, conn plugin.DriverConnection) error

+ type PostgreSQLDriverConnection struct

+ Conn *pgx.Conn

+ func (c *PostgreSQLDriverConnection) AppendAuditLog(ctx context.Context, execCtx plugin.DriverExecutionContext, ...) error

+ func (c *PostgreSQLDriverConnection) LockAuditLog(ctx context.Context, execCtx plugin.DriverExecutionContext, ...) error

+ func (c *PostgreSQLDriverConnection) Query(execCtx plugin.DriverExecutionContext) plugin.DriverQuery

+ func (c *PostgreSQLDriverConnection) ReadAuditLogs(ctx context.Context, execCtx plugin.DriverExecutionContext) ([]plugin.DriverAuditLog, error)

+ func (c *PostgreSQLDriverConnection) UnlockAuditLog(ctx context.Context, execCtx plugin.DriverExecutionContext, ...) error

+ func (c *PostgreSQLDriverConnection) UpsertAuditLockTable(ctx context.Context, execCtx plugin.DriverExecutionContext) error

+ func (c *PostgreSQLDriverConnection) UpsertAuditLogTable(ctx context.Context, execCtx plugin.DriverExecutionContext) error

+ type PostgreSQLQuery struct

+ func (q *PostgreSQLQuery) Begin(ctx context.Context) (plugin.DriverQuery, error)

+ func (q *PostgreSQLQuery) Commit(ctx context.Context) error

+ func (q *PostgreSQLQuery) Exec(ctx context.Context, query string, args ...any) error

+ func (q *PostgreSQLQuery) Query(ctx context.Context, query string, args ...any) (*plugin.DriverQueryResult, error)

+ func (q *PostgreSQLQuery) Rollback(ctx context.Context) error

+ type Registry struct

+ func New() *Registry

+ func (r *Registry) Get(name string) (plugin.Driver, error)

+ func (r *Registry) GetBrowser(name string) (plugin.Browser, error)

+ func (r *Registry) Register(name string, driver plugin.Driver)

+ func (r *Registry) RegisterAll()

+ func (r *Registry) RegisterBrowser(name string, browser plugin.Browser)

+ type SQLiteDriver struct

+ func NewSQLiteDriver() *SQLiteDriver

+ func (d *SQLiteDriver) Connect(ctx context.Context, config config.DriverConfig) (plugin.DriverConnection, error)

+ func (d *SQLiteDriver) Disconnect(ctx context.Context, conn plugin.DriverConnection) error

+ type SQLiteDriverConnection struct

+ func (c *SQLiteDriverConnection) AppendAuditLog(ctx context.Context, execCtx plugin.DriverExecutionContext, ...) error

+ func (c *SQLiteDriverConnection) LockAuditLog(ctx context.Context, execCtx plugin.DriverExecutionContext, ...) error

+ func (c *SQLiteDriverConnection) Query(execCtx plugin.DriverExecutionContext) plugin.DriverQuery

+ func (c *SQLiteDriverConnection) ReadAuditLogs(ctx context.Context, execCtx plugin.DriverExecutionContext) ([]plugin.DriverAuditLog, error)

+ func (c *SQLiteDriverConnection) UnlockAuditLog(ctx context.Context, execCtx plugin.DriverExecutionContext, ...) error

+ func (c *SQLiteDriverConnection) UpsertAuditLockTable(ctx context.Context, execCtx plugin.DriverExecutionContext) error

+ func (c *SQLiteDriverConnection) UpsertAuditLogTable(ctx context.Context, execCtx plugin.DriverExecutionContext) error

+ type SQLiteDriverQuery struct

+ func (q *SQLiteDriverQuery) Begin(ctx context.Context) (plugin.DriverQuery, error)

+ func (q *SQLiteDriverQuery) Commit(ctx context.Context) error

+ func (q *SQLiteDriverQuery) Exec(ctx context.Context, query string, args ...any) error

+ func (q *SQLiteDriverQuery) Query(ctx context.Context, query string, args ...any) (*plugin.DriverQueryResult, error)

+ func (q *SQLiteDriverQuery) Rollback(ctx context.Context) error

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