Struct AuditReplicationCommands 

pub struct AuditReplicationCommands;

Redis commands for audit stream replication.

Implementations

impl AuditReplicationCommands

pub fn publish_fields(entry_json: &str) -> Vec<(&str, &str)>

Publish an audit entry to the stream. XADD key MAXLEN ~ max_length * data

pub fn create_group(stream_key: &str, group: &str) -> Vec<String>

Create consumer group (idempotent with MKSTREAM).

pub fn read_new( stream_key: &str, group: &str, consumer: &str, count: u64, ) -> Vec<String>

Read new entries from the stream for a consumer.

pub fn ack(stream_key: &str, group: &str, ids: &[&str]) -> Vec<String>

Acknowledge processed entries.