Struct SourceObservationEntry 

struct SourceObservationEntry {
    binding: SourceBinding,
    _watcher: RecommendedWatcher,
    receiver: Mutex<Receiver<Event>>,
    ingress_sequence: Arc<AtomicU64>,
    continuity_lost: Arc<AtomicBool>,
    reconcile: Mutex<()>,
    state: Mutex<ObservationState>,
}

Concrete watcher and state for one exact source binding.

Fields

binding: SourceBinding

Exact source, database, and configuration identity.

_watcher: RecommendedWatcher

Native watcher kept alive for the entry lifetime.

receiver: Mutex<Receiver<Event>>

Bounded watcher event receiver drained during reconciliation.

ingress_sequence: Arc<AtomicU64>

Monotonic count of relevant events accepted by the callback.

continuity_lost: Arc<AtomicBool>

Whether overflow, disconnection, or rescan invalidated event continuity.

reconcile: Mutex<()>

Serializes exact verification and epoch installation for this binding.

state: Mutex<ObservationState>

Current process-local verified epoch.

Implementations

impl SourceObservationEntry

fn start(binding: SourceBinding) -> Result<Self, CliError>

Start a bounded native watcher for one source binding.

fn invalidate(&self)

Discard the current verified epoch after any uncertainty.

fn clear_before_exact_verification(&self) -> Result<(), CliError>

Reset continuity and drain events before sampling exact source truth.

fn changed_since_exact_verification( &self, scan_options: &ScanOptions, ) -> Result<bool, CliError>

Return whether any potentially relevant event arrived since exact truth was sampled.

fn install_epoch( &self, process_nonce: [u8; 16], binding: &CapturedProjectBinding, generation: IndexGeneration, ingress_sequence: u64, contract_fingerprint: String, policy_witness: String, ) -> Result<VerifiedSourceEpoch, CliError>

Install a new verified epoch after exact source and policy reconciliation.

fn current_epoch(&self) -> Result<Option<VerifiedSourceEpoch>, CliError>

Clone the current verified epoch without holding the state lock.

Trait Implementations

impl Debug for SourceObservationEntry

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

Formats the value using the given formatter.