Struct AttributeBuffer

pub struct AttributeBuffer { /* private fields */ }

Local dirty-mutation queue for subscriber attributes. Unlike the session buffer, callers list then delete separately so the dispatcher can keep rows queued when a flush fails (attributes are durable user data, not fire-and-forget telemetry).

Implementations

impl AttributeBuffer

pub fn new(store: Arc<CacheStore>) -> Self

pub fn set( &self, rovenue_id: &str, key: &str, value: Option<&str>, ) -> RovenueResult<()>

Queue a single attribute mutation under rovenue_id, the wire identity it was made under. None value means delete.

pub fn list(&self, limit: usize) -> RovenueResult<Vec<AttributeMutationRow>>

pub fn delete(&self, ids: &[i64]) -> RovenueResult<()>