Struct FileObservationSinkConfig 

pub struct FileObservationSinkConfig {
    pub path: PathBuf,
    pub max_file_bytes: u64,
    pub retained_files: usize,
    pub queue_capacity: usize,
    pub sync_every_records: usize,
}

Local observation drain limits and retention policy.

Fields

path: PathBuf

Active JSONL file path.

max_file_bytes: u64

Maximum active file size before rotation.

retained_files: usize

Number of rotated files retained.

queue_capacity: usize

Maximum queued observations awaiting disk.

sync_every_records: usize

Number of records written between fsync calls.

Implementations

impl FileObservationSinkConfig

pub fn new(path: impl Into<PathBuf>) -> Self

Creates a production-safe bounded configuration.

Trait Implementations

impl Clone for FileObservationSinkConfig

fn clone(&self) -> FileObservationSinkConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for FileObservationSinkConfig

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

Formats the value using the given formatter.

impl Eq for FileObservationSinkConfig

impl PartialEq for FileObservationSinkConfig

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for FileObservationSinkConfig