Struct KLINE

Source
pub struct KLINE {
    pub ticker: String,
    pub timestamp: Vec<i64>,
    pub open: Option<Vec<f64>>,
    pub high: Option<Vec<f64>>,
    pub low: Option<Vec<f64>>,
    pub close: Vec<f64>,
    pub volume: Option<Vec<f64>>,
    pub adjclose: Option<Vec<f64>>,
}
Expand description

KLINE Struct

§Description

  • Represents historical price/volume data for a financial instrument
  • Stores OHLCV (Open, High, Low, Close, Volume) data with UNIX timestamps
  • Supports both adjusted and unadjusted closing prices
  • Designed for efficient time series analysis and portfolio construction
  • Flexible data ingestion from multiple sources

§Fields

  • ticker: Instrument symbol (e.g., “AAPL”, “BTC-USD”)
  • timestamp: UNIX timestamps (seconds since epoch) for each data point
  • open: Opening prices (optional)
  • high: Daily high prices (optional)
  • low: Daily low prices (optional)
  • close: Closing prices (required)
  • volume: Trading volumes (optional)
  • adjclose: Adjusted closing prices (optional)

§Features

  • Multi-format Support: Load data from CSV, JSON, and Polars DataFrames
  • Flexible Integration: Works seamlessly with Tickers and Portfolio structs
  • Performance Analysis: Enables risk/return calculations and reporting

§Example: Loading Data and Generating Reports

use std::error::Error;
use finalytics::prelude::*;

#[tokio::main]
async fn main() -> Result<(), Box<dyn Error>> {
    // Method 1: Load from CSV files
    let aapl_csv = KLINE::from_csv("AAPL", "../examples/datasets/aapl.csv")?;
    let goog_csv = KLINE::from_csv("GOOG", "../examples/datasets/goog.csv")?;
    let gspc_csv = KLINE::from_csv("^GSPC", "../examples/datasets/gspc.csv")?;

    // Method 2: Load from JSON files
    let msft_json = KLINE::from_json("MSFT", "../examples/datasets/msft.json")?;
    let btc_json = KLINE::from_json("BTC-USD", "../examples/datasets/btc.json")?;

    // Method 3: Load from Polars DataFrame
    let df = KLINE::from_csv("NVDA","../examples/datasets/nvda.csv")?.to_dataframe()?;
    let nvda_df = KLINE::from_dataframe("NVDA", &df)?;

    // Combine all data sources
    let tickers_data = vec![aapl_csv, goog_csv, msft_json, btc_json, nvda_df];

    // Initialize Tickers Struct
    let tickers = Tickers::builder()
        .tickers_data(Some(tickers_data))
        .benchmark_data(Some(gspc_csv))
        .confidence_level(0.95)
        .risk_free_rate(0.02)
        .build();

    // Generate a Single Ticker Report
    let ticker = tickers.clone().get_ticker("AAPL").await?;
    ticker.report(Some(ReportType::Performance)).await?.show()?;

    // Generate a Multiple Ticker Report
    tickers.report(Some(ReportType::Performance)).await?.show()?;

    // Portfolio optimization
    let portfolio = tickers.optimize(Some(ObjectiveFunction::MaxSharpe), None, None).await?;
    portfolio.report(Some(ReportType::Performance)).await?.show()?;

    Ok(())
}

§Supported Data Sources

  1. CSV Files:

    timestamp,open,high,low,close,volume,adjclose
     1672704000,130.28,130.90,124.17,125.07,112117500,124.82
     1672790400,126.89,128.66,125.08,126.36,89113600,126.11
  2. JSON Files:

    {
      "timestamp": [1672704000, 1672790400],
      "open": [130.28, 126.89],
      "high": [130.90, 128.66],
      "low": [124.17, 125.08],
      "close": [125.07, 126.36],
      "volume": [112117500, 89113600],
      "adjclose": [124.82, 126.11]
    }
  3. Polars DataFrames:

    use polars::prelude::*;
    
    let df = df!(
         "timestamp" => &[1672704000, 1672790400],
         "open" => &[130.28, 126.89],
         "high" => &[130.90, 128.66],
         "low" => &[124.17, 125.08],
         "close" => &[125.07, 126.36],
         "volume" => &[112117500.0, 89113600.0],
         "adjclose" => &[124.82, 126.11]
     );

§Important Notes

  • All sources must include timestamp and close columns
  • Column names are case-sensitive and must match exactly
  • Timestamps should be UNIX format (seconds since epoch)
  • Missing columns will be initialized as None

Fields§

§ticker: String§timestamp: Vec<i64>§open: Option<Vec<f64>>§high: Option<Vec<f64>>§low: Option<Vec<f64>>§close: Vec<f64>§volume: Option<Vec<f64>>§adjclose: Option<Vec<f64>>

Implementations§

Source§

impl KLINE

Source

pub fn interval_days(&self) -> IntervalDays

Source

pub fn start_date(&self) -> String

Source

pub fn end_date(&self) -> String

Source

pub fn to_dataframe(&self) -> Result<DataFrame, Box<dyn Error>>

Source

pub fn from_dataframe( ticker: &str, df: &DataFrame, ) -> Result<KLINE, Box<dyn Error>>

Source

pub fn from_csv(ticker: &str, path: &str) -> Result<Self, Box<dyn Error>>

Source

pub fn from_json(ticker: &str, path: &str) -> Result<Self, Box<dyn Error>>

Trait Implementations§

Source§

impl Clone for KLINE

Source§

fn clone(&self) -> KLINE

Returns a duplicate of the value. Read more
1.0.0 · Source§

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

Performs copy-assignment from source. Read more
Source§

impl Debug for KLINE

Source§

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

Formats the value using the given formatter. Read more

Auto Trait Implementations§

§

impl Freeze for KLINE

§

impl RefUnwindSafe for KLINE

§

impl Send for KLINE

§

impl Sync for KLINE

§

impl Unpin for KLINE

§

impl UnwindSafe for KLINE

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<T> CloneToUninit for T
where T: Clone,

Source§

unsafe fn clone_to_uninit(&self, dest: *mut u8)

🔬This is a nightly-only experimental API. (clone_to_uninit)
Performs copy-assignment from self to dest. Read more
Source§

impl<T> DynClone for T
where T: Clone,

Source§

fn __clone_box(&self, _: Private) -> *mut ()

Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T> Instrument for T

Source§

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more
Source§

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T> IntoEither for T

Source§

fn into_either(self, into_left: bool) -> Either<Self, Self>

Converts self into a Left variant of Either<Self, Self> if into_left is true. Converts self into a Right variant of Either<Self, Self> otherwise. Read more
Source§

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
where F: FnOnce(&Self) -> bool,

Converts self into a Left variant of Either<Self, Self> if into_left(&self) returns true. Converts self into a Right variant of Either<Self, Self> otherwise. Read more
Source§

impl<T> Key for T
where T: Clone,

Source§

fn align() -> usize

The alignment necessary for the key. Must return a power of two.
Source§

fn size(&self) -> usize

The size of the key in bytes.
Source§

unsafe fn init(&self, ptr: *mut u8)

Initialize the key in the given memory location. Read more
Source§

unsafe fn get<'a>(ptr: *const u8) -> &'a T

Get a reference to the key from the given memory location. Read more
Source§

unsafe fn drop_in_place(ptr: *mut u8)

Drop the key in place. Read more
Source§

impl<T> Pointable for T

Source§

const ALIGN: usize

The alignment of pointer.
Source§

type Init = T

The type for initializers.
Source§

unsafe fn init(init: <T as Pointable>::Init) -> usize

Initializes a with the given initializer. Read more
Source§

unsafe fn deref<'a>(ptr: usize) -> &'a T

Dereferences the given pointer. Read more
Source§

unsafe fn deref_mut<'a>(ptr: usize) -> &'a mut T

Mutably dereferences the given pointer. Read more
Source§

unsafe fn drop(ptr: usize)

Drops the object pointed to by the given pointer. Read more
Source§

impl<T> PolicyExt for T
where T: ?Sized,

Source§

fn and<P, B, E>(self, other: P) -> And<T, P>
where T: Policy<B, E>, P: Policy<B, E>,

Create a new Policy that returns Action::Follow only if self and other return Action::Follow. Read more
Source§

fn or<P, B, E>(self, other: P) -> Or<T, P>
where T: Policy<B, E>, P: Policy<B, E>,

Create a new Policy that returns Action::Follow if either self or other returns Action::Follow. Read more
Source§

impl<T> Same for T

Source§

type Output = T

Should always be Self
Source§

impl<SS, SP> SupersetOf<SS> for SP
where SS: SubsetOf<SP>,

Source§

fn to_subset(&self) -> Option<SS>

The inverse inclusion map: attempts to construct self from the equivalent element of its superset. Read more
Source§

fn is_in_subset(&self) -> bool

Checks if self is actually part of its subset T (and can be converted to it).
Source§

fn to_subset_unchecked(&self) -> SS

Use with care! Same as self.to_subset but without any property checks. Always succeeds.
Source§

fn from_subset(element: &SS) -> SP

The inclusion map: converts self to the equivalent element of its superset.
Source§

impl<T> ToOwned for T
where T: Clone,

Source§

type Owned = T

The resulting type after obtaining ownership.
Source§

fn to_owned(&self) -> T

Creates owned data from borrowed data, usually by cloning. Read more
Source§

fn clone_into(&self, target: &mut T)

Uses borrowed data to replace owned data, usually by cloning. Read more
Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
Source§

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

Source§

fn vzip(self) -> V

Source§

impl<T> WithSubscriber for T

Source§

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more
Source§

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more
Source§

impl<T> ErasedDestructor for T
where T: 'static,