adapter

Documentation

Index

• func NewDBConnectionFromPGXPool(pool *pgxpool.Pool) migrator.DBConnection
• type DirectoryOperator
  • func NewDirectoryOperator() *DirectoryOperator
  • func (do *DirectoryOperator) IsFileExist(name string) bool
  • func (do *DirectoryOperator) ReadFile(name string) ([]byte, error)
• type PGXPoolAdapter
  • func (p PGXPoolAdapter) Exec(ctx context.Context, sql string) error

Functions

func NewDBConnectionFromPGXPool

func NewDBConnectionFromPGXPool(pool *pgxpool.Pool) migrator.DBConnection

Types

type DirectoryOperator

type DirectoryOperator struct {
}

func NewDirectoryOperator

func NewDirectoryOperator() *DirectoryOperator

func (*DirectoryOperator) IsFileExist

func (do *DirectoryOperator) IsFileExist(name string) bool

func (*DirectoryOperator) ReadFile

func (do *DirectoryOperator) ReadFile(name string) ([]byte, error)

type PGXPoolAdapter

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

func (PGXPoolAdapter) Exec

func (p PGXPoolAdapter) Exec(ctx context.Context, sql string) error