Crate ocular_protocol 

Re-exports

pub use resp::RespValue;

pub use resp::parse_resp;

pub use mysql::parse_mysql_request;

pub use mysql::parse_mysql_response;

pub use amqp::parse_amqp_request;

pub use amqp::parse_amqp_response;

pub use amqp::format_amqp_response_detail;

pub use amqp::parse_amqp_frame;

pub use amqp::parse_amqp_request_full;

pub use amqp::is_async_method;

pub use amqp::frame_len as amqp_frame_len;

pub use handler::ProtocolHandler;

pub use handler::HandshakeAction;

pub use handlers::*;

Modules

amqp

AMQP 0-9-1 wire protocol parser

handler

handlers

http

Generic HTTP/1.1 protocol parser for Ocular. Parses request line, headers, and body. Used for Elasticsearch and other HTTP services.

kafka

memcached

mongodb

MongoDB wire protocol parser (OP_MSG only, modern MongoDB 3.6+) All integers are little-endian.

mysql

MySQL wire protocol parser (client command packets)

postgres

PostgreSQL wire protocol parser (v3)

resp

Structs

ConnectionState

Connection state for a proxy/capture component (shared with TUI for status display)

ProxyEvent

A single request→response event (merged)

Enums

Direction

Protocol

Functions

extract_full_command

Extract the full command/SQL from raw bytes (no truncation)

format_response_detail

Parse response bytes into a detailed display string (for detail panel)

get_handler

Get the protocol handler for a given protocol.

parse_request

Parse request bytes, returning a human-readable summary (truncated)

parse_response

Parse response bytes, returning a short summary

Type Aliases

StatusMap

Shared map from component name to connection state