Crate cryo_freeze

Source
Expand description

cryo_freeze extracts EVM data to parquet, csv, or json

Modules§

address_appearances
address appearances
balance_diffs
balance diffs
balance_reads
balance reads
balances
balances
blocks
blocks
chunks
type specifications for cryo_freeze crate type specifications for chunk types
code_diffs
code diffs
code_reads
code reads
codes
codes
collect_by_block
collect by block
collect_by_transaction
collect by transaction
collect_generic
generic collection functions
collection
collection traits
columns
column data specification
contracts
contracts
conversions
conversion operations
dataframes
type specifications for dataframes
datatypes
type specifications for collectable types
decoders
decoders
erc20_balances
erc20 balances
erc20_metadata
erc20 metadata
erc20_supplies
erc20 supplies
erc20_transfers
erc20 transfers
erc721_metadata
erc721 metadata
erc721_transfers
erc721 transfers
errors
error specifications
eth_calls
eth calls
execution
execution environment
files
type specifications for output data formats
four_byte_counts
four byte counts
geth_balance_diffs
geth balance diffs
geth_calls
geth calls
geth_code_diffs
geth code diffs
geth_nonce_diffs
geth nonce diffs
geth_opcodes
geth opcodes
geth_state_diffs
geth state diffs
geth_storage_diffs
geth storage diffs
javascript_traces
javascript traces
log_decoder
log decoder
logs
logs
meta
meta datatypes
native_transfers
native transfers
nonce_diffs
nonce diffs
nonce_reads
nonce reads
nonces
nonces
partitions
partitions
queries
queries
reports
report generation
rpc_params
rpc_params
schemas
type specifications for data schemas
signatures
function and event signatures
slots
slots
sources
type specifications for data sources
storage_diffs
storage diffs
storage_reads
storage reads
summaries
types related to summaries
trace_calls
trace calls
traces
traces
transactions
transactions
vm_traces
vm traces

Macros§

define_datatypes
define datatypes
source_provider
extract the provider from a source and run specified method
store
store values in columns if column present in schema
with_series
convert a Vec to Series and add to Vec
with_series_binary
convert a Vec to Series, as hex if specified, and add to Vec
with_series_option_u256
convert a Vec<Option> to variety of u256 Series representations
with_series_u256
convert a Vec to variety of u256 Series representations

Structs§

AddressAppearances
columns for transactions
BalanceDiffs
columns for transactions
BalanceReads
columns for transactions
Balances
columns for balances
Blocks
columns for transactions
BlocksAndTransactions
BlocksAndTransactions
CallTraceDerivatives
CallTraceDerivatives
ChunkStats
statistics of a Chunk’s contents
CodeDiffs
columns for transactions
CodeReads
columns for transactions
Codes
columns for balances
Contracts
columns for transactions
EVENT_ERC20_TRANSFER
event hash of EVENT_ERC20_TRANSFER
EVENT_ERC721_TRANSFER
event hash of EVENT_ERC721_TRANSFER
Erc20Balances
columns for transactions
Erc20Metadata
columns for transactions
Erc20Supplies
columns for transactions
Erc20Transfers
columns for transactions
Erc721Metadata
columns for transactions
Erc721Transfers
columns for transactions
EthCalls
columns for transactions
ExecutionEnv
configuration of execution environment
ExecutionEnvBuilder
build ExecutionEnv using builder pattern
FUNCTION_ERC20_BALANCE_OF
function signature of FUNCTION_ERC20_BALANCE_OF
FUNCTION_ERC20_DECIMALS
function signature of FUNCTION_ERC20_DECIMALS
FUNCTION_ERC20_NAME
function signature of FUNCTION_ERC20_NAME
FUNCTION_ERC20_SYMBOL
function signature of FUNCTION_ERC20_SYMBOL
FUNCTION_ERC20_TOTAL_SUPPLY
function signature of FUNCTION_ERC20_TOTAL_SUPPLY
Fetcher
Wrapper over Provider<P> that adds concurrency and rate limiting controls
FileOutput
Options for file output
FourByteCounts
columns for transactions
FreezeSummary
summary of a freeze
GethBalanceDiffs
columns for transactions
GethCalls
columns for geth traces
GethCodeDiffs
columns for transactions
GethNonceDiffs
columns for transactions
GethOpcodes
columns for geth traces
GethStateDiffs
state diffs from geth debug traces
GethStorageDiffs
columns for transactions
JavascriptTraces
columns for transactions
LogDecoder
container for log decoding context
Logs
columns for transactions
NativeTransfers
columns for transactions
NonceDiffs
columns for transactions
NonceReads
columns for transactions
Nonces
columns for balances
Params
represents parameters for a single rpc call
Partition
a group of chunks along multiple dimensions
PartitionLabels
labels for Partition
Query
Query
QueryLabels
query labels (non-functional)
Slots
columns for balances
Source
Options for fetching data from node
SourceLabels
source labels (non-functional)
StateDiffs
StateDiffs
StateReads
StateReads
StorageDiffs
columns for transactions
StorageReads
columns for transactions
Table
Schema for a particular table
TraceCalls
columns for transactions
Traces
columns for transactions
Transactions
columns for transactions
VmTraces
columns for transactions

Enums§

Chunk
Chunk of data
ChunkError
Error performing a chunk operation
CollectError
Error related to data collection
ColumnEncoding
Encoding for binary data in a column
ColumnType
datatype of column
Datatype
Datatypes
Dim
a dimension of chunking
FileError
Error related to file operations
FileFormat
File format
FreezeError
Error related to running freeze function
MetaDatatype
datatype representing either a Datatype or MultiDatatype
MultiDatatype
enum of possible sets of datatypes that cryo can collect used when multiple datatypes are collected together
ParseError
Error related to parsing
SubDir
Possible item to use as subdirectory
TimeDimension
Time dimension for queries
U256Type
representation of a U256 datum

Constants§

CRYO_VERSION
cryo version

Traits§

ChunkData
Trait for common chunk methods
CollectByBlock
defines how to collect dataset by block
CollectByTransaction
defines how to collect dataset by block
ColumnData
container for a dataset partition
Dataset
Dataset manages collection and management of a particular datatype
SchemaFunctions
funcitons for Schemas
Subchunk
Aggregation operations related to chunks
ToDataFrames
converts to dataframes
ToU256Series
Converts a Vec of U256-like data into a polars Series
ToVecHex
Encodes data as Vec of hex String
ToVecU8
Converts data to Vec

Functions§

bytes_to_u32
convert Bytes to u32
cluster_datatypes
cluster datatypes into MultiDatatype / ScalarDatatype groups
collect
collect single dataframe
collect_by_block
collect by block
collect_by_transaction
collect by transaction
collect_partition
collect single partition
err
return basic CollectError from str slice
freeze
collect data and output as files
print_all_datasets
print all datasets
print_dataset_info
print info about datasets
read_binary_column
read single binary column of parquet file as Vec

Type Aliases§

AddressChunk
address chunk
BlockChunk
block chunk
CallDataChunk
call data chunk
R
standard CollectError Result
RateLimiter
RateLimiter based on governor crate
Schemas
collection of schemas
SlotChunk
slot chunk
TopicChunk
topic chunk
TransactionAndReceipt
tuple representing transaction and optional receipt
TransactionChunk
transaction chunk