Documentation ¶
Index ¶
- type BlobsDumper
- type DumpError
- type DumpTask
- type Pipeliner
- type PlainDumpPipeline
- type SequenceDumper
- type TableDumper
- type TransformationFunc
- type TransformationPipeline
- func (tp *TransformationPipeline) CompleteDump() (err error)
- func (tp *TransformationPipeline) Done(ctx context.Context) error
- func (tp *TransformationPipeline) Dump(ctx context.Context, data []byte) (err error)
- func (tp *TransformationPipeline) Init(ctx context.Context) error
- func (tp *TransformationPipeline) TransformAsync(ctx context.Context, r *toolkit.Record) (*toolkit.Record, error)
- func (tp *TransformationPipeline) TransformSync(ctx context.Context, r *toolkit.Record) (*toolkit.Record, error)
- type TransformationWindow
- type ValidationPipeline
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type BlobsDumper ¶
func NewLargeObjectDumper ¶
func NewLargeObjectDumper(blobs *dump.Blobs) *BlobsDumper
func (*BlobsDumper) DebugInfo ¶
func (lod *BlobsDumper) DebugInfo() string
type DumpError ¶
type PlainDumpPipeline ¶
type PlainDumpPipeline struct {
// contains filtered or unexported fields
}
func NewPlainDumpPipeline ¶
func NewPlainDumpPipeline(table *dump.Table, w io.Writer) *PlainDumpPipeline
func (*PlainDumpPipeline) CompleteDump ¶
func (pdp *PlainDumpPipeline) CompleteDump() (err error)
type SequenceDumper ¶
type SequenceDumper struct {
// contains filtered or unexported fields
}
func NewSequenceDumper ¶
func NewSequenceDumper(sequence *dump.Sequence) *SequenceDumper
func (*SequenceDumper) DebugInfo ¶
func (sd *SequenceDumper) DebugInfo() string
type TableDumper ¶
type TableDumper struct {
// contains filtered or unexported fields
}
func NewTableDumper ¶
func NewTableDumper(table *dump.Table, validate bool, validateWithOriginal bool) *TableDumper
func (*TableDumper) DebugInfo ¶
func (td *TableDumper) DebugInfo() string
type TransformationFunc ¶
type TransformationPipeline ¶
type TransformationPipeline struct { Transform TransformationFunc // contains filtered or unexported fields }
func (*TransformationPipeline) CompleteDump ¶
func (tp *TransformationPipeline) CompleteDump() (err error)
func (*TransformationPipeline) Done ¶
func (tp *TransformationPipeline) Done(ctx context.Context) error
func (*TransformationPipeline) Dump ¶
func (tp *TransformationPipeline) Dump(ctx context.Context, data []byte) (err error)
func (*TransformationPipeline) Init ¶
func (tp *TransformationPipeline) Init(ctx context.Context) error
func (*TransformationPipeline) TransformAsync ¶
func (*TransformationPipeline) TransformSync ¶
type TransformationWindow ¶
type TransformationWindow struct {
// contains filtered or unexported fields
}
func NewTransformationWindow ¶
func NewTransformationWindow(ctx context.Context, eg *errgroup.Group) *TransformationWindow
func (*TransformationWindow) Done ¶
func (tw *TransformationWindow) Done()
func (*TransformationWindow) Init ¶
func (tw *TransformationWindow) Init()
func (*TransformationWindow) TryAdd ¶
func (tw *TransformationWindow) TryAdd(table *dump.Table, t utils.Transformer) bool
type ValidationPipeline ¶
type ValidationPipeline struct { *TransformationPipeline // contains filtered or unexported fields }
func NewValidationPipeline ¶
Click to show internal directories.
Click to hide internal directories.