Struct AnalyticsCoordinator 

pub struct AnalyticsCoordinator {
    pub config: CoordinatorConfig,
    pub state: PipelineState,
    pub stats: CoordinatorStats,
    /* private fields */
}

Analytics pipeline coordinator.

Manages GPU kernel actors and orchestrates the analytics pipeline.

Fields

config: CoordinatorConfig

Configuration.

state: PipelineState

Pipeline state.

stats: CoordinatorStats

Processing statistics.

Implementations

impl AnalyticsCoordinator

pub fn new(config: CoordinatorConfig) -> Self

Create a new coordinator.

pub fn begin_snapshot(&mut self) -> u64

Start processing a new network snapshot.

pub fn create_pagerank_request( &self, account_count: u32, edge_count: u32, graph_offset: u64, ) -> PageRankRequest

Create a PageRank request.

pub fn create_fraud_detection_request( &self, flow_count: u32, flows_offset: u64, accounts_offset: u64, account_count: u32, ) -> FraudDetectionRequest

Create a fraud detection request.

pub fn create_gaap_validation_request( &self, flow_count: u32, flows_offset: u64, account_types_offset: u64, ) -> GaapValidationRequest

Create a GAAP validation request.

pub fn create_benford_analysis_request( &self, amount_count: u32, amounts_offset: u64, ) -> BenfordAnalysisRequest

Create a Benford analysis request.

pub fn create_suspense_detection_request( &self, account_count: u32, balances_offset: u64, risk_scores_offset: u64, flow_counts_offset: u64, ) -> SuspenseDetectionRequest

Create a suspense detection request.

pub fn handle_pagerank_response(&mut self, _response: PageRankResponse)

Handle PageRank response.

pub fn handle_fraud_response(&mut self, response: FraudDetectionResponse)

Handle fraud detection response.

pub fn handle_gaap_response(&mut self, response: GaapValidationResponse)

Handle GAAP validation response.

pub fn handle_benford_response(&mut self, response: BenfordAnalysisResponse)

Handle Benford analysis response.

pub fn handle_suspense_response(&mut self, response: SuspenseDetectionResponse)

Handle suspense detection response.

pub fn finalize_snapshot(&mut self) -> AnalyticsResult

Finalize the current snapshot.