Struct Candle 

pub struct Candle {
    pub close_time: DateTime<Utc>,
    pub open: Decimal,
    pub high: Decimal,
    pub low: Decimal,
    pub close: Decimal,
    pub volume: Decimal,
    pub trade_count: u64,
}

Normalised Barter OHLCV Candle model.

close_time contract

close_time is the exclusive end-of-period boundary of the candle:

close_time == open_time + interval

A candle aggregates the trades that fall in the half-open interval [close_time − interval, close_time) — i.e. trades with open_time ≤ ts < close_time. A trade landing exactly on close_time belongs to the next candle, so close_time equals the next candle’s open instant.

Two distinct caveats apply to the boundary — do not conflate them:

• Not session-aligned (daily/weekly/monthly): the boundary is the UTC period grid (day → next 00:00 UTC, etc.), not an exchange session close. The library has no session calendar.
• Variable-length calendar arithmetic (month/quarter/year only): these are nominal boundaries computed with calendar months (chrono Months), not fixed Durations. Daily and weekly are exact fixed durations in UTC (no DST), exact to the millisecond. The open_time + N months equality holds only when open_time is calendar-grid-aligned (e.g. a 1M candle opens on the 1st at 00:00 UTC); a non-aligned open day-clamps (Jan 31 + 1 month → Feb 28/29). Venue-supplied open times are always aligned, so clamping never arises in practice, but it is part of the contract for callers computing boundaries from arbitrary instants.

Candle deliberately carries neither open_time nor interval — recover them from the originating fetch request / subscription resolution (open_time ≡ close_time − interval). Range-computing producers derive close_time through close_time_from_open so the boundary is defined in exactly one place (the Massive WS path uses the venue-supplied boundary directly — see close_time_from_open for the full producer list).

Using a Candle with the engine

When wrapping a Candle into a MarketEvent for a consuming engine (live or backtest), set time_exchange to this close_time — it is the period-END instant, the only choice that avoids lookahead (see that field’s contract). The library’s own candle producers already do this.

Fields

close_time: DateTime<Utc>

open: Decimal

high: Decimal

low: Decimal

close: Decimal

volume: Decimal

trade_count: u64

Trait Implementations

impl Clone for Candle

fn clone(&self) -> Candle

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for Candle

impl Debug for Candle

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for Candle

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl From<Candle> for DataKind

fn from(value: Candle) -> Self

Converts to this type from the input type.

impl PartialEq for Candle

fn eq(&self, other: &Candle) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl PartialOrd for Candle

fn partial_cmp(&self, other: &Candle) -> Option<Ordering>

This method returns an ordering between self and other values if one exists.

fn lt(&self, other: &Rhs) -> bool

Tests less than (for self and other) and is used by the < operator.

fn le(&self, other: &Rhs) -> bool

Tests less than or equal to (for self and other) and is used by the <= operator.

fn gt(&self, other: &Rhs) -> bool

Tests greater than (for self and other) and is used by the > operator.

fn ge(&self, other: &Rhs) -> bool

Tests greater than or equal to (for self and other) and is used by the >= operator.

impl Serialize for Candle

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for Candle