pub struct RealtimeSyncConfig {
pub mode: SyncMode,
pub batch_size: usize,
}Expand description
HTAP 실시간 동기화 설정
Fields§
§mode: SyncMode동기화 모드
batch_size: usize배치 크기 (flush 당 최대 처리 행 수)
Implementations§
Source§impl RealtimeSyncConfig
impl RealtimeSyncConfig
Sourcepub fn async_batch(max_latency_ms: u64, batch_size: usize) -> Self
pub fn async_batch(max_latency_ms: u64, batch_size: usize) -> Self
비동기 배치 동기화 설정 생성
Sourcepub fn is_immediate(&self) -> bool
pub fn is_immediate(&self) -> bool
현재 설정이 즉시 동기화 모드인지 확인
Sourcepub fn should_flush(&self, row_count: usize) -> bool
pub fn should_flush(&self, row_count: usize) -> bool
Delta 행 수가 flush 기준에 도달했는지 확인
Immediate → 항상 true
Threshold(n) → row_count >= n
AsyncBatch → false (백그라운드 스레드가 결정)
Trait Implementations§
Source§impl Clone for RealtimeSyncConfig
impl Clone for RealtimeSyncConfig
Source§fn clone(&self) -> RealtimeSyncConfig
fn clone(&self) -> RealtimeSyncConfig
Returns a duplicate 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 RealtimeSyncConfig
impl Debug for RealtimeSyncConfig
Auto Trait Implementations§
impl Freeze for RealtimeSyncConfig
impl RefUnwindSafe for RealtimeSyncConfig
impl Send for RealtimeSyncConfig
impl Sync for RealtimeSyncConfig
impl Unpin for RealtimeSyncConfig
impl UnsafeUnpin for RealtimeSyncConfig
impl UnwindSafe for RealtimeSyncConfig
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§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>
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 more