harmos-storage 0.1.8

Harmos storage: durable journals, snapshots and Arrow-backed stream storage.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74

/* ***
 *
 * Harmos
 *
 * SPDX-License-Identifier: Apache-2.0
 *
 * ***
 */

/* === Modules === */

/* === Re-Exports === */

/* === Imports === */

// Standard Library Imports

// Third Party Imports

// Local Imports

/* === Constants === */

/* === Macros === */

/* === Type Aliases === */

/* === Structs === */

/* === Enums === */

/* === Traits === */

/* === Implementations === */

/* === Public Functions === */

#[must_use]
pub fn derivative(x: &[f64], y: &[f64]) -> Vec<f64> {
    let length = x.len().min(y.len());
    if length < 2 {
        return Vec::new();
    }

    let mut slope = Vec::with_capacity(length);
    slope.push((y[1] - y[0]) / (x[1] - x[0]));
    slope.extend((1..length - 1).map(|index| (y[index + 1] - y[index - 1]) / (x[index + 1] - x[index - 1])));
    slope.push((y[length - 1] - y[length - 2]) / (x[length - 1] - x[length - 2]));

    slope
}

#[must_use]
pub fn integral(x: &[f64], y: &[f64]) -> Vec<f64> {
    let length = x.len().min(y.len());
    if length == 0 {
        return Vec::new();
    }

    let mut accumulated = 0.0;
    let mut area = Vec::with_capacity(length);
    area.push(0.0);

    for index in 1..length {
        accumulated += (y[index] + y[index - 1]) / 2.0 * (x[index] - x[index - 1]);
        area.push(accumulated);
    }

    area
}

/* === Private Functions === */

/* === Tests === */