Documentation
¶
Index ¶
- func InsertChunkDataPack(sc *storage.StoredChunkDataPack) func(w pebble.Writer) error
- func InsertProcessedIndex(jobName string, processed uint64) func(pebble.Writer) error
- func RemoveChunkDataPack(chunkID flow.Identifier) func(w pebble.Writer) error
- func RetrieveChunkDataPack(chunkID flow.Identifier, sc *storage.StoredChunkDataPack) func(r pebble.Reader) error
- func RetrieveProcessedIndex(jobName string, processed *uint64) func(pebble.Reader) error
- func SetProcessedIndex(jobName string, processed uint64) func(pebble.Writer) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func InsertChunkDataPack ¶
func InsertChunkDataPack(sc *storage.StoredChunkDataPack) func(w pebble.Writer) error
InsertChunkDataPack inserts a chunk data pack keyed by chunk ID. any error are exceptions
func InsertProcessedIndex ¶ added in v0.37.1
func RemoveChunkDataPack ¶
func RemoveChunkDataPack(chunkID flow.Identifier) func(w pebble.Writer) error
RemoveChunkDataPack removes the chunk data pack with the given chunk ID. any error are exceptions
func RetrieveChunkDataPack ¶
func RetrieveChunkDataPack(chunkID flow.Identifier, sc *storage.StoredChunkDataPack) func(r pebble.Reader) error
RetrieveChunkDataPack retrieves a chunk data pack by chunk ID. it returns storage.ErrNotFound if the chunk data pack is not found
func RetrieveProcessedIndex ¶ added in v0.37.1
RetrieveProcessedIndex returns the processed index for a job consumer
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.