storage

package

v0.37.0 Latest Latest Go to latest Published: Dec 19, 2025 License: MIT Imports: 28 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/aldor007/mort

Links

Open Source Insights

Documentation ¶

Index ¶

func CreatePreSign(obj *object.FileObject) *response.Response
func Delete(obj *object.FileObject) *response.Response
func Get(obj *object.FileObject) *response.Response
func Head(obj *object.FileObject) *response.Response
func List(obj *object.FileObject, maxKeys int, _ string, prefix string, marker string) *response.Response
func Set(obj *object.FileObject, metaHeaders http.Header, contentLen int64, ...) *response.Response
type RestoreCache
- func GetRestoreCache(cacheCfg config.CacheCfg) *RestoreCache
- func NewRestoreCache(cacheCfg config.CacheCfg) *RestoreCache
- func (r *RestoreCache) GetRestoreStatus(ctx context.Context, key string) (*RestoreStatus, error)
- func (r *RestoreCache) MarkRestoreRequested(ctx context.Context, key string, expiresIn time.Duration) error
type RestoreStatus

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func CreatePreSign ¶ added in v0.22.0

func CreatePreSign(obj *object.FileObject) *response.Response

func Delete ¶ added in v0.4.1

func Delete(obj *object.FileObject) *response.Response

Delete remove object from given storage

func Get ¶

func Get(obj *object.FileObject) *response.Response

Get retrieve obj from given storage and returns its wrapped in response

func Head ¶

func Head(obj *object.FileObject) *response.Response

Head retrieve obj from given storage and returns its wrapped in response (but only headers, content of object is omitted)

func List ¶

func List(obj *object.FileObject, maxKeys int, _ string, prefix string, marker string) *response.Response

List returns list of object in given path in S3 format nolint: gocyclo

func Set ¶

func Set(obj *object.FileObject, metaHeaders http.Header, contentLen int64, body io.Reader) *response.Response

Set create object on storage wit given body and headers

Types ¶

type RestoreCache ¶ added in v0.36.0

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

RestoreCache handles GLACIER restore status tracking using generic cache

func GetRestoreCache ¶ added in v0.36.0

func GetRestoreCache(cacheCfg config.CacheCfg) *RestoreCache

GetRestoreCache returns the singleton restore cache instance

func NewRestoreCache ¶ added in v0.36.0

func NewRestoreCache(cacheCfg config.CacheCfg) *RestoreCache

NewRestoreCache creates a RestoreCache using the generic cache

func (*RestoreCache) GetRestoreStatus ¶ added in v0.36.0

func (r *RestoreCache) GetRestoreStatus(ctx context.Context, key string) (*RestoreStatus, error)

GetRestoreStatus checks if restore was already requested

func (*RestoreCache) MarkRestoreRequested ¶ added in v0.36.0

func (r *RestoreCache) MarkRestoreRequested(ctx context.Context, key string, expiresIn time.Duration) error

MarkRestoreRequested records that a restore was initiated

type RestoreStatus ¶ added in v0.36.0

type RestoreStatus struct {
	Key         string    `msgpack:"key"`
	RequestedAt time.Time `msgpack:"requestedAt"`
	ExpiresAt   time.Time `msgpack:"expiresAt"`
	InProgress  bool      `msgpack:"inProgress"`
}

RestoreStatus represents the state of a GLACIER restore operation All fields are exported for msgpack serialization

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL