Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Config ¶
type Config struct {
// Postgres connection URL. Required.
URL string
// BatchPageSize represents the size of the table page range that will be
// processed concurrently by the table workers. Defaults to 1000.
BatchPageSize uint
// SchemaWorkers represents the number of tables the snapshot generator will
// process concurrently per schema. Defaults to 4.
SchemaWorkers uint
// TableWorkers represents the number of concurrent workers per table. Each
// worker will process a different page range in parallel. Defaults to 4.
TableWorkers uint
}
type Option ¶
type Option func(sg *SnapshotGenerator)
func WithInstrumentation ¶ added in v0.6.0
func WithInstrumentation(i *otel.Instrumentation) Option
func WithLogger ¶
type SnapshotGenerator ¶
type SnapshotGenerator struct {
// contains filtered or unexported fields
}
func NewSnapshotGenerator ¶
func NewSnapshotGenerator(ctx context.Context, cfg *Config, rowsProcessor snapshot.RowsProcessor, opts ...Option) (*SnapshotGenerator, error)
func (*SnapshotGenerator) Close ¶
func (sg *SnapshotGenerator) Close() error
func (*SnapshotGenerator) CreateSnapshot ¶
Click to show internal directories.
Click to hide internal directories.