plugins

package
v0.21.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Feb 22, 2026 License: MIT Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

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

Functions

This section is empty.

Types

type NullDriver 

type NullDriver struct {
	plugin.Driver
}

func NewNullDriver 

func NewNullDriver() *NullDriver

func (*NullDriver) Connect 

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

func (*NullDriver) Disconnect 

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

type NullDriverConnection 

type NullDriverConnection struct {
	plugin.DriverConnection
}

func (*NullDriverConnection) AppendAuditLog 

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

func (*NullDriverConnection) LockAuditLog 

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

func (*NullDriverConnection) Query 

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

func (*NullDriverConnection) ReadAuditLogs 

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

func (*NullDriverConnection) UnlockAuditLog 

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

func (*NullDriverConnection) UpsertAuditLockTable 

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

func (*NullDriverConnection) UpsertAuditLogTable 

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

type NullDriverQuery 

type NullDriverQuery struct{}

func (*NullDriverQuery) Begin 

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

func (*NullDriverQuery) Commit 

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

func (*NullDriverQuery) Exec 

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

func (*NullDriverQuery) Query 

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

func (*NullDriverQuery) Rollback 

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

type PostgreSQLBrowser 

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

func NewPostgreSQLBrowser 

func NewPostgreSQLBrowser(driver *PostgreSQLDriver) *PostgreSQLBrowser

func (*PostgreSQLBrowser) Connect 

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

func (*PostgreSQLBrowser) Disconnect 

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

func (*PostgreSQLBrowser) List 

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

func (*PostgreSQLBrowser) ParseExplain 

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

func (*PostgreSQLBrowser) Query 

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

func (*PostgreSQLBrowser) Show 

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

type PostgreSQLDriver 

type PostgreSQLDriver struct {
}

func NewPostgreSQLDriver 

func NewPostgreSQLDriver() *PostgreSQLDriver

func (*PostgreSQLDriver) Connect 

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

func (*PostgreSQLDriver) Disconnect 

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

type PostgreSQLDriverConnection 

type PostgreSQLDriverConnection struct {
	Conn *pgx.Conn
}

func (*PostgreSQLDriverConnection) AppendAuditLog 

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

func (*PostgreSQLDriverConnection) LockAuditLog 

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

func (*PostgreSQLDriverConnection) Query 

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

func (*PostgreSQLDriverConnection) ReadAuditLogs 

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

func (*PostgreSQLDriverConnection) UnlockAuditLog 

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

func (*PostgreSQLDriverConnection) UpsertAuditLockTable 

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

func (*PostgreSQLDriverConnection) UpsertAuditLogTable 

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

type PostgreSQLQuery 

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

func (*PostgreSQLQuery) Begin 

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

func (*PostgreSQLQuery) Commit 

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

func (*PostgreSQLQuery) Exec 

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

func (*PostgreSQLQuery) Query 

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

func (*PostgreSQLQuery) Rollback 

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

type Registry 

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

func New 

func New() *Registry

func (*Registry) Get 

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

func (*Registry) GetBrowser 

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

func (*Registry) Register 

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

func (*Registry) RegisterAll 

func (r *Registry) RegisterAll()

func (*Registry) RegisterBrowser 

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

type SQLiteDriver 

type SQLiteDriver struct {
}

func NewSQLiteDriver 

func NewSQLiteDriver() *SQLiteDriver

func (*SQLiteDriver) Connect 

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

func (*SQLiteDriver) Disconnect 

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

type SQLiteDriverConnection 

type SQLiteDriverConnection struct {
}

func (*SQLiteDriverConnection) AppendAuditLog 

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

func (*SQLiteDriverConnection) LockAuditLog 

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

func (*SQLiteDriverConnection) Query 

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

func (*SQLiteDriverConnection) ReadAuditLogs 

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

func (*SQLiteDriverConnection) UnlockAuditLog 

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

func (*SQLiteDriverConnection) UpsertAuditLockTable 

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

func (*SQLiteDriverConnection) UpsertAuditLogTable 

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

type SQLiteDriverQuery 

type SQLiteDriverQuery struct{}

func (*SQLiteDriverQuery) Begin 

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

func (*SQLiteDriverQuery) Commit 

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

func (*SQLiteDriverQuery) Exec 

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

func (*SQLiteDriverQuery) Query 

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

func (*SQLiteDriverQuery) Rollback 

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

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.