s3

package

v0.9.310 Latest Latest Go to latest Published: Oct 9, 2026 License: AGPL-3.0 Imports: 20 Imported by: 0

Details

View Source

const (
	CredentialsModeStatic         = "static"
	CredentialsModeEKSPodIdentity = "eksPodIdentity"
	CredentialsModeAmbient        = "ambient"
)

View Source

const MULTIPART_SIZE = 5 * utils.MEBIBYTE

View Source

const PATH_PREFIX = "s3://"

This section is empty.

func CheckConfig() types.Check

func LoadAWSConfig(ctx context.Context, settings cedanaconfig.AWS) (cfg aws.Config, err error)

LoadAWSConfig validates the selected authentication mode and creates the AWS configuration shared by S3 storage and its health check.

func NewStorage(ctx context.Context) (cedana_io.Storage, error)

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

func NewFile(ctx context.Context, client *s3.Client, bucket, key string) *File

func (c *File) Close() error

func (c *File) Read(p []byte) (int, error)

func (c *File) Write(p []byte) (int, error)

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

S3 storage

func (s *Storage) Create(ctx context.Context, path string) (io.WriteCloser, error)

func (s *Storage) CreatePath(ctx context.Context, dir, name string) (path string, cleanup func(cancel bool) error, err error)

func (s *Storage) Delete(_ context.Context, path string) error

func (s *Storage) IsDir(_ context.Context, path string) (bool, error)

func (s *Storage) IsRemote() bool

func (s *Storage) Open(ctx context.Context, path string) (io.ReadCloser, error)

func (s *Storage) ReadDir(ctx context.Context, path string) ([]string, error)

func (s *Storage) ReadPath(ctx context.Context, path string) (string, func() error, error)