postgres

Documentation

Index

• func NewStorage(conn *sql.DB, dumper PgDumper, timeout time.Duration) reader.Reader
• type PgDump
  • func NewPgDump(dsn string) (*PgDump, error)
  • func (p *PgDump) GetStructure() (string, error)
• type PgDumper

Functions

func NewStorage

func NewStorage(conn *sql.DB, dumper PgDumper, timeout time.Duration) reader.Reader

NewStorage creates a new postgres storage reader.

Types

type PgDump

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

PgDump is responsible for executing the pg dump command.

func NewPgDump

func NewPgDump(dsn string) (*PgDump, error)

NewPgDump creates a new PgDump.

func (*PgDump) GetStructure

func (p *PgDump) GetStructure() (string, error)

GetStructure executes the pg dump command.

type PgDumper

type PgDumper interface {
	GetStructure() (stmt string, err error)
}

PgDumper executes the pg dump command.