storage

Documentation

Index

• type Storage
  • func NewStorage(log *slog.Logger, cfg config.Config) (*Storage, error)
  • func (s *Storage) DownloadBucket(ctx context.Context, endpoint string, id bucket.ID, ttl time.Duration) error
  • func (s *Storage) DownloadFile(ctx context.Context, endpoint string, bucketID bucket.ID, file string) error
  • func (s *Storage) GetBucket(id bucket.ID, addTTL *time.Duration) (path string, unlock func(), err error)
  • func (s *Storage) GetBucketMeta(id bucket.ID) (meta BucketMeta, err error)
  • func (s *Storage) GetFile(bucketID bucket.ID, file string) (path string, unlock func(), err error)
  • func (s *Storage) RemoveBucket(id bucket.ID) (err error)
  • func (s *Storage) ReserveBucket(id bucket.ID, ttl time.Duration) (path string, commit, abort func() error, err error)
  • func (s *Storage) ReserveFile(bucketID bucket.ID, file string) (path string, commit, abort func() error, err error)
  • func (s *Storage) Shutdown()

Types

type Storage

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

func NewStorage

func NewStorage(log *slog.Logger, cfg config.Config) (*Storage, error)

func (*Storage) DownloadBucket

func (s *Storage) DownloadBucket(
	ctx context.Context,
	endpoint string,
	id bucket.ID,
	ttl time.Duration,
) error

DownloadBucket Скачивает бакет id с указанного endpoint ttl - время жизни бакета Если бакет существует, то его время жизни продлевается на ttl

func (*Storage) DownloadFile

func (s *Storage) DownloadFile(
	ctx context.Context,
	endpoint string,
	bucketID bucket.ID,
	file string,
) error

DownloadFile Скачивает файл file в существующий бакет bucketID с указанного endpoint Если файл уже существует, то ничего не происходит

func (*Storage) GetBucket

func (s *Storage) GetBucket(id bucket.ID, addTTL *time.Duration) (path string, unlock func(), err error)

GetBucket Возвращает абсолютный путь бакета id addTTL - длительность продления жизни бакета (без надобности оставьте nil) Бакет блокируется в режиме на чтение. Для разблокировки необходимо вызвать unlock() НЕ гарантируется консистентность данных при модификации данных

func (*Storage) GetBucketMeta

func (s *Storage) GetBucketMeta(id bucket.ID) (meta BucketMeta, err error)

GetBucketMeta Возвращает метаинформацию о бакете id

func (*Storage) GetFile

func (s *Storage) GetFile(bucketID bucket.ID, file string) (path string, unlock func(), err error)

GetFile Возвращает абсолютный путь бакета bucketID, в котором лежит файл file Бакет и файл блокируются в режиме на чтение. Для разблокировки необходимо вызвать unlock() НЕ гарантируется консистентность данных при модификации данных

func (*Storage) RemoveBucket

func (s *Storage) RemoveBucket(id bucket.ID) (err error)

RemoveBucket Удаляет бакет id

func (*Storage) ReserveBucket

func (s *Storage) ReserveBucket(id bucket.ID, ttl time.Duration) (path string, commit, abort func() error, err error)

ReserveBucket Разервирует бакет id ttl - время жизни бакета Бакет изначально создаётся во временной директории; path - абсолютный путь временной директории Бакет блокируется в режиме на запись. Для разблокировки необходимо вызвать commit() или abort() При вызове функции commit() бакет перемещается в storage При вызове функции abort() бакет удаляется

func (*Storage) ReserveFile

func (s *Storage) ReserveFile(bucketID bucket.ID, file string) (path string, commit, abort func() error, err error)

ReserveFile Резервирует файл file в существующем бакете bucketID Бакет блокируется в режиме на запись. Для разблокировки необходимо вызвать commit() или abort() Файл резервируется во временной директории; path - абсолютный путь до временной директории При вызове функции commit() файл перемещается в storage При вызове функции abort() файл удаляется

func (*Storage) Shutdown

func (s *Storage) Shutdown()