storage

Documentation

Index

• func NewAmazonBucketProvider(requirements *config.RequirementsConfig) buckets.Provider
• type AmazonBucketProvider
  • func (b *AmazonBucketProvider) CreateNewBucketForCluster(clusterName string, bucketKind string) (string, error)
  • func (b *AmazonBucketProvider) DownloadFileFromBucket(bucketURL string) (io.ReadCloser, error)
  • func (b *AmazonBucketProvider) EnsureBucketIsCreated(bucketURL string) error
  • func (b *AmazonBucketProvider) UploadFileToBucket(reader io.Reader, outputName string, bucketURL string) (string, error)

Functions

func NewAmazonBucketProvider

func NewAmazonBucketProvider(requirements *config.RequirementsConfig) buckets.Provider

NewAmazonBucketProvider create a new provider for AWS

Types

type AmazonBucketProvider

type AmazonBucketProvider struct {
	Requirements *config.RequirementsConfig
	// contains filtered or unexported fields
}

AmazonBucketProvider the bucket provider for AWS

func (*AmazonBucketProvider) CreateNewBucketForCluster

func (b *AmazonBucketProvider) CreateNewBucketForCluster(clusterName string, bucketKind string) (string, error)

CreateNewBucketForCluster creates a new dynamic bucket

func (*AmazonBucketProvider) DownloadFileFromBucket

func (b *AmazonBucketProvider) DownloadFileFromBucket(bucketURL string) (io.ReadCloser, error)

DownloadFileFromBucket downloads a file from an S3 bucket and converts the contents to a bufio.Scanner

func (*AmazonBucketProvider) EnsureBucketIsCreated

func (b *AmazonBucketProvider) EnsureBucketIsCreated(bucketURL string) error

EnsureBucketIsCreated ensures the bucket URL is created

func (*AmazonBucketProvider) UploadFileToBucket

func (b *AmazonBucketProvider) UploadFileToBucket(reader io.Reader, outputName string, bucketURL string) (string, error)

UploadFileToBucket uploads a file to an S3 bucket to the provided bucket with the provided outputName