pipeline

package
v0.0.0-...-dc3a03b Latest Latest
Warning

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

Go to latest
Published: May 31, 2021 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func CleanSwap

func CleanSwap(dbInstance db.Storage, jobID string) error

CleanSwap removes LocalSource and LocalDestination files/directories.

func SetupJob

func SetupJob(jobID string, dbInstance db.Storage, config gonfig.Gonfig) (*types.Job, error)

SetupJob is responsible for set the initial state for a given job before starting. It sets local source and destination paths and the final destination as well.

func StartJob

func StartJob(logger lager.Logger, config gonfig.Gonfig, dbInstance db.Storage, job types.Job)

StartJob starts the job

Types

This section is empty.

Jump to

Keyboard shortcuts

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