Struct SessionTeeFileRequest 

pub struct SessionTeeFileRequest {
    pub session_id: String,
    pub session_kind: SessionTeeKind,
    pub stream: SessionTeeStream,
    pub path: PathBuf,
    pub mode: SessionTeeFileMode,
    pub queue_capacity: u32,
    pub write_missed_markers: bool,
    pub backpressure: SessionTeeBackpressure,
}

Request used to register a daemon-managed file tee for a session stream.

Fields

session_id: String

Session identifier returned by the spawn API.

session_kind: SessionTeeKind

Kind of session that owns session_id.

stream: SessionTeeStream

Stream to mirror into the file.

path: PathBuf

Destination file path on the daemon host.

mode: SessionTeeFileMode

File open mode for the destination path.

queue_capacity: u32

0 means use the daemon default.

write_missed_markers: bool

Whether the daemon writes marker lines when tee bytes are missed.

backpressure: SessionTeeBackpressure

Queue behavior when the file sink cannot keep up.

Implementations

impl SessionTeeFileRequest

pub fn new<P>( session_id: impl Into<String>, session_kind: SessionTeeKind, stream: SessionTeeStream, path: P, ) -> Self

where P: AsRef<Path>,

Create a file tee request with append mode and daemon-default queue size.

pub fn truncate(self) -> Self

Open the destination file in truncate mode instead of append mode.

pub fn queue_capacity(self, capacity: u32) -> Self

Set the bounded queue capacity; 0 keeps the daemon default.

pub fn suppress_missed_markers(self) -> Self

Disable marker lines for bytes missed by the file tee.

pub fn backpressure(self, backpressure: SessionTeeBackpressure) -> Self

Set the queue backpressure policy for this tee.

Trait Implementations

impl Clone for SessionTeeFileRequest

fn clone(&self) -> SessionTeeFileRequest

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SessionTeeFileRequest

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

Formats the value using the given formatter.

impl Eq for SessionTeeFileRequest

impl PartialEq for SessionTeeFileRequest

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

Tests for self and other values to be equal, and is used by ==.

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

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

impl StructuralPartialEq for SessionTeeFileRequest