dump

Documentation

Index

• type Dumper
  • func New(pgDump string, sub *conf.Subscribe) *Dumper
  • func (d *Dumper) Dump(snapshotID string, h handler.Handler) error

Types

type Dumper

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

Dumper dump database

func New

func New(pgDump string, sub *conf.Subscribe) *Dumper

New create a Dumper

func (*Dumper) Dump

func (d *Dumper) Dump(snapshotID string, h handler.Handler) error

Dump database with snapshot, parse sql then write to handler