Module pipeline 

Packet pipeline for the HOPR protocol. HOPR packet processing pipeline.

Re-exports

pub use builder::PacketPipelineBuilder;

pub use builder::Unset;

pub use config::AcknowledgementPipelineConfig;

pub use config::PacketPipelineConfig;

Modules

builder 🔒

Builder for constructing the HOPR packet pipeline.

config 🔒

Configuration structures for the HOPR packet processing pipeline.

Enums

NodeType

Node type for which the packet processing pipeline is being constructed.

PacketPipelineProcesses

Constants

DEFAULT_ACK_INPUT_CONCURRENCY 🔒

Default concurrency for the incoming acknowledgement processing pipeline when not overridden via AcknowledgementPipelineConfig::ack_input_concurrency.

DEFAULT_ACK_OUTPUT_CONCURRENCY 🔒

Default concurrency for the outgoing acknowledgement processing pipeline when not overridden via AcknowledgementPipelineConfig::ack_output_concurrency.

PACKET_DECODING_TIMEOUT 🔒

PACKET_ENCODING_TIMEOUT 🔒

QUEUE_SEND_TIMEOUT 🔒

Functions

run_packet_pipeline_inner 🔒

Shared implementation of the packet pipeline used by PacketPipelineBuilder’s terminal build_for_* methods.

start_exit_incoming_ack_pipeline 🔒

Drains incoming acknowledgements without forwarding them to an [UnacknowledgedTicketProcessor].

start_incoming_packet_pipeline 🔒

Performs HOPR protocol decoding of incoming packets into Application protocol packets.

start_outgoing_ack_pipeline 🔒

start_outgoing_packet_pipeline 🔒

Performs encoding of outgoing Application protocol packets into HOPR protocol outgoing packets.

start_relay_incoming_ack_pipeline 🔒