Struct RetryingDraftProcessor 

pub struct RetryingDraftProcessor<I: LlmInvoker> { /* private fields */ }

LLM-backed draft processor with bounded validation retry.

Implementations

impl<I: LlmInvoker> RetryingDraftProcessor<I>

pub fn new( invoker: I, max_retries: u32, workspace_log: impl AsRef<Path>, ) -> Result<Self, LibrarianError>

Construct a processor using the embedded librarian system prompt and the current wall clock for validation.

Errors

Returns LibrarianError::ValidationClock if the host clock cannot be converted into a Mimir ClockTime.

pub fn new_at( invoker: I, max_retries: u32, now: ClockTime, workspace_log: impl AsRef<Path>, ) -> Result<Self, LibrarianError>

Construct with a caller-supplied validation clock.

Tests use this for deterministic candidates; production code normally calls Self::new.

Errors

Returns LibrarianError::StoreOpen when the canonical store cannot be opened.

pub fn with_system_prompt(self, system_prompt: impl Into<String>) -> Self

Override the system prompt. Useful for controlled integration tests and future prompt-version experiments.

pub fn with_conflict_policy(self, policy: SupersessionConflictPolicy) -> Self

Override how deterministic supersession conflicts are handled.

pub fn with_dedup_policy(self, policy: DedupPolicy) -> Self

Override deterministic duplicate-detection behavior.

Trait Implementations

impl<I: Debug + LlmInvoker> Debug for RetryingDraftProcessor<I>

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

Formats the value using the given formatter.

impl<I: LlmInvoker> DraftProcessor for RetryingDraftProcessor<I>

fn process( &mut self, draft: &Draft, ) -> Result<DraftProcessingDecision, LibrarianError>

Process one draft and decide where it should move next.