storage

Documentation

Index

• func EnableLongTermStorage(gcloud gke.GClouder, installValues map[string]string, ...) (string, error)
• func NewGKEBucketProvider(requirements *config.RequirementsConfig) buckets.Provider
• type GKEBucketProvider
  • func (b *GKEBucketProvider) CreateNewBucketForCluster(clusterName string, bucketKind string) (string, error)
  • func (b *GKEBucketProvider) DownloadFileFromBucket(bucketURL string) (io.ReadCloser, error)
  • func (b *GKEBucketProvider) EnsureBucketIsCreated(bucketURL string) error
  • func (b *GKEBucketProvider) UploadFileToBucket(reader io.Reader, key string, bucketURL string) (string, error)

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