cache

Jul 17, 2026

Changes in this version

+ func NewStorageCache(storage blob.ObjectStorage, minRemaining time.Duration) blob.ObjectStorage

type Cache

+ func (c *Cache) AttachRenditions(ctx context.Context, id *blobpb.BlobId, refs []blob.RenditionRef) error

+ func (c *Cache) ClaimForFinalization(ctx context.Context, id *blobpb.BlobId, asOf, until time.Time) (bool, error)

+ func (c *Cache) DelayFinalization(ctx context.Context, id *blobpb.BlobId, nextAttemptAt time.Time) error

+ func (c *Cache) GetDueForFinalization(ctx context.Context, kind blob.ContentKind, asOf time.Time, limit int) ([]*blob.FinalizationTask, error)

+ func (c *Cache) GetFinalizationQueueStats(ctx context.Context, kind blob.ContentKind) (*blob.FinalizationQueueStats, error)

+ func (c *Cache) MarkForFinalization(ctx context.Context, id *blobpb.BlobId, kind blob.ContentKind, ...) error

+ type StorageCache struct

+ func (c *StorageCache) CopyToOrigin(ctx context.Context, key string) error

+ func (c *StorageCache) DeleteUpload(ctx context.Context, key string) error

+ func (c *StorageCache) GetUploaded(ctx context.Context, key string) ([]byte, error)

+ func (c *StorageCache) PresignUpload(ctx context.Context, key, mimeType string, sizeBytes uint64) (*blobpb.UploadTarget, error)

+ func (c *StorageCache) PutOrigin(ctx context.Context, key, mimeType string, data []byte) error

+ func (c *StorageCache) SignDownloadURL(ctx context.Context, key string) (*blobpb.DownloadUrl, error)

+ func (c *StorageCache) UploadExists(ctx context.Context, key string) (bool, error)

Jul 6, 2026

Changes in this version

+ func NewInCache(db blob.Store) blob.Store

+ type Cache struct

+ func (c *Cache) Advance(ctx context.Context, id *blobpb.BlobId, to blob.State, ...) (bool, error)

+ func (c *Cache) CreatePending(ctx context.Context, b *blob.Blob) error

+ func (c *Cache) GetByID(ctx context.Context, id *blobpb.BlobId) (*blob.Blob, error)

+ func (c *Cache) GetByIDs(ctx context.Context, ids []*blobpb.BlobId) ([]*blob.Blob, error)

+ func (c *Cache) GetRenditions(ctx context.Context, parentID *blobpb.BlobId) ([]*blob.Blob, error)

+ func (c *Cache) Reject(ctx context.Context, id *blobpb.BlobId, rejection *blob.RejectionMetadata) (bool, error)