sigil-node · compute_durable

Source: sigil/node/sigil-node/src/compute_durable.rs. SHA-256: 437021897c9eb2d2d32ce2847faeec14accea136edca2bf1de537c06e0707126.

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.

Module condition:

#[cfg(feature = "compute")]

compute_durable::PREFIX_VIGIL_SUB

Reserved durable-state prefix for Vigils subscriptions.

#[cfg(feature = "compute")]
pub const PREFIX_VIGIL_SUB: &[u8];

Source line: 78.

compute_durable::PREFIX_VIGIL_INGESTOR

Reserved durable-state prefix for Vigils ingestors.

#[cfg(feature = "compute")]
pub const PREFIX_VIGIL_INGESTOR: &[u8];

Source line: 80.

compute_durable::PREFIX_VIGIL_DELIVERY

Reserved durable-state prefix for Vigils delivery records.

#[cfg(feature = "compute")]
pub const PREFIX_VIGIL_DELIVERY: &[u8];

Source line: 82.

compute_durable::PREFIX_VIGIL_CALLBACK

Reserved durable-state prefix for scheduled Vigils callbacks.

#[cfg(feature = "compute")]
pub const PREFIX_VIGIL_CALLBACK: &[u8];

Source line: 84.

compute_durable::DurableComputeStore

Durable compute marketplace store backed by AkashaKV.

#[cfg(feature = "compute")]
pub struct DurableComputeStore {

}

Source line: 176.

compute_durable::DurableComputeStore::open

Open (or create) the store at path. The directory becomes the AkashaKV data root for the compute marketplace.

#[cfg(feature = "compute")]
pub fn open(path: &Path) -> Result<Self, NodeError>;

Source line: 190.

compute_durable::DurableComputeStore::put_provider

#[cfg(feature = "compute")]
pub fn put_provider(&self, p: &ComputeProvider) -> Result<(), NodeError>;

Source line: 279.

compute_durable::DurableComputeStore::get_provider

#[cfg(feature = "compute")]
pub fn get_provider(&self, did: &str) -> Result<Option<ComputeProvider>, NodeError>;

Source line: 285.

compute_durable::DurableComputeStore::list_providers

#[cfg(feature = "compute")]
pub fn list_providers(&self) -> Result<Vec<ComputeProvider>, NodeError>;

Source line: 293.

compute_durable::DurableComputeStore::put_escrow

#[cfg(feature = "compute")]
pub fn put_escrow(&self, e: &ComputeEscrow) -> Result<(), NodeError>;

Source line: 305.

compute_durable::DurableComputeStore::get_escrow

#[cfg(feature = "compute")]
pub fn get_escrow(&self, owner: &str) -> Result<Option<ComputeEscrow>, NodeError>;

Source line: 311.

compute_durable::DurableComputeStore::list_escrows

#[cfg(feature = "compute")]
pub fn list_escrows(&self) -> Result<Vec<ComputeEscrow>, NodeError>;

Source line: 319.

compute_durable::DurableComputeStore::put_job

#[cfg(feature = "compute")]
pub fn put_job(&self, j: &ComputeJob) -> Result<(), NodeError>;

Source line: 331.

compute_durable::DurableComputeStore::get_job

#[cfg(feature = "compute")]
pub fn get_job(&self, id: &str) -> Result<Option<ComputeJob>, NodeError>;

Source line: 337.

compute_durable::DurableComputeStore::list_jobs

#[cfg(feature = "compute")]
pub fn list_jobs(&self, filter: &JobIndexFilter) -> Result<Vec<ComputeJob>, NodeError>;

Source line: 345.

compute_durable::DurableComputeStore::put_receipt

#[cfg(feature = "compute")]
pub fn put_receipt(&self, r: &ComputeReceiptRecord) -> Result<(), NodeError>;

Source line: 369.

compute_durable::DurableComputeStore::get_receipt

#[cfg(feature = "compute")]
pub fn get_receipt(&self, id: &str) -> Result<Option<ComputeReceiptRecord>, NodeError>;

Source line: 382.

compute_durable::DurableComputeStore::list_receipts

#[cfg(feature = "compute")]
pub fn list_receipts(&self) -> Result<Vec<ComputeReceiptRecord>, NodeError>;

Source line: 390.

compute_durable::DurableComputeStore::list_settled_ids

#[cfg(feature = "compute")]
pub fn list_settled_ids(&self) -> Result<Vec<String>, NodeError>;

Source line: 400.

compute_durable::DurableComputeStore::is_settled

#[cfg(feature = "compute")]
pub fn is_settled(&self, id: &str) -> Result<bool, NodeError>;

Source line: 411.

compute_durable::DurableComputeStore::is_tuple_settled

#[cfg(feature = "compute")]
pub fn is_tuple_settled(
        &self,
        receipt_id: &str,
        job_id: &str,
        task_id: Option<&str>,
    ) -> Result<bool, NodeError>;

Source line: 415.

compute_durable::DurableComputeStore::put_challenge

#[cfg(feature = "compute")]
pub fn put_challenge(&self, c: &ComputeChallenge) -> Result<(), NodeError>;

Source line: 427.

compute_durable::DurableComputeStore::get_challenge

#[cfg(feature = "compute")]
pub fn get_challenge(&self, id: &str) -> Result<Option<ComputeChallenge>, NodeError>;

Source line: 438.

compute_durable::DurableComputeStore::list_challenges

#[cfg(feature = "compute")]
pub fn list_challenges(&self) -> Result<Vec<ComputeChallenge>, NodeError>;

Source line: 446.

compute_durable::DurableComputeStore::list_challenges_by_receipt

#[cfg(feature = "compute")]
pub fn list_challenges_by_receipt(
        &self,
        receipt_id: &str,
    ) -> Result<Vec<ComputeChallenge>, NodeError>;

Source line: 456.

compute_durable::DurableComputeStore::append_audit

#[cfg(feature = "compute")]
pub fn append_audit(&self, mut event: ComputeAuditEvent) -> Result<u64, NodeError>;

Source line: 480.

compute_durable::DurableComputeStore::list_audit

#[cfg(feature = "compute")]
pub fn list_audit(&self, query: &AuditQuery) -> Result<Vec<ComputeAuditEvent>, NodeError>;

Source line: 499.

compute_durable::DurableComputeStore::append_reputation

#[cfg(feature = "compute")]
pub fn append_reputation(&self, sig: &ComputeReputationSignal) -> Result<(), NodeError>;

Source line: 526.

compute_durable::DurableComputeStore::list_reputation

#[cfg(feature = "compute")]
pub fn list_reputation(
        &self,
        provider_did: &str,
    ) -> Result<Vec<ComputeReputationSignal>, NodeError>;

Source line: 537.

compute_durable::DurableComputeStore::list_all_reputation

#[cfg(feature = "compute")]
pub fn list_all_reputation(
        &self,
    ) -> Result<std::collections::HashMap<String, Vec<ComputeReputationSignal>>, NodeError>;

Source line: 552.

compute_durable::DurableComputeStore::put_maca_claim

#[cfg(feature = "compute")]
pub fn put_maca_claim(&self, c: &MacaWorkClaim) -> Result<(), NodeError>;

Source line: 570.

compute_durable::DurableComputeStore::get_maca_claim

#[cfg(feature = "compute")]
pub fn get_maca_claim(&self, work_id: &SigilHash) -> Result<Option<MacaWorkClaim>, NodeError>;

Source line: 575.

compute_durable::DurableComputeStore::list_maca_claims

#[cfg(feature = "compute")]
pub fn list_maca_claims(&self) -> Result<Vec<MacaWorkClaim>, NodeError>;

Source line: 583.

compute_durable::DurableComputeStore::put_maca_validation

#[cfg(feature = "compute")]
pub fn put_maca_validation(&self, record: &MacaValidationRecord) -> Result<(), NodeError>;

Source line: 593.

compute_durable::DurableComputeStore::list_maca_validations

#[cfg(feature = "compute")]
pub fn list_maca_validations(
        &self,
        work_id: &SigilHash,
    ) -> Result<Vec<MacaValidationRecord>, NodeError>;

Source line: 603.

compute_durable::DurableComputeStore::list_all_maca_validations

#[cfg(feature = "compute")]
pub fn list_all_maca_validations(&self) -> Result<Vec<MacaValidationRecord>, NodeError>;

Source line: 618.

compute_durable::DurableComputeStore::put_balance

#[cfg(feature = "compute")]
pub fn put_balance(&self, did: &str, amount: u64) -> Result<(), NodeError>;

Source line: 645.

compute_durable::DurableComputeStore::get_balance

#[cfg(feature = "compute")]
pub fn get_balance(&self, did: &str) -> Result<Option<u64>, NodeError>;

Source line: 649.

compute_durable::DurableComputeStore::list_balances

#[cfg(feature = "compute")]
pub fn list_balances(&self) -> Result<Vec<(String, u64)>, NodeError>;

Source line: 660.

compute_durable::DurableComputeStore::put_identity

#[cfg(feature = "compute")]
pub fn put_identity(&self, did: &str, document: &serde_json::Value) -> Result<(), NodeError>;

Source line: 677.

compute_durable::DurableComputeStore::get_identity

#[cfg(feature = "compute")]
pub fn get_identity(&self, did: &str) -> Result<Option<serde_json::Value>, NodeError>;

Source line: 681.

compute_durable::DurableComputeStore::list_identities

#[cfg(feature = "compute")]
pub fn list_identities(&self) -> Result<Vec<(String, serde_json::Value)>, NodeError>;

Source line: 700.

compute_durable::DurableComputeStore::put_vigil_subscription

#[cfg(feature = "compute")]
pub fn put_vigil_subscription(
        &self,
        subscription: &sigil_core::vigil::VigilSubscription,
    ) -> Result<(), NodeError>;

Source line: 719.

compute_durable::DurableComputeStore::get_vigil_subscription

#[cfg(feature = "compute")]
pub fn get_vigil_subscription(
        &self,
        subscription_id: &SigilHash,
    ) -> Result<Option<sigil_core::vigil::VigilSubscription>, NodeError>;

Source line: 729.

compute_durable::DurableComputeStore::list_vigil_subscriptions

#[cfg(feature = "compute")]
pub fn list_vigil_subscriptions(
        &self,
        subscriber_did: Option<&str>,
        limit: u32,
    ) -> Result<Vec<sigil_core::vigil::VigilSubscription>, NodeError>;

Source line: 739.

compute_durable::DurableComputeStore::put_vigil_ingestor

#[cfg(feature = "compute")]
pub fn put_vigil_ingestor(
        &self,
        ingestor: &sigil_core::vigil::Ingestor,
    ) -> Result<(), NodeError>;

Source line: 756.

compute_durable::DurableComputeStore::get_vigil_ingestor

#[cfg(feature = "compute")]
pub fn get_vigil_ingestor(
        &self,
        ingestor_did: &str,
    ) -> Result<Option<sigil_core::vigil::Ingestor>, NodeError>;

Source line: 766.

compute_durable::DurableComputeStore::list_vigil_ingestors

#[cfg(feature = "compute")]
pub fn list_vigil_ingestors(&self) -> Result<Vec<sigil_core::vigil::Ingestor>, NodeError>;

Source line: 776.

compute_durable::DurableComputeStore::put_vigil_delivery

#[cfg(feature = "compute")]
pub fn put_vigil_delivery(
        &self,
        record: &sigil_core::vigil::VigilDeliveryRecord,
    ) -> Result<(), NodeError>;

Source line: 785.

compute_durable::DurableComputeStore::has_vigil_delivery

#[cfg(feature = "compute")]
pub fn has_vigil_delivery(
        &self,
        subscription_id: &SigilHash,
        event_id: &SigilHash,
    ) -> Result<bool, NodeError>;

Source line: 799.

compute_durable::DurableComputeStore::list_vigil_delivery_history

#[cfg(feature = "compute")]
pub fn list_vigil_delivery_history(
        &self,
        subscription_id: &SigilHash,
        limit: u32,
    ) -> Result<Vec<sigil_core::vigil::VigilDeliveryRecord>, NodeError>;

Source line: 811.

compute_durable::DurableComputeStore::list_all_vigil_deliveries

#[cfg(feature = "compute")]
pub fn list_all_vigil_deliveries(
        &self,
    ) -> Result<Vec<sigil_core::vigil::VigilDeliveryRecord>, NodeError>;

Source line: 832.

compute_durable::DurableComputeStore::schedule_vigil_callback

#[cfg(feature = "compute")]
pub fn schedule_vigil_callback(
        &self,
        callback: &sigil_core::vigil::ScheduledVigilCallback,
    ) -> Result<(), NodeError>;

Source line: 858.

compute_durable::DurableComputeStore::list_vigil_callbacks

#[cfg(feature = "compute")]
pub fn list_vigil_callbacks(
        &self,
    ) -> Result<Vec<sigil_core::vigil::ScheduledVigilCallback>, NodeError>;

Source line: 865.

compute_durable::DurableComputeStore::drain_vigil_callbacks_for_height

#[cfg(feature = "compute")]
pub fn drain_vigil_callbacks_for_height(
        &self,
        height: u64,
        limit: u32,
    ) -> Result<Vec<sigil_core::vigil::ScheduledVigilCallback>, NodeError>;

Source line: 881.

compute_durable::DurableComputeStore::put_validator_record

#[cfg(feature = "compute")]
pub fn put_validator_record(
        &self,
        record: &crate::executor::ValidatorRecord,
    ) -> Result<(), NodeError>;

Source line: 915.

compute_durable::DurableComputeStore::get_validator_record

#[cfg(feature = "compute")]
pub fn get_validator_record(
        &self,
        did: &str,
    ) -> Result<Option<crate::executor::ValidatorRecord>, NodeError>;

Source line: 922.

compute_durable::DurableComputeStore::list_validator_records

#[cfg(feature = "compute")]
pub fn list_validator_records(
        &self,
    ) -> Result<Vec<crate::executor::ValidatorRecord>, NodeError>;

Source line: 947.

compute_durable::DurableComputeStore::put_delegation_shares

#[cfg(feature = "compute")]
pub fn put_delegation_shares(
        &self,
        delegator: &str,
        validator: &str,
        shares: u64,
    ) -> Result<(), NodeError>;

Source line: 956.

compute_durable::DurableComputeStore::get_delegation_shares

#[cfg(feature = "compute")]
pub fn get_delegation_shares(
        &self,
        delegator: &str,
        validator: &str,
    ) -> Result<Option<u64>, NodeError>;

Source line: 972.

compute_durable::DurableComputeStore::list_delegations_for_delegator

#[cfg(feature = "compute")]
pub fn list_delegations_for_delegator(
        &self,
        delegator: &str,
    ) -> Result<Vec<(String, u64)>, NodeError>;

Source line: 991.

compute_durable::DurableComputeStore::list_delegations

#[cfg(feature = "compute")]
pub fn list_delegations(&self) -> Result<Vec<(String, String, u64)>, NodeError>;

Source line: 1018.

compute_durable::DurableComputeStore::put_delegation_unbonding

#[cfg(feature = "compute")]
pub fn put_delegation_unbonding(
        &self,
        delegator: &str,
        validator: &str,
        claim: &crate::executor::DelegationUnbonding,
    ) -> Result<(), NodeError>;

Source line: 1051.

compute_durable::DurableComputeStore::get_delegation_unbonding

#[cfg(feature = "compute")]
pub fn get_delegation_unbonding(
        &self,
        delegator: &str,
        validator: &str,
    ) -> Result<Option<crate::executor::DelegationUnbonding>, NodeError>;

Source line: 1067.

compute_durable::DurableComputeStore::clear_delegation_unbonding

#[cfg(feature = "compute")]
pub fn clear_delegation_unbonding(
        &self,
        delegator: &str,
        validator: &str,
    ) -> Result<(), NodeError>;

Source line: 1081.

compute_durable::DurableComputeStore::put_nonce

#[cfg(feature = "compute")]
pub fn put_nonce(&self, did: &str, nonce: u64) -> Result<(), NodeError>;

Source line: 1101.

compute_durable::DurableComputeStore::get_nonce

#[cfg(feature = "compute")]
pub fn get_nonce(&self, did: &str) -> Result<Option<u64>, NodeError>;

Source line: 1105.

compute_durable::DurableComputeStore::list_nonces

#[cfg(feature = "compute")]
pub fn list_nonces(&self) -> Result<Vec<(String, u64)>, NodeError>;

Source line: 1116.

compute_durable::DurableComputeStore::mark_tx_included

Record tx_hash as included at block_height. Idempotent: writing the same hash twice is harmless because the value encodes the originating block height; the lookup path only inspects presence.

#[cfg(feature = "compute")]
pub fn mark_tx_included(&self, tx_hash: &[u8; 32], block_height: u64) -> Result<(), NodeError>;

Source line: 1145.

compute_durable::DurableComputeStore::has_tx_included

Check whether tx_hash has been durably recorded as included.

#[cfg(feature = "compute")]
pub fn has_tx_included(&self, tx_hash: &[u8; 32]) -> Result<bool, NodeError>;

Source line: 1151.

compute_durable::DurableComputeStore::get_tx_included_height

Return the block height at which tx_hash was recorded, if any.

#[cfg(feature = "compute")]
pub fn get_tx_included_height(&self, tx_hash: &[u8; 32]) -> Result<Option<u64>, NodeError>;

Source line: 1156.

compute_durable::DurableComputeStore::list_tx_included

#[cfg(feature = "compute")]
pub fn list_tx_included(&self) -> Result<Vec<([u8; 32], u64)>, NodeError>;

Source line: 1167.

compute_durable::DurableComputeStore::put_clock

#[cfg(feature = "compute")]
pub fn put_clock(&self, epoch: u64, height: u64) -> Result<(), NodeError>;

Source line: 1189.

compute_durable::DurableComputeStore::get_clock

#[cfg(feature = "compute")]
pub fn get_clock(&self) -> Result<(u64, u64), NodeError>;

Source line: 1196.

compute_durable::DurableComputeStore::put_policy

#[cfg(feature = "compute")]
pub fn put_policy(&self, policy: &ComputePolicy) -> Result<(), NodeError>;

Source line: 1209.

compute_durable::DurableComputeStore::get_policy

#[cfg(feature = "compute")]
pub fn get_policy(&self) -> Result<Option<ComputePolicy>, NodeError>;

Source line: 1213.

compute_durable::DurableComputeStore::put_validator_agent

#[cfg(feature = "compute")]
pub fn put_validator_agent(&self, r: &ValidatorAgentRecord) -> Result<(), NodeError>;

Source line: 1222.

compute_durable::DurableComputeStore::get_validator_agent

#[cfg(feature = "compute")]
pub fn get_validator_agent(
        &self,
        agent_did: &str,
    ) -> Result<Option<ValidatorAgentRecord>, NodeError>;

Source line: 1228.

compute_durable::DurableComputeStore::list_validator_agents

#[cfg(feature = "compute")]
pub fn list_validator_agents(&self) -> Result<Vec<ValidatorAgentRecord>, NodeError>;

Source line: 1238.

compute_durable::DurableComputeStore::put_beacon

#[cfg(feature = "compute")]
pub fn put_beacon(&self, r: &BeaconRecord) -> Result<(), NodeError>;

Source line: 1248.

compute_durable::DurableComputeStore::get_beacon

#[cfg(feature = "compute")]
pub fn get_beacon(&self, epoch_id: u64) -> Result<Option<BeaconRecord>, NodeError>;

Source line: 1254.

compute_durable::DurableComputeStore::put_maca_epoch

#[cfg(feature = "compute")]
pub fn put_maca_epoch(&self, e: &MacaEpoch) -> Result<(), NodeError>;

Source line: 1261.

compute_durable::DurableComputeStore::get_maca_epoch

#[cfg(feature = "compute")]
pub fn get_maca_epoch(&self, epoch_id: u64) -> Result<Option<MacaEpoch>, NodeError>;

Source line: 1267.

compute_durable::DurableComputeStore::list_maca_epochs

#[cfg(feature = "compute")]
pub fn list_maca_epochs(&self, query: &EpochQuery) -> Result<Vec<MacaEpoch>, NodeError>;

Source line: 1274.

compute_durable::DurableComputeStore::put_epoch_attestation

Append an attestation to the per-epoch index. Stored under compute/epoch_att/<epoch_id BE>/<work_id 32B>/<validator_did>.

#[cfg(feature = "compute")]
pub fn put_epoch_attestation(
        &self,
        record: &MacaValidationRecord,
        epoch_id: u64,
    ) -> Result<(), NodeError>;

Source line: 1292.

compute_durable::DurableComputeStore::list_epoch_attestations

#[cfg(feature = "compute")]
pub fn list_epoch_attestations(
        &self,
        epoch_id: u64,
        work_id: &SigilHash,
    ) -> Result<Vec<MacaValidationRecord>, NodeError>;

Source line: 1310.

compute_durable::DurableComputeStore::put_quorum_proof

#[cfg(feature = "compute")]
pub fn put_quorum_proof(&self, p: &MacaQuorumProof) -> Result<(), NodeError>;

Source line: 1329.

compute_durable::DurableComputeStore::get_quorum_proof

#[cfg(feature = "compute")]
pub fn get_quorum_proof(
        &self,
        epoch_id: u64,
        work_id: &SigilHash,
    ) -> Result<Option<MacaQuorumProof>, NodeError>;

Source line: 1339.

compute_durable::DurableComputeStore::list_quorum_proofs

#[cfg(feature = "compute")]
pub fn list_quorum_proofs(&self, epoch_id: u64) -> Result<Vec<MacaQuorumProof>, NodeError>;

Source line: 1355.

compute_durable::DurableComputeStore::flush

Force a flush of the underlying AkashaKV memtables to SSTables. Useful in tests that drop and reopen the store at the same path to verify durability without waiting for the background flush.

#[cfg(feature = "compute")]
pub fn flush(&self) -> Result<(), NodeError>;

Source line: 1371.

compute_durable::DurableComputeStore::close

Graceful shutdown — flushes memtables and stops background tasks.

#[cfg(feature = "compute")]
pub fn close(&self) -> Result<(), NodeError>;

Source line: 1378.

compute_durable::DurableComputeStore::namespace_prefix

Test helper: return the namespace prefix used by every compute key so callers can co-locate other data under different roots without risk of collision.

#[cfg(feature = "compute")]
pub fn namespace_prefix() -> &'static [u8];

Source line: 1387.

compute_durable::DurableComputeStore::commit_batch

Apply all operations in batch atomically via a single AkashaKV MVCC transaction.

Atomicity guarantee: if any individual operation fails (encoding error or storage error) the transaction is dropped (auto-aborted via Drop) before it can be committed, leaving zero partial state visible. Either every operation in the batch lands or none of them do.

This is the only write path that compute transaction handlers should use after the handler has finished its read-only checks.

#[cfg(feature = "compute")]
pub fn commit_batch(&self, batch: &ComputeWriteBatch) -> Result<(), NodeError>;

Source line: 1403.

compute_durable::ArcStore

#[cfg(feature = "compute")]
pub type ArcStore = Arc<DurableComputeStore>;

Source line: 1595.

compute_durable::ComputeBatchOp

An individual operation inside a [ComputeWriteBatch].

Cloning is derived from the inner state types which already implement Clone.

#[cfg(feature = "compute")]
#[derive(Clone)]
pub enum ComputeBatchOp {
    PutProvider(ComputeProvider),
    PutEscrow(ComputeEscrow),
    PutJob(ComputeJob),
    /// Puts both the receipt record and the settled-marker in one atomic op.
    PutReceipt(ComputeReceiptRecord),
    PutChallenge(ComputeChallenge),
    AppendAudit(ComputeAuditEvent),
    AppendReputation(ComputeReputationSignal),
    PutMacaWorkClaim(MacaWorkClaim),
    PutMacaValidationRecord(MacaValidationRecord),
    PutBalance(String, u64),
    PutClock(u64, u64),
    PutPolicy(ComputePolicy),
    PutValidatorAgent(ValidatorAgentRecord),
    PutBeacon(BeaconRecord),
    PutMacaEpoch(MacaEpoch),
    PutQuorumProof(MacaQuorumProof),
}

Source line: 1606.

compute_durable::ComputeWriteBatch

Write batch accumulating all mutations for a single compute executor handler. Commit the batch via [crate::executor::ExecutionState::commit_compute_tx] at the end of the handler to apply all mutations atomically.

#[cfg(feature = "compute")]
#[derive(Default)]
pub struct ComputeWriteBatch {

}

Source line: 1630.

compute_durable::ComputeWriteBatch::new

Create an empty write batch.

#[cfg(feature = "compute")]
pub fn new() -> Self;

Source line: 1636.

compute_durable::ComputeWriteBatch::put_provider

#[cfg(feature = "compute")]
pub fn put_provider(&mut self, p: ComputeProvider);

Source line: 1640.

compute_durable::ComputeWriteBatch::put_escrow

#[cfg(feature = "compute")]
pub fn put_escrow(&mut self, e: ComputeEscrow);

Source line: 1644.

compute_durable::ComputeWriteBatch::put_job

#[cfg(feature = "compute")]
pub fn put_job(&mut self, j: ComputeJob);

Source line: 1648.

compute_durable::ComputeWriteBatch::put_receipt

Put a receipt record and its settled marker atomically.

#[cfg(feature = "compute")]
pub fn put_receipt(&mut self, r: ComputeReceiptRecord);

Source line: 1653.

compute_durable::ComputeWriteBatch::put_challenge

#[cfg(feature = "compute")]
pub fn put_challenge(&mut self, c: ComputeChallenge);

Source line: 1657.

compute_durable::ComputeWriteBatch::append_audit

#[cfg(feature = "compute")]
pub fn append_audit(&mut self, ev: ComputeAuditEvent);

Source line: 1661.

compute_durable::ComputeWriteBatch::append_reputation

#[cfg(feature = "compute")]
pub fn append_reputation(&mut self, sig: ComputeReputationSignal);

Source line: 1665.

compute_durable::ComputeWriteBatch::put_maca_work_claim

#[cfg(feature = "compute")]
pub fn put_maca_work_claim(&mut self, c: MacaWorkClaim);

Source line: 1669.

compute_durable::ComputeWriteBatch::put_maca_validation_record

#[cfg(feature = "compute")]
pub fn put_maca_validation_record(&mut self, r: MacaValidationRecord);

Source line: 1673.

compute_durable::ComputeWriteBatch::put_balance

#[cfg(feature = "compute")]
pub fn put_balance(&mut self, did: String, amount: u64);

Source line: 1677.

compute_durable::ComputeWriteBatch::put_clock

#[cfg(feature = "compute")]
pub fn put_clock(&mut self, epoch: u64, height: u64);

Source line: 1681.

compute_durable::ComputeWriteBatch::put_policy

#[cfg(feature = "compute")]
pub fn put_policy(&mut self, policy: ComputePolicy);

Source line: 1685.

compute_durable::ComputeWriteBatch::put_validator_agent

#[cfg(feature = "compute")]
pub fn put_validator_agent(&mut self, r: ValidatorAgentRecord);

Source line: 1689.

compute_durable::ComputeWriteBatch::put_beacon

#[cfg(feature = "compute")]
pub fn put_beacon(&mut self, r: BeaconRecord);

Source line: 1693.

compute_durable::ComputeWriteBatch::put_maca_epoch

#[cfg(feature = "compute")]
pub fn put_maca_epoch(&mut self, e: MacaEpoch);

Source line: 1697.

compute_durable::ComputeWriteBatch::put_quorum_proof

#[cfg(feature = "compute")]
pub fn put_quorum_proof(&mut self, p: MacaQuorumProof);

Source line: 1701.

compute_durable::ComputeWriteBatch::len

Number of operations queued in this batch.

#[cfg(feature = "compute")]
pub fn len(&self) -> usize;

Source line: 1706.

compute_durable::ComputeWriteBatch::is_empty

Returns true if no operations have been queued.

#[cfg(feature = "compute")]
pub fn is_empty(&self) -> bool;

Source line: 1711.

compute_durable::ComputeWriteBatch::into_ops

Consume the batch and return the inner op list.

Used by the in-memory MemoryExecutionState::commit_compute_tx path to iterate ops without an extra clone.

#[cfg(feature = "compute")]
pub fn into_ops(self) -> Vec<ComputeBatchOp>;

Source line: 1719.

sigil-node · compute_durable

On this page