Struct ResolveJob 

pub struct ResolveJob {
    pub original_tir: AnyTir,
    pub args: ArgMap,
    pub compiler: Value,
    pub round: usize,
    pub last_eval: Option<CompiledTx>,
    pub converged: bool,
    pub log: Vec<ResolveLogEntry>,
    pub input_queries: Vec<QueryResolution>,
    pub input_pool: Option<HashMap<UtxoRef, Utxo>>,
}

Fields

original_tir: AnyTir

args: ArgMap

compiler: Value

round: usize

last_eval: Option<CompiledTx>

converged: bool

log: Vec<ResolveLogEntry>

input_queries: Vec<QueryResolution>

input_pool: Option<HashMap<UtxoRef, Utxo>>

Implementations

impl ResolveJob

pub fn approximate_queries(&mut self)

For each query, filter the pool by hard constraints, rank by closeness to the target asset composition, then filter by aggregate constraints.

impl ResolveJob

pub fn assign_all(&mut self) -> Result<(), Error>

Given queries with their ranked candidates (from the approximation stage), find an allocation that satisfies all queries simultaneously using greedy assignment. Returns an error if any query cannot be resolved.

impl ResolveJob

pub async fn build_utxo_pool<T: UtxoStore>( &mut self, store: &T, ) -> Result<(), Error>

Query the UTxO store for all queries and write the shared pool of candidate UTxOs into the job.

impl ResolveJob

pub async fn resolve_queries<T: UtxoStore>( &mut self, utxos: &T, ) -> Result<(), Error>

Run the full input resolution pipeline: narrow, approximate, assign.

pub async fn resolve_inputs<T: UtxoStore>( &mut self, tx: AnyTir, utxos: &T, ) -> Result<AnyTir, Error>

Resolve all input queries in a TIR transaction.

impl ResolveJob

pub fn new(tx: AnyTir, args: ArgMap) -> Self

pub fn record(&mut self, event: ResolveLog)

pub fn resolved_tir(&self) -> &AnyTir

pub fn set_input_queries(&mut self, queries: Vec<(String, CanonicalQuery)>)

pub fn pool_refs(&self) -> Vec<UtxoRef>

pub fn to_input_map(&self) -> BTreeMap<String, UtxoSet>

pub async fn execute<C, S>( &mut self, compiler: &mut C, utxos: &S, max_optimize_rounds: usize, ) -> Result<CompiledTx, Error>

where C: Compiler<Expression = Expression, CompilerOp = CompilerOp>, S: UtxoStore,

Trait Implementations

impl Clone for ResolveJob

fn clone(&self) -> ResolveJob

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ResolveJob

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for ResolveJob

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl DiagnosticDump for ResolveJob

fn to_dump(&self) -> Value

impl Serialize for ResolveJob

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.