Struct TaskRepository 

pub struct TaskRepository { /* private fields */ }

Implementation of TaskRepository.

Implementations

impl TaskRepository

pub fn new(conn: Connection) -> TaskRepository

Construct a TaskRepository.

pub fn create_table_if_not_exists(&self) -> Result<()>

Create table tasks. This function is to be called at first time.

Trait Implementations

impl IESTaskRepository for TaskRepository

fn issue_sequential_id(&self, aggregate_id: AggregateID) -> Result<SequentialID>

issue_sequential_id issue SequentialID incremented from latest serial number.

fn load_by_sequential_id( &self, sequential_id: SequentialID, ) -> Result<Option<Task>>

load_by_sequential_id loads Task by sequential_id.

fn load_all_sequential_ids(&self) -> Result<Vec<SequentialID>>

load_all_sequential_ids loads all sequential_ids.

impl Repository<Task> for TaskRepository

fn load(&self, aggregate_id: AggregateID) -> Result<Task>

load a Task by id.

fn save(&self, task: &mut Task) -> Result<()>

save the task events. The reason why an argument task as mut is to clear events associated to the task.