storage

package
v2.0.400-0...-14731b4 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 21, 2021 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func EnableLongTermStorage

func EnableLongTermStorage(gcloud gke.GClouder, installValues map[string]string, providedBucketName string) (string, error)

EnableLongTermStorage will take the cluster install values and a provided bucket name and use it / create a new one for gs

func NewGKEBucketProvider

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

NewGKEBucketProvider create a new provider for GKE

Types

type GKEBucketProvider

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

GKEBucketProvider the bucket provider for GKE

func (*GKEBucketProvider) CreateNewBucketForCluster

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

CreateNewBucketForCluster creates a new dynamic bucket

func (*GKEBucketProvider) DownloadFileFromBucket

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

DownloadFileFromBucket downloads a file from GCS from the given bucketURL and server its contents with a bufio.Scanner

func (*GKEBucketProvider) EnsureBucketIsCreated

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

EnsureBucketIsCreated ensures the bucket URL is createtd

func (*GKEBucketProvider) UploadFileToBucket

func (b *GKEBucketProvider) UploadFileToBucket(reader io.Reader, key string, bucketURL string) (string, error)

UploadFileToBucket uploads a file to the provided GCS bucket with the provided outputName

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL