Struct TransactionLog 

pub struct TransactionLog { /* private fields */ }

Implementations

impl TransactionLog

pub async fn new( max_position_counter: Option<u32>, max_price_counter: Option<u32>, max_pnl_counter: Option<u32>, mongodb_uri: &str, db_r_name: &str, db_w_name: &str, back_test: bool, ) -> Self

pub fn increment_counter(&self, counter_type: CounterType) -> u32

pub async fn get_last_transaction_id( db: &Database, counter_type: CounterType, ) -> u32

pub async fn get_w_db(&self) -> Option<Database>

pub async fn get_r_db(&self) -> Option<Database>

pub async fn update_transaction( db: &Database, item: &PositionLog, ) -> Result<(), Box<dyn Error>>

pub async fn update_price( db: &Database, item: PriceLog, ) -> Result<(), Box<dyn Error>>

pub async fn copy_price(db_r: &Database, db_w: &Database, limit: Option<u32>)

pub async fn copy_position(db_r: &Database, db_w: &Database, limit: Option<u32>)

pub async fn get_price_market_data( db: &Database, limit: Option<u32>, id: Option<u32>, is_ascend: bool, ) -> HashMap<String, HashMap<String, Vec<PricePoint>>>

pub async fn get_all_positions( db: &Database, limit: Option<u32>, id: Option<u32>, is_ascend: bool, ) -> Vec<PositionLog>

pub async fn insert_pnl( db: &Database, item: PnlLog, ) -> Result<(), Box<dyn Error>>

pub async fn get_app_state(db: &Database) -> AppState

pub async fn update_app_state( db: &Database, last_execution_time: Option<SystemTime>, last_equity: Option<Decimal>, ave_dd: Option<Decimal>, max_dd: Option<Decimal>, cumulative_return: Option<Decimal>, cumulative_dd: Option<Decimal>, score: Option<Decimal>, score_2: Option<Decimal>, score_3: Option<Decimal>, curcuit_break: bool, error_time: Option<String>, max_invested_amount: Option<Decimal>, fund_configs: Option<Vec<FundConfig>>, ) -> Result<(), Box<dyn Error>>

pub fn db_w_name(&self) -> &str