util

Documentation

Index

• func Compress(src string, dest string) error
• func DeCompress(tarFile, dest string) error
• func ParallelizeUntil(ctx context.Context, workers, pieces int, doWorkPiece DoWorkPieceFunc)
• func ScpDir(client *sftp.Client, srcDir, dstDir string, forward bool) error
• func ScpFile(client *sftp.Client, srcPath, dstPath string, forward bool) error
• func SetupSigusr1Trap()
• type DoWorkPieceFunc

Functions

func Compress

func Compress(src string, dest string) error

func DeCompress

func DeCompress(tarFile, dest string) error

func ParallelizeUntil

func ParallelizeUntil(ctx context.Context, workers, pieces int, doWorkPiece DoWorkPieceFunc)

ParallelizeUntil is a framework that allows for parallelizing N independent pieces of work until done or the context is canceled.

func ScpDir

func ScpDir(client *sftp.Client, srcDir, dstDir string, forward bool) error

func ScpFile

func ScpFile(client *sftp.Client, srcPath, dstPath string, forward bool) error

func SetupSigusr1Trap

func SetupSigusr1Trap()

Types

type DoWorkPieceFunc

type DoWorkPieceFunc func(piece int)