List of all items
Structs
- app::App
- app::AppState
- app::ProcessorRegistry
- app::ServiceBuilder
- app::ServiceContext
- app::ServiceHandle
- app::StateProvider
- backfill::onchain_events::EventTypeResult
- backfill::onchain_events::OnChainEventBackfiller
- backfill::onchain_events::OnchainEventBackfillResult
- backfill::reconciler::MessageReconciler
- backfill::reconciler::ReconcileStats
- backfill::worker::BackfillJob
- backfill::worker::BackfillQueue
- backfill::worker::QueueMetrics
- backfill::worker::Worker
- config::BackfillConfig
- config::Config
- config::DatabaseConfig
- config::HubConfig
- config::LoggingConfig
- config::McpConfig
- config::RedisConfig
- config::StatsdConfig
- core::data_context::DataContext
- core::data_context::DataContextBuilder
- core::normalize::CastIdData
- core::normalize::HashData
- core::normalize::NormalizedEmbed
- core::types::Fid
- core::types::Message
- core::types::MessageId
- core::util::HubError
- database::batch::BatchInserter
- database::batch::CastInsert
- database::batch::LinkInsert
- database::batch::ReactionInsert
- database::batch::UserDataInsert
- database::batch::UsernameProofInsert
- database::batch::VerificationInsert
- database::client::Database
- database::client::DatabaseConnectionInfo
- database::models::AutoFollow
- database::models::AutoFollowRow
- database::models::IdRegisterEvent
- database::models::Message
- database::models::MessageRow
- database::models::NerfedUser
- database::models::SignerEvent
- database::models::SignerMigratedEvent
- database::models::SpammyUser
- database::models::StorageRentEvent
- database::models::TierPurchase
- database::providers::PostgresDatabaseClient
- error::WaypointError
- eth::AlchemyProvider
- eth::EthConfig
- eth::MnemonicWallet
- eth::SecureMnemonic
- eth::types::Address
- eth::types::TransactionReceipt
- health::HealthServer
- hub::circuit_breaker::CircuitBreaker
- hub::circuit_breaker::CircuitBreakerConfig
- hub::client::Hub
- hub::filter::SpamFilter
- hub::providers::FarcasterHubClient
- hub::stats::ProcessingStats
- hub::stream::EventStream
- hub::subscriber::HubSubscriber
- hub::subscriber::SubscriberOptions
- metrics::MetricsTimer
- metrics::StatsdClientWrapper
- processor::consumer::Consumer
- processor::database::DatabaseProcessor
- processor::print::PrintProcessor
- processor::types::AppResources
- proto::Block
- proto::BlockConfirmedBody
- proto::BlockEvent
- proto::BlockEventData
- proto::BlockHeader
- proto::BlocksRequest
- proto::BulkMessageResponse
- proto::CastAddBody
- proto::CastId
- proto::CastRemoveBody
- proto::CastsByParentRequest
- proto::CommitSignature
- proto::Commits
- proto::ConsensusMessage
- proto::ContactInfo
- proto::ContactInfoBody
- proto::DbMerkleTrieMetadata
- proto::DbStats
- proto::DbTrieNode
- proto::DecidedValue
- proto::Embed
- proto::Empty
- proto::EventRequest
- proto::EventsRequest
- proto::EventsResponse
- proto::FidAddressTypeRequest
- proto::FidAddressTypeResponse
- proto::FidRequest
- proto::FidTimestampRequest
- proto::FidsRequest
- proto::FidsResponse
- proto::FnameState
- proto::FnameTransfer
- proto::FrameActionBody
- proto::FullProposal
- proto::GetConnectedPeersRequest
- proto::GetConnectedPeersResponse
- proto::GetInfoRequest
- proto::GetInfoResponse
- proto::GossipMessage
- proto::HeartbeatEventBody
- proto::Height
- proto::HubEvent
- proto::IdRegisterEventBody
- proto::IdRegistryEventByAddressRequest
- proto::LendStorageBody
- proto::LinkBody
- proto::LinkCompactStateBody
- proto::LinkRequest
- proto::LinksByFidRequest
- proto::LinksByTargetRequest
- proto::MempoolMessage
- proto::MergeFailureBody
- proto::MergeMessageBody
- proto::MergeMessageEventBody
- proto::MergeOnChainEventBody
- proto::MergeUserNameProofBody
- proto::Message
- proto::MessageData
- proto::MessageError
- proto::MessagesResponse
- proto::OnChainEvent
- proto::OnChainEventRequest
- proto::OnChainEventResponse
- proto::OnChainEventState
- proto::Proposal
- proto::PruneMessageBody
- proto::ReactionBody
- proto::ReactionRequest
- proto::ReactionsByFidRequest
- proto::ReactionsByTargetRequest
- proto::ReadNodeMessage
- proto::RetryBlockNumberRange
- proto::RetryFnameRequest
- proto::RetryOnchainEventsRequest
- proto::RevokeMessageBody
- proto::RunOnchainEventsMigrationRequest
- proto::ShardChunk
- proto::ShardChunkWitness
- proto::ShardChunksRequest
- proto::ShardChunksResponse
- proto::ShardHash
- proto::ShardHeader
- proto::ShardInfo
- proto::ShardWitness
- proto::SignerEventBody
- proto::SignerMigratedEventBody
- proto::SignerRequest
- proto::StatusMessage
- proto::StorageLimit
- proto::StorageLimitsResponse
- proto::StorageRentEventBody
- proto::StorageUnitDetails
- proto::SubmitBulkMessagesRequest
- proto::SubmitBulkMessagesResponse
- proto::SubscribeRequest
- proto::SyncRequest
- proto::SyncResponse
- proto::SyncValueRequest
- proto::SyncValueResponse
- proto::SyncVoteSetRequest
- proto::SyncVoteSetResponse
- proto::TierDetails
- proto::TierPurchaseBody
- proto::Transaction
- proto::TrieNodeMetadataRequest
- proto::TrieNodeMetadataResponse
- proto::UploadSnapshotRequest
- proto::UserDataBody
- proto::UserDataRequest
- proto::UserNameProof
- proto::UsernameProofRequest
- proto::UsernameProofsResponse
- proto::ValidationResponse
- proto::Validator
- proto::ValidatorMessage
- proto::ValidatorSet
- proto::VerificationAddAddressBody
- proto::VerificationRemoveBody
- proto::VerificationRequest
- proto::Vote
- proto::admin_service_client::AdminServiceClient
- proto::hub_service_client::HubServiceClient
- redis::client::Redis
- redis::error::ErrorHelpers
- redis::error::RedisError
- redis::stream::RedisPipeline
- redis::stream::RedisStream
- redis::stream::StreamEntry
- redis::types::ConsumerGroupHealth
- redis::types::ConsumerInfo
- redis::types::PendingItem
- redis::types::StreamMetrics
- services::mcp::McpService
- services::mcp::MooCow
- services::mcp::NullDb
- services::mcp::WaypointMcpService
- services::mcp::WaypointMcpTools
- services::streaming::Consumer
- services::streaming::StreamingOptions
- services::streaming::StreamingService
- types::Message
Enums
- app::AppError
- app::ProcessorError
- app::ServiceError
- backfill::worker::JobPriority
- backfill::worker::JobState
- config::ConfigError
- core::data_context::DataAccessError
- core::normalize::EmbedData
- core::types::MessageType
- database::error::Error
- database::models::CastType
- database::models::HashScheme
- database::models::IdRegisterEventType
- database::models::MessageType
- database::models::OnChainEventType
- database::models::Protocol
- database::models::ReactionType
- database::models::SignatureScheme
- database::models::SignerEventType
- database::models::TierType
- database::models::UserDataType
- error::ErrorContext
- eth::EthError
- eth::NetworkKind
- hub::circuit_breaker::CircuitBreakerError
- hub::circuit_breaker::CircuitState
- hub::client::Error
- hub::error::Error
- processor::error::Error
- proto::BlockEventType
- proto::CastType
- proto::FarcasterNetwork
- proto::HashScheme
- proto::HubEventType
- proto::IdRegisterEventType
- proto::MessageType
- proto::OnChainEventType
- proto::Protocol
- proto::ReactionType
- proto::SignatureScheme
- proto::SignerEventType
- proto::StorageUnitType
- proto::StoreType
- proto::TierType
- proto::UserDataType
- proto::UserNameType
- proto::VoteType
- proto::block_event_data::Body
- proto::bulk_message_response::Response
- proto::cast_add_body::Parent
- proto::casts_by_parent_request::Parent
- proto::consensus_message::ConsensusMessage
- proto::decided_value::Value
- proto::embed::Embed
- proto::full_proposal::ProposedValue
- proto::gossip_message::GossipMessage
- proto::hub_event::Body
- proto::link_body::Target
- proto::link_request::Target
- proto::links_by_target_request::Target
- proto::mempool_message::MempoolMessage
- proto::message_data::Body
- proto::on_chain_event::Body
- proto::reaction_body::Target
- proto::reaction_request::Target
- proto::reactions_by_target_request::Target
- proto::read_node_message::ReadNodeMessage
- proto::retry_fname_request::Kind
- proto::retry_onchain_events_request::Kind
- proto::sync_request::SyncRequest
- proto::sync_response::SyncResponse
- redis::error::Error
- redis::error::RedisErrorKind
- redis::types::DeadLetterPolicy
- services::streaming::ProcessorType
Traits
- app::EventProcessor
- app::Service
- core::data_context::Database
- core::data_context::HubClient
- error::IntoWaypointError
- eth::Wallet
- processor::consumer::EventProcessor
- redis::error::IntoRedisError
Functions
- backfill::bench::benchmark_batch_inserts
- backfill::bench::benchmark_individual_inserts
- backfill::bench::run_benchmark
- core::util::calculate_message_hash
- core::util::from_farcaster_time
- core::util::get_farcaster_time
- core::util::get_time_diff
- core::util::to_farcaster_time
- database::batch::build_insert_sql
- database::batch::convert_timestamp
- error::helpers::attach_context
- error::helpers::error_with_context
- error::install_error_handlers
- hub::add_custom_headers
- metrics::increment_casts_processed
- metrics::increment_database_errors
- metrics::increment_events_filtered
- metrics::increment_events_processed
- metrics::increment_events_received
- metrics::increment_fids_processed
- metrics::increment_follows_processed
- metrics::increment_hub_errors
- metrics::increment_job_errors
- metrics::increment_jobs_processed
- metrics::increment_processing_errors
- metrics::increment_reactions_processed
- metrics::increment_redis_errors
- metrics::increment_user_data_processed
- metrics::init_prometheus
- metrics::init_prometheus_default
- metrics::record_database_query_duration
- metrics::record_event_processing_time
- metrics::set_backfill_fids_per_second
- metrics::set_cpu_usage
- metrics::set_database_connections_active
- metrics::set_jobs_in_queue
- metrics::set_memory_usage
- metrics::setup_metrics
- metrics::time_async
- processor::format::format_eth_address
- processor::format::format_eth_hex
- processor::format::format_message
- types::get_stream_key
Type Aliases
- app::ProcessorResult
- app::Result
- core::data_context::Result
- database::models::Fid
- error::Result
- eth::types::TxHash
- eth::types::U256
- hub::subscriber::PostProcessHandler
- hub::subscriber::PreProcessHandler
- redis::error::Result