rocketmq-transport 1.0.0

// Copyright 2023 The RocketMQ Rust Authors
//
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
//     http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.

//! Deliberate transport entry points.

pub use crate::contract::TransportContractViolation;
pub use crate::error::TransportError;

pub use crate::admission::AdmissionClass;
pub use crate::admission::AdmissionController;
pub use crate::admission::AdmissionLimits;
pub use crate::admission::AdmissionOutcome;
pub use crate::admission::AdmissionRejection;
pub use crate::admission::AdmissionResource;
pub use crate::admission::AdmissionScope;
pub use crate::admission::AdmissionSnapshot;
pub use crate::admission::FullPolicy;
pub use crate::admission::ResourceLimit;
pub use crate::admission::ResourceSnapshot;
pub use crate::base::channel_event_listener::ChannelEventListener;
pub use crate::base::connection_net_event::ConnectionNetEvent;
pub use crate::client::OneShotTransportClient;
pub use crate::clients::nameserver_endpoint::diff_name_server_endpoints;
pub use crate::clients::nameserver_endpoint::ConnectTarget;
pub use crate::clients::nameserver_endpoint::NameServerEndpoint;
pub use crate::clients::nameserver_endpoint::NameServerEndpointDiff;
pub use crate::clients::rocketmq_tokio_client::CachedConnectionState;
pub use crate::clients::rocketmq_tokio_client::ClientShutdownReport;
pub use crate::clients::rocketmq_tokio_client::ClientSnapshot;
pub use crate::clients::rocketmq_tokio_client::ClientStartReport;
pub use crate::clients::rocketmq_tokio_client::ConnectionShutdownReport;
pub use crate::clients::rocketmq_tokio_client::PendingUsage;
pub use crate::clients::rocketmq_tokio_client::RemotingClient;
pub use crate::clients::rocketmq_tokio_client::RemotingClientBuilder;
pub use crate::clients::rocketmq_tokio_client::RequestTarget;
pub use crate::clients::rocketmq_tokio_client::SendReceipt;
pub use crate::clients::rocketmq_tokio_client::TransportClient;
pub use crate::clients::rocketmq_tokio_client::TransportClientBuilder;
pub use crate::codec::remoting_command_codec::FrameLimits;
pub use crate::common::heartbeat_v2_result::HeartbeatV2Result;
pub use crate::common::remoting_helper::RemotingHelper;
pub use crate::config::ServerConfig;
pub use crate::config::SocketOptions;
pub use crate::config::TcpKeepaliveConfig;
pub use crate::config::TlsClientAuth;
pub use crate::config::TlsClientConfig;
pub use crate::config::TlsConfig;
pub use crate::config::TlsConfigError;
pub use crate::config::TlsMode;
pub use crate::config::TlsServerConfig;
pub use crate::config_support::network_util::NetworkUtil;
pub use crate::connection::ConnectionState;
pub use crate::deadline::RequestDeadline;
pub use crate::discovery::default_top_addressing::DefaultTopAddressing;
pub use crate::discovery::http_tiny_client::HttpResult;
pub use crate::discovery::http_tiny_client::HttpTinyClient;
pub use crate::discovery::name_server_update_callback::NameServerUpdateCallback;
pub use crate::discovery::top_addressing::TopAddressing;
pub use crate::dispatch::AuthenticationState;
pub use crate::dispatch::AuthorizedCommandDispatcher;
pub use crate::dispatch::ClaimedDeferred;
pub use crate::dispatch::DeferredAdmission;
pub use crate::dispatch::DeferredAdmissionAcquireOutcome;
pub use crate::dispatch::DeferredAdmissionSnapshot;
pub use crate::dispatch::DeferredCancellationReason;
pub use crate::dispatch::DeferredClaimOutcome;
pub use crate::dispatch::DeferredExpiry;
pub use crate::dispatch::DeferredExpiryBatch;
pub use crate::dispatch::DeferredExpiryBatchStats;
pub use crate::dispatch::DeferredExpiryKind;
pub use crate::dispatch::DeferredExpiryMargins;
pub use crate::dispatch::DeferredExpiryOutcome;
pub use crate::dispatch::DeferredId;
pub use crate::dispatch::DeferredParts;
pub use crate::dispatch::DeferredRegistration;
pub use crate::dispatch::DeferredRegistry;
pub use crate::dispatch::DeferredRegistryOutcome;
pub use crate::dispatch::DeferredRegistryRecovery;
pub use crate::dispatch::DeferredRegistryShutdownOutcome;
pub use crate::dispatch::DeferredRegistryShutdownStats;
pub use crate::dispatch::DeferredRequest;
pub use crate::dispatch::DeferredResponder;
pub use crate::dispatch::DeferredResponderOutcome;
pub use crate::dispatch::DeferredResponseOutcome;
pub use crate::dispatch::DeferredResumeOutcome;
pub use crate::dispatch::DeferredResumeRetainedSize;
pub use crate::dispatch::DeferredResumeSubmitOutcome;
pub use crate::dispatch::DeferredRetainedSize;
pub use crate::dispatch::DeferredRetainedSizeParts;
pub use crate::dispatch::DeferredTerminalReason;
pub use crate::dispatch::DeferredWaitLimits;
pub use crate::dispatch::DeferredWaitPermit;
pub use crate::dispatch::DeferredWakeReason;
pub use crate::dispatch::EmbeddedCaller;
pub use crate::dispatch::EmbeddedDispatchOutcome;
pub use crate::dispatch::EmbeddedResponse;
pub use crate::dispatch::EmbeddedResponseBody;
pub use crate::dispatch::IngressRequestView;
pub use crate::dispatch::OriginalRequestIdentity;
pub use crate::dispatch::ProtocolNoResponse;
pub use crate::dispatch::ProtocolNoResponseReason;
pub use crate::dispatch::RemotingRequest;
pub use crate::dispatch::RemotingResponse;
pub use crate::dispatch::RequestControlView;
pub use crate::dispatch::RequestId;
pub use crate::dispatch::RequestMeta;
pub use crate::dispatch::RequestOrigin;
pub use crate::dispatch::ResponseAction;
pub use crate::dispatch::ResponseBodyKind;
pub use crate::dispatch::ResponseCompletionOutcome;
pub use crate::dispatch::ResponseDisposition;
pub use crate::dispatch::ResponseReceipt;
pub use crate::dispatch::ResponseTerminalState;
pub use crate::dispatch::WriteProgress;
pub use crate::file_region::FileRegion;
pub use crate::file_region::FileRegionLease;
pub use crate::file_region::FileRegionSequence;
pub use crate::file_region::FileTransferMode;
pub use crate::file_region_writer::file_transfer_snapshot;
pub use crate::file_region_writer::FileTransferSnapshot;
pub use crate::proxy_protocol::ProxyProtocolConfig;
pub use crate::remoting_server::rocketmq_tokio_server::TransportServer;
pub use crate::request_ordering::RequestOrdering;
pub use crate::request_ordering::RequestOrderingKey;
pub use crate::request_outcome::OutboundRequestContract;
pub use crate::request_outcome::OutboundRequestContractReason;
pub use crate::request_outcome::OutboundRequestOutcome;
pub use crate::request_outcome::OutboundRequestRejection;
pub use crate::request_outcome::OutboundRequestRejectionReason;
pub use crate::request_outcome::OutboundRequestStage;
pub use crate::request_processor::default_request_processor::DefaultRequestProcessor;
pub use crate::rpc::client_metadata::ClientMetadata;
pub use crate::rpc::rpc_client::RpcClient;
pub use crate::rpc::rpc_client::RpcClientLocal;
pub use crate::rpc::rpc_client_hook::RpcClientHookFn;
pub use crate::rpc::rpc_client_impl::RpcClientImpl;
pub use crate::rpc::rpc_client_utils::RpcClientUtils;
pub use crate::rpc::rpc_request::RpcRequest;
pub use crate::rpc::rpc_request_header::RpcRequestHeader;
pub use crate::rpc::rpc_response::RpcResponse;
pub use crate::rpc::topic_request_header::TopicRequestHeader;
pub use crate::runtime::config::client_config::ConnectConfig;
pub use crate::runtime::config::client_config::MaintenanceConfig;
pub use crate::runtime::config::client_config::TransportClientConfig;
pub use crate::runtime::processor::LocalRequestProcessor;
pub use crate::runtime::processor::RejectRequestDecision;
pub use crate::runtime::processor::RequestProcessor;
pub use crate::runtime::processor::ResponseMetadata;
pub use crate::runtime::processor::ResponseObservation;
pub use crate::runtime::processor::ResponseObservationMode;
pub use crate::runtime::processor::ResponseObservationOutcome;
pub use crate::runtime::processor::ResponseWriteObservation;
pub use crate::runtime::processor::ResponseWriteOutcome;
pub use crate::runtime::processor::ResponseWritePath;
pub use crate::runtime::RPCHook;
pub use crate::runtime::RPCHookArc;
pub use crate::security::TransportSecurity;
pub use crate::session_registry::ServerPushCommand;
pub use crate::session_registry::ServerPushKind;
pub use crate::session_registry::ServerPushOutcome;
pub use crate::session_registry::ServerPushReceipt;
pub use crate::session_registry::ServerPushSender;
pub use crate::session_registry::ServerRequestCommand;
pub use crate::session_registry::ServerRequestKind;
pub use crate::session_registry::ServerRequestOutcome;
pub use crate::session_registry::ServerRequestResponse;
pub use crate::session_registry::ServerRequestSender;
pub use crate::session_registry::SessionCloseHandle;
pub use crate::session_registry::SessionCloseOutcome;
pub use crate::session_registry::SessionCloseReason;
pub use crate::session_registry::SessionEvent;
pub use crate::session_registry::SessionLifecycleListener;
pub use crate::session_registry::SessionRegistry;
pub use crate::session_view::ProxyInfoSnapshot;
pub use crate::session_view::SessionId;
pub use crate::session_view::SessionStateView;
pub use crate::session_view::SessionView;
#[cfg(feature = "socks")]
pub use crate::socks::SocksProxyConfig;
#[cfg(feature = "socks")]
pub use crate::socks::SocksProxyRoute;
pub use crate::telemetry::TransportTelemetry;
#[cfg(feature = "tls")]
pub use crate::tls::build_server_acceptor_exact;
#[cfg(feature = "tls")]
pub use crate::tls::build_server_acceptor_exact_with_alpn;
#[cfg(feature = "tls")]
pub use crate::tls::PrivateKeyLoader;
pub use crate::tls::TlsServerRuntime;
pub use rocketmq_protocol::protocol::RemotingDeserializable;
pub use rocketmq_protocol::protocol::RemotingSerializable;

pub use crate::error_response::error_response;
pub use crate::error_response::RemotingErrorTarget;