Enum RequestBody 

pub enum RequestBody {
    Noop,
    StartStream,
    StopStream,
    SetLevel(WireLevel),
    SetCacheLevel(WireLevelFilter),
    SetCacheChance(f64),
    SetSamplingRate(f64),
}

Variants

Noop

Filler used by the framework for control-only frames (cancel / end).

StartStream

Begin streaming closed spans to the client. Server keeps streaming until the client cancels the RPC (drops its handle).

StopStream

Stop the current stream. In protosocket-rpc terms, the cleaner way is to drop the streaming-RPC handle on the client; this command is here for completeness and explicit shutdown.

SetLevel(WireLevel)

Per-connection minimum span level filter. Only spans whose level is at least this severe (per tracing ordering) are streamed.

SetCacheLevel(WireLevelFilter)

Server-wide cache-recording level. Mutates the subscriber’s LevelPredicate, so it affects what the cache records, not just what gets streamed to one client. The server pushes the resulting level back to every connected stream as ResponseBody::CacheLevel.

SetCacheChance(f64)

Server-wide chance percentage [0.0, 100.0] that a root span passes the cache’s ChancePredicate. Out-of-range or NaN values are clamped server-side; the resulting effective chance is broadcast as ResponseBody::CacheChance.

SetSamplingRate(f64)

Sample the stream — 1.0 = every span, 0.5 = ~half. Applied per root-span family so a sampled root drops its whole subtree.

Trait Implementations

impl Clone for RequestBody

fn clone(&self) -> RequestBody

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RequestBody

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for RequestBody

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for RequestBody

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

where __S: Serializer,

Serialize this value into the given Serde serializer.