Struct StreamIngester 

pub struct StreamIngester { /* private fields */ }

채널 기반 스트리밍 수집 파이프라인

백그라운드 스레드가 채널에서 StreamEvent 배치를 수신하여 batch_size 또는 max_latency 조건 충족 시 DBX에 일괄 반영합니다.

Implementations

impl StreamIngester

pub fn new( db: Arc<Database>, table: &str, batch_size: usize, max_latency: Duration, ) -> Self

스트림 인제스터 생성

인수

• db - 대상 데이터베이스 (Arc 공유)
• table - 이벤트를 적용할 테이블 이름
• batch_size - 이 이벤트 수에 도달하면 즉시 flush
• max_latency - 버퍼가 차지 않아도 이 시간마다 강제 flush

pub fn sender(&self) -> SyncSender<Vec<StreamEvent>>

이벤트 배치 송신용 sender 클론 반환

여러 스레드에서 동시에 이벤트를 전송할 수 있습니다.

pub fn flush(self) -> DbxResult<()>

채널을 닫고, 백그라운드 스레드가 남은 이벤트를 모두 flush한 뒤 종료할 때까지 대기

이 메서드 호출 후에는 sender를 통한 이벤트 전송이 불가능합니다.