edc-dataplane-core 0.2.0

An EDC compatible dataplane
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32

use miwa::{
    core::{Extension, MiwaContext, MiwaResult},
    derive::extension,
};

use crate::core::{
    db::transfer::TransferRepoRef,
    service::transfer::{TransferManagerRef, TransferService},
};

pub struct TransferServiceExtension;

#[async_trait::async_trait]
impl Extension for TransferServiceExtension {
    async fn start(&self) -> MiwaResult<()> {
        Ok(())
    }

    async fn shutdown(&self) -> MiwaResult<()> {
        Ok(())
    }
}

#[extension(name = "Transfer Service sextension", provides(TransferService))]
pub async fn transfer_service_extension(
    ctx: &MiwaContext,
    manager: TransferManagerRef,
    repo: TransferRepoRef,
) -> MiwaResult<TransferServiceExtension> {
    ctx.register(TransferService::new(manager, repo));
    Ok(TransferServiceExtension)
}