global: snapshot

This commit is contained in:
nym21
2025-11-25 15:39:40 +01:00
parent eedc0dd075
commit c644781d18
65 changed files with 233 additions and 264 deletions
@@ -8,13 +8,13 @@ use vecdb::{
use crate::utils::get_percentile;
use super::ComputedType;
use super::ComputedVecValue;
#[derive(Clone, Debug, Traversable)]
pub struct EagerVecsBuilder<I, T>
where
I: VecIndex,
T: ComputedType,
T: ComputedVecValue,
{
pub first: Option<Box<EagerVec<I, T>>>,
pub average: Option<Box<EagerVec<I, T>>>,
@@ -35,7 +35,7 @@ const VERSION: Version = Version::ZERO;
impl<I, T> EagerVecsBuilder<I, T>
where
I: VecIndex,
T: ComputedType,
T: ComputedVecValue,
{
pub fn forced_import_compressed(
db: &Database,
@@ -4,16 +4,16 @@ use vecdb::{FromCoarserIndex, IterableBoxedVec, IterableCloneableVec, LazyVecFro
use crate::grouped::{EagerVecsBuilder, VecBuilderOptions};
use super::ComputedType;
use super::ComputedVecValue;
#[allow(clippy::type_complexity)]
#[derive(Clone, Traversable)]
pub struct LazyVecsBuilder<I, T, S1I, S2T>
where
I: VecIndex,
T: ComputedType,
T: ComputedVecValue,
S1I: VecIndex,
S2T: ComputedType,
S2T: ComputedVecValue,
{
pub first: Option<Box<LazyVecFrom2<I, T, S1I, T, I, S2T>>>,
pub average: Option<Box<LazyVecFrom2<I, T, S1I, T, I, S2T>>>,
@@ -29,9 +29,9 @@ const VERSION: Version = Version::ZERO;
impl<I, T, S1I, S2T> LazyVecsBuilder<I, T, S1I, S2T>
where
I: VecIndex,
T: ComputedType + 'static,
T: ComputedVecValue + 'static,
S1I: VecIndex + 'static + FromCoarserIndex<I>,
S2T: ComputedType,
S2T: ComputedVecValue,
{
#[allow(clippy::too_many_arguments)]
pub fn forced_import(
+5 -5
View File
@@ -1,10 +1,10 @@
use std::ops::{Add, AddAssign, Div};
use vecdb::{Compressable, Formattable};
use vecdb::{Formattable, Pco};
pub trait ComputedType
pub trait ComputedVecValue
where
Self: Compressable
Self: Pco
+ From<usize>
+ Div<usize, Output = Self>
+ Add<Output = Self>
@@ -13,8 +13,8 @@ where
+ Formattable,
{
}
impl<T> ComputedType for T where
T: Compressable
impl<T> ComputedVecValue for T where
T: Pco
+ From<usize>
+ Div<usize, Output = Self>
+ Add<Output = Self>
@@ -8,12 +8,12 @@ use vecdb::{AnyWritableVec, Database, EagerVec, Exit, IterableCloneableVec, Iter
use crate::{Indexes, grouped::LazyVecsBuilder, indexes};
use super::{ComputedType, EagerVecsBuilder, Source, VecBuilderOptions};
use super::{ComputedVecValue, EagerVecsBuilder, Source, VecBuilderOptions};
#[derive(Clone)]
pub struct ComputedVecsFromDateIndex<T>
where
T: ComputedType + PartialOrd,
T: ComputedVecValue + PartialOrd,
{
pub dateindex: Option<EagerVec<DateIndex, T>>,
pub dateindex_extra: EagerVecsBuilder<DateIndex, T>,
@@ -29,7 +29,7 @@ const VERSION: Version = Version::ZERO;
impl<T> ComputedVecsFromDateIndex<T>
where
T: ComputedType + 'static,
T: ComputedVecValue + 'static,
{
#[allow(clippy::too_many_arguments)]
pub fn forced_import(
@@ -146,7 +146,7 @@ where
impl<T> Traversable for ComputedVecsFromDateIndex<T>
where
T: ComputedType,
T: ComputedVecValue,
{
fn to_tree_node(&self) -> brk_traversable::TreeNode {
let dateindex_extra_node = self.dateindex_extra.to_tree_node();
@@ -13,12 +13,12 @@ use crate::{
indexes,
};
use super::{ComputedType, EagerVecsBuilder, VecBuilderOptions};
use super::{ComputedVecValue, EagerVecsBuilder, VecBuilderOptions};
#[derive(Clone)]
pub struct ComputedVecsFromHeight<T>
where
T: ComputedType + PartialOrd,
T: ComputedVecValue + PartialOrd,
{
pub height: Option<EagerVec<Height, T>>,
pub height_extra: EagerVecsBuilder<Height, T>,
@@ -37,7 +37,7 @@ const VERSION: Version = Version::ZERO;
impl<T> ComputedVecsFromHeight<T>
where
T: ComputedType + Ord + From<f64> + 'static,
T: ComputedVecValue + Ord + From<f64> + 'static,
f64: From<T>,
{
#[allow(clippy::too_many_arguments)]
@@ -202,7 +202,7 @@ where
impl<T> Traversable for ComputedVecsFromHeight<T>
where
T: ComputedType,
T: ComputedVecValue,
{
fn to_tree_node(&self) -> brk_traversable::TreeNode {
let height_extra_node = self.height_extra.to_tree_node();
@@ -6,12 +6,12 @@ use vecdb::{AnyWritableVec, Database, EagerVec, Exit};
use crate::{Indexes, indexes};
use super::{ComputedType, EagerVecsBuilder, VecBuilderOptions};
use super::{ComputedVecValue, EagerVecsBuilder, VecBuilderOptions};
#[derive(Clone)]
pub struct ComputedVecsFromHeightStrict<T>
where
T: ComputedType + PartialOrd,
T: ComputedVecValue + PartialOrd,
{
pub height: EagerVec<Height, T>,
pub height_extra: EagerVecsBuilder<Height, T>,
@@ -23,7 +23,7 @@ const VERSION: Version = Version::ZERO;
impl<T> ComputedVecsFromHeightStrict<T>
where
T: ComputedType + Ord + From<f64>,
T: ComputedVecValue + Ord + From<f64>,
f64: From<T>,
{
pub fn forced_import(
@@ -86,7 +86,7 @@ where
impl<T> Traversable for ComputedVecsFromHeightStrict<T>
where
T: ComputedType,
T: ComputedVecValue,
{
fn to_tree_node(&self) -> brk_traversable::TreeNode {
let height_extra_node = self.height_extra.to_tree_node();
@@ -16,12 +16,12 @@ use crate::{
indexes, price,
};
use super::{ComputedType, EagerVecsBuilder, VecBuilderOptions};
use super::{ComputedVecValue, EagerVecsBuilder, VecBuilderOptions};
#[derive(Clone)]
pub struct ComputedVecsFromTxindex<T>
where
T: ComputedType + PartialOrd,
T: ComputedVecValue + PartialOrd,
{
pub txindex: Option<Box<EagerVec<TxIndex, T>>>,
pub height: EagerVecsBuilder<Height, T>,
@@ -40,7 +40,7 @@ const VERSION: Version = Version::ZERO;
impl<T> ComputedVecsFromTxindex<T>
where
T: ComputedType + Ord + From<f64> + 'static,
T: ComputedVecValue + Ord + From<f64> + 'static,
f64: From<T>,
{
#[allow(clippy::too_many_arguments)]
@@ -465,7 +465,7 @@ impl ComputedVecsFromTxindex<Dollars> {
impl<T> Traversable for ComputedVecsFromTxindex<T>
where
T: ComputedType,
T: ComputedVecValue,
{
fn to_tree_node(&self) -> brk_traversable::TreeNode {
brk_traversable::TreeNode::Branch(
@@ -1,6 +1,6 @@
use std::collections::BTreeMap;
use vecdb::{Compressable, CompressedVec, RawVec, VecIndex, VecValue};
use vecdb::{CompressedVec, Pco, RawVec, VecIndex, VecValue};
#[derive(Debug)]
pub struct RangeMap<I, T>(BTreeMap<I, T>);
@@ -39,7 +39,7 @@ where
impl<I, T> From<&CompressedVec<I, T>> for RangeMap<T, I>
where
I: VecIndex,
T: VecIndex + Compressable,
T: VecIndex + Pco,
{
#[inline]
fn from(vec: &CompressedVec<I, T>) -> Self {