postgres

Documentation

Index

• Constants
• type Config
• type RestoreOutputPostgresql
  • func (r *RestoreOutputPostgresql) Close() error
  • func (r *RestoreOutputPostgresql) GetConfig() interface{}
  • func (r *RestoreOutputPostgresql) GetGroup() core.ModuleGroup
  • func (r *RestoreOutputPostgresql) GetName() string
  • func (r *RestoreOutputPostgresql) GetType() core.ModuleType
  • func (r *RestoreOutputPostgresql) InitModule(cfg interface{}) error
  • func (r *RestoreOutputPostgresql) InitPipe(w io.Writer, rd io.Reader) error
  • func (r *RestoreOutputPostgresql) Run(ctx context.Context) error

Constants

const GROUP_NAME = "restore"

Module Constants

const MODULE_NAME = "postgresql"

const TYPE_NAME = "output"

Types

type Config

type Config struct {
	DSN string
}

Config PostgreSQL

type RestoreOutputPostgresql

type RestoreOutputPostgresql struct {
	core.Module
	// contains filtered or unexported fields
}

BackupInputPostgresql is struct storing inner properties for mysql backups

func (*RestoreOutputPostgresql) Close

func (r *RestoreOutputPostgresql) Close() error

Close connection to DB.

func (*RestoreOutputPostgresql) GetConfig

func (r *RestoreOutputPostgresql) GetConfig() interface{}

GetConfig returns Config of module

func (*RestoreOutputPostgresql) GetGroup

func (r *RestoreOutputPostgresql) GetGroup() core.ModuleGroup

GetGroup returns module group

func (*RestoreOutputPostgresql) GetName

func (r *RestoreOutputPostgresql) GetName() string

GetName returns name of module

func (*RestoreOutputPostgresql) GetType

func (r *RestoreOutputPostgresql) GetType() core.ModuleType

GetType returns module type

func (*RestoreOutputPostgresql) InitModule

func (r *RestoreOutputPostgresql) InitModule(cfg interface{}) error

InitModule initialize connection to DB

func (*RestoreOutputPostgresql) InitPipe

func (r *RestoreOutputPostgresql) InitPipe(w io.Writer, rd io.Reader) error

InitPipe initialize reader and writer

func (*RestoreOutputPostgresql) Run

func (r *RestoreOutputPostgresql) Run(ctx context.Context) error

Run dumps database