List of all items
Structs
- AcknowledgementPipelineConfig
- PacketPipelineConfig
- codec::FixedLengthCodec
- counters::PeerProtocolCounterRegistry
- counters::PeerProtocolCounters
- heartbeat::config::HeartbeatProtocolConfig
- pipeline::AcknowledgementPipelineConfig
- pipeline::METRIC_PACKET_COUNT
- pipeline::METRIC_PACKET_DECODE_TIMEOUTS
- pipeline::METRIC_PACKET_REJECTED_COUNT
- pipeline::METRIC_VALIDATION_ERRORS
- pipeline::PacketPipelineConfig
Enums
Functions
- pipeline::default_ack_buffer_interval
- pipeline::default_ack_grouping_capacity
- pipeline::default_ack_out_buffer_size
- pipeline::default_ticket_ack_buffer_size
- pipeline::run_packet_pipeline
- pipeline::start_incoming_ack_pipeline
- pipeline::start_incoming_packet_pipeline
- pipeline::start_outgoing_ack_pipeline
- pipeline::start_outgoing_packet_pipeline
- run_packet_pipeline
- stream::build_peer_stream_io
- stream::process_stream_protocol
Type Aliases
Constants
- CURRENT_HOPR_MSG_PROTOCOL
- HOPR_PACKET_SIZE
- pipeline::DEFAULT_ACK_INPUT_CONCURRENCY
- pipeline::DEFAULT_ACK_OUTPUT_CONCURRENCY
- pipeline::PACKET_DECODING_TIMEOUT
- pipeline::PACKET_ENCODING_TIMEOUT
- pipeline::QUEUE_SEND_TIMEOUT
- stream::DEFAULT_FRAME_WRITER_BACKPRESSURE_BYTES
- stream::GLOBAL_STREAM_OPEN_TIMEOUT
- stream::MAX_CONCURRENT_PACKETS