Struct PostgresStorage 

pub struct PostgresStorage { /* private fields */ }

Implementations

impl PostgresStorage

pub fn new(db_url: String) -> Result<Self, Whatever>

pub async fn client(&self) -> Result<Object, Whatever>

pub async fn statement( &self, client: &Object, query: &str, ) -> Result<Statement, Whatever>

pub async fn query( &self, client: &Object, stmt: &Statement, params: &[&(dyn ToSql + Sync)], ) -> Result<Vec<Row>, Whatever>

Trait Implementations

impl FeedStorage for PostgresStorage

async fn insert_timeline_entry( &mut self, entry: &TimelineEntry, ) -> Result<(), Self::Error>

Inserts a new timeline entry into the database, in case of conflict it tries to update the last operation ID.

type Error = Whatever

async fn get_last_processed_operation( &self, rid: &RepoId, cob_id: &ObjectId, typename: &TypeName, ) -> Result<Option<Oid>, Self::Error>

Get the last processed operation ID for a specific repository and COB (Collaborative Object)

async fn operation_exists( &self, operation_id: &Oid, ) -> Result<bool, Self::Error>

Check if an operation already exists in storage (for duplicate prevention)

async fn insert_batch( &mut self, entries: &[OperationEntry], ) -> Result<(), Self::Error>

Insert a batch of operations entries into storage

async fn get_stats(&self) -> Result<StorageStats, Self::Error>

Get statistics about stored data (optional, used for debugging/monitoring)