Struct PgClaimedBufferStore 

pub struct PgClaimedBufferStore { /* private fields */ }

Implementations

impl PgClaimedBufferStore

pub fn new(pool: PgPool, config: PgClaimedBufferStoreConfig) -> Self

pub async fn connect( pool: PgPool, config: PgClaimedBufferStoreConfig, ) -> Result<Self>

pub async fn prepare_schema( pool: &PgPool, config: &PgClaimedBufferStoreConfig, ) -> Result<()>

pub fn schema_sql(config: &PgClaimedBufferStoreConfig) -> String

Trait Implementations

impl ClaimedBufferStore for PgClaimedBufferStore

type Id = i64

async fn push(&self, event: &Event) -> Result<Self::Id>

async fn claim_batch( &self, owner_id: &OwnerId, max: usize, visibility: Duration, ) -> Result<Vec<ClaimedBufferEntry<Self::Id>>>

async fn ack(&self, id: &Self::Id) -> Result<()>

async fn nack(&self, id: &Self::Id) -> Result<()>

impl Clone for PgClaimedBufferStore

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.