Struct cdc::endpoint::Initializer

[+] Show declaration

struct Initializer {
    sched: Scheduler<Task>,
    sink: Sink,
    region_id: u64,
    observe_id: ObserveID,
    downstream_id: DownstreamID,
    downstream_state: Arc<AtomicCell<DownstreamState>>,
    conn_id: ConnID,
    request_id: u64,
    checkpoint_ts: TimeStamp,
    txn_extra_op: TxnExtraOp,
    speed_limter: Limiter,
    max_scan_batch_bytes: usize,
    max_scan_batch_size: usize,
    build_resolver: bool,
}

Fields

sched: Scheduler<Task>

sink: Sink

region_id: u64

observe_id: ObserveID

downstream_id: DownstreamID

downstream_state: Arc<AtomicCell<DownstreamState>>

conn_id: ConnID

request_id: u64

checkpoint_ts: TimeStamp

txn_extra_op: TxnExtraOp

speed_limter: Limiter

max_scan_batch_bytes: usize

max_scan_batch_size: usize

build_resolver: bool

Implementations

impl Initializer[−]

async fn on_change_cmd(&mut self, resp: ReadResponse<RocksSnapshot>)

async fn async_incremental_scan<S: Snapshot + 'static>(
    &mut self,
    snap: S,
    region: Region,
    require_barrier: bool
)

async fn scan_batch<S: Snapshot>(
    &self,
    scanner: &mut DeltaScanner<S>,
    resolver: Option<&mut Resolver>
) -> Result<Vec<Option<TxnEntry>>>

async fn sink_scan_events(
    &mut self,
    entries: Vec<Option<TxnEntry>>,
    done: bool,
    require_barrier: bool
) -> Result<()>

fn finish_building_resolver(
    &self,
    resolver: Resolver,
    region: Region,
    takes: Duration
)

fn deregister_downstream(&self, err: Option<Error>)