service

Documentation

Index

• func StageFileBatching(files []model.StagingFile, batchSize int) [][]model.StagingFile
• type Recovery
  • func NewRecovery(destinationType string, repo repo) *Recovery
  • func (r *Recovery) Recover(ctx context.Context, whManager destination, wh warehouseutils.Warehouse) error

Functions

func StageFileBatching

func StageFileBatching(files []model.StagingFile, batchSize int) [][]model.StagingFile

StageFileBatching batches staging files.

Types

type Recovery

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

func NewRecovery

func NewRecovery(destinationType string, repo repo) *Recovery

func (*Recovery) Recover

func (r *Recovery) Recover(ctx context.Context, whManager destination, wh warehouseutils.Warehouse) error

Recover recovers a warehouse, for a non-graceful shutdown.