s3

package

v0.2.25 Latest Latest Go to latest Published: Jul 6, 2026 License: Apache-2.0 Imports: 30 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

func New(ctx context.Context, tracer trace.Tracer, decryptfn backend.DecryptCredentailFunc, url *url.URL) (*S3Backend, error)

func (self *S3Backend) Close() error

func (self *S3Backend) CreateObject(ctx context.Context, req schema.CreateObjectRequest) (*schema.Object, error)

Create object in the backend

func (self *S3Backend) DeleteObjects(context.Context, schema.DeleteObjectsRequest) error

Delete objects in the backend (single object or prefix)

func (self *S3Backend) GetObject(ctx context.Context, req schema.GetObjectRequest) (_ *schema.Object, err error)

Get object metadata from the backend

func (self *S3Backend) ListObjects(ctx context.Context, iterator *schema.ObjectListIterator) (err error)

Iterate through the list of objects in the backend, until io.EOF is returned.

func (self *S3Backend) Name() string

func (self *S3Backend) ReadObject(ctx context.Context, req schema.GetObjectRequest) (_ io.ReadCloser, _ *schema.Object, err error)

Read object content from the backend. Caller must close the returned reader.

func (self *S3Backend) URL() *url.URL

Path	Synopsis
_aws