Documentation
¶
Index ¶
- Constants
- Variables
- type Adapter
- type DirectDownloadAdapter
- type FilesystemAdapter
- func (a *FilesystemAdapter) Clear(_ context.Context) error
- func (a *FilesystemAdapter) CountFilesInFolder(_ context.Context, folderName string) (int, error)
- func (a *FilesystemAdapter) CreateDownloadStream(_ context.Context, objectName string) (io.ReadCloser, error)
- func (a *FilesystemAdapter) DeleteFolder(_ context.Context, folderName string) error
- func (a *FilesystemAdapter) UploadStream(ctx context.Context, objectName string, stream io.Reader) error
- type ObjectNotFoundError
- type S3Adapter
- func (a *S3Adapter) Clear(ctx context.Context) error
- func (a *S3Adapter) CountFilesInFolder(ctx context.Context, folderName string) (int, error)
- func (a *S3Adapter) CreateDownloadStream(ctx context.Context, objectName string) (io.ReadCloser, error)
- func (a *S3Adapter) CreateDownloadURL(ctx context.Context, objectName string, ttl time.Duration) (string, error)
- func (a *S3Adapter) DeleteFolder(ctx context.Context, folderName string) error
- func (a *S3Adapter) UploadStream(ctx context.Context, objectName string, stream io.Reader) error
Constants ¶
View Source
const ( DriverFilesystem = "filesystem" DriverS3 = "s3" )
Variables ¶
View Source
var ErrObjectNotFound = errors.New("object not found in storage")
Functions ¶
This section is empty.
Types ¶
type Adapter ¶
type Adapter interface {
UploadStream(ctx context.Context, objectName string, stream io.Reader) error
CreateDownloadStream(ctx context.Context, objectName string) (io.ReadCloser, error)
DeleteFolder(ctx context.Context, folderName string) error
CountFilesInFolder(ctx context.Context, folderName string) (int, error)
Clear(ctx context.Context) error
}
func NewAdapter ¶
type DirectDownloadAdapter ¶
type FilesystemAdapter ¶
type FilesystemAdapter struct {
// contains filtered or unexported fields
}
func NewFilesystemAdapter ¶
func NewFilesystemAdapter(root string) (*FilesystemAdapter, error)
func (*FilesystemAdapter) CountFilesInFolder ¶
func (*FilesystemAdapter) CreateDownloadStream ¶
func (a *FilesystemAdapter) CreateDownloadStream(_ context.Context, objectName string) (io.ReadCloser, error)
func (*FilesystemAdapter) DeleteFolder ¶
func (a *FilesystemAdapter) DeleteFolder(_ context.Context, folderName string) error
func (*FilesystemAdapter) UploadStream ¶
type ObjectNotFoundError ¶
type ObjectNotFoundError struct {
ObjectName string
}
func (ObjectNotFoundError) Error ¶
func (e ObjectNotFoundError) Error() string
func (ObjectNotFoundError) Unwrap ¶
func (e ObjectNotFoundError) Unwrap() error
type S3Adapter ¶
type S3Adapter struct {
// contains filtered or unexported fields
}
func NewS3Adapter ¶
func (*S3Adapter) CountFilesInFolder ¶
func (*S3Adapter) CreateDownloadStream ¶
func (*S3Adapter) CreateDownloadURL ¶
func (*S3Adapter) DeleteFolder ¶
Source Files
Click to show internal directories.
Click to hide internal directories.