Struct MemorySerialBackend 

pub struct MemorySerialBackend { /* private fields */ }

基于内存 + tokio::sync::Mutex 的单号生成后端

适用于单机部署。计数器按 {rule_key}:{cycle_value} 维度分组存储。

示例

let backend = MemorySerialBackend::new();
backend.register_rule(SerialRule::new("order", "ORD{SEQ:6}")).await?;
let no = backend.generate("order").await?;

Implementations

impl MemorySerialBackend

pub fn new() -> Self

创建内存后端（最多保留 10000 条记录）

pub fn with_max_records(self, max: usize) -> Self

设置最大记录数

Trait Implementations

impl Default for MemorySerialBackend

fn default() -> Self

Returns the “default value” for a type.

impl SerialGenerator for MemorySerialBackend

fn generate<'life0, 'life1, 'async_trait>( &'life0 self, rule_key: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<String, SerialError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

生成下一个单号

fn batch_generate<'life0, 'life1, 'async_trait>( &'life0 self, rule_key: &'life1 str, count: u32, ) -> Pin<Box<dyn Future<Output = Result<Vec<String>, SerialError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

批量生成单号

fn peek<'life0, 'life1, 'async_trait>( &'life0 self, rule_key: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<String, SerialError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

预览下一个单号（不消耗计数器）

fn register_rule<'life0, 'async_trait>( &'life0 self, rule: SerialRule, ) -> Pin<Box<dyn Future<Output = Result<(), SerialError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

运行时注册/更新一条规则

fn remove_rule<'life0, 'life1, 'async_trait>( &'life0 self, rule_key: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<(), SerialError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

运行时删除一条规则

fn enable_rule<'life0, 'life1, 'async_trait>( &'life0 self, rule_key: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<(), SerialError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

运行时启用一条规则

fn disable_rule<'life0, 'life1, 'async_trait>( &'life0 self, rule_key: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<(), SerialError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

运行时禁用一条规则

fn query_records<'life0, 'life1, 'async_trait>( &'life0 self, rule_key: &'life1 str, page: u64, page_size: u64, ) -> Pin<Box<dyn Future<Output = Result<(Vec<SerialRecord>, u64), SerialError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

查询生成记录（分页），返回 (记录列表, 总数)

fn list_rules<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Vec<SerialRule>, SerialError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

获取所有已注册的规则