Enum Event 

pub enum Event {
    Trade {
        exchange: ExchangeId,
        symbol: String,
        point: TradePoint,
    },
    AggTrade {
        exchange: ExchangeId,
        symbol: String,
        point: AggTradePoint,
    },
    Bar {
        exchange: ExchangeId,
        symbol: String,
        timeframe: KlineInterval,
        point: BarPoint,
    },
    Ticker {
        exchange: ExchangeId,
        symbol: String,
        point: TickerPoint,
    },
    OrderbookSnapshot {
        exchange: ExchangeId,
        symbol: String,
        point: ObSnapshotPoint,
    },
    OrderbookDelta {
        exchange: ExchangeId,
        symbol: String,
        point: ObDeltaPoint,
    },
    MarkPrice {
        exchange: ExchangeId,
        symbol: String,
        point: MarkPricePoint,
    },
    FundingRate {
        exchange: ExchangeId,
        symbol: String,
        point: FundingRatePoint,
    },
    OpenInterest {
        exchange: ExchangeId,
        symbol: String,
        point: OpenInterestPoint,
    },
    Liquidation {
        exchange: ExchangeId,
        symbol: String,
        point: LiquidationPoint,
    },
    BlockTrade {
        exchange: ExchangeId,
        symbol: String,
        point: BlockTradePoint,
    },
    AuctionEvent {
        exchange: ExchangeId,
        symbol: String,
        point: AuctionEventPoint,
    },
    IndexPrice {
        exchange: ExchangeId,
        symbol: String,
        point: IndexPricePoint,
    },
    CompositeIndex {
        exchange: ExchangeId,
        symbol: String,
        point: CompositeIndexPoint,
    },
    OptionGreeks {
        exchange: ExchangeId,
        symbol: String,
        point: OptionGreeksPoint,
    },
    VolatilityIndex {
        exchange: ExchangeId,
        symbol: String,
        point: VolatilityIndexPoint,
    },
    HistoricalVolatility {
        exchange: ExchangeId,
        symbol: String,
        point: HistoricalVolatilityPoint,
    },
    LongShortRatio {
        exchange: ExchangeId,
        symbol: String,
        point: LongShortRatioPoint,
    },
    TakerVolume {
        exchange: ExchangeId,
        symbol: String,
        point: TakerVolumePoint,
    },
    LiquidationBucket {
        exchange: ExchangeId,
        symbol: String,
        point: LiquidationBucketPoint,
    },
    Basis {
        exchange: ExchangeId,
        symbol: String,
        point: BasisPoint,
    },
    InsuranceFund {
        exchange: ExchangeId,
        symbol: String,
        point: InsuranceFundPoint,
    },
    OrderbookL3 {
        exchange: ExchangeId,
        symbol: String,
        point: OrderbookL3Point,
    },
    SettlementEvent {
        exchange: ExchangeId,
        symbol: String,
        point: SettlementEventPoint,
    },
    MarketWarning {
        exchange: ExchangeId,
        symbol: String,
        point: MarketWarningPoint,
    },
    RiskLimit {
        exchange: ExchangeId,
        symbol: String,
        point: RiskLimitPoint,
    },
    PredictedFunding {
        exchange: ExchangeId,
        symbol: String,
        point: PredictedFundingPoint,
    },
    FundingSettlement {
        exchange: ExchangeId,
        symbol: String,
        point: FundingSettlementPoint,
    },
    MarkPriceKline {
        exchange: ExchangeId,
        symbol: String,
        timeframe: KlineInterval,
        point: MarkPriceKlinePoint,
    },
    IndexPriceKline {
        exchange: ExchangeId,
        symbol: String,
        timeframe: KlineInterval,
        point: IndexPriceKlinePoint,
    },
    PremiumIndexKline {
        exchange: ExchangeId,
        symbol: String,
        timeframe: KlineInterval,
        point: PremiumIndexKlinePoint,
    },
    Footprint {
        exchange: ExchangeId,
        symbol: String,
        point: FootprintPoint,
    },
    RenkoBar {
        exchange: ExchangeId,
        symbol: String,
        point: RenkoBrickPoint,
    },
    PnfBar {
        exchange: ExchangeId,
        symbol: String,
        point: PnfColumnPoint,
    },
    KagiBar {
        exchange: ExchangeId,
        symbol: String,
        point: KagiSegmentPoint,
    },
    CvdLine {
        exchange: ExchangeId,
        symbol: String,
        point: ScalarBarPoint,
    },
    ThreeLineBreakUpdate {
        exchange: ExchangeId,
        symbol: String,
        point: ThreeLineBreakLinePoint,
    },
    TpoProfile {
        exchange: ExchangeId,
        symbol: String,
        point: TpoSessionPoint,
    },
    ConnectorReady {
        exchange: ExchangeId,
    },
    SymbolsLoaded {
        exchange: ExchangeId,
        account_type: AccountType,
        symbols: Vec<SymbolInfo>,
    },
    OrderUpdate {
        exchange: ExchangeId,
        account_type: AccountType,
        symbol: String,
        point: OrderUpdatePoint,
    },
    BalanceUpdate {
        exchange: ExchangeId,
        account_type: AccountType,
        symbol: String,
        point: BalanceUpdatePoint,
    },
    PositionUpdate {
        exchange: ExchangeId,
        account_type: AccountType,
        symbol: String,
        point: PositionUpdatePoint,
    },
}

Events forwarded to consumers. One variant per market-data class.

Variants

Trade

Fields

exchange: ExchangeId

symbol: String

point: TradePoint

AggTrade

Fields

exchange: ExchangeId

symbol: String

point: AggTradePoint

Bar

Fields

exchange: ExchangeId

symbol: String

timeframe: KlineInterval

point: BarPoint

Ticker

Fields

exchange: ExchangeId

symbol: String

point: TickerPoint

OrderbookSnapshot

Fields

exchange: ExchangeId

symbol: String

point: ObSnapshotPoint

OrderbookDelta

Fields

exchange: ExchangeId

symbol: String

point: ObDeltaPoint

MarkPrice

Fields

exchange: ExchangeId

symbol: String

point: MarkPricePoint

FundingRate

Fields

exchange: ExchangeId

symbol: String

point: FundingRatePoint

OpenInterest

Fields

exchange: ExchangeId

symbol: String

point: OpenInterestPoint

Liquidation

Fields

exchange: ExchangeId

symbol: String

point: LiquidationPoint

BlockTrade

Fields

exchange: ExchangeId

symbol: String

point: BlockTradePoint

AuctionEvent

Fields

exchange: ExchangeId

symbol: String

point: AuctionEventPoint

IndexPrice

Fields

exchange: ExchangeId

symbol: String

point: IndexPricePoint

CompositeIndex

Fields

exchange: ExchangeId

symbol: String

point: CompositeIndexPoint

OptionGreeks

Fields

exchange: ExchangeId

symbol: String

point: OptionGreeksPoint

VolatilityIndex

Fields

exchange: ExchangeId

symbol: String

point: VolatilityIndexPoint

HistoricalVolatility

Fields

exchange: ExchangeId

symbol: String

point: HistoricalVolatilityPoint

LongShortRatio

Fields

exchange: ExchangeId

symbol: String

point: LongShortRatioPoint

TakerVolume

Fields

exchange: ExchangeId

symbol: String

point: TakerVolumePoint

LiquidationBucket

Fields

exchange: ExchangeId

symbol: String

point: LiquidationBucketPoint

Basis

Fields

exchange: ExchangeId

symbol: String

point: BasisPoint

InsuranceFund

Fields

exchange: ExchangeId

symbol: String

point: InsuranceFundPoint

OrderbookL3

Fields

exchange: ExchangeId

symbol: String

point: OrderbookL3Point

SettlementEvent

Fields

exchange: ExchangeId

symbol: String

point: SettlementEventPoint

MarketWarning

Fields

exchange: ExchangeId

symbol: String

point: MarketWarningPoint

RiskLimit

Fields

exchange: ExchangeId

symbol: String

point: RiskLimitPoint

PredictedFunding

Fields

exchange: ExchangeId

symbol: String

point: PredictedFundingPoint

FundingSettlement

Fields

exchange: ExchangeId

symbol: String

point: FundingSettlementPoint

MarkPriceKline

Fields

exchange: ExchangeId

symbol: String

timeframe: KlineInterval

point: MarkPriceKlinePoint

IndexPriceKline

Fields

exchange: ExchangeId

symbol: String

timeframe: KlineInterval

point: IndexPriceKlinePoint

PremiumIndexKline

Fields

exchange: ExchangeId

symbol: String

timeframe: KlineInterval

point: PremiumIndexKlinePoint

Footprint

Footprint bar update. Emitted on every trade (open bar, same upsert semantics as Event::Bar). Kind::Footprint carries the interval.

Fields

exchange: ExchangeId

symbol: String

point: FootprintPoint

RenkoBar

Renko brick close. Each event is one completed brick (no in-progress emit — Renko bricks are atomic).

Fields

exchange: ExchangeId

symbol: String

point: RenkoBrickPoint

PnfBar

Point-and-Figure column update — emitted on every trade that touches the current column (in-progress upsert) plus on column roll. Use column_id on the point to group emits into columns.

Fields

exchange: ExchangeId

symbol: String

point: PnfColumnPoint

KagiBar

Kagi segment / connector emit. One event per closed segment.

Fields

exchange: ExchangeId

symbol: String

point: KagiSegmentPoint

CvdLine

Running cumulative volume delta sample. Emitted per upstream trade.

Fields

exchange: ExchangeId

symbol: String

point: ScalarBarPoint

ThreeLineBreakUpdate

Three Line Break line close. Each event is one completed line (no in-progress emit — lines are atomic once a breakout or reversal condition is met).

Fields

exchange: ExchangeId

symbol: String

point: ThreeLineBreakLinePoint

TpoProfile

TPO Market Profile session snapshot. Emitted on every upstream source event (trade or 1m kline); Series upserts on open_time = session_date_ms so the on-disk record at any time reflects the current intraday view of that session.

Fields

exchange: ExchangeId

symbol: String

point: TpoSessionPoint

ConnectorReady

Emitted once when hub.connect_public(exchange) succeeds, or immediately if it was already connected when warmup() called.

Fields

exchange: ExchangeId

SymbolsLoaded

Emitted once per (exchange, account_type) after REST get_exchange_info succeeds. Multiple emits per exchange if both Spot and Futures resolve. symbols is the raw exchange response.

Fields

exchange: ExchangeId

account_type: AccountType

symbols: Vec<SymbolInfo>

OrderUpdate

Order lifecycle event (create/fill/cancel/expire). symbol is the instrument symbol from the order, or "" if the exchange did not include it in this event.

Fields

exchange: ExchangeId

account_type: AccountType

symbol: String

point: OrderUpdatePoint

BalanceUpdate

Account balance change event. symbol is the asset ticker (e.g. "USDT"), not a trading pair.

Fields

exchange: ExchangeId

account_type: AccountType

symbol: String

point: BalanceUpdatePoint

PositionUpdate

Futures position change event. symbol is the instrument symbol for the position.

Fields

exchange: ExchangeId

account_type: AccountType

symbol: String

point: PositionUpdatePoint

Implementations

impl Event

pub fn exchange(&self) -> ExchangeId

pub fn symbol(&self) -> &str

pub fn timestamp_ms(&self) -> i64

Trait Implementations

impl Clone for Event

fn clone(&self) -> Event

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for Event

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.