auditdb

Documentation

Index

• Variables
• type ReadHandle
  • func NewReadHandle(pool *db.Pool, cfg *config.DatabaseEnvironmentConfig, ...) *ReadHandle
  • func (h *ReadHandle) ReadOnly(ctx context.Context, do func(ctx context.Context) error) (err error)
• type ReadSQLExecutor
  • func NewReadSQLExecutor(handle *ReadHandle) *ReadSQLExecutor
• type SQLBuilder
  • func NewSQLBuilder(c *config.AuditDatabaseCredentials) *SQLBuilder
  • func (b SQLBuilder) TableName(table string) string
  • func (b SQLBuilder) WithAppID(appID string) *SQLBuilderApp
  • func (b SQLBuilder) WithoutAppID() *db.SQLBuilder
• type SQLBuilderApp
  • func NewSQLBuilderApp(c *config.AuditDatabaseCredentials, id config.AppID) *SQLBuilderApp
• type WriteHandle
  • func NewWriteHandle(pool *db.Pool, cfg *config.DatabaseEnvironmentConfig, ...) *WriteHandle
  • func (h *WriteHandle) WithTx(ctx context.Context, do func(ctx context.Context) error) (err error)
• type WriteSQLExecutor
  • func NewWriteSQLExecutor(handle *WriteHandle) *WriteSQLExecutor

Variables

var DependencySet = wire.NewSet(
	NewReadSQLExecutor,
	NewWriteSQLExecutor,
	NewSQLBuilder,
	NewSQLBuilderApp,
)

Types

type ReadHandle

type ReadHandle struct {
	*db.HookHandle
}

func NewReadHandle

func NewReadHandle(
	pool *db.Pool,
	cfg *config.DatabaseEnvironmentConfig,
	credentials *config.AuditDatabaseCredentials,
	lf *log.Factory,
) *ReadHandle

func (*ReadHandle) ReadOnly

func (h *ReadHandle) ReadOnly(ctx context.Context, do func(ctx context.Context) error) (err error)

type ReadSQLExecutor

type ReadSQLExecutor struct {
	db.SQLExecutor
}

func NewReadSQLExecutor

func NewReadSQLExecutor(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(
	pool *db.Pool,
	cfg *config.DatabaseEnvironmentConfig,
	credentials *config.AuditDatabaseCredentials,
	lf *log.Factory,
) *WriteHandle

func (*WriteHandle) WithTx

func (h *WriteHandle) WithTx(ctx context.Context, do func(ctx context.Context) error) (err error)

type WriteSQLExecutor

type WriteSQLExecutor struct {
	db.SQLExecutor
}

func NewWriteSQLExecutor

func NewWriteSQLExecutor(handle *WriteHandle) *WriteSQLExecutor