cache

package

v1.20.0 Latest Latest Go to latest Published: Jul 6, 2026 License: MIT Imports: 4 Imported by: 0

Details

This section is empty.

This section is empty.

func NewInCache(db blob.Store) blob.Store

NewInCache returns a blob.Store that caches terminal blob records in front of db. It composes over any backing implementation.

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

Cache wraps a blob.Store, caching only blobs that have reached a terminal state (Ready or Rejected).

func (c *Cache) Advance(ctx context.Context, id *blobpb.BlobId, to blob.State, image *blob.ImageMetadata) (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)