persistence

Documentation

Index

• Constants
• Variables
• type MysqlDump
  • func NewMysqlDump(ip, username, password string) *MysqlDump
  • func NewRemoteMysqlDump(username, password string, sshCfg command.SshConfig) (*MysqlDump, error)
  • func (s *MysqlDump) Dump(dest io.Writer) (err error)
  • func (s *MysqlDump) Import(lfile io.Reader) (err error)
• type PgDump
  • func NewPgDump(ip string, port int, database, username, password string) *PgDump
  • func NewPgRemoteDump(port int, database, username, password string, sshCfg command.SshConfig) (*PgDump, error)
  • func (s *PgDump) Dump(dest io.Writer) (err error)
  • func (s *PgDump) Import(lfile io.Reader) (err error)

Constants

const (
	MSQLDMP_CONNECT_CMD string = "%s -u %s -h %s --password=%s"
	MSQLDMP_CREATE_CMD         = "%s < %s"
	MSQLDMP_FLUSH_CMD          = "%s > flush privileges"
	MSQLDMP_DUMP_CMD           = "%s --all-databases"
)

const (
	PGDMP_DROP_CMD   string = "drop schema public cascade;"
	PGDMP_CREATE_CMD        = "create schema public;"
)

Variables

var (
	MSQLDMP_DUMP_BIN string = "/var/vcap/packages/mariadb/bin/mysqldump"
	MSQLDMP_SQL_BIN         = "/var/vcap/packages/mariadb/bin/mysql"
)

var (
	PGDMP_DUMP_BIN    string = "/var/vcap/packages/postgres/bin/pg_dump"
	PGDMP_RESTORE_BIN string = "/var/vcap/packages/postgres/bin/pg_restore"
)

Types

type MysqlDump

type MysqlDump struct {
	Ip         string
	Username   string
	Password   string
	DbFile     string
	ConfigFile string
	Caller     command.Executer
	RemoteOps  remoteOperationsInterface
}

func NewMysqlDump

func NewMysqlDump(ip, username, password string) *MysqlDump

func NewRemoteMysqlDump

func NewRemoteMysqlDump(username, password string, sshCfg command.SshConfig) (*MysqlDump, error)

func (*MysqlDump) Dump

func (s *MysqlDump) Dump(dest io.Writer) (err error)

func (*MysqlDump) Import

func (s *MysqlDump) Import(lfile io.Reader) (err error)

type PgDump

type PgDump struct {
	Ip        string
	Port      int
	Database  string
	Username  string
	Password  string
	DbFile    string
	Caller    command.Executer
	RemoteOps remoteOperationsInterface
	// contains filtered or unexported fields
}

func NewPgDump

func NewPgDump(ip string, port int, database, username, password string) *PgDump

func NewPgRemoteDump

func NewPgRemoteDump(port int, database, username, password string, sshCfg command.SshConfig) (*PgDump, error)

func (*PgDump) Dump

func (s *PgDump) Dump(dest io.Writer) (err error)

func (*PgDump) Import

func (s *PgDump) Import(lfile io.Reader) (err error)