service

package
v1.9.0-rc.2 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: May 19, 2023 License: AGPL-3.0 Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

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 model.Warehouse) error

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

Directories

Path Synopsis
loadfiles

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL