214 releases

new 0.7.62 Apr 29, 2025
0.7.57 Mar 25, 2025
0.7.45 Dec 11, 2024
0.7.43 Nov 21, 2024
0.1.24 Nov 16, 2022

#199 in Authentication

Download history 157/week @ 2025-01-06 239/week @ 2025-01-13 312/week @ 2025-01-20 483/week @ 2025-01-27 300/week @ 2025-02-03 256/week @ 2025-02-10 285/week @ 2025-02-17 454/week @ 2025-02-24 374/week @ 2025-03-03 345/week @ 2025-03-10 357/week @ 2025-03-17 268/week @ 2025-03-24 293/week @ 2025-03-31 405/week @ 2025-04-07 236/week @ 2025-04-14 212/week @ 2025-04-21

1,155 downloads per month
Used in divviup-cli

MPL-2.0 license

455KB
11K SLoC

A DAP-PPM collector

This library implements the collector role of the DAP-PPM protocol. It works in concert with two DAP-PPM aggregator servers to compute a statistical aggregate over data from many clients, while preserving the privacy of each client's data.

Examples

Initialize an instance of Collector.

use std::{fs::File, str::FromStr};

use janus_collector::{Collector, PrivateCollectorCredential};
use janus_messages::{Duration, FixedSizeQuery, Interval, Query, TaskId, Time};
use prio::vdaf::prio3::Prio3;
use url::Url;

let task_id = TaskId::from_str("[your DAP task ID here]").unwrap();

let collector_credential: PrivateCollectorCredential =
    serde_json::from_reader(File::open("[path to JSON encoded collector credential]").unwrap())
        .unwrap();

let leader_url =
    Url::from_str("[absolute URI to the DAP leader, e.g. https://leader.dap.example.com/]")
        .unwrap();

// Supply a VDAF implementation, corresponding to this task.
let vdaf = Prio3::new_count(2).unwrap();

let collector = Collector::new(
    task_id,
    leader_url,
    collector_credential.authentication_token(),
    collector_credential.hpke_keypair(),
    vdaf,
)
.unwrap();

// If this is a time interval task, specify the time interval over which the aggregation
// should be calculated.
let interval = Interval::new(
    Time::from_seconds_since_epoch(1_656_000_000),
    Duration::from_seconds(3600),
)
.unwrap();

// Make the requests and retrieve the aggregated statistic.
let aggregation_result = collector
    .collect(Query::new_time_interval(interval), &())
    .await
    .unwrap();

// Or if this is a fixed size task, make a fixed size query.
let query = Query::new_fixed_size(FixedSizeQuery::CurrentBatch);
let aggregation_result = collector.collect(query, &()).await.unwrap();

janus_collector

Build Status latest version docs badge

janus_collector is a self-contained implementation of the Distributed Aggregation Protocol's collector role. It is intended for use with Janus and Divvi Up, ISRG's privacy-respecting metrics service. janus_collector is published to crates.io by a GitHub Action that runs when a janus release is created.

Dependencies

~99MB
~2.5M SLoC