s3storage

Nov 6, 2024

Changes in this version

type Client

+ func (cl *Client) GetUsedSize() (uint64, error)

type Options

+ DisableUsage bool

type S3Connection

+ GetUsedSize func() (uint64, error)

type S3Storage

+ func (s3 *S3Storage) StatFs() (*common.Statfs_t, bool, error)

Dec 20, 2023

Changes in this version

+ var UserAgent = func() string

Oct 19, 2023

Changes in this version

+ const DefaultConcurrency

+ const DefaultPartSize

+ const DefaultUploadCutoff

+ const MaxPartSizeMb

+ var ContentTypes = map[string]string

+ func News3storageComponent() internal.Component

+ func ParseAndReadDynamicConfig(s3 *S3Storage, opt Options, reload bool) error

+ func ParseAndValidateConfig(s3 *S3Storage, opt Options) error

+ type Client struct

+ func (cl *Client) Configure(cfg Config) error

+ func (cl *Client) CreateDirectory(name string) error

+ func (cl *Client) CreateFile(name string, mode os.FileMode) error

+ func (cl *Client) CreateLink(source string, target string, isSymlink bool) error

+ func (cl *Client) DeleteDirectory(name string) error

+ func (cl *Client) DeleteFile(name string) error

+ func (cl *Client) GetAttr(name string) (*internal.ObjAttr, error)

+ func (cl *Client) GetFileBlockOffsets(name string) (*common.BlockOffsetList, error)

+ func (cl *Client) List(prefix string, marker *string, count int32) ([]*internal.ObjAttr, *string, error)

+ func (cl *Client) ListBuckets() ([]string, error)

+ func (cl *Client) NewCredentialKey(key, value string) error

+ func (cl *Client) ReadBuffer(name string, offset int64, length int64, isSymlink bool) ([]byte, error)

+ func (cl *Client) ReadInBuffer(name string, offset int64, length int64, data []byte) error

+ func (cl *Client) ReadToFile(name string, offset int64, count int64, fi *os.File) error

+ func (cl *Client) RenameDirectory(source string, target string) error

+ func (cl *Client) RenameFile(source string, target string, isSymLink bool) error

+ func (cl *Client) SetPrefixPath(path string) error

+ func (cl *Client) StageAndCommit(name string, bol *common.BlockOffsetList) error

+ func (cl *Client) TruncateFile(name string, size int64) error

+ func (cl *Client) UpdateConfig(cfg Config) error

+ func (cl *Client) Write(options internal.WriteFileOptions) error

+ func (cl *Client) WriteFromBuffer(name string, metadata map[string]string, data []byte) error

+ func (cl *Client) WriteFromFile(name string, metadata map[string]string, fi *os.File) error

+ type Config struct

+ type Connection struct

+ Config Config

+ Endpoint *url.URL

+ type Options struct

+ BucketName string

+ ChecksumAlgorithm types.ChecksumAlgorithm

+ Concurrency int

+ DisableConcurrentDownload bool

+ EnableChecksum bool

+ Endpoint string

+ KeyID string

+ PartSizeMb int64

+ PrefixPath string

+ Profile string

+ Region string

+ RestrictedCharsWin bool

+ SecretKey string

+ UploadCutoffMb int64

+ UsePathStyle bool

+ type S3Connection interface

+ Configure func(cfg Config) error

+ CreateDirectory func(name string) error

+ CreateFile func(name string, mode os.FileMode) error

+ CreateLink func(source string, target string, isSymlink bool) error

+ DeleteDirectory func(name string) error

+ DeleteFile func(name string) error

+ GetAttr func(name string) (attr *internal.ObjAttr, err error)

+ GetFileBlockOffsets func(name string) (*common.BlockOffsetList, error)

+ List func(prefix string, marker *string, count int32) ([]*internal.ObjAttr, *string, error)

+ ListBuckets func() ([]string, error)

+ NewCredentialKey func(_, _ string) error

+ ReadBuffer func(name string, offset int64, length int64, isSymlink bool) ([]byte, error)

+ ReadInBuffer func(name string, offset int64, length int64, data []byte) error

+ ReadToFile func(name string, offset int64, count int64, fi *os.File) error

+ RenameDirectory func(string, string) error

+ RenameFile func(string, string, bool) error

+ SetPrefixPath func(string) error

+ StageAndCommit func(name string, bol *common.BlockOffsetList) error

+ TruncateFile func(string, int64) error

+ UpdateConfig func(cfg Config) error

+ Write func(options internal.WriteFileOptions) error

+ WriteFromBuffer func(name string, metadata map[string]string, data []byte) error

+ WriteFromFile func(name string, metadata map[string]string, fi *os.File) error

+ func NewConnection(cfg Config) (S3Connection, error)

+ type S3Storage struct

+ func (s3 *S3Storage) Chmod(options internal.ChmodOptions) error

+ func (s3 *S3Storage) Chown(options internal.ChownOptions) error

+ func (s3 *S3Storage) CloseFile(options internal.CloseFileOptions) error

+ func (s3 *S3Storage) Configure(isParent bool) error

+ func (s3 *S3Storage) CopyFromFile(options internal.CopyFromFileOptions) error

+ func (s3 *S3Storage) CopyToFile(options internal.CopyToFileOptions) error

+ func (s3 *S3Storage) CreateDir(options internal.CreateDirOptions) error

+ func (s3 *S3Storage) CreateFile(options internal.CreateFileOptions) (*handlemap.Handle, error)

+ func (s3 *S3Storage) CreateLink(options internal.CreateLinkOptions) error

+ func (s3 *S3Storage) DeleteDir(options internal.DeleteDirOptions) error

+ func (s3 *S3Storage) DeleteFile(options internal.DeleteFileOptions) error

+ func (s3 *S3Storage) FlushFile(options internal.FlushFileOptions) error

+ func (s3 *S3Storage) GetAttr(options internal.GetAttrOptions) (*internal.ObjAttr, error)

+ func (s3 *S3Storage) GetFileBlockOffsets(options internal.GetFileBlockOffsetsOptions) (*common.BlockOffsetList, error)

+ func (s3 *S3Storage) IsDirEmpty(options internal.IsDirEmptyOptions) bool

+ func (s3 *S3Storage) ListBuckets() ([]string, error)

+ func (s3 *S3Storage) Name() string

+ func (s3 *S3Storage) OnConfigChange()

+ func (s3 *S3Storage) OpenFile(options internal.OpenFileOptions) (*handlemap.Handle, error)

+ func (s3 *S3Storage) Priority() internal.ComponentPriority

+ func (s3 *S3Storage) ReadDir(options internal.ReadDirOptions) ([]*internal.ObjAttr, error)

+ func (s3 *S3Storage) ReadFile(options internal.ReadFileOptions) ([]byte, error)

+ func (s3 *S3Storage) ReadInBuffer(options internal.ReadInBufferOptions) (int, error)

+ func (s3 *S3Storage) ReadLink(options internal.ReadLinkOptions) (string, error)

+ func (s3 *S3Storage) RenameDir(options internal.RenameDirOptions) error

+ func (s3 *S3Storage) RenameFile(options internal.RenameFileOptions) error

+ func (s3 *S3Storage) SetName(name string)

+ func (s3 *S3Storage) SetNextComponent(c internal.Component)

+ func (s3 *S3Storage) Start(ctx context.Context) error

+ func (s3 *S3Storage) Stop() error

+ func (s3 *S3Storage) StreamDir(options internal.StreamDirOptions) ([]*internal.ObjAttr, string, error)

+ func (s3 *S3Storage) TruncateFile(options internal.TruncateFileOptions) error

+ func (s3 *S3Storage) WriteFile(options internal.WriteFileOptions) (int, error)