Struct CheckpointReaderConfigExt 

pub struct CheckpointReaderConfigExt { /* private fields */ }

Extends CheckpointReaderConfig with opt-in configuration toggles.

Use this type when you need framework features beyond what the base CheckpointReaderConfig exposes (e.g. server-side transaction filtering for fullnode connections).

Example

use iota_data_ingestion_core::{
    ReaderOptions,
    filters::fullnode::TransactionFilter,
    reader::config::{CheckpointReaderConfig, CheckpointReaderConfigExt, RemoteUrl},
};

let config = CheckpointReaderConfigExt::new(ReaderOptions::default())
    .with_remote_store_url(RemoteUrl::Fullnode("http://127.0.0.1:50051".into()))
    .with_fullnode_transaction_filter(TransactionFilter::new().execution_status(true));

Example with an existing CheckpointReaderConfig

use iota_data_ingestion_core::{
    ReaderOptions,
    filters::fullnode::TransactionFilter,
    reader::config::{CheckpointReaderConfig, CheckpointReaderConfigExt, RemoteUrl},
};

let base_config = CheckpointReaderConfig {
    reader_options: ReaderOptions::default(),
    remote_store_url: Some(RemoteUrl::Fullnode("http://127.0.0.1:50051".into())),
    ..Default::default()
};

let config = CheckpointReaderConfigExt::from(base_config)
    .with_fullnode_transaction_filter(TransactionFilter::new().execution_status(true));

Implementations

impl CheckpointReaderConfigExt

pub fn new(reader_options: ReaderOptions) -> Self

Constructs a new configuration with the given ReaderOptions.

pub fn with_ingestion_path(self, path: impl Into<PathBuf>) -> Self

Sets the local path where checkpoints will be ingested from.

If not provided, checkpoints will be ingested from a temporary directory.

pub fn with_remote_store_url(self, url: RemoteUrl) -> Self

Sets the remote source from which checkpoints are downloaded.

pub fn with_fullnode_transaction_filter(self, filter: TransactionFilter) -> Self

Enables server-side filtering of transactions within each checkpoint.

When set, the remote source will only return checkpoints containing transactions that match the provided TransactionFilter.

Errors

Using this filter with any source other than RemoteUrl::Fullnode will cause the executor to return an error when started.

Trait Implementations

impl Clone for CheckpointReaderConfigExt

fn clone(&self) -> CheckpointReaderConfigExt

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for CheckpointReaderConfigExt

fn default() -> CheckpointReaderConfigExt

Returns the “default value” for a type.

impl From<CheckpointReaderConfig> for CheckpointReaderConfigExt

fn from(config: CheckpointReaderConfig) -> Self

Converts to this type from the input type.