Trait sda_server::stores::AggregationsStore [−] [src]

pub trait AggregationsStore: BaseStore {
    fn list_aggregations(&self,
                         filter: Option<&str>,
                         recipient: Option<&AgentId>)
                         -> SdaServerResult<Vec<AggregationId>>;
    fn create_aggregation(&self,
                          aggregation: &Aggregation)
                          -> SdaServerResult<()>;
    fn get_aggregation(&self,
                       aggregation: &AggregationId)
                       -> SdaServerResult<Option<Aggregation>>;
    fn delete_aggregation(&self,
                          aggregation: &AggregationId)
                          -> SdaServerResult<()>;
    fn get_committee(&self,
                     owner: &AggregationId)
                     -> SdaServerResult<Option<Committee>>;
    fn create_committee(&self, committee: &Committee) -> SdaServerResult<()>;
    fn create_participation(&self,
                            participation: &Participation)
                            -> SdaServerResult<()>;
    fn create_snapshot(&self, snapshot: &Snapshot) -> SdaServerResult<()>;
    fn list_snapshots(&self,
                      aggregation: &AggregationId)
                      -> SdaServerResult<Vec<SnapshotId>>;
    fn get_snapshot(&self,
                    aggregation: &AggregationId,
                    snapshot: &SnapshotId)
                    -> SdaServerResult<Option<Snapshot>>;
    fn count_participations(&self,
                            aggregation: &AggregationId)
                            -> SdaServerResult<usize>;
    fn snapshot_participations(&self,
                               aggregation: &AggregationId,
                               snapshot: &SnapshotId)
                               -> SdaServerResult<()>;
    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 { ... }
}

Required Methods

`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 list_snapshots(&self, aggregation: &AggregationId) -> SdaServerResult<Vec<SnapshotId>>`

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

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

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

`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>>>`

Provided Methods

`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

Implementors

impl AggregationsStore for JfsAggregationsStore