Struct AttributeDispatcher

pub struct AttributeDispatcher { /* private fields */ }

Implementations

impl AttributeDispatcher

pub fn new(buffer: Arc<AttributeBuffer>, http: Arc<HttpClient>) -> Self

pub fn flush_once(&self) -> RovenueResult<usize>

List → POST → delete-on-success, oldest first, each mutation under the identity it was made under (a log out in between changes nothing). One POST carries the leading run of up to 200 rows that share a rovenue_id, coalesced within that run only; runs are sent in order until the queue is empty or a POST fails. Returns the number of distinct keys synced. On a retryable error the run stays queued.

pub fn start(self: Arc<Self>, scheduler: &PollingScheduler)

Register the periodic flush on the scheduler (30s, same cadence as sessions; only fires while foregrounded).