operation

package

v0.38.0-preview.0 Latest Latest Go to latest Published: Sep 18, 2024 License: AGPL-3.0 Imports: 8 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

This section is empty.

This section is empty.

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(jobName string, processed uint64) func(pebble.Writer) error

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(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(jobName string, processed *uint64) func(pebble.Reader) error

RetrieveProcessedIndex returns the processed index for a job consumer

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

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

This section is empty.