cache

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

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

type CapacityTrigger interface {
	Trigger()
}

type CreateUploadResult struct {
	UploadID int64
}

type DownloadError struct {
	Err               error
	CacheEntryID      string
	StorageLocationID string
	Representation    string
}

type DownloadMetadata struct {
	CacheEntryID      string
	StorageLocationID string
	Representation    string
	ContentLength     int64
}

type DownloadRange struct {
	Offset int64
	Count  int64
}

type DownloadStream struct {
	io.ReadCloser
	CacheEntryID      string
	StorageLocationID string
	Representation    string
	ContentLength     int64
	TotalLength       int64
	Range             *DownloadRange
}

type MatchResult struct {
	CacheEntry  *ent.CacheEntry
	DownloadURL string
}

type Options struct {
	DB                        *ent.Client
	Storage                   storage.Adapter
	EnableDirectDownloads     bool
	MergeConcurrency          int
	Lifecycle                 *storagelifecycle.Service
	Logger                    *zerolog.Logger
	Capacity                  CapacityTrigger
	Now                       func() time.Time
	UploadHeartbeatInterval   time.Duration
	PartIndexDiscoveryTimeout time.Duration
	// PartIndexCacheBytes bounds immutable multipart boundary indexes by
	// charged bytes. Non-positive values use the 64 MiB default.
	PartIndexCacheBytes int64
}

type RangeNotSatisfiableError struct {
	SizeBytes int64
}

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