Struct pulsar::producer::ProducerOptions

pub struct ProducerOptions {
    pub encrypted: Option<bool>,
    pub metadata: BTreeMap<String, String>,
    pub schema: Option<Schema>,
    pub batch_size: Option<u32>,
    pub batch_byte_size: Option<usize>,
    pub compression: Option<Compression>,
    pub access_mode: Option<i32>,
}

Configuration options for producers

Fields

encrypted: Option<bool>

end to end message encryption (not implemented yet)

metadata: BTreeMap<String, String>

user defined properties added to all messages

schema: Option<Schema>

schema used to encode this producer’s messages

batch_size: Option<u32>

batch message size

batch_byte_size: Option<usize>

batch size in bytes treshold (only relevant when batch_size active). batch is sent when batch size in bytes is reached

compression: Option<Compression>

algorithm used to compress the messages

access_mode: Option<i32>

producer access mode: shared = 0, exclusive = 1, waitforexclusive =2, exclusivewithoutfencing =3

Trait Implementations

impl Clone for ProducerOptions

fn clone(&self) -> ProducerOptions

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Default for ProducerOptions

fn default() -> ProducerOptions

Returns the “default value” for a type.