Enum FileConsumerMode 

pub enum FileConsumerMode {
    Consume {
        delete: bool,
    },
    Subscribe {
        delete: bool,
    },
    GroupSubscribe {
        group_id: String,
        read_from_tail: bool,
    },
}

Variants

Consume

Queue Mode: Standard point-to-point consumption. Reads from the start of the file. If delete is true, processed lines are physically removed from the file once they are successfully acknowledged.

Fields

delete: bool

Subscribe

Broadcast Mode: Pub-sub style consumption. Tails the file by starting at the current end. If delete is true, lines are removed only after all local application subscribers for this specific file have acknowledged them.

Fields

delete: bool

GroupSubscribe

Persistent Mode: Consumption with external offset tracking. Saves the last read byte position to a .offset file identified by the group_id. This allows the consumer to resume exactly where it left off after a restart without deleting data or requiring the bridge to stay running.

Fields

group_id: String

The consumer group ID that is used for offset tracking. Should be unique.

read_from_tail: bool

If true, starts reading from the end of the file if no offset is stored. If false, starts reading from the beginning.

Trait Implementations

impl Clone for FileConsumerMode

fn clone(&self) -> FileConsumerMode

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for FileConsumerMode

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

Formats the value using the given formatter.

impl Default for FileConsumerMode

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for FileConsumerMode

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for FileConsumerMode

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.