repository

Documentation

Index

• func MigrateSchema(cfg *config.DB, instance int) error
• func RunTx(ctx context.Context, db TxRunner, fn TxFunc) error
• type DB
  • func NewDB(cfg *config.DB) (*DB, error)
  • func NewPostgresDB(cfg *config.DB) (*DB, error)
  • func (db *DB) Close() error
• type LogRepository
  • func NewRepository(db *DB, log *zap.Logger) *LogRepository
  • func (r *LogRepository) ReadLog(ctx context.Context, id int) (models.Log, error)
  • func (r *LogRepository) ReadLogs(ctx context.Context) ([]models.Log, error)
  • func (r *LogRepository) WriteLog(ctx context.Context, raw string) (int64, error)
• type TxFunc
• type TxRunner

Functions

func MigrateSchema

func MigrateSchema(cfg *config.DB, instance int) error

func RunTx

func RunTx(ctx context.Context, db TxRunner, fn TxFunc) error

Types

type DB

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

func NewDB

func NewDB(cfg *config.DB) (*DB, error)

func NewPostgresDB

func NewPostgresDB(cfg *config.DB) (*DB, error)

func (*DB) Close

func (db *DB) Close() error

type LogRepository

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

func NewRepository

func NewRepository(db *DB, log *zap.Logger) *LogRepository

func (*LogRepository) ReadLog

func (r *LogRepository) ReadLog(ctx context.Context, id int) (models.Log, error)

func (*LogRepository) ReadLogs

func (r *LogRepository) ReadLogs(ctx context.Context) ([]models.Log, error)

func (*LogRepository) WriteLog

func (r *LogRepository) WriteLog(ctx context.Context, raw string) (int64, error)

type TxFunc

type TxFunc func(tx *sqlx.Tx) error

type TxRunner

type TxRunner interface {
	BeginTxx(ctx context.Context, opts *sql.TxOptions) (*sqlx.Tx, error)
}