diff options
| author | Alex Auvolat <alex@adnab.me> | 2021-03-16 11:47:39 +0100 |
|---|---|---|
| committer | Alex Auvolat <alex@adnab.me> | 2021-03-16 11:47:39 +0100 |
| commit | 0aad2f2e066b5914ac94bb319e7679e2e7761b2b (patch) | |
| tree | 81b52a8b8647c0ba0ce44e3ffc554ec46a84b0b2 /src/table/gc.rs | |
| parent | 515029d026937d29395379c76188f509984b8ace (diff) | |
| download | garage-0aad2f2e066b5914ac94bb319e7679e2e7761b2b.tar.gz garage-0aad2f2e066b5914ac94bb319e7679e2e7761b2b.zip | |
some reordering
Diffstat (limited to 'src/table/gc.rs')
| -rw-r--r-- | src/table/gc.rs | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/src/table/gc.rs b/src/table/gc.rs index d99e3e40..20ebe3c7 100644 --- a/src/table/gc.rs +++ b/src/table/gc.rs @@ -25,8 +25,8 @@ const TABLE_GC_BATCH_SIZE: usize = 1024; const TABLE_GC_RPC_TIMEOUT: Duration = Duration::from_secs(30); pub struct TableGC<F: TableSchema, R: TableReplication> { - data: Arc<TableData<F, R>>, system: Arc<System>, + data: Arc<TableData<F, R>>, rpc_client: Arc<RpcClient<GcRPC>>, } @@ -46,16 +46,16 @@ where R: TableReplication + 'static, { pub(crate) fn launch( - data: Arc<TableData<F, R>>, system: Arc<System>, + data: Arc<TableData<F, R>>, rpc_server: &mut RpcServer, ) -> Arc<Self> { let rpc_path = format!("table_{}/gc", data.name); let rpc_client = system.rpc_client::<GcRPC>(&rpc_path); let gc = Arc::new(Self { - data: data.clone(), system: system.clone(), + data: data.clone(), rpc_client, }); |