Versions in this module Expand all Collapse all v0 v0.14.0 Oct 31, 2022 Changes in this version + type Config struct + AccessKey string + Bucket string + CredentialsEndpoint string + Region string + RegionEndpoint string + RootDirectory string + SecretKey string + SessionToken string + Workers int + type S3Bucket struct + S3 *s3.S3 + func NewS3Datastore(conf Config) (*S3Bucket, error) + func (s *S3Bucket) Batch(_ context.Context) (ds.Batch, error) + func (s *S3Bucket) Close() error + func (s *S3Bucket) Delete(ctx context.Context, k ds.Key) error + func (s *S3Bucket) Get(ctx context.Context, k ds.Key) ([]byte, error) + func (s *S3Bucket) GetSize(ctx context.Context, k ds.Key) (size int, err error) + func (s *S3Bucket) Has(ctx context.Context, k ds.Key) (exists bool, err error) + func (s *S3Bucket) Put(ctx context.Context, k ds.Key, value []byte) error + func (s *S3Bucket) Query(ctx context.Context, q dsq.Query) (dsq.Results, error) + func (s *S3Bucket) Sync(ctx context.Context, prefix ds.Key) error