operation

package
v0.37.10-fix-root-bloc... Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 17, 2024 License: AGPL-3.0 Imports: 8 Imported by: 0

Documentation

Index

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 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 added in v0.37.1

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

RetrieveProcessedIndex returns the processed index for a job consumer

func SetProcessedIndex added in v0.37.1

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

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

Types

This section is empty.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL