gcs

Documentation

Index

• type Provider
  • func NewProvider(logger *logrus.Logger) *Provider
  • func (p *Provider) BucketExists(ctx context.Context, request *storageProvider.BucketExistsRequest) (bool, error)
  • func (p *Provider) Close() error
  • func (p *Provider) Configure(config map[string]interface{}) error
  • func (p *Provider) CopyObject(ctx context.Context, request *storageProvider.CopyObjectRequest) (*storageProvider.CopyObjectResponse, error)
  • func (p *Provider) CreateBucket(ctx context.Context, request *storageProvider.CreateBucketRequest) error
  • func (p *Provider) DeleteBucket(ctx context.Context, request *storageProvider.DeleteBucketRequest) error
  • func (p *Provider) DeleteObject(ctx context.Context, request *storageProvider.DeleteObjectRequest) error
  • func (p *Provider) DeleteObjects(ctx context.Context, request *storageProvider.DeleteObjectsRequest) (*storageProvider.DeleteObjectsResponse, error)
  • func (p *Provider) GeneratePresignedURL(ctx context.Context, request *storageProvider.PresignedURLRequest) (string, error)
  • func (p *Provider) GeneratePublicURL(ctx context.Context, request *storageProvider.PublicURLRequest) (string, error)
  • func (p *Provider) GetAllowedTypes() []string
  • func (p *Provider) GetMaxFileSize() int64
  • func (p *Provider) GetName() string
  • func (p *Provider) GetObject(ctx context.Context, request *storageProvider.GetObjectRequest) (*storageProvider.GetObjectResponse, error)
  • func (p *Provider) GetObjectInfo(ctx context.Context, request *storageProvider.GetObjectInfoRequest) (*storageProvider.ObjectInfo, error)
  • func (p *Provider) GetSupportedFeatures() []storageProvider.StorageFeature
  • func (p *Provider) HealthCheck(ctx context.Context) error
  • func (p *Provider) IsConfigured() bool
  • func (p *Provider) ListBuckets(ctx context.Context) ([]storageProvider.BucketInfo, error)
  • func (p *Provider) ListObjects(ctx context.Context, request *storageProvider.ListObjectsRequest) (*storageProvider.ListObjectsResponse, error)
  • func (p *Provider) MoveObject(ctx context.Context, request *storageProvider.MoveObjectRequest) (*storageProvider.MoveObjectResponse, error)
  • func (p *Provider) ObjectExists(ctx context.Context, request *storageProvider.ObjectExistsRequest) (bool, error)
  • func (p *Provider) PutObject(ctx context.Context, request *storageProvider.PutObjectRequest) (*storageProvider.PutObjectResponse, error)

Types

type Provider

type Provider struct {
	// contains filtered or unexported fields
}

Provider implements StorageProvider for Google Cloud Storage

func NewProvider

func NewProvider(logger *logrus.Logger) *Provider

NewProvider creates a new GCS storage provider

func (*Provider) BucketExists

func (p *Provider) BucketExists(ctx context.Context, request *storageProvider.BucketExistsRequest) (bool, error)

BucketExists checks if a bucket exists in GCS

func (*Provider) Close

func (p *Provider) Close() error

Close closes the GCS provider

func (*Provider) Configure

func (p *Provider) Configure(config map[string]interface{}) error

Configure configures the GCS provider

func (*Provider) CopyObject

func (p *Provider) CopyObject(ctx context.Context, request *storageProvider.CopyObjectRequest) (*storageProvider.CopyObjectResponse, error)

CopyObject copies an object within GCS

func (*Provider) CreateBucket

func (p *Provider) CreateBucket(ctx context.Context, request *storageProvider.CreateBucketRequest) error

CreateBucket creates a bucket in GCS

func (*Provider) DeleteBucket

func (p *Provider) DeleteBucket(ctx context.Context, request *storageProvider.DeleteBucketRequest) error

DeleteBucket deletes a bucket from GCS

func (*Provider) DeleteObject

func (p *Provider) DeleteObject(ctx context.Context, request *storageProvider.DeleteObjectRequest) error

DeleteObject deletes an object from GCS

func (*Provider) DeleteObjects

func (p *Provider) DeleteObjects(ctx context.Context, request *storageProvider.DeleteObjectsRequest) (*storageProvider.DeleteObjectsResponse, error)

DeleteObjects deletes multiple objects from GCS

func (*Provider) GeneratePresignedURL

func (p *Provider) GeneratePresignedURL(ctx context.Context, request *storageProvider.PresignedURLRequest) (string, error)

GeneratePresignedURL generates a presigned URL for GCS

func (*Provider) GeneratePublicURL

func (p *Provider) GeneratePublicURL(ctx context.Context, request *storageProvider.PublicURLRequest) (string, error)

GeneratePublicURL generates a public URL for GCS

func (*Provider) GetAllowedTypes

func (p *Provider) GetAllowedTypes() []string

GetAllowedTypes returns allowed content types

func (*Provider) GetMaxFileSize

func (p *Provider) GetMaxFileSize() int64

GetMaxFileSize returns maximum file size (5TB for GCS)

func (*Provider) GetName

func (p *Provider) GetName() string

GetName returns the provider name

func (*Provider) GetObject

func (p *Provider) GetObject(ctx context.Context, request *storageProvider.GetObjectRequest) (*storageProvider.GetObjectResponse, error)

GetObject downloads an object from GCS

func (*Provider) GetObjectInfo

func (p *Provider) GetObjectInfo(ctx context.Context, request *storageProvider.GetObjectInfoRequest) (*storageProvider.ObjectInfo, error)

GetObjectInfo gets object information from GCS

func (*Provider) GetSupportedFeatures

func (p *Provider) GetSupportedFeatures() []storageProvider.StorageFeature

GetSupportedFeatures returns supported features

func (*Provider) HealthCheck

func (p *Provider) HealthCheck(ctx context.Context) error

HealthCheck performs a health check on GCS

func (*Provider) IsConfigured

func (p *Provider) IsConfigured() bool

IsConfigured checks if the provider is configured

func (*Provider) ListBuckets

func (p *Provider) ListBuckets(ctx context.Context) ([]storageProvider.BucketInfo, error)

ListBuckets lists buckets in GCS

func (*Provider) ListObjects

func (p *Provider) ListObjects(ctx context.Context, request *storageProvider.ListObjectsRequest) (*storageProvider.ListObjectsResponse, error)

ListObjects lists objects in GCS

func (*Provider) MoveObject

func (p *Provider) MoveObject(ctx context.Context, request *storageProvider.MoveObjectRequest) (*storageProvider.MoveObjectResponse, error)

MoveObject moves an object within GCS

func (*Provider) ObjectExists

func (p *Provider) ObjectExists(ctx context.Context, request *storageProvider.ObjectExistsRequest) (bool, error)

ObjectExists checks if an object exists in GCS

func (*Provider) PutObject

func (p *Provider) PutObject(ctx context.Context, request *storageProvider.PutObjectRequest) (*storageProvider.PutObjectResponse, error)

PutObject uploads an object to GCS