pub struct ArrowResponse {
pub blocks: RecordBatch,
pub transactions: RecordBatch,
pub logs: RecordBatch,
pub traces: RecordBatch,
}Expand description
A response containing Arrow RecordBatches for each EVM table.
Each batch uses the canonical tiders-evm-schema schemas so the data
can be passed directly into the tiders-core pipeline.
Fields§
§blocks: RecordBatchBlock header rows.
transactions: RecordBatchTransaction rows (may include receipt data if requested).
logs: RecordBatchEvent log rows.
traces: RecordBatchExecution trace rows.
Implementations§
Source§impl ArrowResponse
impl ArrowResponse
Sourcepub fn next_block(&self) -> Result<Option<u64>>
pub fn next_block(&self) -> Result<Option<u64>>
Returns the next block number that should be requested, derived from the maximum block number present across all tables in this response.
Returns None if every table is empty (zero rows).
Sourcepub fn with_logs(logs: RecordBatch) -> Self
pub fn with_logs(logs: RecordBatch) -> Self
Build a response with only the logs RecordBatch populated.
Other tables are empty with correct schemas.
Sourcepub fn with_blocks(blocks: RecordBatch, transactions: RecordBatch) -> Self
pub fn with_blocks(blocks: RecordBatch, transactions: RecordBatch) -> Self
Build a response with blocks and transactions populated.
Other tables (logs, traces) are empty with correct schemas.
Sourcepub fn with_traces(traces: RecordBatch) -> Self
pub fn with_traces(traces: RecordBatch) -> Self
Build a response with only the traces RecordBatch populated.
Other tables are empty with correct schemas.
Trait Implementations§
Source§impl Clone for ArrowResponse
impl Clone for ArrowResponse
Source§fn clone(&self) -> ArrowResponse
fn clone(&self) -> ArrowResponse
1.0.0 · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
source. Read moreAuto Trait Implementations§
impl Freeze for ArrowResponse
impl !RefUnwindSafe for ArrowResponse
impl Send for ArrowResponse
impl Sync for ArrowResponse
impl Unpin for ArrowResponse
impl !UnwindSafe for ArrowResponse
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
§impl<T> Instrument for T
impl<T> Instrument for T
§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read more