[−][src]Struct nature_db::RawTask
Fields
task_id: Vec<u8>
task_key: String
task_type: i8
task_for: String
task_state: i8
data: String
create_time: NaiveDateTime
execute_time: NaiveDateTime
retried_times: i16
Methods
impl RawTask
[src]
pub fn new<T: Serialize + Debug>(
task: &T,
task_key: &str,
task_type: i8,
task_for: &str
) -> Result<RawTask>
[src]
task: &T,
task_key: &str,
task_type: i8,
task_for: &str
) -> Result<RawTask>
pub fn finish_old<FI, FD>(
&mut self,
old: &RawTask,
_dao_insert: FI,
_dao_delete: FD
) -> Result<usize> where
FI: Fn(&RawTask) -> Result<usize>,
FD: Fn(&[u8]) -> Result<usize>,
[src]
&mut self,
old: &RawTask,
_dao_insert: FI,
_dao_delete: FD
) -> Result<usize> where
FI: Fn(&RawTask) -> Result<usize>,
FD: Fn(&[u8]) -> Result<usize>,
for performance reason, one-to-one carry which we can reuse the beginning carry to finish all flows. That way we need not to communicate with DB for create new and delete old carrier. But for failure we must redo from beginning. but I think it has small chance. Another disadvantage is the failure information will be attached to the beginning.
pub fn save_batch<FI, FD>(
news: &[RawTask],
old_id: &[u8],
dao_insert: FI,
dao_finish: FD
) -> Result<()> where
FI: Fn(&RawTask) -> Result<usize>,
FD: Fn(&[u8]) -> Result<usize>,
[src]
news: &[RawTask],
old_id: &[u8],
dao_insert: FI,
dao_finish: FD
) -> Result<()> where
FI: Fn(&RawTask) -> Result<usize>,
FD: Fn(&[u8]) -> Result<usize>,
pub fn task_string(&self) -> String
[src]
Trait Implementations
impl Clone for RawTask
[src]
impl Debug for RawTask
[src]
impl<'de> Deserialize<'de> for RawTask
[src]
fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error> where
__D: Deserializer<'de>,
[src]
__D: Deserializer<'de>,
impl<'insert> Insertable<table> for RawTask
[src]
type Values = <(Option<Eq<task_id, Vec<u8>>>, Option<Eq<task_key, String>>, Option<Eq<task_type, i8>>, Option<Eq<task_for, String>>, Option<Eq<task_state, i8>>, Option<Eq<data, String>>, Option<Eq<create_time, NaiveDateTime>>, Option<Eq<execute_time, NaiveDateTime>>, Option<Eq<retried_times, i16>>) as Insertable<table>>::Values
The VALUES
clause to insert these records Read more
fn values(self) -> Self::Values
[src]
fn insert_into(
self,
table: T
) -> InsertStatement<T, Self::Values, Insert, NoReturningClause>
[src]
self,
table: T
) -> InsertStatement<T, Self::Values, Insert, NoReturningClause>
impl<'insert> Insertable<table> for &'insert RawTask
[src]
type Values = <(Option<Eq<task_id, &'insert Vec<u8>>>, Option<Eq<task_key, &'insert String>>, Option<Eq<task_type, &'insert i8>>, Option<Eq<task_for, &'insert String>>, Option<Eq<task_state, &'insert i8>>, Option<Eq<data, &'insert String>>, Option<Eq<create_time, &'insert NaiveDateTime>>, Option<Eq<execute_time, &'insert NaiveDateTime>>, Option<Eq<retried_times, &'insert i16>>) as Insertable<table>>::Values
The VALUES
clause to insert these records Read more
fn values(self) -> Self::Values
[src]
fn insert_into(
self,
table: T
) -> InsertStatement<T, Self::Values, Insert, NoReturningClause>
[src]
self,
table: T
) -> InsertStatement<T, Self::Values, Insert, NoReturningClause>
impl PartialEq<RawTask> for RawTask
[src]
impl<__DB: Backend, __ST> Queryable<__ST, __DB> for RawTask where
(Vec<u8>, String, i8, String, i8, String, NaiveDateTime, NaiveDateTime, i16): Queryable<__ST, __DB>,
[src]
(Vec<u8>, String, i8, String, i8, String, NaiveDateTime, NaiveDateTime, i16): Queryable<__ST, __DB>,
type Row = <(Vec<u8>, String, i8, String, i8, String, NaiveDateTime, NaiveDateTime, i16) as Queryable<__ST, __DB>>::Row
The Rust type you'd like to map from. Read more
fn build(row: Self::Row) -> Self
[src]
impl<__DB: Backend> QueryableByName<__DB> for RawTask where
Vec<u8>: FromSql<SqlTypeOf<task_id>, __DB>,
String: FromSql<SqlTypeOf<task_key>, __DB>,
i8: FromSql<SqlTypeOf<task_type>, __DB>,
String: FromSql<SqlTypeOf<task_for>, __DB>,
i8: FromSql<SqlTypeOf<task_state>, __DB>,
String: FromSql<SqlTypeOf<data>, __DB>,
NaiveDateTime: FromSql<SqlTypeOf<create_time>, __DB>,
NaiveDateTime: FromSql<SqlTypeOf<execute_time>, __DB>,
i16: FromSql<SqlTypeOf<retried_times>, __DB>,
[src]
Vec<u8>: FromSql<SqlTypeOf<task_id>, __DB>,
String: FromSql<SqlTypeOf<task_key>, __DB>,
i8: FromSql<SqlTypeOf<task_type>, __DB>,
String: FromSql<SqlTypeOf<task_for>, __DB>,
i8: FromSql<SqlTypeOf<task_state>, __DB>,
String: FromSql<SqlTypeOf<data>, __DB>,
NaiveDateTime: FromSql<SqlTypeOf<create_time>, __DB>,
NaiveDateTime: FromSql<SqlTypeOf<execute_time>, __DB>,
i16: FromSql<SqlTypeOf<retried_times>, __DB>,
impl Serialize for RawTask
[src]
fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error> where
__S: Serializer,
[src]
__S: Serializer,
impl StructuralPartialEq for RawTask
[src]
impl<'insert> UndecoratedInsertRecord<table> for RawTask
[src]
Auto Trait Implementations
impl RefUnwindSafe for RawTask
impl Send for RawTask
impl Sync for RawTask
impl Unpin for RawTask
impl UnwindSafe for RawTask
Blanket Implementations
impl<T> Any for T where
T: 'static + ?Sized,
[src]
T: 'static + ?Sized,
impl<T> Borrow<T> for T where
T: ?Sized,
[src]
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
[src]
T: ?Sized,
fn borrow_mut(&mut self) -> &mut T
[src]
impl<T> DeserializeOwned for T where
T: Deserialize<'de>,
[src]
T: Deserialize<'de>,
impl<T> From<T> for T
[src]
impl<T, U> Into<U> for T where
U: From<T>,
[src]
U: From<T>,
impl<T> IntoSql for T
[src]
fn into_sql<T>(self) -> Self::Expression where
Self: AsExpression<T>,
[src]
Self: AsExpression<T>,
fn as_sql<'a, T>(&'a self) -> <&'a Self as AsExpression<T>>::Expression where
&'a Self: AsExpression<T>,
[src]
&'a Self: AsExpression<T>,
impl<T> ToOwned for T where
T: Clone,
[src]
T: Clone,
type Owned = T
The resulting type after obtaining ownership.
fn to_owned(&self) -> T
[src]
fn clone_into(&self, target: &mut T)
[src]
impl<T, U> TryFrom<U> for T where
U: Into<T>,
[src]
U: Into<T>,
type Error = Infallible
The type returned in the event of a conversion error.
fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>
[src]
impl<T, U> TryInto<U> for T where
U: TryFrom<T>,
[src]
U: TryFrom<T>,
type Error = <U as TryFrom<T>>::Error
The type returned in the event of a conversion error.
fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>
[src]
impl<V, T> VZip<V> for T where
V: MultiLane<T>,
V: MultiLane<T>,