Struct D1ExportContext 

pub struct D1ExportContext {
    pub database_id: String,
    pub table_name: String,
    pub account_id: String,
    pub api_token: String,
    pub http_client: Arc<Client>,
    pub key_fields_schema: Vec<FieldSchema>,
    pub value_fields_schema: Vec<FieldSchema>,
    pub metrics: PerformanceMetrics,
}

D1 export context (runtime state)

Fields

database_id: String

table_name: String

account_id: String

api_token: String

http_client: Arc<Client>

Shared HTTP client with connection pooling

key_fields_schema: Vec<FieldSchema>

value_fields_schema: Vec<FieldSchema>

metrics: PerformanceMetrics

Implementations

impl D1ExportContext

pub fn new( database_id: String, table_name: String, account_id: String, api_token: String, http_client: Arc<Client>, key_fields_schema: Vec<FieldSchema>, value_fields_schema: Vec<FieldSchema>, metrics: PerformanceMetrics, ) -> Result<Self, RecocoError>

Create a new D1 export context with a shared HTTP client

pub fn new_with_default_client( database_id: String, table_name: String, account_id: String, api_token: String, key_fields_schema: Vec<FieldSchema>, value_fields_schema: Vec<FieldSchema>, metrics: PerformanceMetrics, ) -> Result<Self, RecocoError>

Create a new D1 export context with a default HTTP client (for tests and examples)

pub fn api_url(&self) -> String

pub fn build_upsert_stmt( &self, key: &KeyValue, values: &FieldValues, ) -> Result<(String, Vec<Value>), RecocoError>

pub fn build_delete_stmt( &self, key: &KeyValue, ) -> Result<(String, Vec<Value>), RecocoError>

pub async fn upsert( &self, upserts: &[ExportTargetUpsertEntry], ) -> Result<(), RecocoError>

pub async fn delete( &self, deletes: &[ExportTargetDeleteEntry], ) -> Result<(), RecocoError>