Struct Executor

pub struct Executor {
    pub builder: Builder,
}

Fields

builder: Builder

Implementations

impl Executor

pub fn new(builder: Builder) -> Self

Creates a new Executor instance with the provided HTTP method, URL, client, and headers.

Arguments

• method - The HTTP method for the request.
• url - The URL for the request.
• client - The Client to use for making the request.
• headers - The HeaderMap containing the headers for the request.

pub async fn execute(self) -> Result<Response, Error>

Executes the constructed HTTP request and returns the response as a Result.

Returns

• Result<Response, Error> - The result of the executed request.

Example

use supabase_storage::{
    Storage,
    config::SupabaseConfig,
};
use dotenv::dotenv;

#[tokio::main]
async fn main() {
    dotenv().ok();
    let config = SupabaseConfig::default();
    let storage = Storage::new_with_config(config);
    let response = storage
        .from()
        .get_bucket_details("thefux")
        .execute()
        .await
        .unwrap()
        .text()
        .await
        .unwrap();

    // Now 'response' contains the reponse as text.
    println!("{:?}", response);
}

Examples found in repository

examples/get_object.rs (line 18)

async fn main() {
    dotenv().ok();

    let config = SupabaseConfig::default();
    let storage = Storage::new_with_config(config);

    let bucket_name = "thefux";
    let object = "btc.pdf";

    let response = storage
        .from()
        .get_object(bucket_name, object)
        .execute()
        .await
        .unwrap();

    println!("{:?}", response);
}

pub async fn execute_from<T>(self) -> Result<T, Error>

where T: for<'de> Deserialize<'de>,

Executes the constructed HTTP request and deserializes the response body into a generic struct.

Returns

• Result<T, errors::Error> - The result of deserializing the response body into the provided generic struct.

Example

use supabase_storage::{
    Storage,
    config::SupabaseConfig,
    model::bucket::BucketDetails,
};
use dotenv::dotenv;

#[tokio::main]
async fn main() {
    dotenv().ok();
    let config = SupabaseConfig::default();
    let storage = Storage::new_with_config(config);
    let response = storage
        .from()
        .get_bucket_details("thefux")
        .execute_from::<BucketDetails>()
        .await;

    // Now 'response' contains the deserialized 'BucketDetails' based on the response.
    println!("{:?}", response);
}