weave-nexus · strand_input
Source declarations, signatures and documentation for strand_input.
Source: sigil/weave/models/nexus/src/strand_input.rs. SHA-256: 3c1505ecda62725e1d841e8b5493ea2ca21926548e9ea3fb706c4983fa911d62.
This reference follows declared source modules, retains conditional attributes, and includes public declarations and implementation methods. Private-module re-exports and trait resolution require the compiler; this is a source reference, not a claim that every listed item is a root import. Function bodies and constant values are omitted.
strand_input::InputStrand
Represents an input strand from a single agent
#[derive(Clone)]
pub struct InputStrand {
/// The strand (single-writer by definition)
pub strand: Arc<Strand>,
/// The writer public key (hex or raw repr as string)
pub writer_key: String,
/// Current length we've processed
pub processed_length: Arc<AtomicU64>,
/// When this strand joined the nexus
pub joined_at: SystemTime
}Source line: 15.
strand_input::InputStrand::new
Create new input strand
pub fn new(strand: Arc<Strand>) -> Self;Source line: 31.
strand_input::InputStrand::processed_length
Get current processed length
pub fn processed_length(&self) -> u64;Source line: 43.
strand_input::InputStrand::set_processed_length
Update processed length
pub fn set_processed_length(&self, length: u64);Source line: 48.
strand_input::InputStrand::unprocessed_count
Get unprocessed entries count
pub async fn unprocessed_count(&self) -> crate::Result<u64>;Source line: 53.
strand_input::InputStrand::has_new_entries
Check if strand has new entries
pub async fn has_new_entries(&self) -> crate::Result<bool>;Source line: 60.
strand_input::StrandStats
Statistics about an input strand
#[derive(Debug, Clone, Serialize)]
pub struct StrandStats {
/// Writer key (string)
pub writer_key: String,
/// Total entries in strand
pub total_entries: u64,
/// Processed entries
pub processed_entries: u64,
/// Unprocessed entries
pub unprocessed_entries: u64,
/// When strand joined
pub joined_at: SystemTime,
/// Last processed timestamp
pub last_processed: Option<SystemTime>
}Source line: 67.
strand_input::StrandStats::from_input_strand
Create stats from input strand
pub async fn from_input_strand(input: &InputStrand) -> crate::Result<Self>;Source line: 89.
