pub struct SdkImpl { /* private fields */ }Expand description
SyncStoreSdkの本実装。
scan→delta→plan→execute を一貫して実行する。
インターフェース層は Arc<dyn SyncStoreSdk> として保持する。
Trait Implementations§
Source§impl SyncStoreSdk for SdkImpl
impl SyncStoreSdk for SdkImpl
Source§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,
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 一括。
Source§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 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,
単一ルート同期。
Source§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 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,
ファイル登録。
Source§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,
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数を返す。
Source§fn restore<'life0, 'life1, 'life2, 'async_trait>(
&'life0 self,
path: &'life1 str,
revision: &'life2 str,
) -> Pin<Box<dyn Future<Output = Result<(), SyncError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
fn restore<'life0, 'life1, 'life2, 'async_trait>(
&'life0 self,
path: &'life1 str,
revision: &'life2 str,
) -> Pin<Box<dyn Future<Output = Result<(), SyncError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
アーカイブからファイル復元。 Read more
Source§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 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,
ファイル取得。
Source§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 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,
ファイル一覧。
Source§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 status<'life0, 'async_trait>(
&'life0 self,
) -> Pin<Box<dyn Future<Output = Result<SyncSummary, SyncError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
ロケーション別同期サマリー。
Source§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 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,
エラー一覧。
Source§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 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,
転送待ち一覧。
Source§fn locations(&self) -> Vec<LocationId>
fn locations(&self) -> Vec<LocationId>
登録済みロケーション一覧。
Source§fn all_edges(&self) -> Vec<(LocationId, LocationId)>
fn all_edges(&self) -> Vec<(LocationId, LocationId)>
全エッジ
(src, dest) 一覧。Source§fn local_root(&self) -> Option<&Path>
fn local_root(&self) -> Option<&Path>
ローカルファイルルート。
Source§fn set_progress_callback(&self, callback: Option<ProgressFn>)
fn set_progress_callback(&self, callback: Option<ProgressFn>)
Set a progress callback for reporting phase/chunk progress. Read more
Auto Trait Implementations§
impl !Freeze for SdkImpl
impl !RefUnwindSafe for SdkImpl
impl Send for SdkImpl
impl Sync for SdkImpl
impl Unpin for SdkImpl
impl UnsafeUnpin for SdkImpl
impl !UnwindSafe for SdkImpl
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more