Struct sda_server::jfs_stores::JfsAggregationsStore

pub struct JfsAggregationsStore { /* fields omitted */ }

Methods

impl JfsAggregationsStore

fn new<P: AsRef<Path>>(prefix: P) -> SdaServerResult<JfsAggregationsStore>

Trait Implementations

impl BaseStore for JfsAggregationsStore

fn ping(&self) -> SdaServerResult<()>

impl AggregationsStore for JfsAggregationsStore

fn list_aggregations(&self,
                     filter: Option<&str>,
                     recipient: Option<&AgentId>)
                     -> SdaServerResult<Vec<AggregationId>>

Search for aggregations by title and/or by recipient.

fn create_aggregation(&self, aggregation: &Aggregation) -> SdaServerResult<()>

Create a new aggregation on the service (without any associated result). If successful, the original id has been replaced by the returned id.

fn get_aggregation(&self,
                   aggregation: &AggregationId)
                   -> SdaServerResult<Option<Aggregation>>

Retrieve an aggregation and its description.

fn delete_aggregation(&self, aggregation: &AggregationId) -> SdaServerResult<()>

Delete all information (including results) regarding an aggregation.

fn get_committee(&self,
                 owner: &AggregationId)
                 -> SdaServerResult<Option<Committee>>

Retrieve the associated committee.

fn create_committee(&self, committee: &Committee) -> SdaServerResult<()>

fn create_participation(&self,
                        participation: &Participation)
                        -> SdaServerResult<()>

fn create_snapshot(&self, snapshot: &Snapshot) -> SdaServerResult<()>

fn count_participations(&self,
                        aggregation: &AggregationId)
                        -> SdaServerResult<usize>

fn snapshot_participations(&self,
                           aggregation: &AggregationId,
                           snapshot: &SnapshotId)
                           -> SdaServerResult<()>

fn list_snapshots(&self,
                  aggregation: &AggregationId)
                  -> SdaServerResult<Vec<SnapshotId>>

fn get_snapshot(&self,
                _aggregation: &AggregationId,
                snapshot: &SnapshotId)
                -> SdaServerResult<Option<Snapshot>>

fn iter_snapped_participations<'a, 'b>(&'b self,
                                       aggregation: &AggregationId,
                                       snapshot: &SnapshotId)
                                       -> SdaServerResult<Box<Iterator<Item=SdaServerResult<Participation>> + 'a>> where 'b: 'a

fn create_snapshot_mask(&self,
                        snapshot: &SnapshotId,
                        mask: Vec<Encryption>)
                        -> SdaServerResult<()>

fn get_snapshot_mask(&self,
                     snapshot: &SnapshotId)
                     -> SdaServerResult<Option<Vec<Encryption>>>

fn count_participations_snapshot(&self,
                                 aggregation: &AggregationId,
                                 snapshot: &SnapshotId)
                                 -> SdaServerResult<usize>

fn iter_snapshot_clerk_jobs_data<'a, 'b>(&'b self,
                                         aggregation: &AggregationId,
                                         snapshot: &SnapshotId,
                                         clerks_number: usize)
                                         -> SdaServerResult<Box<Iterator<Item=SdaServerResult<Vec<Encryption>>> + 'a>> where 'b: 'a