Struct LdpAdapter 

pub struct LdpAdapter { /* private fields */ }

LDP protocol adapter.

Can be used standalone or registered with a ProtocolRegistry (including JamJet’s registry via the jamjet feature).

Implementations

impl LdpAdapter

pub fn new(config: LdpAdapterConfig) -> Self

Create a new LDP adapter with the given configuration.

pub fn with_client(config: LdpAdapterConfig, client: LdpClient) -> Self

Create with a custom HTTP client (useful for testing).

pub fn session_manager(&self) -> &SessionManager

Get the session manager (for external session control).

Trait Implementations

impl ProtocolAdapter for LdpAdapter

fn discover<'life0, 'life1, 'async_trait>( &'life0 self, url: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<RemoteCapabilities, String>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Discover remote delegate capabilities.

1. Fetch LDP identity card
2. Validate trust domain (if configured)
3. Map to RemoteCapabilities

fn invoke<'life0, 'life1, 'async_trait>( &'life0 self, url: &'life1 str, task: TaskRequest, ) -> Pin<Box<dyn Future<Output = Result<TaskHandle, String>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Submit a task to an LDP delegate.

1. Get or establish session (transparent to caller)
2. Send TASK_SUBMIT within session
3. Return TaskHandle

fn stream<'life0, 'life1, 'async_trait>( &'life0 self, url: &'life1 str, task: TaskRequest, ) -> Pin<Box<dyn Future<Output = Result<TaskStream, String>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Stream task progress events.

Submits the task, then polls for updates until completion. In a full implementation, this would use SSE or WebSocket.

fn status<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, url: &'life1 str, task_id: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<TaskStatus, String>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Poll task status.

fn cancel<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, url: &'life1 str, task_id: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<(), String>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Cancel a running task.