dumpers

type BlobsDumper struct {
	Blobs          *entries.Blobs
	OriginalSize   int64
	CompressedSize int64
}

type DumpError struct {
	Schema string `json:"schema,omitempty"`
	Table  string `json:"table,omitempty"`
	Line   uint64 `json:"line,omitempty"`
	Err    error  `json:"err,omitempty"`
}

type DumpTask interface {
	Execute(ctx context.Context, tx pgx.Tx, st storages.Storager) (entries.Entry, error)
	DebugInfo() string
}

type Pipeliner interface {
	Dump(ctx context.Context, data []byte) error
	Init(ctx context.Context) error
	Done(ctx context.Context) error
	CompleteDump() error
}

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

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

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

type TransformationFunc func(ctx context.Context, r *toolkit.Record) (*toolkit.Record, error)

type TransformationPipeline struct {
	Transform TransformationFunc
	// contains filtered or unexported fields
}

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

type ValidationPipeline struct {
	*TransformationPipeline
}