NewAnthropicClaudeConsumer creates a new instance using the provided configuration.

AnthropicClaudeConsumer batches messages and sends them to the Anthropic/Claude API.

Asset represents a Stellar asset.

ClientFilters contains filter criteria for events.

FormattedEvent represents a processed Soroban event.

MarketAnalytics represents aggregated market data for a trading pair.

NotificationRule defines when to send notifications.

RegistrationMessage represents the initial registration message.

SaveAssetEnrichmentConsumer saves enriched asset data to PostgreSQL.

TickerOrderbook represents the orderbook data for a market.

Processor defines the interface for processing messages.

AnalyticsPeriod represents different time periods for analytics.