Struct SqliteShipmentRepository 

pub struct SqliteShipmentRepository { /* private fields */ }

Available on crate feature sqlite only.

SQLite implementation of ShipmentRepository

Implementations

impl SqliteShipmentRepository

pub const fn new(pool: Pool<SqliteConnectionManager>) -> Self

Trait Implementations

impl Debug for SqliteShipmentRepository

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

Formats the value using the given formatter.

impl ShipmentRepository for SqliteShipmentRepository

fn create(&self, input: CreateShipment) -> Result<Shipment>

Create a new shipment

fn get(&self, id: ShipmentId) -> Result<Option<Shipment>>

Get shipment by ID

fn get_by_number(&self, shipment_number: &str) -> Result<Option<Shipment>>

Get shipment by shipment number

fn get_by_tracking(&self, tracking_number: &str) -> Result<Option<Shipment>>

Get shipment by tracking number

fn update(&self, id: ShipmentId, input: UpdateShipment) -> Result<Shipment>

Update a shipment

fn list(&self, filter: ShipmentFilter) -> Result<Vec<Shipment>>

List shipments with filter

fn for_order(&self, order_id: OrderId) -> Result<Vec<Shipment>>

Get shipments for an order

fn delete(&self, id: ShipmentId) -> Result<()>

Delete a shipment (cancel if not shipped)

fn mark_processing(&self, id: ShipmentId) -> Result<Shipment>

Mark shipment as processing

fn mark_ready(&self, id: ShipmentId) -> Result<Shipment>

Mark shipment as ready to ship

fn ship( &self, id: ShipmentId, tracking_number: Option<String>, ) -> Result<Shipment>

Mark shipment as shipped with tracking number

fn mark_in_transit(&self, id: ShipmentId) -> Result<Shipment>

Mark shipment as in transit

fn mark_out_for_delivery(&self, id: ShipmentId) -> Result<Shipment>

Mark shipment as out for delivery

fn mark_delivered(&self, id: ShipmentId) -> Result<Shipment>

Mark shipment as delivered

fn mark_failed(&self, id: ShipmentId) -> Result<Shipment>

Mark shipment as failed delivery

fn hold(&self, id: ShipmentId) -> Result<Shipment>

Put shipment on hold

fn cancel(&self, id: ShipmentId) -> Result<Shipment>

Cancel shipment

fn add_item( &self, shipment_id: ShipmentId, item: CreateShipmentItem, ) -> Result<ShipmentItem>

Add item to shipment

fn remove_item(&self, item_id: Uuid) -> Result<()>

Remove item from shipment

fn get_items(&self, shipment_id: ShipmentId) -> Result<Vec<ShipmentItem>>

Get items in shipment

fn add_event( &self, shipment_id: ShipmentId, event: AddShipmentEvent, ) -> Result<ShipmentEvent>

Add tracking event

fn get_events(&self, shipment_id: ShipmentId) -> Result<Vec<ShipmentEvent>>

Get tracking events for shipment

fn count(&self, filter: ShipmentFilter) -> Result<u64>

Count shipments matching filter

fn create_batch( &self, inputs: Vec<CreateShipment>, ) -> Result<BatchResult<Shipment>>

Create multiple shipments - partial success allowed

fn create_batch_atomic( &self, inputs: Vec<CreateShipment>, ) -> Result<Vec<Shipment>>

Create multiple shipments - atomic (all-or-nothing)

fn update_batch( &self, updates: Vec<(ShipmentId, UpdateShipment)>, ) -> Result<BatchResult<Shipment>>

Update multiple shipments - partial success allowed

fn update_batch_atomic( &self, updates: Vec<(ShipmentId, UpdateShipment)>, ) -> Result<Vec<Shipment>>

Update multiple shipments - atomic (all-or-nothing)

fn delete_batch(&self, ids: Vec<ShipmentId>) -> Result<BatchResult<Uuid>>

Delete multiple shipments - partial success allowed

fn delete_batch_atomic(&self, ids: Vec<ShipmentId>) -> Result<()>

Delete multiple shipments - atomic (all-or-nothing)

fn get_batch(&self, ids: Vec<ShipmentId>) -> Result<Vec<Shipment>>

Get multiple shipments by ID