Documentation
¶
Index ¶
- func NewExporter(ctx context.Context, opts *connectors.Options, name string, ...) (exporter.Exporter, error)
- type Exporter
- func (p *Exporter) Close(ctx context.Context) error
- func (p *Exporter) Export(ctx context.Context, records <-chan *connectors.Record, ...) error
- func (p *Exporter) Flags() location.Flags
- func (p *Exporter) Origin() string
- func (p *Exporter) Ping(ctx context.Context) error
- func (p *Exporter) Root() string
- func (p *Exporter) Type() string
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type Exporter ¶
type Exporter struct {
// contains filtered or unexported fields
}
func (*Exporter) Export ¶
func (p *Exporter) Export(ctx context.Context, records <-chan *connectors.Record, results chan<- *connectors.Result) error
Export restores each record to the configured PostgreSQL server. Records ending in ".dump" are restored via pg_restore (pg_dump custom format). Records ending in ".sql" are fed to psql (pg_dumpall plain-SQL format).
Source Files
Click to show internal directories.
Click to hide internal directories.