table_restorer

Documentation

Index

• func Builder(in chan []string, out chan string)
• type LineReader
  • func NewReader(input io.Reader) *LineReader
  • func (r *LineReader) Parse(row chan []interface{})
• type Restorer
  • func New(dsn, tableName string, columns []string) *Restorer
  • func (r *Restorer) Run(in io.Reader, conn *sqlx.DB) (stats, error)
  • func (r *Restorer) WithDryRun(dryRun bool) *Restorer
  • func (r *Restorer) WithFilter(filter filter.BoolExpr) *Restorer

Functions

func Builder

func Builder(in chan []string, out chan string)

Types

type LineReader

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

func NewReader

func NewReader(input io.Reader) *LineReader

func (*LineReader) Parse

func (r *LineReader) Parse(row chan []interface{})

type Restorer

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

func New

func New(dsn, tableName string, columns []string) *Restorer

func (*Restorer) Run

func (r *Restorer) Run(in io.Reader, conn *sqlx.DB) (stats, error)

func (*Restorer) WithDryRun

func (r *Restorer) WithDryRun(dryRun bool) *Restorer

func (*Restorer) WithFilter

func (r *Restorer) WithFilter(filter filter.BoolExpr) *Restorer