repo

Documentation

Index

• func NewPGShareToken(ctx context.Context, db *sql.DB) (*pgShareToken, error)
• type MinioAdapter
  • func NewMinioBlob(cli *minio.Client) *MinioAdapter
  • func (s *MinioAdapter) CreateBucket(ctx context.Context, bucketName string) (any, error)
  • func (s *MinioAdapter) Delete(ctx context.Context, bucketName, key string) error
  • func (s *MinioAdapter) Get(ctx context.Context, bucketName, filename string) (*blob.Object, error)
  • func (s *MinioAdapter) GetShareUrl(bucket, key string) blob.ShareFunc
  • func (s *MinioAdapter) GetUsage(ctx context.Context, bucket string) (int64, error)
  • func (s *MinioAdapter) Info(ctx context.Context, bucketName, fileName string) (*blob.Info, error)
  • func (s *MinioAdapter) ObjectIterator(ctx context.Context, bucketName string, limit int, lastFilename string) *blob.Iterator
  • func (s *MinioAdapter) Put(ctx context.Context, bucketName, key string, file io.ReadCloser, size int64, ...) (*blob.Info, error)

Functions

func NewPGShareToken

func NewPGShareToken(ctx context.Context, db *sql.DB) (*pgShareToken, error)

Types

type MinioAdapter

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

represent blob storage

func NewMinioBlob

func NewMinioBlob(cli *minio.Client) *MinioAdapter

func (*MinioAdapter) CreateBucket

func (s *MinioAdapter) CreateBucket(ctx context.Context, bucketName string) (any, error)

func (*MinioAdapter) Delete

func (s *MinioAdapter) Delete(ctx context.Context, bucketName, key string) error

func (*MinioAdapter) Get

func (s *MinioAdapter) Get(ctx context.Context, bucketName, filename string) (*blob.Object, error)

func (*MinioAdapter) GetShareUrl

func (s *MinioAdapter) GetShareUrl(bucket, key string) blob.ShareFunc

func (*MinioAdapter) GetUsage

func (s *MinioAdapter) GetUsage(ctx context.Context, bucket string) (int64, error)

func (*MinioAdapter) Info

func (s *MinioAdapter) Info(ctx context.Context, bucketName, fileName string) (*blob.Info, error)

func (*MinioAdapter) ObjectIterator

func (s *MinioAdapter) ObjectIterator(ctx context.Context, bucketName string, limit int, lastFilename string) *blob.Iterator

func (*MinioAdapter) Put

func (s *MinioAdapter) Put(ctx context.Context, bucketName, key string, file io.ReadCloser, size int64, contentType string) (*blob.Info, error)