operation

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

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

func InsertProcessedIndex(jobName string, processed uint64) func(pebble.Writer) error

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

func RetrieveProcessedIndex(jobName string, processed *uint64) func(pebble.Reader) error

RetrieveProcessedIndex returns the processed index for a job consumer

func SetProcessedIndex

func SetProcessedIndex(jobName string, processed uint64) func(pebble.Writer) error

SetProcessedIndex updates the processed index for a job consumer with given index