Documentation
¶
Overview ¶
Package aws package
Index ¶
- type ObjectStore
- func (s *ObjectStore) DoesObjectExist(ctx context.Context, key string) (bool, error)
- func (s *ObjectStore) DownloadObject(ctx context.Context, key string, w io.WriterAt, ...) error
- func (s *ObjectStore) GetObjectStream(ctx context.Context, key string, options *objectstore.DownloadOptions) (io.ReadCloser, error)
- func (s *ObjectStore) GetPresignedURL(ctx context.Context, key string) (string, error)
- func (s *ObjectStore) UploadObject(ctx context.Context, key string, body io.Reader) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ObjectStore ¶
type ObjectStore struct {
// contains filtered or unexported fields
}
ObjectStore implementation for AWS S3
func New ¶
func New(ctx context.Context, logger logger.Logger, pluginData map[string]string) (*ObjectStore, error)
New returns an S3 implementation of the ObjectStore interface
func (*ObjectStore) DoesObjectExist ¶
DoesObjectExist returns a boolean indicating an object's existence. It doesn't download the object itself but simply queries for it's metadata.
func (*ObjectStore) DownloadObject ¶
func (s *ObjectStore) DownloadObject(ctx context.Context, key string, w io.WriterAt, options *objectstore.DownloadOptions) error
DownloadObject downloads an object using a concurrent download
func (*ObjectStore) GetObjectStream ¶
func (s *ObjectStore) GetObjectStream(ctx context.Context, key string, options *objectstore.DownloadOptions) (io.ReadCloser, error)
GetObjectStream returns an object stream for the object at the specified key
func (*ObjectStore) GetPresignedURL ¶
GetPresignedURL returns a presigned URL which can be used to temporarily provide access to an object from object storage without requiring IAM or AWS credentials.
func (*ObjectStore) UploadObject ¶
UploadObject uploads an object to the object store
Source Files
Click to show internal directories.
Click to hide internal directories.