Enum s2n_netbench::operation::Connection

pub enum Connection {
    Sleep {
        amount: Duration,
    },
    OpenBidirectionalStream {
        stream_id: u64,
    },
    OpenSendStream {
        stream_id: u64,
    },
    Send {
        stream_id: u64,
        bytes: Byte,
    },
    SendFinish {
        stream_id: u64,
    },
    SendRate {
        stream_id: u64,
        rate: Rate,
    },
    Receive {
        stream_id: u64,
        bytes: Byte,
    },
    ReceiveAll {
        stream_id: u64,
    },
    ReceiveFinish {
        stream_id: u64,
    },
    ReceiveRate {
        stream_id: u64,
        rate: Rate,
    },
    Park {
        checkpoint: u64,
    },
    Unpark {
        checkpoint: u64,
    },
    Trace {
        trace_id: u64,
    },
    Profile {
        trace_id: u64,
        operations: Vec<Connection>,
    },
    Iterate {
        value: IterateValue,
        operations: Vec<Connection>,
        trace_id: Option<u64>,
    },
    Scope {
        threads: Vec<Vec<Connection>>,
    },
}

Variants

Sleep

Fields

amount: Duration

Pause for the specified duration before processing the next op

OpenBidirectionalStream

Fields

stream_id: u64

Open a bidirectional stream with an identifier

OpenSendStream

Fields

stream_id: u64

Open a unidirectional stream with an identifier

Send

Fields

stream_id: u64

bytes: Byte

Send a specific amount of data over the stream id

SendFinish

Fields

stream_id: u64

Finish sending data on the stream

SendRate

Fields

stream_id: u64

rate: Rate

Sets the send rate for a stream

Receive

Fields

stream_id: u64

bytes: Byte

Send a specific amount of data over the stream id

ReceiveAll

Fields

stream_id: u64

Receives all of the data on the stream until it is finished

ReceiveFinish

Fields

stream_id: u64

Finish receiving data on the stream

ReceiveRate

Fields

stream_id: u64

rate: Rate

Sets the receive rate for a stream

Park

Fields

checkpoint: u64

Parks the current thread and waits for the checkpoint to be unparked

Unpark

Fields

checkpoint: u64

Notifies the parked checkpoint that it can continue

Trace

Fields

trace_id: u64

Emit a trace event

Profile

Fields

trace_id: u64

operations: Vec<Connection>

Profiles the time it takes to perform the contained operations

Iterate

Fields

value: IterateValue

operations: Vec<Connection>

trace_id: Option<u64>

Evaluates the contained operations for the specified value

Scope

Fields

threads: Vec<Vec<Connection>>

Perform operations concurrently

Trait Implementations

impl Clone for Connection

fn clone(&self) -> Connection

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for Connection

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for Connection

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Hash for Connection

fn hash<__H: Hasher>(&self, state: &mut __H)

Feeds this value into the given Hasher.

fn hash_slice<H>(data: &[Self], state: &mut H)

where H: Hasher, Self: Sized,

Feeds a slice of this type into the given Hasher.

impl PartialEq for Connection

fn eq(&self, other: &Connection) -> bool

This method tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

This method tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Serialize for Connection

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl Eq for Connection

impl StructuralEq for Connection

impl StructuralPartialEq for Connection