Struct StreamResultSetConfig 

pub struct StreamResultSetConfig {
    pub batch_size: usize,
    pub backpressure_threshold: usize,
    pub pagination_strategy: PaginationStrategy,
    pub keyset_column: Option<String>,
    pub order_direction: OrderDirection,
    pub db_type: DbType,
}

流式结果集配置

Fields

batch_size: usize

批次大小（默认 1000）

backpressure_threshold: usize

背压阈值（默认 10000）

pagination_strategy: PaginationStrategy

分页策略

keyset_column: Option<String>

keyset 列名（Keyset 策略时必须设置）

order_direction: OrderDirection

排序方向

db_type: DbType

数据库类型

Implementations

impl StreamResultSetConfig

pub fn new(db_type: DbType) -> Self

pub fn with_batch_size(self, batch_size: usize) -> Self

pub fn with_backpressure_threshold(self, threshold: usize) -> Self

pub fn with_pagination_strategy(self, strategy: PaginationStrategy) -> Self

pub fn with_keyset_column(self, column: impl Into<String>) -> Self

pub fn with_order_direction(self, direction: OrderDirection) -> Self

pub fn validate(&self) -> Result<(), String>

校验配置合法性

Trait Implementations

impl Clone for StreamResultSetConfig

fn clone(&self) -> StreamResultSetConfig

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for StreamResultSetConfig

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for StreamResultSetConfig

fn default() -> Self

Returns the “default value” for a type.