Initialize RemoteFetchActor

This commit is contained in:
Kitaiti Makoto 2021-02-01 00:50:48 +09:00
parent 6401cb6fb7
commit 61b68c3a42

View File

@ -16,6 +16,7 @@ use plume_models::{
db_conn::{DbPool, PragmaForeignKey}, db_conn::{DbPool, PragmaForeignKey},
instance::Instance, instance::Instance,
migrations::IMPORTED_MIGRATIONS, migrations::IMPORTED_MIGRATIONS,
remote_fetch_actor::RemoteFetchActor,
search::{actor::SearchActor, Searcher as UnmanagedSearcher}, search::{actor::SearchActor, Searcher as UnmanagedSearcher},
Connection, CONFIG, Connection, CONFIG,
}; };
@ -104,6 +105,7 @@ Then try to restart Plume.
&CONFIG.search_index, &CONFIG.search_index,
&CONFIG.search_tokenizers, &CONFIG.search_tokenizers,
)); ));
RemoteFetchActor::init(dbpool.clone());
SearchActor::init(searcher.clone(), dbpool.clone()); SearchActor::init(searcher.clone(), dbpool.clone());
let commiter = searcher.clone(); let commiter = searcher.clone();
workpool.execute_with_fixed_delay( workpool.execute_with_fixed_delay(