Struct SourceObservationEntry 

struct SourceObservationEntry {
    binding: SourceBinding,
    watcher: RecommendedWatcher,
    receiver: Arc<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: Arc<Mutex<Receiver<Event>>>

Bounded receiver whose lock serializes callback publication with drain acknowledgment.

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 invalidate_epoch(&self, epoch: &VerifiedSourceEpoch)

Discard only the failed operation’s epoch without clearing a successor.

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

Reject all cached and in-flight evidence after exact source verification fails.

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 drain_source_events( &self, receiver: &Receiver<Event>, scan_options: &ScanOptions, ) -> Result<bool, CliError>

Drain and invalidate atomically with callback publication and epoch installation.

fn drain_epoch_events( &self, receiver: &Receiver<Event>, epoch: &VerifiedSourceEpoch, scan_options: &ScanOptions, ) -> Result<ObservedAcceptance, CliError>

Consume events only while the sampled epoch still owns their selection policy.

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.