Crate uwheel

µWheel is an embeddable aggregate management system for streams and queries.

Learn more about the project here.

Feature Flags

• std (enabled by default)
  • Enables features that rely on the standard library
• sum (enabled by default)
  • Enables sum aggregation
• avg (enabled by default)
  • Enables avg aggregation
• min (enabled by default)
  • Enables min aggregation
• max (enabled by default)
  • Enables max aggregation
• min_max (enabled by default)
  • Enables min-max aggregation
• all (enabled by default)
  • Enables all aggregation
• top_n
  • Enables Top-N aggregation
• simd (requires nightly)
  • Enables support to speed up aggregation functions with SIMD operations
• sync (implicitly enables std)
  • Enables a sync version of ReaderWheel that can be shared and queried across threads
• profiler (implicitly enables std)
  • Enables recording of latencies for various operations
• serde
  • Enables serde support
• timer
  • Enables scheduling user-defined functions

Re-exports

pub use duration::Duration;

pub use duration::NumericalDuration;

pub use aggregator::Aggregator;

pub use wheels::read::aggregation::conf::CompressionPolicy;

pub use wheels::read::aggregation::conf::RetentionPolicy;

pub use wheels::read::aggregation::conf::WheelConf;

pub use wheels::read::hierarchical::Haw;

pub use wheels::read::hierarchical::HawConf;

pub use wheels::read::hierarchical::WheelRange;

pub use wheels::Conf;

pub use wheels::RwWheel;

Modules

aggregator

Aggregation interface and pre-defined aggregators (e.g., SUM, AVG, Top-N)

duration

Duration of time for µWheel intervals

wheels

Various wheels used by µWheel

Structs

DeltaState

Delta State that may be used to update or initiate a ReaderWheel

Entry

Timestamped Entry that can be inserted into µWheel

WindowAggregate

Window Aggregation Result

Enums

Window

Different window variants supported by µWheel