Struct Store 

pub struct Store { /* private fields */ }

PostgreSQL-backed storage. Also exported as PostgresBackend.

Implementations

impl Store

pub fn new(db: PgPool) -> Self

pub fn with_block_size(self, block_size: usize) -> Self

pub fn pool(&self) -> &PgPool

Trait Implementations

impl Clone for Store

fn clone(&self) -> Store

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl StorageBackend for Store

async fn create_bucket(&self, name: &str) -> Result<BucketInfo, Post3Error>

async fn head_bucket( &self, name: &str, ) -> Result<Option<BucketInfo>, Post3Error>

async fn delete_bucket(&self, name: &str) -> Result<(), Post3Error>

async fn list_buckets(&self) -> Result<Vec<BucketInfo>, Post3Error>

async fn put_object( &self, bucket: &str, key: &str, content_type: Option<&str>, metadata: HashMap<String, String>, body: Bytes, ) -> Result<PutObjectResult, Post3Error>

async fn get_object( &self, bucket: &str, key: &str, ) -> Result<GetObjectResult, Post3Error>

async fn head_object( &self, bucket: &str, key: &str, ) -> Result<Option<HeadObjectResult>, Post3Error>

async fn delete_object(&self, bucket: &str, key: &str) -> Result<(), Post3Error>

async fn list_objects_v2( &self, bucket: &str, prefix: Option<&str>, continuation_token: Option<&str>, max_keys: Option<i64>, delimiter: Option<&str>, ) -> Result<ListObjectsResult, Post3Error>

async fn create_multipart_upload( &self, bucket: &str, key: &str, content_type: Option<&str>, metadata: HashMap<String, String>, ) -> Result<CreateMultipartUploadResult, Post3Error>

async fn upload_part( &self, bucket: &str, key: &str, upload_id: &str, part_number: i32, body: Bytes, ) -> Result<UploadPartResult, Post3Error>

async fn complete_multipart_upload( &self, bucket: &str, key: &str, upload_id: &str, part_etags: Vec<(i32, String)>, ) -> Result<CompleteMultipartUploadResult, Post3Error>

async fn abort_multipart_upload( &self, bucket: &str, key: &str, upload_id: &str, ) -> Result<(), Post3Error>

async fn list_parts( &self, bucket: &str, key: &str, upload_id: &str, max_parts: Option<i32>, part_number_marker: Option<i32>, ) -> Result<ListPartsResult, Post3Error>

async fn list_multipart_uploads( &self, bucket: &str, prefix: Option<&str>, key_marker: Option<&str>, upload_id_marker: Option<&str>, max_uploads: Option<i32>, ) -> Result<ListMultipartUploadsResult, Post3Error>