Helper functions for asset extraction.

Helper functions for balance extraction.

CreateTransactionReader creates a new ingest.LedgerTransactionReader from a processor.Message.

Add this helper function.

ExtractLedgerCloseMeta extracts xdr.LedgerCloseMeta from a processor.Message.

ExtractLedgerTransaction extracts ingest.LedgerTransaction from a processor.Message.

ForwardToProcessors marshals the payload and forwards it to all downstream processors.

Helper function to convert ledger entry to hash.

NewMarketMetricsProcessor creates a new market metrics processor.

Add this function after the existing helper functions.

NewTransformToAppAccount creates a new TransformToAppAccount processor.

NewTransformToTokenPrice creates a new TransformToTokenPrice processor.

AccountData represents key account information we want to track.

AccountTransaction represents a transaction involving a specific account.

AssetEnrichment represents the enriched asset data.

AssetEnrichmentProcessor processes ledger entries to enrich asset data.

Data type definitions.

ContractCreation represents a contract creation event.

ContractEvent represents an event emitted by a contract.

ContractInvocation represents a contract invocation event.

DiagnosticData captures additional event diagnostic information.

Enhanced LatestLedger struct with transaction metrics.

LedgerChange represents a change in the ledger.

MarketAnalytics represents aggregated market data for a trading pair.

MarketCapAnalytics represents market cap and supply data for an asset.

MarketMetrics represents market analysis data for a trading pair.

MarketMetricsProcessor processes ledger data into market metrics.

Message encapsulates the payload to be processed.

TickerAsset represents the final ticker asset data structure Amount represents the operation amount in stroops (1 XLM = 10^7 stroops) - For payments: the payment amount - For claimable balances: the balance amount - For trustline operations: not used.

TickerOrderbook represents the orderbook data for a market.

TradeWindowEntry is used to store individual trade contributions within a sliding window.

TransformToAppAccount represents a processor that transforms account data.

TransformToTickerAssetProcessor transforms xdr.LedgerCloseMeta data into TickerAsset format.

Processor defines the interface for processing messages.

AnalyticsPeriod represents different time periods for analytics.

Add these type definitions after the existing var block.