Detailed Description

#include <chunk_store_reader.h>

Public Attributes
bool	ordered = true
	Whether to read chunks in the explicit seq order. If `false`, chunks will be read in the order they arrive in the store. This is useful for streaming data where the order of chunks is not important, such as parallel independent processing of chunks.

bool	remove_chunks = true
	Whether to remove chunks from the store after reading them. If `false`, chunks will remain in the store after reading. This is useful if you want to read the same chunks multiple times or if you want to keep the chunks for later processing.

size_t	n_chunks_to_buffer = 32
	The number of chunks to buffer in memory before the background fiber blocks on reading more chunks.

absl::Duration	timeout = absl::InfiniteDuration()
	The timeout for reading chunks from the store, which applies to the Next() method.

Member Data Documentation

◆ n_chunks_to_buffer

size_t act::ChunkStoreReaderOptions::n_chunks_to_buffer = 32

The number of chunks to buffer in memory before the background fiber blocks on reading more chunks.

◆ ordered

bool act::ChunkStoreReaderOptions::ordered = true

Whether to read chunks in the explicit seq order. If false, chunks will be read in the order they arrive in the store. This is useful for streaming data where the order of chunks is not important, such as parallel independent processing of chunks.

◆ remove_chunks

bool act::ChunkStoreReaderOptions::remove_chunks = true

Whether to remove chunks from the store after reading them. If false, chunks will remain in the store after reading. This is useful if you want to read the same chunks multiple times or if you want to keep the chunks for later processing.

◆ timeout

absl::Duration act::ChunkStoreReaderOptions::timeout = absl::InfiniteDuration()

The timeout for reading chunks from the store, which applies to the Next() method.

The documentation for this struct was generated from the following file: