Struct scylla_proxy::ResponseReaction
source · pub struct ResponseReaction {
pub to_addressee: Option<Action<ResponseFrame, ResponseFrame>>,
pub to_sender: Option<Action<ResponseFrame, RequestFrame>>,
pub drop_connection: Option<Option<Duration>>,
pub feedback_channel: Option<UnboundedSender<(ResponseFrame, Option<TargetShard>)>>,
}
Fields§
§to_addressee: Option<Action<ResponseFrame, ResponseFrame>>
§to_sender: Option<Action<ResponseFrame, RequestFrame>>
§drop_connection: Option<Option<Duration>>
§feedback_channel: Option<UnboundedSender<(ResponseFrame, Option<TargetShard>)>>
Trait Implementations§
source§impl Clone for ResponseReaction
impl Clone for ResponseReaction
source§fn clone(&self) -> ResponseReaction
fn clone(&self) -> ResponseReaction
Returns a copy of the value. Read more
1.0.0 · source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source
. Read moresource§impl Debug for ResponseReaction
impl Debug for ResponseReaction
source§impl Reaction for ResponseReaction
impl Reaction for ResponseReaction
type Incoming = ResponseFrame
type Returning = RequestFrame
source§fn drop_frame() -> Self
fn drop_frame() -> Self
Drops frame, i.e. passes it into void.
source§fn forge_response(
f: Arc<dyn Fn(Self::Incoming) -> Self::Returning + Send + Sync>,
) -> Self
fn forge_response( f: Arc<dyn Fn(Self::Incoming) -> Self::Returning + Send + Sync>, ) -> Self
Instead of passing the frame to the addressee, returns the forged frame back to the addresser.
source§fn forge_response_with_delay(
time: Duration,
f: Arc<dyn Fn(Self::Incoming) -> Self::Returning + Send + Sync>,
) -> Self
fn forge_response_with_delay( time: Duration, f: Arc<dyn Fn(Self::Incoming) -> Self::Returning + Send + Sync>, ) -> Self
The same as forge_response, but with specified delay.
source§fn drop_connection() -> Self
fn drop_connection() -> Self
Drops the frame AND drops the connection with both the driver and the cluster.
source§fn drop_connection_with_delay(time: Duration) -> Self
fn drop_connection_with_delay(time: Duration) -> Self
The same as drop_connection, but with specified delay.
source§fn with_feedback_when_performed(
self,
tx: UnboundedSender<(Self::Incoming, Option<TargetShard>)>,
) -> Self
fn with_feedback_when_performed( self, tx: UnboundedSender<(Self::Incoming, Option<TargetShard>)>, ) -> Self
Adds sending the matching frame as feedback using the provided channel.
Modifies the existing
Reaction
.Auto Trait Implementations§
impl Freeze for ResponseReaction
impl !RefUnwindSafe for ResponseReaction
impl Send for ResponseReaction
impl Sync for ResponseReaction
impl Unpin for ResponseReaction
impl !UnwindSafe for ResponseReaction
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
source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
source§default unsafe fn clone_to_uninit(&self, dst: *mut T)
default unsafe fn clone_to_uninit(&self, dst: *mut T)
🔬This is a nightly-only experimental API. (
clone_to_uninit
)