Documentation
¶
Index ¶
- func New(cfg config.FilesystemConfig) (storage.Service, error)
- type Service
- func (s *Service) AbortMultipart(_ context.Context, opts storage.AbortMultipartOptions) error
- func (s *Service) CompleteMultipart(_ context.Context, opts storage.CompleteMultipartOptions) (*storage.ObjectInfo, error)
- func (s *Service) CopyObject(_ context.Context, opts storage.CopyObjectOptions) (*storage.ObjectInfo, error)
- func (s *Service) DeleteObject(_ context.Context, opts storage.DeleteObjectOptions) error
- func (s *Service) DeleteObjects(ctx context.Context, opts storage.DeleteObjectsOptions) error
- func (s *Service) GetObject(_ context.Context, opts storage.GetObjectOptions) (io.ReadCloser, error)
- func (s *Service) InitMultipart(_ context.Context, opts storage.InitMultipartOptions) (*storage.MultipartSession, error)
- func (s *Service) ListObjects(_ context.Context, opts storage.ListObjectsOptions) ([]storage.ObjectInfo, error)
- func (*Service) MaxPartCount() int
- func (*Service) PartSize() int64
- func (s *Service) PutObject(_ context.Context, opts storage.PutObjectOptions) (*storage.ObjectInfo, error)
- func (s *Service) PutPart(_ context.Context, opts storage.PutPartOptions) (*storage.PartInfo, error)
- func (s *Service) StatObject(_ context.Context, opts storage.StatObjectOptions) (*storage.ObjectInfo, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func New ¶
func New(cfg config.FilesystemConfig) (storage.Service, error)
New creates a filesystem storage service.
Root MUST point to a shared volume (NFS, CephFS, EFS, k8s ReadWriteMany PVC) when more than one application instance is deployed; otherwise PutPart and CompleteMultipart from different instances will not see each other's parts.
Types ¶
type Service ¶
type Service struct {
// contains filtered or unexported fields
}
func (*Service) AbortMultipart ¶ added in v0.23.0
func (*Service) CompleteMultipart ¶ added in v0.23.0
func (s *Service) CompleteMultipart(_ context.Context, opts storage.CompleteMultipartOptions) (*storage.ObjectInfo, error)
func (*Service) CopyObject ¶
func (s *Service) CopyObject(_ context.Context, opts storage.CopyObjectOptions) (*storage.ObjectInfo, error)
func (*Service) DeleteObject ¶
func (*Service) DeleteObjects ¶
func (*Service) GetObject ¶
func (s *Service) GetObject(_ context.Context, opts storage.GetObjectOptions) (io.ReadCloser, error)
func (*Service) InitMultipart ¶ added in v0.23.0
func (s *Service) InitMultipart(_ context.Context, opts storage.InitMultipartOptions) (*storage.MultipartSession, error)
func (*Service) ListObjects ¶
func (s *Service) ListObjects(_ context.Context, opts storage.ListObjectsOptions) ([]storage.ObjectInfo, error)
func (*Service) MaxPartCount ¶ added in v0.23.0
func (*Service) PutObject ¶
func (s *Service) PutObject(_ context.Context, opts storage.PutObjectOptions) (*storage.ObjectInfo, error)
func (*Service) StatObject ¶
func (s *Service) StatObject(_ context.Context, opts storage.StatObjectOptions) (*storage.ObjectInfo, error)
Source Files
Click to show internal directories.
Click to hide internal directories.