Enum LinkManagerAction 

pub enum LinkManagerAction {
    SendPacket {
        raw: Vec<u8>,
        dest_type: u8,
        attached_interface: Option<InterfaceId>,
    },
    LinkEstablished {
        link_id: LinkId,
        dest_hash: [u8; 16],
        hops: u8,
        rebalanced_at: Option<f64>,
        rtt: f64,
        is_initiator: bool,
    },
    LinkClosed {
        link_id: LinkId,
        reason: Option<TeardownReason>,
    },
    RemoteIdentified {
        link_id: LinkId,
        identity_hash: [u8; 16],
        public_key: [u8; 64],
    },
    RegisterLinkDest {
        link_id: LinkId,
    },
    DeregisterLinkDest {
        link_id: LinkId,
    },
    ManagementRequest {
        link_id: LinkId,
        path_hash: [u8; 16],
        data: Vec<u8>,
        request_id: [u8; 16],
        remote_identity: Option<([u8; 16], [u8; 64])>,
    },
    ResourceReceived {
        link_id: LinkId,
        data: Vec<u8>,
        metadata: Option<Vec<u8>>,
    },
    ResourceFileReceived {
        link_id: LinkId,
        resource: ReceivedResourceFile,
    },
    ResourceCompleted {
        link_id: LinkId,
    },
    ResourceFailed {
        link_id: LinkId,
        error: String,
    },
    ResourceProgress {
        link_id: LinkId,
        received: usize,
        total: usize,
    },
    ResourceStreamCompleted {
        link_id: LinkId,
        transfer_id: ResourceTransferId,
    },
    ResourceStreamFailed {
        link_id: LinkId,
        transfer_id: ResourceTransferId,
        error: ResourceTransferError,
    },
    ResourceStreamProgress {
        link_id: LinkId,
        transfer_id: ResourceTransferId,
        transferred: u64,
        total: u64,
    },
    ResourceAcceptQuery {
        link_id: LinkId,
        resource_hash: Vec<u8>,
        transfer_size: u64,
        has_metadata: bool,
    },
    ChannelMessageReceived {
        link_id: LinkId,
        msgtype: u16,
        payload: Vec<u8>,
    },
    LinkDataReceived {
        link_id: LinkId,
        context: u8,
        data: Vec<u8>,
    },
    ResponseReceived {
        link_id: LinkId,
        request_id: [u8; 16],
        data: Vec<u8>,
        metadata: Option<Vec<u8>>,
    },
    RequestFailed {
        link_id: LinkId,
        request_id: [u8; 16],
        reason: RequestFailure,
    },
    LinkRequestReceived {
        link_id: LinkId,
        receiving_interface: InterfaceId,
    },
    ProtocolViolation {
        receiving_interface: InterfaceId,
    },
}

Actions produced by LinkManager for the driver to dispatch.

Variants

SendPacket

Send a packet via the transport engine outbound path.

Fields

raw: Vec<u8>

dest_type: u8

attached_interface: Option<InterfaceId>

LinkEstablished

Link established — notify callbacks.

Fields

link_id: LinkId

dest_hash: [u8; 16]

hops: u8

rebalanced_at: Option<f64>

rtt: f64

is_initiator: bool

LinkClosed

Link closed — notify callbacks.

Fields

link_id: LinkId

reason: Option<TeardownReason>

RemoteIdentified

Remote peer identified — notify callbacks.

Fields

link_id: LinkId

identity_hash: [u8; 16]

public_key: [u8; 64]

RegisterLinkDest

Register a link_id as local destination in transport (for receiving link data).

Fields

link_id: LinkId

DeregisterLinkDest

Deregister a link_id from transport local destinations.

Fields

link_id: LinkId

ManagementRequest

A management request that needs to be handled by the driver. The driver has access to engine state needed to build the response.

Fields

link_id: LinkId

path_hash: [u8; 16]

data: Vec<u8>

The request data (msgpack-encoded Value from the request array).

request_id: [u8; 16]

The request_id (truncated hash of the packed request).

remote_identity: Option<([u8; 16], [u8; 64])>

ResourceReceived

Resource data fully received and assembled.

Fields

link_id: LinkId

data: Vec<u8>

metadata: Option<Vec<u8>>

ResourceFileReceived

A disk-backed Resource is ready for application ownership.

Fields

link_id: LinkId

resource: ReceivedResourceFile

ResourceCompleted

Resource transfer completed (proof validated on sender side).

Fields

link_id: LinkId

ResourceFailed

Resource transfer failed.

Fields

link_id: LinkId

error: String

ResourceProgress

Resource transfer progress update.

Fields

link_id: LinkId

received: usize

total: usize

ResourceStreamCompleted

Fields

link_id: LinkId

transfer_id: ResourceTransferId

ResourceStreamFailed

Fields

link_id: LinkId

transfer_id: ResourceTransferId

error: ResourceTransferError

ResourceStreamProgress

Fields

link_id: LinkId

transfer_id: ResourceTransferId

transferred: u64

total: u64

ResourceAcceptQuery

Query application whether to accept an incoming resource (for AcceptApp strategy).

Fields

link_id: LinkId

resource_hash: Vec<u8>

transfer_size: u64

has_metadata: bool

ChannelMessageReceived

Channel message received on a link.

Fields

link_id: LinkId

msgtype: u16

payload: Vec<u8>

LinkDataReceived

Generic link data received (CONTEXT_NONE).

Fields

link_id: LinkId

context: u8

data: Vec<u8>

ResponseReceived

Response received on a link.

Fields

link_id: LinkId

request_id: [u8; 16]

data: Vec<u8>

metadata: Option<Vec<u8>>

RequestFailed

An outbound request failed.

Fields

link_id: LinkId

request_id: [u8; 16]

reason: RequestFailure

LinkRequestReceived

A link request was received (for hook notification).

Fields

link_id: LinkId

receiving_interface: InterfaceId

ProtocolViolation

A malformed link request was rejected on an interface.

Fields

receiving_interface: InterfaceId

Trait Implementations

impl Debug for LinkManagerAction

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.