yr.ProducerConfig#
- class yr.ProducerConfig(delay_flush_time: int = 5, page_size: int = 1048576, max_stream_size: int = 1073741824, auto_clean_up: bool = False, encrypt_stream: bool = False, retain_for_num_consumers: int = 0, reserve_size: int = 0, extend_config: ~typing.Dict[str, str] = <factory>)#
基类:
object生产者创建的配置类。
属性:
指定流是否开启自动清理功能。
发送数据后最多延迟相应时长后触发一次刷新。
指定流是否开启内容加密功能。
指定一个流可使用的最大共享内存大小,单位为字节(B)。
表示生产者对应的缓冲页大小,单位为字节(B)。
表示预留内存大小,单位为字节(B)。
生产者发送的数据将保留到第
N个消费者接收。扩展配置,以字典形式存储,允许用户自定义配置项。
方法: