objectstore

Documentation

Overview

This package contains helper methods for using object stores.

Index

• func DownloadBlob(ctx context.Context, bucket *blob.Bucket, localDir, blobDir string) error
• func MinioDefaultEndpoint() string
• func OpenBucket(ctx context.Context, k8sClient kubernetes.Interface, namespace string, ...) (bucket *blob.Bucket, err error)
• func UploadBlob(ctx context.Context, bucket *blob.Bucket, localPath, blobPath string) error
• type Config
  • func ParseBucketConfig(path string) (*Config, error)
  • func ParseBucketConfigForArtifactURI(uri string) (*Config, error)
  • func (b *Config) KeyFromURI(uri string) (string, error)
  • func (b *Config) PrefixedBucket() string
  • func (b *Config) UriFromKey(blobKey string) string

Functions

func DownloadBlob

func DownloadBlob(ctx context.Context, bucket *blob.Bucket, localDir, blobDir string) error

func MinioDefaultEndpoint

func MinioDefaultEndpoint() string

func OpenBucket

func OpenBucket(ctx context.Context, k8sClient kubernetes.Interface, namespace string, config *Config) (bucket *blob.Bucket, err error)

func UploadBlob

func UploadBlob(ctx context.Context, bucket *blob.Bucket, localPath, blobPath string) error

Types

type Config

type Config struct {
	Scheme      string
	BucketName  string
	Prefix      string
	QueryString string
}

func ParseBucketConfig

func ParseBucketConfig(path string) (*Config, error)

func ParseBucketConfigForArtifactURI

func ParseBucketConfigForArtifactURI(uri string) (*Config, error)

func (*Config) KeyFromURI

func (b *Config) KeyFromURI(uri string) (string, error)

func (*Config) PrefixedBucket

func (b *Config) PrefixedBucket() string

func (*Config) UriFromKey

func (b *Config) UriFromKey(blobKey string) string