Module pipeline 

Packet pipeline for the HOPR protocol.

Structs

AcknowledgementPipelineConfig

Configuration for the acknowledgement processing pipeline.

METRIC_PACKET_COUNT 🔒

METRIC_PACKET_DECODE_TIMEOUTS 🔒

METRIC_PACKET_REJECTED_COUNT 🔒

METRIC_VALIDATION_ERRORS 🔒

PacketPipelineConfig

Overall configuration of the input/output packet processing pipeline.

Enums

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

default_ack_buffer_interval 🔒

default_ack_grouping_capacity 🔒

default_ack_out_buffer_size 🔒

default_ticket_ack_buffer_size 🔒

run_packet_pipeline

Run all processes responsible for handling the msg and acknowledgment protocols.

start_incoming_ack_pipeline 🔒

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.