Struct StreamEntry 

pub struct StreamEntry {
    pub id: String,
    pub fields: HashMap<String, String>,
}

Represents a single entry in a Redis Stream

Fields

id: String

The unique ID of the entry (e.g., “1234567890123-0”)

fields: HashMap<String, String>

The field-value pairs of the entry

Implementations

impl StreamEntry

pub fn new(id: String, fields: HashMap<String, String>) -> Self

Create a new stream entry

pub fn get_field(&self, field: &str) -> Option<&String>

Get a field value by name

pub fn has_field(&self, field: &str) -> bool

Check if the entry has a specific field

pub fn timestamp(&self) -> Option<u64>

Get the timestamp part of the entry ID

Examples

use redis_oxide::StreamEntry;
use std::collections::HashMap;

let entry = StreamEntry::new("1234567890123-0".to_string(), HashMap::new());
assert_eq!(entry.timestamp(), Some(1234567890123));

pub fn sequence(&self) -> Option<u64>

Get the sequence number part of the entry ID

Examples

use redis_oxide::StreamEntry;
use std::collections::HashMap;

let entry = StreamEntry::new("1234567890123-5".to_string(), HashMap::new());
assert_eq!(entry.sequence(), Some(5));

Trait Implementations

impl Clone for StreamEntry

fn clone(&self) -> StreamEntry

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for StreamEntry

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

Formats the value using the given formatter.