Struct scylla_proxy::RequestReaction

pub struct RequestReaction {
    pub to_addressee: Option<Action<RequestFrame, RequestFrame>>,
    pub to_sender: Option<Action<RequestFrame, ResponseFrame>>,
    pub drop_connection: Option<Option<Duration>>,
    pub feedback_channel: Option<UnboundedSender<(RequestFrame, Option<TargetShard>)>>,
}

Fields

to_addressee: Option<Action<RequestFrame, RequestFrame>>

to_sender: Option<Action<RequestFrame, ResponseFrame>>

drop_connection: Option<Option<Duration>>

feedback_channel: Option<UnboundedSender<(RequestFrame, Option<TargetShard>)>>

Implementations

impl RequestReaction

pub fn forge_with_error_lazy( gen_error: Box<dyn Fn() -> DbError + Send + Sync>, ) -> Self

pub fn forge_with_error_lazy_delay( gen_error: Box<dyn Fn() -> DbError + Send + Sync>, delay: Option<Duration>, ) -> Self

A convenient shortcut for forging a various error-type responses, useful e.g. for testing retries. Errors are computed on-demand by the provided closure.

pub fn forge_with_error(error: DbError) -> Self

pub fn forge_with_error_and_message(error: DbError, msg: Option<String>) -> Self

A convenient shortcut for forging a various error-type responses, useful e.g. for testing retries.

pub fn forge() -> ResponseForger

Trait Implementations

impl Clone for RequestReaction

fn clone(&self) -> RequestReaction

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for RequestReaction

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Reaction for RequestReaction

type Incoming = RequestFrame

type Returning = ResponseFrame

fn noop() -> Self

Does nothing extraordinary, i.e. passes the frame with no changes to it.

fn drop_frame() -> Self

Drops frame, i.e. passes it into void.

fn delay(time: Duration) -> Self

Passes the frame only after specified delay.

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.

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.

fn drop_connection() -> Self

Drops the frame AND drops the connection with both the driver and the cluster.

fn drop_connection_with_delay(time: Duration) -> Self

The same as drop_connection, but with specified delay.

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.