Struct FunctionsClient

pub struct FunctionsClient { /* private fields */ }

Edge Functions クライアント

Implementations

impl FunctionsClient

pub fn new(supabase_url: &str, supabase_key: &str, http_client: Client) -> Self

新しい Edge Functions クライアントを作成

pub async fn invoke<T: DeserializeOwned, B: Serialize>( &self, function_name: &str, body: Option<B>, options: Option<FunctionOptions>, ) -> Result<FunctionResponse<T>>

Edge Function を呼び出す

pub async fn invoke_json<T: DeserializeOwned, B: Serialize>( &self, function_name: &str, body: Option<B>, ) -> Result<T>

JSONを返すファンクションを呼び出す（シンプルなラッパー）

pub async fn invoke_text<B: Serialize>( &self, function_name: &str, body: Option<B>, ) -> Result<String>

テキストを返すファンクションを呼び出す（シンプルなラッパー）

pub async fn invoke_binary<B: Serialize>( &self, function_name: &str, body: Option<B>, options: Option<FunctionOptions>, ) -> Result<Bytes>

バイナリ形式で関数レスポンスを取得

pub async fn invoke_binary_stream<B: Serialize>( &self, function_name: &str, body: Option<B>, options: Option<FunctionOptions>, ) -> Result<ByteStream>

バイナリストリームを取得するメソッド（大きなバイナリデータに最適）

pub fn process_binary_chunks<F>( &self, stream: ByteStream, chunk_size: usize, processor: F, ) -> Pin<Box<dyn Stream<Item = Result<Bytes>> + Send + '_>>

where F: FnMut(&[u8]) -> Result<Bytes, String> + Send + 'static,

チャンク単位でバイナリを処理する補助メソッド

pub async fn invoke_stream<B: Serialize>( &self, function_name: &str, body: Option<B>, options: Option<FunctionOptions>, ) -> Result<ByteStream>

ストリーミングレスポンスを取得するメソッド

pub async fn invoke_json_stream<B: Serialize>( &self, function_name: &str, body: Option<B>, options: Option<FunctionOptions>, ) -> Result<Pin<Box<dyn Stream<Item = Result<Value>> + Send + '_>>>

JSONストリームを取得するメソッド（SSE形式のJSONイベントを扱う）

pub fn stream_to_lines( &self, stream: ByteStream, ) -> Pin<Box<dyn Stream<Item = Result<String>> + Send + '_>>

ストリームを行に変換する

pub fn create_request<T: DeserializeOwned>( &self, function_name: &str, ) -> FunctionRequest<'_, T>

関数リクエストを作成する