Struct Client

pub struct Client<V: Client<16>> { /* private fields */ }

A DAP client.

Implementations

impl<V: Client<16>> Client<V>

pub async fn new( task_id: TaskId, leader_aggregator_endpoint: Url, helper_aggregator_endpoint: Url, time_precision: Duration, vdaf: V, ) -> Result<Self, Error>

Construct a new client from the required set of DAP task parameters.

pub fn with_hpke_configs( task_id: TaskId, leader_aggregator_endpoint: Url, helper_aggregator_endpoint: Url, time_precision: Duration, vdaf: V, leader_hpke_config: HpkeConfig, helper_hpke_config: HpkeConfig, ) -> Result<Self, Error>

👎Deprecated: Use ClientBuilder::with_leader_hpke_config, ClientBuilder::with_helper_hpke_config and ClientBuilder::build instead

Construct a new client, and provide the aggregator HPKE configurations through an out-of-band means.

Notes

This method is not compatible with OHTTP. Use ClientBuilder::with_ohttp_config and then ClientBuilder::build to provide OHTTP configuration.

pub fn builder( task_id: TaskId, leader_aggregator_endpoint: Url, helper_aggregator_endpoint: Url, time_precision: Duration, vdaf: V, ) -> ClientBuilder<V>

Creates a ClientBuilder for further configuration from the required set of DAP task parameters.

pub async fn upload(&self, measurement: &V::Measurement) -> Result<(), Error>

Upload a Report to the leader, per the DAP specification. The provided measurement is sharded into two shares and then uploaded to the leader.

pub async fn upload_with_time<T>( &self, measurement: &V::Measurement, time: T, ) -> Result<(), Error>

where T: TryInto<Time> + Debug, Error: From<<T as TryInto<Time>>::Error>,

Upload a Report to the leader, per the DAP specification, and override the report’s timestamp. The provided measurement is sharded into two shares and then uploaded to the leader.

let client = Client::new(
    random(),
    "https://example.com/".parse().unwrap(),
    "https://example.net/".parse().unwrap(),
    Duration::from_seconds(3600),
    vdaf,
).await?;
client.upload_with_time(&measurement, std::time::SystemTime::now()).await?;
client.upload_with_time(&measurement, janus_messages::Time::from_seconds_since_epoch(timestamp)).await?;

Trait Implementations

impl<V: Clone + Client<16>> Clone for Client<V>

fn clone(&self) -> Client<V>

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<V: Debug + Client<16>> Debug for Client<V>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.