Skip to main content

create_test_shared_drt_async

dynamo_runtime::distributed::distributed_test_utils

Function create_test_shared_drt_async 

Source 
pub async fn create_test_shared_drt_async(
    store_path: &Path,
) -> DistributedRuntime
Expand description

Helper function to create a DRT instance which points at a (shared) file-backed KV store and ephemeral NATS transport so that multiple DRT instances may observe the same registration state. NOTE: This gets around the fact that create_test_drt_async() is hardcoded to spin up a memory-backed discovery store which means we can’t share discovery state across runtimes.