Struct LiquidationExecutor 

pub struct LiquidationExecutor {
    cache: Arc<LiquidationCache>,
    portfolio_cache: Arc<PortfolioCache>,
    event_sender: Option<UnboundedSender<EngineMessage>>,
    rsm_directive_publisher: Option<Arc<RsmDirectivePublisher>>,
    rsm_signer: Option<Arc<dyn RsmSigner>>,
    full_target_buffer_bps: u32,
}

Liquidation executor service.

Orchestrates full-liquidation request submission and reconciliation metadata updates.

Fields

cache: Arc<LiquidationCache>

Liquidation state cache.

portfolio_cache: Arc<PortfolioCache>

Portfolio cache for getting account positions.

event_sender: Option<UnboundedSender<EngineMessage>>

Event sender for publishing state changes.

rsm_directive_publisher: Option<Arc<RsmDirectivePublisher>>

Shared publisher for signed RSM transaction requests.

rsm_signer: Option<Arc<dyn RsmSigner>>

Shared backend RSM signer.

full_target_buffer_bps: u32

Target health buffer after full liquidation, in basis points.

Implementations

impl LiquidationExecutor

pub fn new( cache: Arc<LiquidationCache>, portfolio_cache: Arc<PortfolioCache>, ) -> Self

Create a new liquidation executor.

pub fn with_event_sender(self, sender: UnboundedSender<EngineMessage>) -> Self

Set the event sender for publishing state changes.

pub fn with_rsm_directive_publisher( self, publisher: Arc<RsmDirectivePublisher>, ) -> Self

pub fn with_rsm_signer(self, rsm_signer: Arc<dyn RsmSigner>) -> Self

pub fn with_full_target_buffer_bps(self, full_target_buffer_bps: u32) -> Self

pub async fn start_auction(&self, wallet: &WalletAddress) -> Result<String>

Submit a StartLiquidation request for a wallet already in pre-liquidation.

The account remains in PreLiquidation until the chain observer sees LiquidationStarted on-chain.

pub async fn stop_auction( &self, wallet: &WalletAddress, start_time: u64, ) -> Result<String>

Submit a StopLiquidation request for an active full liquidation.

The account remains in InLiquidation until the chain observer sees LiquidationStopped on-chain.

async fn get_position_symbols(&self, wallet: &WalletAddress) -> Vec<String>

Get position symbols for a wallet.

fn compute_margin_needed( full_target_buffer_bps: u32, status: &AccountLiquidationStatus, ) -> Decimal

fn apply_start_claim( status: &mut AccountLiquidationStatus, wallet: &WalletAddress, auction_id: &str, request_id: &str, margin_needed: Decimal, timestamp: u64, ) -> bool

fn apply_stop_claim( status: &mut AccountLiquidationStatus, wallet: &WalletAddress, request_id: &str, timestamp: u64, ) -> bool

async fn clear_start_claim_after_publish_failure( &self, wallet: &WalletAddress, request_id: &str, )

async fn clear_stop_claim_after_publish_failure( &self, wallet: &WalletAddress, request_id: &str, )

fn clear_start_claim( status: &mut AccountLiquidationStatus, wallet: &WalletAddress, request_id: &str, timestamp: u64, ) -> bool

fn clear_stop_claim( status: &mut AccountLiquidationStatus, wallet: &WalletAddress, request_id: &str, timestamp: u64, ) -> bool

fn emit_status_update( &self, previous_state: &LiquidationState, status: &AccountLiquidationStatus, timestamp: u64, )