pub struct AgentProtocol;Expand description
Agent relay protocol specialization; it owns no router or SDK services.
Implementations§
Source§impl AgentProtocol
impl AgentProtocol
Sourcepub fn ensure_version_compat_for(
message_type: MessageType,
negotiated: u8,
) -> ClientResult<()>
pub fn ensure_version_compat_for( message_type: MessageType, negotiated: u8, ) -> ClientResult<()>
Validate a known operation against a separately retained generation.
Trait Implementations§
Source§impl Protocol for AgentProtocol
impl Protocol for AgentProtocol
Source§type Ready = AgentReady
type Ready = AgentReady
Shared immutable metadata negotiated during setup.
Source§fn establish(
stream: BoxTransport,
options: ConnectOptions,
) -> BoxFuture<'static, ClientResult<Established<AgentReady>>>
fn establish( stream: BoxTransport, options: ConnectOptions, ) -> BoxFuture<'static, ClientResult<Established<AgentReady>>>
Consume an owned stream and preserve any prefetched bytes in the result.
Source§fn prepare(ready: &AgentReady, wire_name: &str) -> ClientResult<SendMetadata>
fn prepare(ready: &AgentReady, wire_name: &str) -> ClientResult<SendMetadata>
Validate availability and select metadata for a named outbound message.
Auto Trait Implementations§
impl Freeze for AgentProtocol
impl RefUnwindSafe for AgentProtocol
impl Send for AgentProtocol
impl Sync for AgentProtocol
impl Unpin for AgentProtocol
impl UnsafeUnpin for AgentProtocol
impl UnwindSafe for AgentProtocol
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more