pub struct ActiveModel {Show 29 fields
pub table_id: ActiveValue<TableId>,
pub name: ActiveValue<String>,
pub optional_associated_source_id: ActiveValue<Option<SourceId>>,
pub table_type: ActiveValue<TableType>,
pub belongs_to_job_id: ActiveValue<Option<ObjectId>>,
pub columns: ActiveValue<ColumnCatalogArray>,
pub pk: ActiveValue<ColumnOrderArray>,
pub distribution_key: ActiveValue<I32Array>,
pub stream_key: ActiveValue<I32Array>,
pub append_only: ActiveValue<bool>,
pub fragment_id: ActiveValue<Option<FragmentId>>,
pub vnode_col_index: ActiveValue<Option<i32>>,
pub row_id_index: ActiveValue<Option<i32>>,
pub value_indices: ActiveValue<I32Array>,
pub definition: ActiveValue<String>,
pub handle_pk_conflict_behavior: ActiveValue<HandleConflictBehavior>,
pub version_column_index: ActiveValue<Option<i32>>,
pub read_prefix_len_hint: ActiveValue<i32>,
pub watermark_indices: ActiveValue<I32Array>,
pub dist_key_in_pk: ActiveValue<I32Array>,
pub dml_fragment_id: ActiveValue<Option<FragmentId>>,
pub cardinality: ActiveValue<Option<Cardinality>>,
pub cleaned_by_watermark: ActiveValue<bool>,
pub description: ActiveValue<Option<String>>,
pub version: ActiveValue<Option<TableVersion>>,
pub retention_seconds: ActiveValue<Option<i32>>,
pub incoming_sinks: ActiveValue<I32Array>,
pub cdc_table_id: ActiveValue<Option<String>>,
pub vnode_count: ActiveValue<i32>,
}Expand description
Generated by sea-orm-macros
Fields§
§table_id: ActiveValue<TableId>Generated by sea-orm-macros
name: ActiveValue<String>Generated by sea-orm-macros
optional_associated_source_id: ActiveValue<Option<SourceId>>Generated by sea-orm-macros
table_type: ActiveValue<TableType>Generated by sea-orm-macros
belongs_to_job_id: ActiveValue<Option<ObjectId>>Generated by sea-orm-macros
columns: ActiveValue<ColumnCatalogArray>Generated by sea-orm-macros
pk: ActiveValue<ColumnOrderArray>Generated by sea-orm-macros
distribution_key: ActiveValue<I32Array>Generated by sea-orm-macros
stream_key: ActiveValue<I32Array>Generated by sea-orm-macros
append_only: ActiveValue<bool>Generated by sea-orm-macros
fragment_id: ActiveValue<Option<FragmentId>>Generated by sea-orm-macros
vnode_col_index: ActiveValue<Option<i32>>Generated by sea-orm-macros
row_id_index: ActiveValue<Option<i32>>Generated by sea-orm-macros
value_indices: ActiveValue<I32Array>Generated by sea-orm-macros
definition: ActiveValue<String>Generated by sea-orm-macros
handle_pk_conflict_behavior: ActiveValue<HandleConflictBehavior>Generated by sea-orm-macros
version_column_index: ActiveValue<Option<i32>>Generated by sea-orm-macros
read_prefix_len_hint: ActiveValue<i32>Generated by sea-orm-macros
watermark_indices: ActiveValue<I32Array>Generated by sea-orm-macros
dist_key_in_pk: ActiveValue<I32Array>Generated by sea-orm-macros
dml_fragment_id: ActiveValue<Option<FragmentId>>Generated by sea-orm-macros
cardinality: ActiveValue<Option<Cardinality>>Generated by sea-orm-macros
cleaned_by_watermark: ActiveValue<bool>Generated by sea-orm-macros
description: ActiveValue<Option<String>>Generated by sea-orm-macros
version: ActiveValue<Option<TableVersion>>Generated by sea-orm-macros
retention_seconds: ActiveValue<Option<i32>>Generated by sea-orm-macros
incoming_sinks: ActiveValue<I32Array>Generated by sea-orm-macros
cdc_table_id: ActiveValue<Option<String>>Generated by sea-orm-macros
vnode_count: ActiveValue<i32>Generated by sea-orm-macros
Trait Implementations§
source§impl ActiveModelBehavior for ActiveModel
impl ActiveModelBehavior for ActiveModel
§fn before_save<'life0, 'async_trait, C>(
self,
db: &'life0 C,
insert: bool,
) -> Pin<Box<dyn Future<Output = Result<Self, DbErr>> + Send + 'async_trait>>where
'life0: 'async_trait,
C: ConnectionTrait + 'async_trait,
Self: Send + 'async_trait,
fn before_save<'life0, 'async_trait, C>(
self,
db: &'life0 C,
insert: bool,
) -> Pin<Box<dyn Future<Output = Result<Self, DbErr>> + Send + 'async_trait>>where
'life0: 'async_trait,
C: ConnectionTrait + 'async_trait,
Self: Send + 'async_trait,
Will be called before
ActiveModel::insert, ActiveModel::update, and ActiveModel::save§fn after_save<'life0, 'async_trait, C>(
model: <Self::Entity as EntityTrait>::Model,
db: &'life0 C,
insert: bool,
) -> Pin<Box<dyn Future<Output = Result<<Self::Entity as EntityTrait>::Model, DbErr>> + Send + 'async_trait>>where
'life0: 'async_trait,
C: ConnectionTrait + 'async_trait,
Self: Send + 'async_trait,
fn after_save<'life0, 'async_trait, C>(
model: <Self::Entity as EntityTrait>::Model,
db: &'life0 C,
insert: bool,
) -> Pin<Box<dyn Future<Output = Result<<Self::Entity as EntityTrait>::Model, DbErr>> + Send + 'async_trait>>where
'life0: 'async_trait,
C: ConnectionTrait + 'async_trait,
Self: Send + 'async_trait,
Will be called after
ActiveModel::insert, ActiveModel::update, and ActiveModel::savesource§impl ActiveModelTrait for ActiveModel
impl ActiveModelTrait for ActiveModel
source§fn take(
&mut self,
c: <Self::Entity as EntityTrait>::Column,
) -> ActiveValue<Value>
fn take( &mut self, c: <Self::Entity as EntityTrait>::Column, ) -> ActiveValue<Value>
Get a mutable [ActiveValue] from an ActiveModel
source§fn get(&self, c: <Self::Entity as EntityTrait>::Column) -> ActiveValue<Value>
fn get(&self, c: <Self::Entity as EntityTrait>::Column) -> ActiveValue<Value>
Get a immutable [ActiveValue] from an ActiveModel
source§fn set(&mut self, c: <Self::Entity as EntityTrait>::Column, v: Value)
fn set(&mut self, c: <Self::Entity as EntityTrait>::Column, v: Value)
Set the Value into an ActiveModel
source§fn not_set(&mut self, c: <Self::Entity as EntityTrait>::Column)
fn not_set(&mut self, c: <Self::Entity as EntityTrait>::Column)
Set the state of an [ActiveValue] to the not set state
source§fn is_not_set(&self, c: <Self::Entity as EntityTrait>::Column) -> bool
fn is_not_set(&self, c: <Self::Entity as EntityTrait>::Column) -> bool
Check the state of a [ActiveValue]
source§fn reset(&mut self, c: <Self::Entity as EntityTrait>::Column)
fn reset(&mut self, c: <Self::Entity as EntityTrait>::Column)
Reset the value from [ActiveValue::Unchanged] to [ActiveValue::Set],
leaving [ActiveValue::NotSet] untouched.
§fn reset_all(self) -> Self
fn reset_all(self) -> Self
Reset all values from [ActiveValue::Unchanged] to [ActiveValue::Set],
leaving [ActiveValue::NotSet] untouched.
§fn get_primary_key_value(&self) -> Option<ValueTuple>
fn get_primary_key_value(&self) -> Option<ValueTuple>
Get the primary key of the ActiveModel Read more
§fn insert<'a, 'async_trait, C>(
self,
db: &'a C,
) -> Pin<Box<dyn Future<Output = Result<<Self::Entity as EntityTrait>::Model, DbErr>> + Send + 'async_trait>>where
'a: 'async_trait,
<Self::Entity as EntityTrait>::Model: IntoActiveModel<Self>,
Self: ActiveModelBehavior + 'a + Send + 'async_trait,
C: ConnectionTrait + 'async_trait,
fn insert<'a, 'async_trait, C>(
self,
db: &'a C,
) -> Pin<Box<dyn Future<Output = Result<<Self::Entity as EntityTrait>::Model, DbErr>> + Send + 'async_trait>>where
'a: 'async_trait,
<Self::Entity as EntityTrait>::Model: IntoActiveModel<Self>,
Self: ActiveModelBehavior + 'a + Send + 'async_trait,
C: ConnectionTrait + 'async_trait,
Perform an
INSERT operation on the ActiveModel Read more§fn update<'a, 'async_trait, C>(
self,
db: &'a C,
) -> Pin<Box<dyn Future<Output = Result<<Self::Entity as EntityTrait>::Model, DbErr>> + Send + 'async_trait>>where
'a: 'async_trait,
<Self::Entity as EntityTrait>::Model: IntoActiveModel<Self>,
Self: ActiveModelBehavior + 'a + Send + 'async_trait,
C: ConnectionTrait + 'async_trait,
fn update<'a, 'async_trait, C>(
self,
db: &'a C,
) -> Pin<Box<dyn Future<Output = Result<<Self::Entity as EntityTrait>::Model, DbErr>> + Send + 'async_trait>>where
'a: 'async_trait,
<Self::Entity as EntityTrait>::Model: IntoActiveModel<Self>,
Self: ActiveModelBehavior + 'a + Send + 'async_trait,
C: ConnectionTrait + 'async_trait,
Perform the
UPDATE operation on an ActiveModel Read more§fn save<'a, 'async_trait, C>(
self,
db: &'a C,
) -> Pin<Box<dyn Future<Output = Result<Self, DbErr>> + Send + 'async_trait>>where
'a: 'async_trait,
<Self::Entity as EntityTrait>::Model: IntoActiveModel<Self>,
Self: ActiveModelBehavior + 'a + Send + 'async_trait,
C: ConnectionTrait + 'async_trait,
fn save<'a, 'async_trait, C>(
self,
db: &'a C,
) -> Pin<Box<dyn Future<Output = Result<Self, DbErr>> + Send + 'async_trait>>where
'a: 'async_trait,
<Self::Entity as EntityTrait>::Model: IntoActiveModel<Self>,
Self: ActiveModelBehavior + 'a + Send + 'async_trait,
C: ConnectionTrait + 'async_trait,
Insert the model if primary key is
NotSet, update otherwise.
Only works if the entity has auto increment primary key.§fn delete<'a, 'async_trait, C>(
self,
db: &'a C,
) -> Pin<Box<dyn Future<Output = Result<DeleteResult, DbErr>> + Send + 'async_trait>>where
'a: 'async_trait,
Self: ActiveModelBehavior + 'a + Send + 'async_trait,
C: ConnectionTrait + 'async_trait,
fn delete<'a, 'async_trait, C>(
self,
db: &'a C,
) -> Pin<Box<dyn Future<Output = Result<DeleteResult, DbErr>> + Send + 'async_trait>>where
'a: 'async_trait,
Self: ActiveModelBehavior + 'a + Send + 'async_trait,
C: ConnectionTrait + 'async_trait,
Delete an active model by its primary key Read more
§fn set_from_json(&mut self, json: Value) -> Result<(), DbErr>where
<Self::Entity as EntityTrait>::Model: IntoActiveModel<Self> + for<'de> Deserialize<'de>,
fn set_from_json(&mut self, json: Value) -> Result<(), DbErr>where
<Self::Entity as EntityTrait>::Model: IntoActiveModel<Self> + for<'de> Deserialize<'de>,
Set the corresponding attributes in the ActiveModel from a JSON value Read more
§fn from_json(json: Value) -> Result<Self, DbErr>where
<Self::Entity as EntityTrait>::Model: IntoActiveModel<Self> + for<'de> Deserialize<'de>,
fn from_json(json: Value) -> Result<Self, DbErr>where
<Self::Entity as EntityTrait>::Model: IntoActiveModel<Self> + for<'de> Deserialize<'de>,
Create ActiveModel from a JSON value
§fn is_changed(&self) -> bool
fn is_changed(&self) -> bool
Return
true if any attribute of ActiveModel is Setsource§impl Clone for ActiveModel
impl Clone for ActiveModel
source§fn clone(&self) -> ActiveModel
fn clone(&self) -> ActiveModel
Returns a copy of the value. Read more
1.0.0 · source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source. Read moresource§impl Debug for ActiveModel
impl Debug for ActiveModel
source§impl Default for ActiveModel
impl Default for ActiveModel
source§impl From<Model> for ActiveModel
impl From<Model> for ActiveModel
source§impl From<Table> for ActiveModel
impl From<Table> for ActiveModel
source§impl IntoActiveModel<ActiveModel> for Model
impl IntoActiveModel<ActiveModel> for Model
source§fn into_active_model(self) -> ActiveModel
fn into_active_model(self) -> ActiveModel
Method to call to perform the conversion
source§impl PartialEq for ActiveModel
impl PartialEq for ActiveModel
source§impl TryFrom<ActiveModel> for Model
impl TryFrom<ActiveModel> for Model
source§impl TryIntoModel<Model> for ActiveModel
impl TryIntoModel<Model> for ActiveModel
source§fn try_into_model(self) -> Result<Model, DbErr>
fn try_into_model(self) -> Result<Model, DbErr>
Method to call to perform the conversion
impl StructuralPartialEq for ActiveModel
Auto Trait Implementations§
impl Freeze for ActiveModel
impl RefUnwindSafe for ActiveModel
impl Send for ActiveModel
impl Sync for ActiveModel
impl Unpin for ActiveModel
impl UnwindSafe for ActiveModel
Blanket Implementations§
source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
source§unsafe fn clone_to_uninit(&self, dst: *mut T)
unsafe fn clone_to_uninit(&self, dst: *mut T)
🔬This is a nightly-only experimental API. (
clone_to_uninit)§impl<T> FutureExt for T
impl<T> FutureExt for T
§fn with_context(self, otel_cx: Context) -> WithContext<Self>
fn with_context(self, otel_cx: Context) -> WithContext<Self>
§fn with_current_context(self) -> WithContext<Self>
fn with_current_context(self) -> WithContext<Self>
§impl<T> Instrument for T
impl<T> Instrument for T
§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
source§impl<T> Instrument for T
impl<T> Instrument for T
source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
§impl<A> IntoActiveModel<A> for Awhere
A: ActiveModelTrait,
impl<A> IntoActiveModel<A> for Awhere
A: ActiveModelTrait,
§fn into_active_model(self) -> A
fn into_active_model(self) -> A
Method to call to perform the conversion
source§impl<T> IntoEither for T
impl<T> IntoEither for T
source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moresource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moresource§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T in a tonic::Request§impl<T> IntoResult<T> for T
impl<T> IntoResult<T> for T
type Err = Infallible
fn into_result(self) -> Result<T, <T as IntoResult<T>>::Err>
source§impl<M> MetricVecRelabelExt for M
impl<M> MetricVecRelabelExt for M
source§fn relabel(
self,
metric_level: MetricLevel,
relabel_threshold: MetricLevel,
) -> RelabeledMetricVec<M>
fn relabel( self, metric_level: MetricLevel, relabel_threshold: MetricLevel, ) -> RelabeledMetricVec<M>
Equivalent to
RelabeledMetricVec::with_metric_level.source§fn relabel_n(
self,
metric_level: MetricLevel,
relabel_threshold: MetricLevel,
relabel_num: usize,
) -> RelabeledMetricVec<M>
fn relabel_n( self, metric_level: MetricLevel, relabel_threshold: MetricLevel, relabel_num: usize, ) -> RelabeledMetricVec<M>
Equivalent to
RelabeledMetricVec::with_metric_level_relabel_n.source§fn relabel_debug_1(
self,
relabel_threshold: MetricLevel,
) -> RelabeledMetricVec<M>
fn relabel_debug_1( self, relabel_threshold: MetricLevel, ) -> RelabeledMetricVec<M>
Equivalent to
RelabeledMetricVec::with_metric_level_relabel_n with metric_level set to
MetricLevel::Debug and relabel_num set to 1.