Documentation
¶
Index ¶
- type Container
- type TestContainerPostgreSQLDriver
- type TestContainerPostgreSQLDriverConnection
- func (c *TestContainerPostgreSQLDriverConnection) AppendAuditLog(ctx context.Context, execCtx plugin.DriverExecutionContext, ...) error
- func (c *TestContainerPostgreSQLDriverConnection) LockAuditLog(ctx context.Context, execCtx plugin.DriverExecutionContext, ...) error
- func (c *TestContainerPostgreSQLDriverConnection) Query(execCtx plugin.DriverExecutionContext) plugin.DriverQuery
- func (c *TestContainerPostgreSQLDriverConnection) ReadAuditLogs(ctx context.Context, execCtx plugin.DriverExecutionContext) ([]plugin.DriverAuditLog, error)
- func (c *TestContainerPostgreSQLDriverConnection) UnlockAuditLog(ctx context.Context, execCtx plugin.DriverExecutionContext, ...) error
- func (c *TestContainerPostgreSQLDriverConnection) UpsertAuditLockTable(ctx context.Context, execCtx plugin.DriverExecutionContext) error
- func (c *TestContainerPostgreSQLDriverConnection) UpsertAuditLogTable(ctx context.Context, execCtx plugin.DriverExecutionContext) error
- type TestContainerPostgreSQLQuery
- func (q *TestContainerPostgreSQLQuery) Begin(ctx context.Context) (plugin.DriverQuery, error)
- func (q *TestContainerPostgreSQLQuery) Commit(ctx context.Context) error
- func (q *TestContainerPostgreSQLQuery) Exec(ctx context.Context, query string, args ...any) error
- func (q *TestContainerPostgreSQLQuery) Query(ctx context.Context, query string, args ...any) (*plugin.DriverQueryResult, error)
- func (q *TestContainerPostgreSQLQuery) Rollback(ctx context.Context) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Container ¶
type Container struct {
Image string
Port string
Env map[string]string
// contains filtered or unexported fields
}
type TestContainerPostgreSQLDriver ¶
type TestContainerPostgreSQLDriver struct {
}
func NewTestContainerPostgreSQLDriver ¶
func NewTestContainerPostgreSQLDriver() *TestContainerPostgreSQLDriver
func (*TestContainerPostgreSQLDriver) Connect ¶
func (d *TestContainerPostgreSQLDriver) Connect(ctx context.Context, config config.DriverConfig) (plugin.DriverConnection, error)
func (*TestContainerPostgreSQLDriver) Disconnect ¶
func (d *TestContainerPostgreSQLDriver) Disconnect(ctx context.Context, conn plugin.DriverConnection) error
type TestContainerPostgreSQLDriverConnection ¶
type TestContainerPostgreSQLDriverConnection struct {
Container *Container
Conn *pgx.Conn
Close func(ctx context.Context)
}
func (*TestContainerPostgreSQLDriverConnection) AppendAuditLog ¶
func (c *TestContainerPostgreSQLDriverConnection) AppendAuditLog(ctx context.Context, execCtx plugin.DriverExecutionContext, log plugin.DriverAuditLog) error
func (*TestContainerPostgreSQLDriverConnection) LockAuditLog ¶
func (c *TestContainerPostgreSQLDriverConnection) LockAuditLog(ctx context.Context, execCtx plugin.DriverExecutionContext, lock plugin.DriverAuditLock) error
func (*TestContainerPostgreSQLDriverConnection) Query ¶
func (c *TestContainerPostgreSQLDriverConnection) Query(execCtx plugin.DriverExecutionContext) plugin.DriverQuery
func (*TestContainerPostgreSQLDriverConnection) ReadAuditLogs ¶
func (c *TestContainerPostgreSQLDriverConnection) ReadAuditLogs(ctx context.Context, execCtx plugin.DriverExecutionContext) ([]plugin.DriverAuditLog, error)
func (*TestContainerPostgreSQLDriverConnection) UnlockAuditLog ¶
func (c *TestContainerPostgreSQLDriverConnection) UnlockAuditLog(ctx context.Context, execCtx plugin.DriverExecutionContext, lock plugin.DriverAuditLock) error
func (*TestContainerPostgreSQLDriverConnection) UpsertAuditLockTable ¶
func (c *TestContainerPostgreSQLDriverConnection) UpsertAuditLockTable(ctx context.Context, execCtx plugin.DriverExecutionContext) error
func (*TestContainerPostgreSQLDriverConnection) UpsertAuditLogTable ¶
func (c *TestContainerPostgreSQLDriverConnection) UpsertAuditLogTable(ctx context.Context, execCtx plugin.DriverExecutionContext) error
type TestContainerPostgreSQLQuery ¶
type TestContainerPostgreSQLQuery struct {
// contains filtered or unexported fields
}
func (*TestContainerPostgreSQLQuery) Begin ¶
func (q *TestContainerPostgreSQLQuery) Begin(ctx context.Context) (plugin.DriverQuery, error)
func (*TestContainerPostgreSQLQuery) Commit ¶
func (q *TestContainerPostgreSQLQuery) Commit(ctx context.Context) error
func (*TestContainerPostgreSQLQuery) Query ¶
func (q *TestContainerPostgreSQLQuery) Query(ctx context.Context, query string, args ...any) (*plugin.DriverQueryResult, error)
Click to show internal directories.
Click to hide internal directories.