store

Feb 7, 2025

Changes in this version

+ type Cache struct

+ func (c *Cache[K, V]) Get(r storage.Reader, key K) (V, error)

+ func (c *Cache[K, V]) Insert(key K, resource V)

+ func (c *Cache[K, V]) IsCached(key K) bool

+ func (c *Cache[K, V]) PutTx(rw storage.ReaderBatchWriter, key K, resource V) error

+ func (c *Cache[K, V]) Remove(key K)

+ type ChunkDataPacks struct

+ func NewChunkDataPacks(collector module.CacheMetrics, db storage.DB, collections storage.Collections, ...) *ChunkDataPacks

+ func (ch *ChunkDataPacks) BatchRemove(chunkID flow.Identifier, rw storage.ReaderBatchWriter) error

+ func (ch *ChunkDataPacks) BatchStore(c *flow.ChunkDataPack, rw storage.ReaderBatchWriter) error

+ func (ch *ChunkDataPacks) ByChunkID(chunkID flow.Identifier) (*flow.ChunkDataPack, error)

+ func (ch *ChunkDataPacks) Remove(chunkIDs []flow.Identifier) error

+ func (ch *ChunkDataPacks) Store(cs []*flow.ChunkDataPack) error

+ type ConsumerProgressInitializer struct

+ func NewConsumerProgress(db storage.DB, consumer string) *ConsumerProgressInitializer

+ func (cpi *ConsumerProgressInitializer) Initialize(defaultIndex uint64) (storage.ConsumerProgress, error)

+ type ResultApprovals struct

+ func NewResultApprovals(collector module.CacheMetrics, db storage.DB) *ResultApprovals

+ func (r *ResultApprovals) ByChunk(resultID flow.Identifier, chunkIndex uint64) (*flow.ResultApproval, error)

+ func (r *ResultApprovals) ByID(approvalID flow.Identifier) (*flow.ResultApproval, error)

+ func (r *ResultApprovals) Index(resultID flow.Identifier, chunkIndex uint64, approvalID flow.Identifier) error

+ func (r *ResultApprovals) Store(approval *flow.ResultApproval) error