Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var DependencySet = wire.NewSet( NewReadSQLExecutor, NewWriteSQLExecutor, NewSQLBuilder, NewSQLBuilderApp, )
Functions ¶
This section is empty.
Types ¶
type ReadHandle ¶
type ReadHandle struct {
*db.HookHandle
}
func NewReadHandle ¶
func NewReadHandle( ctx context.Context, pool *db.Pool, cfg *config.DatabaseEnvironmentConfig, credentials *config.AuditDatabaseCredentials, lf *log.Factory, ) *ReadHandle
func (*ReadHandle) ReadOnly ¶
func (h *ReadHandle) ReadOnly(do func() error) (err error)
type ReadSQLExecutor ¶
type ReadSQLExecutor struct {
db.SQLExecutor
}
func NewReadSQLExecutor ¶
func NewReadSQLExecutor(c context.Context, handle *ReadHandle) *ReadSQLExecutor
type SQLBuilder ¶
type SQLBuilder struct {
// contains filtered or unexported fields
}
func NewSQLBuilder ¶
func NewSQLBuilder(c *config.AuditDatabaseCredentials) *SQLBuilder
func (SQLBuilder) TableName ¶
func (b SQLBuilder) TableName(table string) string
func (SQLBuilder) WithAppID ¶
func (b SQLBuilder) WithAppID(appID string) *SQLBuilderApp
func (SQLBuilder) WithoutAppID ¶
func (b SQLBuilder) WithoutAppID() *db.SQLBuilder
type SQLBuilderApp ¶
type SQLBuilderApp struct {
db.SQLBuilderApp
}
func NewSQLBuilderApp ¶
func NewSQLBuilderApp(c *config.AuditDatabaseCredentials, id config.AppID) *SQLBuilderApp
type WriteHandle ¶
type WriteHandle struct {
*db.HookHandle
}
func NewWriteHandle ¶
func NewWriteHandle( ctx context.Context, pool *db.Pool, cfg *config.DatabaseEnvironmentConfig, credentials *config.AuditDatabaseCredentials, lf *log.Factory, ) *WriteHandle
func (*WriteHandle) WithTx ¶
func (h *WriteHandle) WithTx(do func() error) (err error)
type WriteSQLExecutor ¶
type WriteSQLExecutor struct {
db.SQLExecutor
}
func NewWriteSQLExecutor ¶
func NewWriteSQLExecutor(c context.Context, handle *WriteHandle) *WriteSQLExecutor
Source Files
Click to show internal directories.
Click to hide internal directories.