puller

Documentation

Index

• func CheckSanePath(path string, baseFolder string) error
• func ExtractTarGz(checkOnly bool, archivePath string, basePath string, maxArchiveSize int64) error
• func IsTarGz(filePath string, maxArchiveSize int64) (bool, error)
• type DataPuller
• type ListObject

Functions

func CheckSanePath

func CheckSanePath(path string, baseFolder string) error

checkSanePath just to make sure we don't delete or overwrite somewhere where we are not supposed to

func ExtractTarGz

func ExtractTarGz(checkOnly bool, archivePath string, basePath string, maxArchiveSize int64) error

func IsTarGz

func IsTarGz(filePath string, maxArchiveSize int64) (bool, error)

Types

type DataPuller

type DataPuller interface {
	Pull(ctx context.Context, clusterName string, runID string) (string, error)
	Extract(ctx context.Context, archivePath string) error
	Close(ctx context.Context, basePath string) error
	ListFiles(ctx context.Context, prefix string, recursive bool) ([]*ListObject, error)
}

type ListObject

type ListObject struct {
	Key string
	// ModTime is the time the blob was last modified.
	ModTime time.Time
}