Documentation
¶
Index ¶
Constants ¶
const ( DefaultBatchSize int = 1000 DefaultDelay time.Duration = 0 )
Variables ¶
This section is empty.
Functions ¶
func IsPossible ¶
IsPossible will return an error if the backfill operation is not supported.
Types ¶
type Backfill ¶
type Backfill struct {
*Config
// contains filtered or unexported fields
}
func New ¶
New creates a new backfill operation with the given options. The backfill is not started until `Start` is invoked.
func (*Backfill) Start ¶
Start updates all rows in the given table, in batches, using the following algorithm: 1. Get the primary key column for the table. 2. Get the first batch of rows from the table, ordered by the primary key. 3. Update each row in the batch, setting the value of the primary key column to itself. 4. Repeat steps 2 and 3 until no more rows are returned.
type CallbackFn ¶
type Config ¶ added in v0.10.0
type Config struct {
// contains filtered or unexported fields
}
func (*Config) AddCallback ¶ added in v0.10.0
func (c *Config) AddCallback(fn CallbackFn)
AddCallback adds a callback to the backfill operation. Callbacks are invoked after each batch is processed.
type NotPossibleError ¶
type NotPossibleError struct {
Table string
}
func (NotPossibleError) Error ¶
func (e NotPossibleError) Error() string
type OptionFn ¶
type OptionFn func(*Config)
func WithBatchDelay ¶
WithBatchDelay sets the delay between batches for the backfill operation.
func WithBatchSize ¶
WithBatchSize sets the batch size for the backfill operation.
Source Files
Directories