Struct DarkfiMinersRegistry 

pub struct DarkfiMinersRegistry {
    pub network: Network,
    pub powrewardv1_zk: PowRewardV1Zk,
    pub block_templates: RwLock<HashMap<String, BlockTemplate>>,
    pub jobs: RwLock<HashMap<String, MinerClient>>,
    pub mm_jobs: RwLock<HashMap<String, String>>,
    pub submit_lock: RwLock<()>,
    stratum_rpc_task: StoppableTaskPtr,
    pub stratum_rpc_connections: Mutex<HashSet<StoppableTaskPtr>>,
    mm_rpc_task: StoppableTaskPtr,
    pub mm_rpc_connections: Mutex<HashSet<StoppableTaskPtr>>,
}

DarkFi node miners registry.

Fields

network: Network

Blockchain network

powrewardv1_zk: PowRewardV1Zk

PowRewardV1 ZK data

block_templates: RwLock<HashMap<String, BlockTemplate>>

Mining block templates of each wallet config

jobs: RwLock<HashMap<String, MinerClient>>

Active native clients mapped to their job information. This client information includes their wallet template key, recipient configuration, current mining job key(job id) and its connection publisher. For native jobs the job key is the hex encoded header hash.

mm_jobs: RwLock<HashMap<String, String>>

Active merge mining jobs mapped to the wallet template they represent. The key(job id) is the the header template hash.

submit_lock: RwLock<()>

Submission lock so we can queue up submissions process

stratum_rpc_task: StoppableTaskPtr

Stratum JSON-RPC background task

stratum_rpc_connections: Mutex<HashSet<StoppableTaskPtr>>

Stratum JSON-RPC connection tracker

mm_rpc_task: StoppableTaskPtr

HTTP JSON-RPC background task

mm_rpc_connections: Mutex<HashSet<StoppableTaskPtr>>

HTTP JSON-RPC connection tracker

Implementations

impl DarkfiMinersRegistry

pub fn init( network: Network, validator: &ValidatorPtr, ) -> Result<Arc<DarkfiMinersRegistry>>

Initialize a DarkFi node miners registry.

pub fn start( &self, executor: &ExecutorPtr, node: &DarkfiNodePtr, stratum_rpc_settings: &Option<RpcSettings>, mm_rpc_settings: &Option<RpcSettings>, ) -> Result<()>

Start the DarkFi node miners registry for provided DarkFi node instance.

pub async fn stop(&self)

Stop the DarkFi node miners registry.

async fn create_template( &self, validator: &ValidatorPtr, wallet: &String, config: &MinerRewardsRecipientConfig, ) -> Result<BlockTemplate>

Create a registry record for provided wallet config. If the record already exists return its template, otherwise create its current template based on provided validator state.

pub async fn register_miner( &self, validator: &ValidatorPtr, wallet: &String, config: &MinerRewardsRecipientConfig, ) -> Result<(String, String, JsonValue, JsonSubscriber)>

Register a new miner and create its job.

pub async fn register_merge_miner( &self, validator: &ValidatorPtr, wallet: &String, config: &MinerRewardsRecipientConfig, ) -> Result<(String, f64)>

Register a new merge miner and create its job.

pub async fn submit( &self, validator: &ValidatorPtr, subscribers: &HashMap<&'static str, JsonSubscriber>, p2p_handler: &Arc<DarkfidP2pHandler>, block: BlockInfo, ) -> Result<()>

Submit provided block to the provided node.

pub async fn refresh_jobs( &self, block_templates: &mut HashMap<String, BlockTemplate>, jobs: &mut HashMap<String, MinerClient>, mm_jobs: &mut HashMap<String, String>, validator: &ValidatorPtr, ) -> Result<()>

Refresh outdated jobs in the provided registry maps based on provided validator state.

pub async fn refresh(&self, validator: &ValidatorPtr) -> Result<()>

Refresh outdated jobs in the registry based on provided validator state.