cloudstorages

Documentation

Index

• Variables
• type GCSInstance
  • func NewGCS() *GCSInstance
  • func (gcsinstance *GCSInstance) Delete(ctx context.Context, bucket string, key string) error
  • func (gcsinstance *GCSInstance) Get(ctx context.Context, bucket string, key string) (string, []byte, error)
  • func (gcsinstance *GCSInstance) GetByStreaming(ctx context.Context, bucket string, key string) (string, io.ReadCloser, error)
  • func (gcsinstance *GCSInstance) GetObjectInfo(ctx context.Context, bucket string, key string) (entity.StorageObjectInfo, error)
  • func (gcsinstance *GCSInstance) List(ctx context.Context, bucket string, key string) ([]string, error)
  • func (gcsinstance *GCSInstance) Put(ctx context.Context, bucket string, path string, file io.ReadSeeker) error
• type S3Instance
  • func NewS3() *S3Instance
  • func (s3instance *S3Instance) Delete(ctx context.Context, bucket string, key string) error
  • func (s3instance *S3Instance) Get(ctx context.Context, bucket string, key string) (string, []byte, error)
  • func (s3instance *S3Instance) GetByStreaming(ctx context.Context, bucket string, key string) (string, io.ReadCloser, error)
  • func (s3instance *S3Instance) GetObjectInfo(ctx context.Context, bucket string, key string) (entity.StorageObjectInfo, error)
  • func (s3instance *S3Instance) List(ctx context.Context, bucket string, key string) ([]string, error)
  • func (s3instance *S3Instance) Put(ctx context.Context, bucket string, path string, file io.ReadSeeker) error
• type StorageInstance

Variables

var GcsBucketUploadfiles = os.Getenv("GCS_BUKET")

GcsBucketUploadfiles is bucket to upload.

var S3BucketUploadfiles = os.Getenv("AWS_S3_BUKET")

S3BucketUploadfiles is bucket to upload.

Types

type GCSInstance

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

GCSInstance struct.

func NewGCS

func NewGCS() *GCSInstance

NewGCS creates a new GCSInstance.

func (*GCSInstance) Delete

func (gcsinstance *GCSInstance) Delete(ctx context.Context, bucket string, key string) error

Delete deletes from storage.

func (*GCSInstance) Get

func (gcsinstance *GCSInstance) Get(ctx context.Context, bucket string, key string) (string, []byte, error)

Get gets from storage.

func (*GCSInstance) GetByStreaming

func (gcsinstance *GCSInstance) GetByStreaming(ctx context.Context, bucket string, key string) (string, io.ReadCloser, error)

GetByStreaming gets from storage by streaming.

func (*GCSInstance) GetObjectInfo

func (gcsinstance *GCSInstance) GetObjectInfo(ctx context.Context, bucket string, key string) (entity.StorageObjectInfo, error)

GetObjectInfo gets from storage.

func (*GCSInstance) List

func (gcsinstance *GCSInstance) List(ctx context.Context, bucket string, key string) ([]string, error)

List get list from storage.

func (*GCSInstance) Put

func (gcsinstance *GCSInstance) Put(ctx context.Context, bucket string, path string, file io.ReadSeeker) error

Put puts to storage.

type S3Instance

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

S3Instance struct.

func NewS3

func NewS3() *S3Instance

NewS3 creates a new S3Instance.

func (*S3Instance) Delete

func (s3instance *S3Instance) Delete(ctx context.Context, bucket string, key string) error

Delete deletes from storage.

func (*S3Instance) Get

func (s3instance *S3Instance) Get(ctx context.Context, bucket string, key string) (string, []byte, error)

Get gets from storage.

func (*S3Instance) GetByStreaming

func (s3instance *S3Instance) GetByStreaming(ctx context.Context, bucket string, key string) (string, io.ReadCloser, error)

GetByStreaming gets from storage by streaming.

func (*S3Instance) GetObjectInfo

func (s3instance *S3Instance) GetObjectInfo(ctx context.Context, bucket string, key string) (entity.StorageObjectInfo, error)

GetObjectInfo gets from storage.

func (*S3Instance) List

func (s3instance *S3Instance) List(ctx context.Context, bucket string, key string) ([]string, error)

List get list from storage.

func (*S3Instance) Put

func (s3instance *S3Instance) Put(ctx context.Context, bucket string, path string, file io.ReadSeeker) error

Put puts to storage.

type StorageInstance

type StorageInstance interface {
	Put(ctx context.Context, bucket string, path string, file io.ReadSeeker) error
	Get(ctx context.Context, bucket string, key string) (string, []byte, error)
	GetByStreaming(ctx context.Context, bucket string, key string) (string, io.ReadCloser, error)
	GetObjectInfo(ctx context.Context, bucket string, key string) (entity.StorageObjectInfo, error)
	List(ctx context.Context, bucket string, key string) ([]string, error)
	Delete(ctx context.Context, bucket string, key string) error
}

StorageInstance interface.