Struct Projection 

pub struct Projection { /* private fields */ }

Implementations

impl Projection

pub fn open( root: &Path, ordering: &K1TxnOrdering, ) -> Result<(Self, Option<TxId>), String>

pub fn apply( &self, callback_txid: TxId, payload: &[u8], ) -> Result<AppliedEvent, String>

pub fn status( &self, fragment_id: FragmentId, ) -> Result<Option<FragmentStatus>, String>

pub fn queued(&self) -> Result<Vec<FragmentId>, String>

pub fn running(&self) -> Result<Vec<InterruptedFragment>, String>

pub fn validate_labels( &self, fragment_id: FragmentId, labels: &[SpeakerLabelV1], ) -> Result<TxId, String>

pub fn clear(&self) -> Result<(), String>