Struct RpcIndexInitConfig

pub struct RpcIndexInitConfig {
    pub db_write_buffer_size: Option<usize>,
    pub cf_write_buffer_size: Option<usize>,
    pub cf_max_write_buffer_number: Option<i32>,
    pub max_background_jobs: Option<i32>,
    pub batch_size_limit: Option<usize>,
}

Configuration for RPC index initialization and bulk loading

Fields

db_write_buffer_size: Option<usize>

Override for RocksDB’s set_db_write_buffer_size during bulk indexing. This is the total memory budget for all column families’ memtables.

Defaults to 90% of system RAM if not specified.

cf_write_buffer_size: Option<usize>

Override for each column family’s write buffer size during bulk indexing.

Defaults to 25% of system RAM divided by max_write_buffer_number if not specified.

cf_max_write_buffer_number: Option<i32>

Override for the maximum number of write buffers per column family during bulk indexing. This value is capped at 32 as an upper bound.

Defaults to a dynamic value based on system RAM if not specified.

max_background_jobs: Option<i32>

Override for the number of background jobs during bulk indexing.

Defaults to the number of CPU cores if not specified.

batch_size_limit: Option<usize>

Override for the batch size limit during bulk indexing. This controls how much data is accumulated in memory before flushing to disk.

Defaults to half the write buffer size or 128MB, whichever is smaller.

Trait Implementations

impl Clone for RpcIndexInitConfig

fn clone(&self) -> RpcIndexInitConfig

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for RpcIndexInitConfig

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for RpcIndexInitConfig

fn default() -> RpcIndexInitConfig

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for RpcIndexInitConfig

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for RpcIndexInitConfig

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.