database

Documentation

Index

• func OpenDB(config *config.Database, logger hclog.Logger) (domain.Repository, broker.Pubsub, error)
• type GormLoggerAdapter
  • func (g *GormLoggerAdapter) Error(ctx context.Context, s string, i ...interface{})
  • func (g *GormLoggerAdapter) Info(ctx context.Context, s string, i ...interface{})
  • func (g *GormLoggerAdapter) LogMode(level logger.LogLevel) logger.Interface
  • func (g *GormLoggerAdapter) Trace(ctx context.Context, begin time.Time, ...)
  • func (g *GormLoggerAdapter) Warn(ctx context.Context, s string, i ...interface{})
• type Postgres
  • func (s *Postgres) DB() *gorm.DB
  • func (s *Postgres) Lock() error
  • func (s *Postgres) Unlock() error
  • func (s *Postgres) UnlockErr(prevErr error) error
• type Sqlite
  • func (s *Sqlite) DB() *gorm.DB
  • func (s *Sqlite) Lock() error
  • func (s *Sqlite) Unlock() error
  • func (s *Sqlite) UnlockErr(prevErr error) error

Functions

func OpenDB

func OpenDB(config *config.Database, logger hclog.Logger) (domain.Repository, broker.Pubsub, error)

Types

type GormLoggerAdapter

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

func (*GormLoggerAdapter) Error

func (g *GormLoggerAdapter) Error(ctx context.Context, s string, i ...interface{})

func (*GormLoggerAdapter) Info

func (g *GormLoggerAdapter) Info(ctx context.Context, s string, i ...interface{})

func (*GormLoggerAdapter) LogMode

func (g *GormLoggerAdapter) LogMode(level logger.LogLevel) logger.Interface

func (*GormLoggerAdapter) Trace

func (g *GormLoggerAdapter) Trace(ctx context.Context, begin time.Time, fc func() (sql string, rowsAffected int64), err error)

func (*GormLoggerAdapter) Warn

func (g *GormLoggerAdapter) Warn(ctx context.Context, s string, i ...interface{})

type Postgres

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

func (*Postgres) DB

func (s *Postgres) DB() *gorm.DB

func (*Postgres) Lock

func (s *Postgres) Lock() error

func (*Postgres) Unlock

func (s *Postgres) Unlock() error

func (*Postgres) UnlockErr

func (s *Postgres) UnlockErr(prevErr error) error

type Sqlite

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

func (*Sqlite) DB

func (s *Sqlite) DB() *gorm.DB

func (*Sqlite) Lock

func (s *Sqlite) Lock() error

func (*Sqlite) Unlock

func (s *Sqlite) Unlock() error

func (*Sqlite) UnlockErr

func (s *Sqlite) UnlockErr(prevErr error) error