Skip to main content

SqliteFulfillmentRepository

Struct SqliteFulfillmentRepository 

Source
pub struct SqliteFulfillmentRepository { /* private fields */ }
Available on crate feature sqlite only.
Expand description

SQLite fulfillment repository

Implementations§

Trait Implementations§

Source§

impl Debug for SqliteFulfillmentRepository

Source§

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

Formats the value using the given formatter. Read more
Source§

impl FulfillmentRepository for SqliteFulfillmentRepository

Source§

fn create_wave(&self, input: CreateWave) -> Result<Wave>

Create a wave from orders
Source§

fn get_wave(&self, id: FulfillmentId) -> Result<Option<Wave>>

Get wave by ID
Source§

fn get_wave_by_number(&self, number: &str) -> Result<Option<Wave>>

Get wave by number
Source§

fn list_waves(&self, filter: WaveFilter) -> Result<Vec<Wave>>

List waves with filter
Source§

fn release_wave(&self, id: FulfillmentId) -> Result<Wave>

Release wave for picking
Source§

fn complete_wave(&self, id: FulfillmentId) -> Result<Wave>

Complete a wave
Source§

fn cancel_wave(&self, id: FulfillmentId) -> Result<Wave>

Cancel a wave
Source§

fn get_wave_orders(&self, wave_id: FulfillmentId) -> Result<Vec<OrderId>>

Get orders in a wave
Source§

fn count_waves(&self, filter: WaveFilter) -> Result<u64>

Count waves
Source§

fn create_pick(&self, input: CreatePickTask) -> Result<PickTask>

Create a pick task
Source§

fn get_pick(&self, id: Uuid) -> Result<Option<PickTask>>

Get pick task by ID
Source§

fn list_picks(&self, filter: PickTaskFilter) -> Result<Vec<PickTask>>

List pick tasks with filter
Source§

fn assign_pick(&self, id: Uuid, assigned_to: &str) -> Result<PickTask>

Assign pick to user
Source§

fn start_pick(&self, id: Uuid) -> Result<PickTask>

Start a pick
Source§

fn complete_pick(&self, input: CompletePick) -> Result<PickTask>

Complete a pick
Source§

fn report_short( &self, id: Uuid, short_qty: Decimal, reason: &str, ) -> Result<PickTask>

Report short pick
Source§

fn cancel_pick(&self, id: Uuid) -> Result<PickTask>

Cancel a pick
Source§

fn get_picks_for_order(&self, order_id: OrderId) -> Result<Vec<PickTask>>

Get picks for order
Source§

fn get_picks_for_wave(&self, wave_id: FulfillmentId) -> Result<Vec<PickTask>>

Get picks for wave
Source§

fn count_picks(&self, filter: PickTaskFilter) -> Result<u64>

Count picks
Source§

fn create_pack(&self, input: CreatePackTask) -> Result<PackTask>

Create a pack task
Source§

fn get_pack(&self, id: Uuid) -> Result<Option<PackTask>>

Get pack task by ID
Source§

fn list_packs(&self, filter: PackTaskFilter) -> Result<Vec<PackTask>>

List pack tasks with filter
Source§

fn assign_pack(&self, id: Uuid, assigned_to: &str) -> Result<PackTask>

Assign pack to user
Source§

fn start_pack(&self, id: Uuid) -> Result<PackTask>

Start packing
Source§

fn complete_pack(&self, id: Uuid) -> Result<PackTask>

Complete packing
Source§

fn add_carton(&self, input: AddCarton) -> Result<Carton>

Add carton to pack task
Source§

fn add_carton_item(&self, input: AddCartonItem) -> Result<CartonItem>

Add item to carton
Source§

fn get_cartons(&self, pack_task_id: Uuid) -> Result<Vec<Carton>>

Get cartons for pack task
Source§

fn get_carton_items(&self, carton_id: Uuid) -> Result<Vec<CartonItem>>

Get items in carton
Source§

fn mark_label_printed(&self, carton_id: Uuid) -> Result<Carton>

Mark carton label printed
Source§

fn cancel_pack(&self, id: Uuid) -> Result<PackTask>

Cancel pack task
Source§

fn count_packs(&self, filter: PackTaskFilter) -> Result<u64>

Count packs
Source§

fn create_ship(&self, input: CreateShipTask) -> Result<ShipTask>

Create a ship task
Source§

fn get_ship(&self, id: Uuid) -> Result<Option<ShipTask>>

Get ship task by ID
Source§

fn list_ships(&self, filter: ShipTaskFilter) -> Result<Vec<ShipTask>>

List ship tasks with filter
Source§

fn assign_ship(&self, id: Uuid, assigned_to: &str) -> Result<ShipTask>

Assign ship to user
Source§

fn print_label(&self, id: Uuid, label_url: &str) -> Result<ShipTask>

Print shipping label
Source§

fn complete_ship(&self, input: CompleteShip) -> Result<ShipTask>

Complete shipping
Source§

fn cancel_ship(&self, id: Uuid) -> Result<ShipTask>

Cancel ship task
Source§

fn count_ships(&self, filter: ShipTaskFilter) -> Result<u64>

Count ships
Source§

fn create_picks_for_order( &self, order_id: OrderId, warehouse_id: i32, ) -> Result<Vec<PickTask>>

Create picks for an order
Source§

fn is_order_ready_to_pack(&self, order_id: OrderId) -> Result<bool>

Check if order is ready to pack
Source§

fn is_order_ready_to_ship(&self, order_id: OrderId) -> Result<bool>

Check if order is ready to ship
Source§

fn create_waves_batch( &self, inputs: Vec<CreateWave>, ) -> Result<BatchResult<Wave>>

Create multiple waves
Source§

fn get_picks_batch(&self, ids: Vec<Uuid>) -> Result<Vec<PickTask>>

Get multiple picks by ID

Auto Trait Implementations§

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T> Instrument for T

Source§

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more
Source§

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T> Same for T

Source§

type Output = T

Should always be Self
Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
Source§

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

Source§

fn vzip(self) -> V

Source§

impl<T> WithSubscriber for T

Source§

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more
Source§

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more