Struct SdkImpl 

pub struct SdkImpl { /* private fields */ }

SyncStoreSdkの本実装。

scan→delta→plan→execute を一貫して実行する。 インターフェース層は Arc<dyn SyncStoreSdk> として保持する。

Trait Implementations

impl SyncStoreSdk for SdkImpl

fn sync<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<SyncReport, SyncError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

全体同期: scan→delta→plan→execute 一括。

fn sync_route<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, src: &'life1 LocationId, dest: &'life2 LocationId, ) -> Pin<Box<dyn Future<Output = Result<SyncReport, SyncError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

単一ルート同期。

fn put<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, path: &'life1 str, file_type: FileType, fingerprint: FileFingerprint, origin: &'life2 LocationId, embedded_id: Option<String>, ) -> Pin<Box<dyn Future<Output = Result<PutReport, SyncError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

ファイル登録。

fn delete<'life0, 'life1, 'async_trait>( &'life0 self, path: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<usize, SyncError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

ファイル削除。削除されたTransfer数を返す。

fn get<'life0, 'life1, 'async_trait>( &'life0 self, path: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Option<TopologyFileView>, SyncError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

ファイル取得。

fn list<'life0, 'async_trait>( &'life0 self, file_type: Option<FileType>, limit: Option<usize>, ) -> Pin<Box<dyn Future<Output = Result<Vec<TopologyFileView>, SyncError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

ファイル一覧。

fn status<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<SyncSummary, SyncError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

ロケーション別同期サマリー。

fn errors<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Vec<ErrorEntry>, SyncError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

エラー一覧。

fn pending<'life0, 'life1, 'async_trait>( &'life0 self, dest: &'life1 LocationId, ) -> Pin<Box<dyn Future<Output = Result<Vec<PendingEntry>, SyncError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

転送待ち一覧。

fn locations(&self) -> Vec<LocationId>

登録済みロケーション一覧。

fn all_edges(&self) -> Vec<(LocationId, LocationId)>

全エッジ (src, dest) 一覧。

fn local_root(&self) -> Option<&Path>

ローカルファイルルート。

fn set_progress_callback(&self, callback: Option<ProgressFn>)

Set a progress callback for reporting phase/chunk progress.