Documentation
¶
Index ¶
- Variables
- func ExtractParamsFromQK(qk block.QualifiedKey) (string, string)
- func LoadConfig(ctx context.Context, params params.S3) (aws.Config, error)
- func WithClientParams(params params.S3) func(options *s3.Options)
- func WithDisablePreSigned(b bool) func(a *Adapter)
- func WithDisablePreSignedMultipart(b bool) func(a *Adapter)
- func WithDisablePreSignedUI(b bool) func(a *Adapter)
- func WithDiscoverBucketRegion(b bool) func(a *Adapter)
- func WithPreSignedExpiry(v time.Duration) func(a *Adapter)
- func WithServerSideEncryption(s string) func(a *Adapter)
- func WithServerSideEncryptionKmsKeyID(s string) func(a *Adapter)
- func WithStatsCollector(s stats.Collector) func(a *Adapter)
- type Adapter
- func (a *Adapter) AbortMultiPartUpload(ctx context.Context, obj block.ObjectPointer, uploadID string) error
- func (a *Adapter) BlockstoreType() string
- func (a *Adapter) CompleteMultiPartUpload(ctx context.Context, obj block.ObjectPointer, uploadID string, ...) (*block.CompleteMultiPartUploadResponse, error)
- func (a *Adapter) Copy(ctx context.Context, sourceObj, destinationObj block.ObjectPointer) error
- func (a *Adapter) CreateMultiPartUpload(ctx context.Context, obj block.ObjectPointer, _ *http.Request, ...) (*block.CreateMultiPartUploadResponse, error)
- func (a *Adapter) Exists(ctx context.Context, obj block.ObjectPointer) (bool, error)
- func (a *Adapter) Get(ctx context.Context, obj block.ObjectPointer, _ int64) (io.ReadCloser, error)
- func (a *Adapter) GetPreSignedURL(ctx context.Context, obj block.ObjectPointer, mode block.PreSignMode) (string, time.Time, error)
- func (a *Adapter) GetPresignUploadPartURL(ctx context.Context, obj block.ObjectPointer, uploadID string, partNumber int) (string, error)
- func (a *Adapter) GetProperties(ctx context.Context, obj block.ObjectPointer) (block.Properties, error)
- func (a *Adapter) GetRange(ctx context.Context, obj block.ObjectPointer, startPosition int64, ...) (io.ReadCloser, error)
- func (a *Adapter) GetStorageNamespaceInfo() block.StorageNamespaceInfo
- func (a *Adapter) GetWalker(uri *url.URL) (block.Walker, error)
- func (a *Adapter) ListParts(ctx context.Context, obj block.ObjectPointer, uploadID string, ...) (*block.ListPartsResponse, error)
- func (a *Adapter) Put(ctx context.Context, obj block.ObjectPointer, sizeBytes int64, ...) error
- func (a *Adapter) Remove(ctx context.Context, obj block.ObjectPointer) error
- func (a *Adapter) ResolveNamespace(storageNamespace, key string, identifierType block.IdentifierType) (block.QualifiedKey, error)
- func (a *Adapter) RuntimeStats() map[string]string
- func (a *Adapter) UploadCopyPart(ctx context.Context, sourceObj, destinationObj block.ObjectPointer, ...) (*block.UploadPartResponse, error)
- func (a *Adapter) UploadCopyPartRange(ctx context.Context, sourceObj, destinationObj block.ObjectPointer, ...) (*block.UploadPartResponse, error)
- func (a *Adapter) UploadPart(ctx context.Context, obj block.ObjectPointer, sizeBytes int64, ...) (*block.UploadPartResponse, error)
- type AdapterOption
- type CaptureExpiresPresigner
- type ClientCache
- func (c *ClientCache) DiscoverBucketRegion(b bool)
- func (c *ClientCache) Get(ctx context.Context, bucket string) *s3.Client
- func (c *ClientCache) GetDefault() *s3.Client
- func (c *ClientCache) SetClientFactory(clientFactory clientFactory)
- func (c *ClientCache) SetS3RegionGetter(s3RegionGetter s3RegionGetter)
- func (c *ClientCache) SetStatsCollector(statsCollector stats.Collector)
- type Walker
Constants ¶
This section is empty.
Variables ¶
Functions ¶
func ExtractParamsFromQK ¶ added in v0.97.0
func ExtractParamsFromQK(qk block.QualifiedKey) (string, string)
func LoadConfig ¶ added in v0.110.0
func WithClientParams ¶ added in v0.110.0
func WithDisablePreSigned ¶ added in v0.94.0
func WithDisablePreSignedMultipart ¶ added in v1.7.0
func WithDisablePreSignedUI ¶ added in v0.97.0
func WithDiscoverBucketRegion ¶ added in v0.55.0
func WithPreSignedExpiry ¶ added in v0.92.0
func WithServerSideEncryption ¶ added in v0.87.0
func WithServerSideEncryptionKmsKeyID ¶ added in v0.87.0
func WithStatsCollector ¶ added in v0.48.0
Types ¶
type Adapter ¶
type Adapter struct { ServerSideEncryption string ServerSideEncryptionKmsKeyID string // contains filtered or unexported fields }
func NewAdapter ¶
func (*Adapter) AbortMultiPartUpload ¶
func (*Adapter) BlockstoreType ¶
func (*Adapter) CompleteMultiPartUpload ¶
func (a *Adapter) CompleteMultiPartUpload(ctx context.Context, obj block.ObjectPointer, uploadID string, multipartList *block.MultipartUploadCompletion) (*block.CompleteMultiPartUploadResponse, error)
func (*Adapter) CreateMultiPartUpload ¶
func (a *Adapter) CreateMultiPartUpload(ctx context.Context, obj block.ObjectPointer, _ *http.Request, opts block.CreateMultiPartUploadOpts) (*block.CreateMultiPartUploadResponse, error)
func (*Adapter) Get ¶
func (a *Adapter) Get(ctx context.Context, obj block.ObjectPointer, _ int64) (io.ReadCloser, error)
func (*Adapter) GetPreSignedURL ¶ added in v0.90.0
func (*Adapter) GetPresignUploadPartURL ¶ added in v1.7.0
func (*Adapter) GetProperties ¶
func (a *Adapter) GetProperties(ctx context.Context, obj block.ObjectPointer) (block.Properties, error)
func (*Adapter) GetRange ¶
func (a *Adapter) GetRange(ctx context.Context, obj block.ObjectPointer, startPosition int64, endPosition int64) (io.ReadCloser, error)
func (*Adapter) GetStorageNamespaceInfo ¶
func (a *Adapter) GetStorageNamespaceInfo() block.StorageNamespaceInfo
func (*Adapter) ListParts ¶ added in v1.19.0
func (a *Adapter) ListParts(ctx context.Context, obj block.ObjectPointer, uploadID string, opts block.ListPartsOpts) (*block.ListPartsResponse, error)
func (*Adapter) ResolveNamespace ¶ added in v0.97.0
func (a *Adapter) ResolveNamespace(storageNamespace, key string, identifierType block.IdentifierType) (block.QualifiedKey, error)
func (*Adapter) RuntimeStats ¶ added in v0.41.1
func (*Adapter) UploadCopyPart ¶
func (a *Adapter) UploadCopyPart(ctx context.Context, sourceObj, destinationObj block.ObjectPointer, uploadID string, partNumber int) (*block.UploadPartResponse, error)
func (*Adapter) UploadCopyPartRange ¶
func (*Adapter) UploadPart ¶
type AdapterOption ¶ added in v0.87.0
type AdapterOption func(a *Adapter)
type CaptureExpiresPresigner ¶ added in v0.110.0
type CaptureExpiresPresigner struct { Presigner s3.HTTPPresignerV4 CredentialsCanExpire bool CredentialsExpireAt time.Time }
func (*CaptureExpiresPresigner) PresignHTTP ¶ added in v0.110.0
type ClientCache ¶ added in v0.48.0
type ClientCache struct {
// contains filtered or unexported fields
}
func NewClientCache ¶ added in v0.48.0
func NewClientCache(awsConfig aws.Config, params params.S3) *ClientCache
func (*ClientCache) DiscoverBucketRegion ¶ added in v0.55.0
func (c *ClientCache) DiscoverBucketRegion(b bool)
func (*ClientCache) GetDefault ¶ added in v0.110.0
func (c *ClientCache) GetDefault() *s3.Client
func (*ClientCache) SetClientFactory ¶ added in v0.55.0
func (c *ClientCache) SetClientFactory(clientFactory clientFactory)
func (*ClientCache) SetS3RegionGetter ¶ added in v0.55.0
func (c *ClientCache) SetS3RegionGetter(s3RegionGetter s3RegionGetter)
func (*ClientCache) SetStatsCollector ¶ added in v0.55.0
func (c *ClientCache) SetStatsCollector(statsCollector stats.Collector)
type Walker ¶ added in v0.97.0
type Walker struct {
// contains filtered or unexported fields
}
func NewS3Walker ¶ added in v0.97.0
func (*Walker) GetSkippedEntries ¶ added in v0.98.0
func (s *Walker) GetSkippedEntries() []block.ObjectStoreEntry
Click to show internal directories.
Click to hide internal directories.