Struct PublicationLease 

pub struct PublicationLease { /* private fields */ }

Implementations

impl PublicationLease

pub fn stream(&self) -> &PluginStream

pub fn publish( &self, payload: Vec<u8>, missed: u64, ) -> Result<(), StreamPublicationError>

pub fn publish_row( &self, row: PublicationRow, missed: u64, ) -> Result<(), StreamPublicationError>

pub fn admit_row( &self, row: PublicationRow, wire_sequence: u64, missed: u64, ) -> Result<ManagedPublication, StreamPublicationError>

pub fn revoke(&self)

pub async fn ingested(&self) -> Result<(), StreamPublicationError>

Trait Implementations

impl Drop for PublicationLease

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.