fileutils

Documentation

Index

• func AddEntryToTar(source *os.File, entryName string, entryContents string) error
• func DownloadS3File(ctx context.Context, s3Downloader S3Downloader, launchRoleArn string, ...) (*os.File, error)
• func UnzipFile(compressed *os.File) (*os.File, error)
• func ZipFile(uncompressed *os.File) (*os.File, error)
• type S3ClientProvider
• type S3Downloader
• type S3ManagerDownloader
  • func NewS3DownloaderWithAssumedRole(ctx context.Context, sdkConfig aws.Config) S3ManagerDownloader
  • func (downloader S3ManagerDownloader) Download(ctx context.Context, launchRoleArn string, tmp *os.File, bucket string, ...) (n int64, err error)

Functions

func AddEntryToTar

func AddEntryToTar(source *os.File, entryName string, entryContents string) error

func DownloadS3File

func DownloadS3File(ctx context.Context, s3Downloader S3Downloader, launchRoleArn string, s3Path string) (*os.File, error)

func UnzipFile

func UnzipFile(compressed *os.File) (*os.File, error)

UnzipFile decompresses the file that is passed and returns an open file containing the newly decompressed source.

It closes the file that was passed to it after it has been fully read.

func ZipFile

func ZipFile(uncompressed *os.File) (*os.File, error)

Types

type S3ClientProvider

type S3ClientProvider func(launchRoleArn string) (*s3.Client, error)

type S3Downloader

type S3Downloader interface {
	Download(ctx context.Context, launchRoleArn string, tmp *os.File, bucket string, key string) (n int64, err error)
}

type S3ManagerDownloader

type S3ManagerDownloader struct {
	S3ClientProvider S3ClientProvider
}

func NewS3DownloaderWithAssumedRole

func NewS3DownloaderWithAssumedRole(ctx context.Context, sdkConfig aws.Config) S3ManagerDownloader

NewS3DownloaderWithAssumedRole creates a new S3 Downloader that will assume the provided launch role to make requests to fetch files from S3

func (S3ManagerDownloader) Download

func (downloader S3ManagerDownloader) Download(ctx context.Context, launchRoleArn string, tmp *os.File, bucket string, objectKey string) (n int64, err error)