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)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
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
Click to show internal directories.
Click to hide internal directories.