pg

package
v0.0.0-...-0b18c8e Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Nov 2, 2016 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func SchemaExists

func SchemaExists(dbh *sql.DB, schema string) (bool, error)

func SchemaInit

func SchemaInit(dbh *sql.DB, schema string) error

func TableExistsInSchema

func TableExistsInSchema(dbh *sql.DB, table, schema string) (bool, error)

Types

type PGConfig

type PGConfig struct {
	Db   string
	User string
	Pass string
	Opts map[string]string
	Url  string
}

func (*PGConfig) Connect

func (cfg *PGConfig) Connect() (*sql.DB, error)

type PgDumper

type PgDumper struct {
	Schema string
	Dbh    *sql.DB
}

func (*PgDumper) BatchDone

func (pd *PgDumper) BatchDone(batchID int64) error

func (*PgDumper) Dump

func (pd *PgDumper) Dump(req *storage.Request) error

func (*PgDumper) MarkBatch

func (pd *PgDumper) MarkBatch() (int64, error)

func (*PgDumper) ReadRequests

func (pd *PgDumper) ReadRequests(batchID int64) ([]storage.Request, error)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL