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>)

Bases: object

The configuration class created by the producer.

Attributes

auto_clean_up	Specifies whether the stream enables the auto-cleanup feature.
delay_flush_time	After Send, Flush will be triggered after a delay up to the specified duration.
encrypt_stream	Specifies whether content encryption is enabled for the stream.
max_stream_size	Specifies the maximum shared memory size that a stream can use on a worker, in bytes (B).
page_size	Represents the buffer page size for the producer, in bytes (B).
reserve_size	Represents the reserved memory size in bytes (B).
retain_for_num_consumers	The data sent by the producer will be retained until received by the Nth consumer.
extend_config	Extended configuration stored as a dictionary, allowing users to customize configuration items.

Methods

__init__